Move changes to node-core

subquery · Oct 26, 2023 · a91947a · a91947a
1 parent 2d3499c
commit a91947a
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/packages/node-core/src/indexer/worker/worker.ts b/packages/node-core/src/indexer/worker/worker.ts
@@ -190,7 +190,7 @@ export async function createIndexerWorker<
     DefaultWorkerFunctions<ApiConnection, DS>
   >(
     workerPath,
-    [...baseWorkerFunctions, ...workerFns],
+    [...baseWorkerFunctions, 'initWorker', ...workerFns],
     {
       ...cacheHostFunctions(cache),
       ...storeHostFunctions(store),

diff --git a/packages/node/src/indexer/blockDispatcher/worker-block-dispatcher.service.ts b/packages/node/src/indexer/blockDispatcher/worker-block-dispatcher.service.ts
@@ -76,7 +76,7 @@ export class WorkerBlockDispatcherService
           SubstrateDatasource
         >(
           path.resolve(__dirname, '../../../dist/indexer/worker/worker.js'),
-          ['syncRuntimeService', 'getSpecFromMap', 'initWorker'],
+          ['syncRuntimeService', 'getSpecFromMap'],
           storeService.getStore(),
           cacheService.getCache(),
           dynamicDsService,

diff --git a/packages/node/src/indexer/worker/worker.ts b/packages/node/src/indexer/worker/worker.ts
@@ -72,7 +72,6 @@ function syncRuntimeService(
 export type IIndexerWorker = IBaseIndexerWorker & {
   syncRuntimeService: typeof syncRuntimeService;
   getSpecFromMap: typeof getSpecFromMap;
-  initWorker: typeof initWorker;
 };
 
 (global as any).host = createWorkerHost([], {