fix: make nonce generator singleton

aleph-im · Oct 30, 2024 · 97057d8 · 97057d8
1 parent 199f071
commit 97057d8
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 5 deletions.
diff --git a/packages/ethereum/src/services/indexer/factory.ts b/packages/ethereum/src/services/indexer/factory.ts
@@ -14,6 +14,7 @@ import {
   IndexableEntityType,
   IndexerMsClient,
   IndexerWorkerDomainI,
+  NonceTimestamp,
   ParserMsClient,
 } from '@aleph-indexer/framework'
 import { EthereumParsedLog, EthereumParsedTransaction } from '../parser/src/types.js'
@@ -46,13 +47,16 @@ export async function ethereumIndexerFactory(
 
   // Instances
 
+  const nonce = new NonceTimestamp()
+
   const transactionFetcher = new EthereumIndexerTransactionFetcher(
     blockchainId,
     fetcherMsClient,
     transactionRequestDAL,
     transactionRequestIncomingEntityDAL,
     transactionRequestPendingSignatureDAL,
     transactionRequestResponseDAL,
+    nonce
   )
 
   const transactionFetcherMain = new BaseEntityIndexer(
@@ -73,6 +77,7 @@ export async function ethereumIndexerFactory(
     logRequestIncomingEntityDAL,
     logRequestPendingSignatureDAL,
     logRequestResponseDAL,
+    nonce
   )
 
   const logFetcherMain = new BaseEntityIndexer(

diff --git a/packages/ethereum/src/services/indexer/src/logFetcher.ts b/packages/ethereum/src/services/indexer/src/logFetcher.ts
@@ -21,7 +21,7 @@ export class EthereumIndexerLogFetcher extends BaseIndexerEntityFetcher<Ethereum
     protected logRequestIncomingLogDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>,
     protected logRequestPendingSignatureDAL: EntityRequestPendingEntityStorage,
     protected logRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>,
-    protected nonce: NonceTimestamp = new NonceTimestamp(),
+    protected nonce: NonceTimestamp,
   ) {
     super(
       blockchainId,

diff --git a/packages/ethereum/src/services/indexer/src/transactionFetcher.ts b/packages/ethereum/src/services/indexer/src/transactionFetcher.ts
@@ -21,7 +21,7 @@ export class EthereumIndexerTransactionFetcher extends BaseIndexerEntityFetcher<
     protected transactionRequestIncomingTransactionDAL: EntityRequestIncomingEntityStorage<EthereumParsedTransaction>,
     protected transactionRequestPendingSignatureDAL: EntityRequestPendingEntityStorage,
     protected transactionRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedTransaction>,
-    protected nonce: NonceTimestamp = new NonceTimestamp(),
+    protected nonce: NonceTimestamp,
   ) {
     super(
       blockchainId,

diff --git a/packages/framework/src/services/indexer/src/entityFetcher.ts b/packages/framework/src/services/indexer/src/entityFetcher.ts
@@ -71,7 +71,7 @@ export abstract class BaseIndexerEntityFetcher<
     protected entityRequestIncomingEntityDAL: EntityRequestIncomingEntityStorage<T>,
     protected entityRequestPendingEntityDAL: EntityRequestPendingEntityStorage,
     protected entityRequestResponseDAL: EntityRequestResponseStorage<T>,
-    protected nonce: NonceTimestamp = new NonceTimestamp(),
+    protected nonce: NonceTimestamp,
   ) {
     this.incomingEntities = new PendingWorkPool({
       id: `${type}-indexer-incoming-entities`,

diff --git a/packages/solana/src/services/indexer/factory.ts b/packages/solana/src/services/indexer/factory.ts
@@ -14,7 +14,8 @@ import {
   IndexerWorkerDomainI,
   ParserMsClient,
   BaseEntityIndexer,
-  BaseIndexer
+  BaseIndexer,
+  NonceTimestamp
 } from '@aleph-indexer/framework'
 import { SolanaParsedTransaction } from '../../types.js'
 import { SolanaIndexerTransactionFetcher } from './src/transactionFetcher.js'
@@ -36,13 +37,16 @@ export async function solanaIndexerFactory(
   const transactionRequestResponseDAL = createEntityRequestResponseDAL(basePath, IndexableEntityType.Transaction)
   const transactionIndexerStateDAL = createEntityIndexerStateDAL(basePath, IndexableEntityType.Transaction)
 
+  const nonce = new NonceTimestamp()
+
   const transactionFetcher = new SolanaIndexerTransactionFetcher(
     blockchainId,
     fetcherMsClient,
     transactionRequestDAL,
     transactionRequestIncomingTransactionDAL,
     transactionRequestPendingSignatureDAL,
     transactionRequestResponseDAL,
+    nonce
   )
 
   const transactionFetcherMain = new BaseEntityIndexer(

diff --git a/packages/solana/src/services/indexer/src/transactionFetcher.ts b/packages/solana/src/services/indexer/src/transactionFetcher.ts
@@ -21,7 +21,7 @@ export class SolanaIndexerTransactionFetcher extends BaseIndexerEntityFetcher<So
     protected transactionRequestIncomingTransactionDAL: EntityRequestIncomingEntityStorage<SolanaParsedTransaction>,
     protected transactionRequestPendingSignatureDAL: EntityRequestPendingEntityStorage,
     protected transactionRequestResponseDAL: EntityRequestResponseStorage<SolanaParsedTransaction>,
-    protected nonce: NonceTimestamp = new NonceTimestamp(),
+    protected nonce: NonceTimestamp,
   ) {
     super(
       blockchainId,