Remove BlockedQueue, fix more lint errors

packages/node-core/src/indexer/index.ts

@@ -4,7 +4,6 @@
 export * from './benchmark.service';
 export * from './entities';
 export * from './PoiBlock';
-export * from './BlockedQueue';
 export * from './types';
 export * from './StoreOperations';
 export * from './store.service';

packages/node-core/src/utils/batch-size.ts

@@ -1,14 +1,14 @@
 // Copyright 2020-2022 OnFinality Limited authors & contributors
 // SPDX-License-Identifier: Apache-2.0
 
-import { getHeapStatistics } from 'v8';
-import { getYargsOption } from '../yargs';
-import { getLogger } from '../logger';
+import {getHeapStatistics} from 'v8';
+import {getLogger} from '../logger';
+import {getYargsOption} from '../yargs';
 
 const HIGH_THRESHOLD = 0.85;
 const LOW_THRESHOLD = 0.6;
 
-const { argv } = getYargsOption();
+const {argv} = getYargsOption();
 const logger = getLogger('memory');
 
 export function checkMemoryUsage(batchSizeScale: number): number {

packages/node/src/app.module.ts

@@ -5,8 +5,8 @@ import { Module } from '@nestjs/common';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { ScheduleModule } from '@nestjs/schedule';
 import { DbModule } from '@subql/node-core/db';
-import { FetchModule } from './indexer/fetch.module';
 import { ConfigureModule } from './configure/configure.module';
+import { FetchModule } from './indexer/fetch.module';
 import { MetaModule } from './meta/meta.module';
 
 @Module({

packages/node/src/indexer/api.service.test.ts

@@ -4,15 +4,11 @@
 import { INestApplication } from '@nestjs/common';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { Test } from '@nestjs/testing';
-import {
-  BlockHash,
-  RuntimeVersion,
-  SignedBlock,
-} from '@polkadot/types/interfaces';
+import { BlockHash, RuntimeVersion } from '@polkadot/types/interfaces';
+import { delay } from '@subql/node-core/utils';
 import { SubstrateBlock } from '@subql/types';
 import { GraphQLSchema } from 'graphql';
 import { SubqueryProject } from '../configure/SubqueryProject';
-import { delay } from '@subql/node-core/utils';
 import { wrapBlock } from '../utils/substrate';
 import { ApiService } from './api.service';
 

packages/node/src/indexer/fetch.service.spec.ts

@@ -10,9 +10,9 @@ import {
   SubstrateDatasourceKind,
   SubstrateHandlerKind,
 } from '@subql/common-substrate';
-import { GraphQLSchema } from 'graphql';
 import { NodeConfig } from '@subql/node-core/configure';
 import { IndexerEvent } from '@subql/node-core/events';
+import { GraphQLSchema } from 'graphql';
 import { SubqueryProject } from '../configure/SubqueryProject';
 import { calcInterval, fetchBlocksBatches } from '../utils/substrate';
 import { ApiService } from './api.service';

packages/node/src/indexer/fetch.service.ts

@@ -20,23 +20,17 @@ import {
   SubstrateDataSource,
   SubstrateRuntimeHandlerFilter,
 } from '@subql/common-substrate';
-import {
-  getYargsOption,
-  getLogger,
-  profiler,
-  profilerWrap,
-} from '@subql/node-core';
+import { getYargsOption, getLogger, profiler } from '@subql/node-core';
 import { NodeConfig } from '@subql/node-core/configure';
 import { IndexerEvent } from '@subql/node-core/events';
-import { BlockedQueue } from '@subql/node-core/indexer';
 import { delay, checkMemoryUsage } from '@subql/node-core/utils';
 import {
   DictionaryQueryEntry,
   SubstrateBlock,
   SubstrateCustomHandler,
 } from '@subql/types';
 import { MetaData } from '@subql/utils';
-import { isUndefined, range, sortBy, uniqBy } from 'lodash';
+import { range, sortBy, uniqBy } from 'lodash';
 import { SubqlProjectDs, SubqueryProject } from '../configure/SubqueryProject';
 import { isBaseHandler, isCustomHandler } from '../utils/project';
 import * as SubstrateUtil from '../utils/substrate';

packages/node/src/indexer/indexer.manager.spec.ts

@@ -2,7 +2,6 @@
 // SPDX-License-Identifier: Apache-2.0
 
 import { EventEmitter2 } from '@nestjs/event-emitter';
-import { SchedulerRegistry } from '@nestjs/schedule';
 import {
   SubstrateDatasourceKind,
   SubstrateHandlerKind,
@@ -19,7 +18,6 @@ import { DynamicDsService } from './dynamic-ds.service';
 import { IndexerManager } from './indexer.manager';
 import { ProjectService } from './project.service';
 import { SandboxService } from './sandbox.service';
-import { FetchService } from './fetch.service';
 
 jest.mock('sequelize', () => {
   const mSequelize = {

packages/node/src/indexer/project.service.test.ts

@@ -2,13 +2,12 @@
 // SPDX-License-Identifier: Apache-2.0
 
 import { Test } from '@nestjs/testing';
-import { GraphQLSchema } from 'graphql';
-import { Sequelize } from 'sequelize';
 import { NodeConfig } from '@subql/node-core/configure';
-import { SubqueryProject } from '../configure/SubqueryProject';
 import { DbModule } from '@subql/node-core/db';
 import { SubqueryRepo } from '@subql/node-core/entities';
-import { IndexerManager } from './indexer.manager';
+import { GraphQLSchema } from 'graphql';
+import { Sequelize } from 'sequelize';
+import { SubqueryProject } from '../configure/SubqueryProject';
 import { ProjectService } from './project.service';
 
 function testSubqueryProject(): SubqueryProject {
@@ -57,34 +56,6 @@ const prepare = async (): Promise<ProjectService> => {
         },
         inject: [Sequelize, SubqueryProject, 'Subquery'],
       },
-      // {
-      //   provide: IndexerManager,
-      //   useFactory: (
-      //     sequelize: Sequelize,
-      //     project: SubqueryProject,
-      //     projectService: ProjectService,
-      //     subqueryRepo: SubqueryRepo,
-      //   ) => {
-      //     const indexerManager = new IndexerManager(
-      //       undefined,
-      //       undefined,
-      //       undefined,
-      //       undefined,
-      //       undefined,
-      //       sequelize,
-      //       project,
-      //       undefined,
-      //       undefined,
-      //       undefined,
-      //       undefined,
-      //       subqueryRepo,
-      //       undefined,
-      //       projectService,
-      //     );
-      //     return indexerManager;
-      //   },
-      //   inject: [Sequelize, SubqueryProject, ProjectService, 'Subquery'],
-      // },
     ],
     imports: [
       DbModule.forRoot({

packages/node/src/indexer/project.service.ts

@@ -3,7 +3,6 @@
 
 import assert from 'assert';
 import fs from 'fs';
-import { off } from 'process';
 import { isMainThread } from 'worker_threads';
 import { Inject, Injectable } from '@nestjs/common';
 import { EventEmitter2 } from '@nestjs/event-emitter';
@@ -17,7 +16,7 @@ import {
   MetadataRepo,
 } from '@subql/node-core/indexer/entities';
 import { getAllEntitiesRelations } from '@subql/utils';
-import { QueryTypes, Sequelize, Transaction } from 'sequelize';
+import { QueryTypes, Sequelize } from 'sequelize';
 import { SubqlProjectDs, SubqueryProject } from '../configure/SubqueryProject';
 import { ApiService } from './api.service';
 import { DsProcessorService } from './ds-processor.service';