index.ts

import { chainIndexerListener } from "./listeners/chain-indexer-listener";
import {
  newConfigurationListener,
  updatedConfigurationListener,
} from "./listeners/config-listener";
import {
  newWebhooksListener,
  updatedWebhooksListener,
} from "./listeners/webhook-listener";
import { addressBalanceListener } from "./listeners/address-balance-listener";
import { initCancelRecycledNoncesWorker } from "./tasks/cancel-recycled-nonces-worker";
import { initMineTransactionWorker } from "./tasks/mine-transaction-worker";
import { initNonceHealthCheckWorker } from "./tasks/nonce-health-check-worker";
import { initNonceResyncWorker } from "./tasks/nonce-resync-worker";
import { initProcessEventLogsWorker } from "./tasks/process-event-logs-worker";
import { initProcessTransactionReceiptsWorker } from "./tasks/process-transaction-receipts-worker";
import { initPruneTransactionsWorker } from "./tasks/prune-transactions-worker";
import { initSendTransactionWorker } from "./tasks/send-transaction-worker";
import { initSendWebhookWorker } from "./tasks/send-webhook-worker";

export const initWorker = async () => {
  initCancelRecycledNoncesWorker();
  initProcessEventLogsWorker();
  initProcessTransactionReceiptsWorker();
  initPruneTransactionsWorker();
  initSendTransactionWorker();
  initMineTransactionWorker();
  initSendWebhookWorker();

  initNonceHealthCheckWorker();

  await initNonceResyncWorker();

  // Listen for new & updated configuration data.
  await newConfigurationListener();
  await updatedConfigurationListener();

  // Listen for new & updated webhooks data.
  await newWebhooksListener();
  await updatedWebhooksListener();

  // Contract subscriptions.
  await chainIndexerListener();

  // Notify address balance
  await addressBalanceListener();
};