feat: menstrual subscription scheduler (#218)

menstrual subscription scheduler

/*
add path in tsconfig for simple path import
add path in jest config for simple path import
*/

src/app.module.ts

@@ -6,13 +6,17 @@ import { MailerModule } from '@nestjs-modules/mailer';
 import { Module } from '@nestjs/common';
 import { ScheduleModule } from '@nestjs/schedule';
 import { TypeOrmModule } from '@nestjs/typeorm';
-import { LocationEntities, ProcessEnvModule, ProcessEnvProxy } from './common';
-import { EscrowAccounts } from './common/escrow/models/deposit.entity';
-import { IndexerModule } from './indexer/indexer.module';
-import { EthereumListenerModule } from './listeners/ethereum-listener/ethereum-listener.module';
-import { SubstrateListenerModule } from './listeners/substrate-listener/substrate-listener.module';
-import { SchedulersModule } from './schedulers/schedulers.module';
-import { keyList, SecretKeyList } from './common/secrets';
+import {
+  LocationEntities,
+  ProcessEnvModule,
+  ProcessEnvProxy,
+} from '@common/index';
+import { EscrowAccounts } from '@common/escrow/models/deposit.entity';
+import { IndexerModule } from '@indexer/indexer.module';
+import { EthereumListenerModule } from '@listeners/ethereum-listener/ethereum-listener.module';
+import { SubstrateListenerModule } from '@listeners/substrate-listener/substrate-listener.module';
+import { SchedulersModule } from '@schedulers/schedulers.module';
+import { keyList, SecretKeyList } from '@common/secrets';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 require('dotenv').config();

src/common/caches/index.ts

@@ -5,7 +5,7 @@ import {
   GCloudSecretManagerModule,
   GCloudSecretManagerService,
 } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { keyList, SecretKeyList } from '../../common/secrets';
+import { keyList, SecretKeyList } from '@common/secrets';
 
 require('dotenv').config(); // eslint-disable-line
 

src/common/common.module.ts

@@ -5,7 +5,7 @@ import {
 import { Module } from '@nestjs/common';
 import { CqrsModule } from '@nestjs/cqrs';
 import { ElasticsearchModule } from '@nestjs/elasticsearch';
-import { keyList, SecretKeyList } from '../common/secrets';
+import { keyList, SecretKeyList } from '@common/secrets';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 require('dotenv').config();

src/common/debio-conversion/debio-conversion.module.ts

@@ -1,7 +1,7 @@
 import { GCloudSecretManagerModule } from '@debionetwork/nestjs-gcloud-secret-manager';
 import { Module } from '@nestjs/common';
 import { DebioConversionService } from './debio-conversion.service';
-import { SecretKeyList } from '../../common/secrets';
+import { SecretKeyList } from '@common/secrets';
 
 @Module({
   imports: [

src/common/debio-conversion/debio-conversion.service.ts

@@ -1,7 +1,7 @@
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
 import { Injectable, Logger } from '@nestjs/common';
 import axios from 'axios';
-import { keyList } from '../../common/secrets';
+import { keyList } from '@common/secrets';
 
 @Injectable()
 export class DebioConversionService {

src/common/escrow/escrow.module.ts

@@ -5,7 +5,7 @@ import { EscrowService } from './escrow.service';
 import { EthereumModule, SubstrateModule } from '../index';
 import { ErrorLoggingModule } from '../error-logging';
 import { GCloudSecretManagerModule } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { SecretKeyList } from '../../common/secrets';
+import { SecretKeyList } from '@common/secrets';
 
 require('dotenv').config(); // eslint-disable-line
 @Module({

src/common/escrow/escrow.service.ts

@@ -7,7 +7,7 @@ import AsyncLock from 'async-lock';
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
 import { ErrorLoggingService } from '../error-logging';
 import { ErrorLoggingDto } from '../error-logging/dto/error-logging.dto';
-import { keyList } from '../../common/secrets';
+import { keyList } from '@common/secrets';
 
 const lock = new AsyncLock();
 const ESCROW_WALLET_LOCK_KEY = 'escrow-wallet-lock';

src/common/ethereum/ethereum.module.ts

@@ -7,7 +7,7 @@ import {
   GCloudSecretManagerModule,
   GCloudSecretManagerService,
 } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { SecretKeyList, keyList } from '../../common/secrets';
+import { SecretKeyList, keyList } from '@common/secrets';
 
 @Module({
   imports: [

src/common/ethereum/ethereum.service.ts

@@ -10,7 +10,7 @@ import escrowContract from './utils/Escrow.json';
 import { ethers } from 'ethers';
 import { CachesService } from '../caches';
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { keyList } from '../../common/secrets';
+import { keyList } from '@common/secrets';
 
 @Injectable()
 export class EthereumService {

src/common/mailer/mailer.manager.ts

@@ -1,7 +1,7 @@
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
 import { MailerService } from '@nestjs-modules/mailer';
 import { Injectable, Logger } from '@nestjs/common';
-import { keyList } from '../../common/secrets';
+import { keyList } from '@common/secrets';
 import { CustomerStakingRequestService, LabRegister } from './models';
 import { NewOrderGA } from './models/new-order-ga.model';
 import { NewOrderLab } from './models/new-order-lab.model';

src/common/mailer/mailer.module.ts

@@ -7,7 +7,7 @@ import { HandlebarsAdapter } from '@nestjs-modules/mailer/dist/adapters/handleba
 import { Module } from '@nestjs/common';
 import { join } from 'path';
 import { MailerManager } from './mailer.manager';
-import { SecretKeyList, keyList } from '../../common/secrets';
+import { SecretKeyList, keyList } from '@common/secrets';
 
 @Module({
   imports: [

src/common/substrate/index.ts

@@ -1,7 +1,7 @@
 import { GCloudSecretManagerModule } from '@debionetwork/nestjs-gcloud-secret-manager';
 import { Module } from '@nestjs/common';
 import { SubstrateService } from './substrate.service';
-import { SecretKeyList } from '../../common/secrets';
+import { SecretKeyList } from '@common/secrets';
 
 @Module({
   imports: [

src/common/substrate/substrate.service.ts

@@ -2,7 +2,7 @@ import { ApiPromise, Keyring, WsProvider } from '@polkadot/api';
 import { Injectable, OnModuleInit, Logger } from '@nestjs/common';
 import { waitReady } from '@polkadot/wasm-crypto';
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { keyList } from '../../common/secrets';
+import { keyList } from '@common/secrets';
 
 @Injectable()
 export class SubstrateService implements OnModuleInit {

src/indexer/indexer.handler.ts

@@ -10,13 +10,13 @@ import {
   DeleteAllIndexesCommand,
   GetLastSubstrateBlockQueryIndexer,
 } from './blocks';
-import { ProcessEnvProxy } from '../common/proxies/process-env/process-env.proxy';
+import { ProcessEnvProxy } from '@common/proxies/process-env/process-env.proxy';
 import { ElasticsearchService } from '@nestjs/elasticsearch';
 import { u32 } from '@polkadot/types';
 import { SchedulerRegistry } from '@nestjs/schedule';
 import { eventRoutes } from './indexer.routes';
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { keyList } from '../common/secrets';
+import { keyList } from '@common/secrets';
 
 @Injectable()
 export class IndexerHandler

src/indexer/indexer.module.ts

@@ -1,14 +1,14 @@
 import { Module } from '@nestjs/common';
 import { LabCommandHandlers } from './events/labs';
 import { ServiceCommandHandlers } from './events/services';
-import { CommonModule } from '../common/common.module';
+import { CommonModule } from '@common/common.module';
 import { BlockCommandHandlers, BlockQueryHandlers } from './blocks';
 import { IndexerHandler } from './indexer.handler';
 import { OrderCommandHandlers } from './events/orders';
 import { GeneticTestingCommandHandlers } from './events/genetic-testing';
 import { RequestServiceCommandHandlers } from './events/service-request';
 import { CertificationsCommandHandlers } from './events/certifications';
-import { ProcessEnvModule } from '../common/proxies/process-env/process-env.module';
+import { ProcessEnvModule } from '@common/proxies/process-env/process-env.module';
 import { GeneticDataCommandHandlers } from './events/genetic-data';
 import { GeneticAnalystQualificationsCommandHandlers } from './events/genetic-analyst-qualifications';
 import { GeneticAnalystServicesCommandHandlers } from './events/genetic-analyst-services';

src/listeners/ethereum-listener/ethereum-listener.handler.ts

@@ -1,7 +1,7 @@
 import { Injectable, OnModuleInit, Logger } from '@nestjs/common';
-import { EthereumService } from '../../common/ethereum/ethereum.service';
-import { EscrowService } from '../../common/escrow/escrow.service';
-import { TransactionLoggingService } from '../../common';
+import { EthereumService } from '@common/ethereum/ethereum.service';
+import { EscrowService } from '@common/escrow/escrow.service';
+import { TransactionLoggingService } from '@common/index';
 
 @Injectable()
 export class EthereumListenerHandler implements OnModuleInit {

src/listeners/ethereum-listener/ethereum-listener.module.ts

@@ -1,9 +1,9 @@
 import { Module } from '@nestjs/common';
-import { EthereumModule } from '../../common/ethereum';
-import { EscrowModule } from '../../common/escrow/escrow.module';
+import { EthereumModule } from '@common/ethereum';
+import { EscrowModule } from '@common/escrow/escrow.module';
 import { EthereumListenerHandler } from './ethereum-listener.handler';
-import { TransactionLoggingModule } from '../../common';
-import { ErrorLoggingModule } from '../../common/error-logging';
+import { TransactionLoggingModule } from '@common/index';
+import { ErrorLoggingModule } from '@common/error-logging';
 
 @Module({
   imports: [

src/listeners/substrate-listener/commands/genetic-analysis-order/genetic-analysis-order-cancelled/genetic-analysis-order-cancelled.handler.ts

@@ -1,7 +1,7 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
-import { TransactionLoggingService } from '../../../../../common';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingService } from '@common/index';
 import { GeneticAnalysisOrderCancelledCommand } from './genetic-analysis-order-cancelled.command';
 
 @Injectable()

src/listeners/substrate-listener/commands/genetic-analysis-order/genetic-analysis-order-fulfilled/genetic-analysis-order-fulfilled.handler.ts

@@ -1,13 +1,13 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 import {
   DateTimeProxy,
   NotificationService,
   TransactionLoggingService,
-} from '../../../../../common';
+} from '@common/index';
 import { GeneticAnalysisOrderFulfilledCommand } from './genetic-analysis-order-fulfilled.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 import currencyUnit from '../../../models/currencyUnit';
 
 @Injectable()

src/listeners/substrate-listener/commands/genetic-analysis-order/genetic-analysis-order-paid/genetic-analysis-order-paid.handler.ts

@@ -1,21 +1,21 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 import {
   DateTimeProxy,
   MailerManager,
   NotificationService,
   SubstrateService,
   TransactionLoggingService,
-} from '../../../../../common';
+} from '@common/index';
 import { GeneticAnalysisOrderPaidCommand } from './genetic-analysis-order-paid.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 import {
   queryGeneticAnalystByAccountId,
   queryGeneticAnalystServicesByHashId,
 } from '@debionetwork/polkadot-provider';
 import { GCloudSecretManagerService } from '@debionetwork/nestjs-gcloud-secret-manager';
-import { keyList } from '../../../../../common/secrets';
+import { keyList } from '@common/secrets';
 
 @Injectable()
 @CommandHandler(GeneticAnalysisOrderPaidCommand)

src/listeners/substrate-listener/commands/genetic-analysis-order/genetic-analysis-order-refunded/genetic-analysis-order-refunded.handler.ts

@@ -1,13 +1,13 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 import {
   DateTimeProxy,
   NotificationService,
   TransactionLoggingService,
-} from '../../../../../common';
+} from '@common/index';
 import { GeneticAnalysisOrderRefundedCommand } from './genetic-analysis-order-refunded.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 @Injectable()
 @CommandHandler(GeneticAnalysisOrderRefundedCommand)
 export class GeneticAnalysisOrderRefundedHandler

src/listeners/substrate-listener/commands/genetic-analysis-order/genetic-analysys-order-created/genetic-analysis-order-created.handler.ts

@@ -1,13 +1,13 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 import {
   TransactionLoggingService,
   DateTimeProxy,
   NotificationService,
-} from '../../../../../common';
+} from '@common/index';
 import { GeneticAnalysisOrderCreatedCommand } from './genetic-analysis-order-created.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 
 @Injectable()
 @CommandHandler(GeneticAnalysisOrderCreatedCommand)

src/listeners/substrate-listener/commands/genetic-analysis/genetic-analysis-rejected/genetic-analysis-rejected.handler.ts

@@ -4,10 +4,10 @@ import {
   DateTimeProxy,
   NotificationService,
   SubstrateService,
-} from '../../../../../common';
+} from '@common/index';
 import { setGeneticAnalysisOrderRefunded } from '@debionetwork/polkadot-provider';
 import { GeneticAnalysisRejectedCommand } from './genetic-analysis-rejected.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 
 @Injectable()
 @CommandHandler(GeneticAnalysisRejectedCommand)

src/listeners/substrate-listener/commands/genetic-analysis/genetic-analysis-resultready/genetic-analysis-result-ready.handler.ts

@@ -4,10 +4,10 @@ import {
   DateTimeProxy,
   NotificationService,
   SubstrateService,
-} from '../../../../../common';
+} from '@common/index';
 import { setGeneticAnalysisOrderFulfilled } from '@debionetwork/polkadot-provider';
 import { GeneticAnalysisResultReadyCommand } from './genetic-analysis-result-ready.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 
 @Injectable()
 @CommandHandler(GeneticAnalysisResultReadyCommand)

src/listeners/substrate-listener/commands/genetic-analyst-services/genetic-analyst-service-created/genetic-analyst-service-created.handler.ts

@@ -1,8 +1,8 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { DateTimeProxy, NotificationService } from '../../../../../common';
+import { DateTimeProxy, NotificationService } from '@common/index';
 import { GeneticAnalystServiceCreatedCommand } from './genetic-analyst-service-created.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 
 @Injectable()
 @CommandHandler(GeneticAnalystServiceCreatedCommand)

src/listeners/substrate-listener/commands/genetic-analysts/genetic-analyst-registered/genetic-analyst-registered.handler.ts

@@ -1,8 +1,8 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
 import { GeneticAnalystRegisteredCommand } from './genetic-analyst-registered.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
-import { DateTimeProxy, NotificationService } from '../../../../../common';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
+import { DateTimeProxy, NotificationService } from '@common/index';
 
 @Injectable()
 @CommandHandler(GeneticAnalystRegisteredCommand)

src/listeners/substrate-listener/commands/genetic-analysts/genetic-analyst-staked/genetic-analyst-staked.handler.ts

@@ -1,10 +1,7 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
-import {
-  DateTimeProxy,
-  TransactionLoggingService,
-} from '../../../../../common';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
+import { DateTimeProxy, TransactionLoggingService } from '@common/index';
 import { GeneticAnalystStakedCommand } from './genetic-analyst-staked.command';
 
 @Injectable()

src/listeners/substrate-listener/commands/genetic-analysts/genetic-analyst-unstake/genetic-analyst-unstaked.handler.ts

@@ -1,10 +1,7 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
-import {
-  DateTimeProxy,
-  TransactionLoggingService,
-} from '../../../../../common';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
+import { DateTimeProxy, TransactionLoggingService } from '@common/index';
 import { GeneticAnalystUnstakedCommand } from './genetic-analyst-unstaked.command';
 
 @Injectable()

src/listeners/substrate-listener/commands/genetic-analysts/genetic-analyst-verification-status/genetic-analyst-verification-status.handler.ts

@@ -1,13 +1,13 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 import {
   DateTimeProxy,
   NotificationService,
   TransactionLoggingService,
-} from '../../../../../common';
+} from '@common/index';
 import { GeneticAnalystVerificationStatusCommand } from './genetic-analyst-verification-status.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
 import { VerificationStatus } from '@debionetwork/polkadot-provider/lib/primitives/verification-status';
 
 @Injectable()

src/listeners/substrate-listener/commands/genetic-testing/data-staked/data-staked.handler.ts

@@ -4,14 +4,14 @@ import {
   DebioConversionService,
   TransactionLoggingService,
   SubstrateService,
-} from '../../../../../common';
+} from '@common/index';
 import {
   convertToDbioUnitString,
   queryOrderDetailByOrderID,
   sendRewards,
 } from '@debionetwork/polkadot-provider';
 import { DataStakedCommand } from './data-staked.command';
-import { TransactionLoggingDto } from '../../../../../common/transaction-logging/dto/transaction-logging.dto';
+import { TransactionLoggingDto } from '@common/transaction-logging/dto/transaction-logging.dto';
 
 @Injectable()
 @CommandHandler(DataStakedCommand)

src/listeners/substrate-listener/commands/genetic-testing/dna-sample-rejected/dna-sample-rejected.handler.ts

@@ -1,8 +1,8 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
 import { DnaSampleRejectedCommand } from './dna-sample-rejected.command';
-import { NotificationDto } from '../../../../../common/notification/dto/notification.dto';
-import { DateTimeProxy, NotificationService } from '../../../../../common';
+import { NotificationDto } from '@common/notification/dto/notification.dto';
+import { DateTimeProxy, NotificationService } from '@common/index';
 
 @Injectable()
 @CommandHandler(DnaSampleRejectedCommand)