From 1c1bd1aa3d2f02136af329fc96e0100c4f3ad9b0 Mon Sep 17 00:00:00 2001 From: Davit Mandzikyan Date: Mon, 15 Dec 2025 15:53:46 +0400 Subject: [PATCH] Fix current nonce activity options. --- .../Workflows/FuelTransactionProcessor.ts | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/js/src/Blockchain/Blockchain.Fuel/Workflows/FuelTransactionProcessor.ts b/js/src/Blockchain/Blockchain.Fuel/Workflows/FuelTransactionProcessor.ts index ecb8fcb3..45e6b6cc 100644 --- a/js/src/Blockchain/Blockchain.Fuel/Workflows/FuelTransactionProcessor.ts +++ b/js/src/Blockchain/Blockchain.Fuel/Workflows/FuelTransactionProcessor.ts @@ -16,6 +16,15 @@ const defaultActivities = proxyActivities({ scheduleToCloseTimeout: '2 days', }); +const nonceActivities = proxyActivities({ + startToCloseTimeout: '1 hour', + scheduleToCloseTimeout: '2 days', + retry: { + initialInterval: '1 seconds', + maximumInterval: '5 seconds', + }, +}) + const nonRetryableActivities = proxyActivities({ startToCloseTimeout: '1 hour', scheduleToCloseTimeout: '2 days', @@ -35,14 +44,14 @@ export async function FuelTransactionProcessor( context: TransactionExecutionContext ): Promise { - const nextNonce = await defaultActivities.GetNextNonce({ + const nextNonce = await nonceActivities.GetNextNonce({ address: request.fromAddress, network: request.network }); try { - await defaultActivities.CheckCurrentNonce( + await nonceActivities.CheckCurrentNonce( { address: request.fromAddress, network: request.network, @@ -88,7 +97,7 @@ export async function FuelTransactionProcessor( transactionResponse.asset = preparedTransaction.callDataAsset; transactionResponse.amount = preparedTransaction.callDataAmount; - await defaultActivities.UpdateCurrentNonce({ + await nonceActivities.UpdateCurrentNonce({ address: request.fromAddress, network: request.network, currentNonce: nextNonce @@ -99,7 +108,7 @@ export async function FuelTransactionProcessor( } catch (error) { - await defaultActivities.UpdateCurrentNonce( + await nonceActivities.UpdateCurrentNonce( { address: request.fromAddress, network: request.network,