Reduce Database Connections

src/common/keybase/keybase.module.ts

@@ -3,7 +3,6 @@ import { NodeModule } from "src/endpoints/nodes/node.module";
 import { ProviderModule } from "src/endpoints/providers/provider.module";
 import { ApiConfigModule } from "../api-config/api.config.module";
 import { GithubModule } from "../github/github.module";
-import { PersistenceModule } from "../persistence/persistence.module";
 import { KeybaseService } from "./keybase.service";
 import { AssetsModule } from "../assets/assets.module";
 
@@ -13,7 +12,6 @@ import { AssetsModule } from "../assets/assets.module";
     forwardRef(() => ProviderModule),
     forwardRef(() => GithubModule),
     ApiConfigModule,
-    PersistenceModule.forRoot(),
     AssetsModule,
   ],
   providers: [

src/common/rabbitmq/rabbitmq.module.ts

@@ -11,11 +11,13 @@ import { RabbitMqNftHandlerService } from './rabbitmq.nft.handler.service';
 import { RabbitMqTokenHandlerService } from './rabbitmq.token.handler.service';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { ScheduleModule } from '@nestjs/schedule';
+import { PersistenceModule } from '../persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     ApiConfigModule,
     NftModule,
     NftWorkerModule,

src/common/websockets/web-socket-publisher-module.ts

@@ -6,11 +6,13 @@ import { DynamicModuleUtils } from "src/utils/dynamic.module.utils";
 import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { EventEmitterModule } from "@nestjs/event-emitter";
 import { ScheduleModule } from "@nestjs/schedule";
+import { PersistenceModule } from "../persistence/persistence.module";
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     TransactionActionModule,
     ApiMetricsModule,
   ],

src/crons/cache.warmer/cache.warmer.module.ts

@@ -13,11 +13,13 @@ import { TpsWarmerService } from '../tps/tps-warmer.service';
 import { TpsModule } from 'src/endpoints/tps/tps.module';
 import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { EventEmitterModule } from '@nestjs/event-emitter';
+import { PersistenceModule } from 'src/common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     EndpointsServicesModule,
     KeybaseModule,
     MexModule.forRoot(),

src/crons/elastic.updater/elastic.updater.module.ts

@@ -1,4 +1,4 @@
-import { forwardRef, Module } from '@nestjs/common';
+import { Module } from '@nestjs/common';
 import { ScheduleModule } from '@nestjs/schedule';
 import { AssetsModule } from 'src/common/assets/assets.module';
 import { PersistenceModule } from 'src/common/persistence/persistence.module';
@@ -11,9 +11,9 @@ import { EventEmitterModule } from '@nestjs/event-emitter';
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     EndpointsServicesModule,
     AssetsModule,
-    forwardRef(() => PersistenceModule),
     ApiMetricsModule,
   ],
   providers: [

src/crons/status.checker/status.checker.module.ts

@@ -6,11 +6,13 @@ import { DynamicModuleUtils } from "src/utils/dynamic.module.utils";
 import { StatusCheckerService } from "./status.checker.service";
 import { ApiMetricsModule } from "src/common/metrics/api.metrics.module";
 import { EventEmitterModule } from "@nestjs/event-emitter";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     EndpointsServicesModule,
     ApiMetricsModule,
   ],

src/crons/transaction.processor/batch.transaction.processor.module.ts

@@ -7,11 +7,13 @@ import { DynamicModuleUtils } from "src/utils/dynamic.module.utils";
 import { BatchTransactionProcessorService } from "./batch.transaction.processor.service";
 import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { EventEmitterModule } from "@nestjs/event-emitter";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     ApiConfigModule,
     DynamicModuleUtils.getCacheModule(),
     TransactionsBatchModule,

src/crons/transaction.processor/transaction.completed.module.ts

@@ -7,11 +7,13 @@ import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { GatewayModule } from 'src/common/gateway/gateway.module';
 import { ProtocolModule } from 'src/common/protocol/protocol.module';
 import { EventEmitterModule } from '@nestjs/event-emitter';
+import { PersistenceModule } from 'src/common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     ApiConfigModule,
     ApiMetricsModule,
     GatewayModule,

src/crons/transaction.processor/transaction.processor.module.ts

@@ -9,11 +9,13 @@ import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { DynamicModuleUtils } from 'src/utils/dynamic.module.utils';
 import { TransactionProcessorService } from './transaction.processor.service';
 import { EventEmitterModule } from '@nestjs/event-emitter';
+import { PersistenceModule } from 'src/common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     TransactionModule,
     ShardModule,
     NodeModule,

src/crons/websocket/websocket.subscription.module.ts

@@ -20,11 +20,13 @@ import { TransfersCustomGateway } from './transfers.custom.gateway';
 import { TransferModule } from 'src/endpoints/transfers/transfer.module';
 import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { EventEmitterModule } from '@nestjs/event-emitter';
+import { PersistenceModule } from 'src/common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     TransactionModule,
     BlockModule,
     NetworkModule,

src/private.app.module.ts

@@ -9,11 +9,13 @@ import { DynamicModuleUtils } from './utils/dynamic.module.utils';
 import { ApiMetricsModule } from './common/metrics/api.metrics.module';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { ScheduleModule } from '@nestjs/schedule';
+import { PersistenceModule } from './common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     LoggingModule,
     ProcessNftsModule,
     ApiMetricsModule,

src/public.app.module.ts

@@ -11,13 +11,15 @@ import { DynamicModuleUtils } from './utils/dynamic.module.utils';
 import { LocalCacheController } from './endpoints/caching/local.cache.controller';
 import { RestrictedRoutesMiddleware } from './utils/restricted.routes.middleware';
 import { ApiMetricsModule } from './common/metrics/api.metrics.module';
+import { PersistenceModule } from './common/persistence/persistence.module';
 import { ScheduleModule } from '@nestjs/schedule';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(), // for plugins, best practice not to have crons in public API
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     LoggingModule,
     EndpointsServicesModule,
     EndpointsControllersModule.forRoot(),

src/queue.worker/nft.worker/nft.worker.module.ts

@@ -1,7 +1,6 @@
 import { Module } from '@nestjs/common';
 import { ClientProxyFactory, Transport } from '@nestjs/microservices';
 import { ApiConfigService } from 'src/common/api-config/api.config.service';
-import { PersistenceModule } from 'src/common/persistence/persistence.module';
 import { NftWorkerService } from './nft.worker.service';
 import { NftAssetModule } from './queue/job-services/assets/nft.asset.module';
 import { NftMediaModule } from './queue/job-services/media/nft.media.module';
@@ -14,7 +13,6 @@ import { NftThumbnailModule } from './queue/job-services/thumbnails/nft.thumbnai
     NftMetadataModule,
     NftThumbnailModule,
     NftAssetModule,
-    PersistenceModule.forRoot(),
   ],
   providers: [
     NftWorkerService,

src/queue.worker/nft.worker/queue/job-services/media/nft.media.module.ts

@@ -1,11 +1,9 @@
 import { Module } from '@nestjs/common';
-import { PersistenceModule } from 'src/common/persistence/persistence.module';
 import { DynamicModuleUtils } from 'src/utils/dynamic.module.utils';
 import { NftMediaService } from './nft.media.service';
 
 @Module({
   imports: [
-    PersistenceModule.forRoot(),
   ],
   controllers: [],
   providers: [

src/queue.worker/nft.worker/queue/nft.queue.module.ts

@@ -6,11 +6,13 @@ import { DynamicModuleUtils } from 'src/utils/dynamic.module.utils';
 import { ApiMetricsModule } from 'src/common/metrics/api.metrics.module';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { ScheduleModule } from '@nestjs/schedule';
+import { PersistenceModule } from 'src/common/persistence/persistence.module';
 
 @Module({
   imports: [
     ScheduleModule.forRoot(),
     EventEmitterModule.forRoot({ maxListeners: 1 }),
+    PersistenceModule.forRoot(),
     NftJobProcessorModule,
     NftModule,
     ApiMetricsModule,

src/test/unit/controllers/accounts.controller.spec.ts

@@ -33,6 +33,7 @@ import { mockAccountService, mockTokenService, mockNftService, mockDelegationLeg
 import { AccountFetchOptions } from "src/endpoints/accounts/entities/account.fetch.options";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe('AccountController', () => {
   let app: INestApplication;
@@ -59,6 +60,7 @@ describe('AccountController', () => {
         DelegationModule,
         ConfigModule.forRoot({}),
         EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot()
       ],
     })
       .overrideProvider(AccountService).useValue(accountServiceMocks)

src/test/unit/controllers/collections.controller.spec.ts

@@ -25,6 +25,7 @@ import { TransferService } from "src/endpoints/transfers/transfer.service";
 import { TransferModule } from "src/endpoints/transfers/transfer.module";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe('CollectionController', () => {
   let app: INestApplication;
@@ -46,6 +47,7 @@ describe('CollectionController', () => {
         TransferModule,
         ConfigModule.forRoot({}),
         EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot(),
       ],
     })
       .overrideProvider(CollectionService).useValue(collectionServiceMocks)

src/test/unit/controllers/delegation.controller.spec.ts

@@ -7,6 +7,7 @@ import { DelegationModule } from "src/endpoints/delegation/delegation.module";
 import { DelegationService } from "src/endpoints/delegation/delegation.service";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe('DelegationController', () => {
   let app: INestApplication;
@@ -20,6 +21,7 @@ describe('DelegationController', () => {
       imports: [
         DelegationModule,
         EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot()
       ],
     })
       .overrideProvider(DelegationService)

src/test/unit/controllers/network.controller.spec.ts

@@ -12,6 +12,7 @@ import { About } from "src/endpoints/network/entities/about";
 import { FeatureConfigs } from "../../../endpoints/network/entities/feature.configs";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe("NetworkController", () => {
   let app: INestApplication;
@@ -24,6 +25,7 @@ describe("NetworkController", () => {
       imports: [
         NetworkModule,
         EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot()
       ],
     })
       .overrideProvider(NetworkService)

src/test/unit/controllers/pool.controller.spec.ts

@@ -10,6 +10,7 @@ import { PoolFilter } from "src/endpoints/pool/entities/pool.filter";
 import { TransactionType } from "src/endpoints/transactions/entities/transaction.type";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe('PoolController', () => {
   let app: INestApplication;
@@ -21,7 +22,11 @@ describe('PoolController', () => {
     jest.resetAllMocks();
     const moduleFixture: TestingModule = await Test.createTestingModule({
       controllers: [PoolController],
-      imports: [PoolModule, EventEmitterModule.forRoot({ maxListeners: 1 })],
+      imports: [
+        PoolModule,
+        EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot(),
+      ],
     }).overrideProvider(PoolService)
       .useValue(poolServiceMocks)
       .overrideProvider(EventEmitter2)

src/test/unit/controllers/shard.controller.spec.ts

@@ -8,6 +8,7 @@ import request = require('supertest');
 import { QueryPagination } from "src/common/entities/query.pagination";
 import { EventEmitter2, EventEmitterModule } from "@nestjs/event-emitter";
 import { mockEventEmitterService } from "./services.mock/event.emitter2.services.mock";
+import { PersistenceModule } from "src/common/persistence/persistence.module";
 
 describe('ShardController', () => {
   let app: INestApplication;
@@ -20,6 +21,7 @@ describe('ShardController', () => {
       imports: [
         ShardModule,
         EventEmitterModule.forRoot({ maxListeners: 1 }),
+        PersistenceModule.forRoot(),
       ],
     })
       .overrideProvider(ShardService)