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,