49 lines
1.2 KiB
TypeScript
49 lines
1.2 KiB
TypeScript
|
//
|
||
|
|
// Copyright 2021 Vulcanize, Inc.
|
||
|
|
//
|
||
|
|
|
||
|
|
import 'reflect-metadata';
|
||
|
|
import debug from 'debug';
|
||
|
|
|
||
|
|
import { FillCmd } from '@cerc-io/cli';
|
||
|
|
import { getContractEntitiesMap } from '@cerc-io/util';
|
||
|
|
import { getGraphDbAndWatcher } from '@cerc-io/graph-node';
|
||
|
|
|
||
|
|
import { Database, ENTITY_QUERY_TYPE_MAP, ENTITY_TO_LATEST_ENTITY_MAP } from './database';
|
||
|
|
import { Indexer } from './indexer';
|
||
|
|
|
||
|
|
const log = debug('vulcanize:fill');
|
||
|
|
|
||
|
|
export const main = async (): Promise<any> => {
|
||
|
|
const fillCmd = new FillCmd();
|
||
|
|
await fillCmd.init(Database);
|
||
|
|
|
||
|
|
const { graphWatcher } = await getGraphDbAndWatcher(
|
||
|
|
fillCmd.config.server,
|
||
|
|
fillCmd.clients.ethClient,
|
||
|
|
fillCmd.ethProvider,
|
||
|
|
fillCmd.database.baseDatabase,
|
||
|
|
ENTITY_QUERY_TYPE_MAP,
|
||
|
|
ENTITY_TO_LATEST_ENTITY_MAP
|
||
|
|
);
|
||
|
|
|
||
|
|
await fillCmd.initIndexer(Indexer, graphWatcher);
|
||
|
|
|
||
|
|
// Get contractEntitiesMap required for fill-state
|
||
|
|
// NOTE: Assuming each entity type is only mapped to a single contract
|
||
|
|
const contractEntitiesMap = getContractEntitiesMap(graphWatcher.dataSources);
|
||
|
|
|
||
|
|
await fillCmd.exec(contractEntitiesMap);
|
||
|
|
};
|
||
|
|
|
||
|
|
main().catch(err => {
|
||
|
|
log(err);
|
||
|
|
}).finally(() => {
|
||
|
|
process.exit();
|
||
|
|
});
|
||
|
|
|
||
|
|
process.on('SIGINT', () => {
|
||
|
|
log(`Exiting process ${process.pid} with code 0`);
|
||
|
|
process.exit(0);
|
||
|
|
});
|