import { createDbConnection, DbConfig } from 'indexer-db';
import { readFileSync } from 'fs';
import { AllInOneService } from './services/all-in-one';
import { config } from './config';
import { JsonRpcServer } from './jsonrpc';
import { retryMethodsJob } from './middlewares/retry';

const main = async () => {
  const spec = JSON.parse(readFileSync(config.spec, 'utf8')) as Record<string, DbConfig>;

  const services = new Map<string, AllInOneService>();

  for (const [genesis, conf] of Object.entries(spec)) {
    const dataSource = await createDbConnection(conf);
    services.set(genesis, new AllInOneService(dataSource));
  }

  const server = new JsonRpcServer(services);

  await server.run();

  retryMethodsJob(server);
};

main().catch((err) => {
  console.error(err);
  process.exit(1);
});