revert add resync missed nonce

debridge-finance · May 23, 2024 · 2ec8dae · 2ec8dae
1 parent 2ead4d0
commit 2ec8dae
Showing 1 changed file with 2 additions and 44 deletions.
diff --git a/debridge_node/src/modules/chain/scanning/services/AddNewEventsAction.ts b/debridge_node/src/modules/chain/scanning/services/AddNewEventsAction.ts
@@ -4,9 +4,9 @@ import { Web3Service } from '../../../web3/services/Web3Service';
 import { SolanaReaderService } from './SolanaReaderService';
 import { ChainConfigService } from '../../config/services/ChainConfigService';
 import { EvmChainConfig } from '../../config/models/configs/EvmChainConfig';
-import { InjectEntityManager, InjectRepository } from '@nestjs/typeorm';
+import { InjectRepository } from '@nestjs/typeorm';
 import { SupportedChainEntity } from '../../../../entities/SupportedChainEntity';
-import { EntityManager, Repository } from 'typeorm';
+import { Repository } from 'typeorm';
 import { SubmissionProcessingService } from './SubmissionProcessingService';
 import { TransformService } from './TransformService';
 import { ProcessNewTransferResultStatusEnum } from '../enums/ProcessNewTransferResultStatusEnum';
@@ -20,8 +20,6 @@ export class AddNewEventsAction {
   constructor(
     @InjectRepository(SupportedChainEntity)
     private readonly supportedChainRepository: Repository<SupportedChainEntity>,
-    @InjectEntityManager()
-    private readonly entityManager: EntityManager,
     private readonly chainConfigService: ChainConfigService,
     private readonly web3Service: Web3Service,
     private readonly solanaReaderService: SolanaReaderService,
@@ -110,46 +108,6 @@ export class AddNewEventsAction {
         break;
       }
     }
-
-    await this.validateAndUpdateProgressWithLatestNonce(registerInstance, chainId);
-  }
-
-  private async validateAndUpdateProgressWithLatestNonce(contract: Contract, chainId: number): Promise<void> {
-    const logger = new Logger(`${AddNewEventsAction.name} chainId ${chainId} validateAndUpdateProgressWithLatestNonce`);
-
-    const lastNonceFromContract = Number(await contract.methods.nonce().call());
-    logger.verbose(`lastNonceFromContract ${lastNonceFromContract}`);
-
-    const recordsDbWithMaxNonce = await this.entityManager.query(
-      `SELECT submissions.nonce as nonce, submissions."blockNumber" as "blockNumber"
-      FROM public.submissions as submissions
-        JOIN (SELECT "chainFrom", MAX(nonce) as nonce
-              FROM public.submissions as submissions
-              JOIN public.supported_chains as chains
-              ON (chains."chainId" = submissions."chainFrom")
-              WHERE (submissions."blockNumber" <= chains."latestBlock"  OR chains."chainId"='7565164')  GROUP BY "chainFrom")
-        as nonces
-        ON (nonces."chainFrom" = submissions."chainFrom" AND nonces.nonce = submissions.nonce)
-      WHERE submissions."chainFrom" = ${chainId}
-      `,
-    );
-    logger.verbose(`records from database ${JSON.stringify(recordsDbWithMaxNonce)}`);
-    if (!recordsDbWithMaxNonce.length) {
-      return;
-    }
-    const recordDbWithMaxNonce = recordsDbWithMaxNonce[0];
-
-    const lastNonceFromDb = recordDbWithMaxNonce.nonce;
-    if (lastNonceFromContract > lastNonceFromDb) {
-      const blockNumberWithLastNonceFromDb = recordDbWithMaxNonce.blockNumber;
-      logger.verbose(`blockNumberWithLastNonceFromDb ${blockNumberWithLastNonceFromDb}`);
-
-      await this.supportedChainRepository.update(chainId, {
-        latestBlock: blockNumberWithLastNonceFromDb,
-      });
-
-      logger.log(`last processed block is update with value ${blockNumberWithLastNonceFromDb}`);
-    }
   }
 
   async getEvents(registerInstance: Contract, fromBlock: number, toBlock: number) {