Function createWorkerHost

packages/node-core/src/indexer/worker/worker.ts:136–167

(extraWorkerFns: (keyof T)[], extraHostFns: H)

];

export function createWorkerHost<
  T extends AsyncMethods,
  H extends AsyncMethods & {initWorker: (height?: number) => Promise<void>},
  ApiConnection /* ApiPromiseConnection*/,
  DS extends BaseDataSource = BaseDataSource,
>(extraWorkerFns: (keyof T)[], extraHostFns: H): WorkerHost<DefaultWorkerFunctions<ApiConnection, DS> & T> {
  // Register these functions to be exposed to worker host
  return WorkerHost.create<DefaultWorkerFunctions<ApiConnection, DS> & T, IBaseIndexerWorker & H>(
    [
      // Have this first to not override the default functions
      ...extraWorkerFns,
      ...hostStoreKeys,
      ...hostCacheKeys,
      ...hostDynamicDsKeys,
      ...hostUnfinalizedBlocksKeys,
      ...hostMonitorKeys,
      ...hostConnectionPoolStateKeys,
    ],
    {
      // Have this first to not override the default functions
      ...extraHostFns,
      fetchBlock,
      processBlock,
      numFetchedBlocks,
      numFetchingBlocks,
      getStatus,
      getMemoryLeft,
      abortFetching,
    },
    logger
  );
}

export type TerminateableWorker<T extends IBaseIndexerWorker> = T & {terminate: () => Promise<number>};