diff --git a/packages/taler-wallet-core/src/operations/backup/index.ts b/packages/taler-wallet-core/src/operations/backup/index.ts index 69ba1ddbc..45b8491df 100644 --- a/packages/taler-wallet-core/src/operations/backup/index.ts +++ b/packages/taler-wallet-core/src/operations/backup/index.ts @@ -245,6 +245,7 @@ async function runBackupCycleForProvider( ws: InternalWalletState, args: BackupForProviderArgs, ): Promise { + const provider = await ws.db .mktx((x) => ({ backupProviders: x.backupProviders })) .runReadOnly(async (tx) => { diff --git a/packages/taler-wallet-core/src/operations/deposits.ts b/packages/taler-wallet-core/src/operations/deposits.ts index 27460849a..41f051cb3 100644 --- a/packages/taler-wallet-core/src/operations/deposits.ts +++ b/packages/taler-wallet-core/src/operations/deposits.ts @@ -149,6 +149,8 @@ async function processDepositGroupImpl( } = {}, ): Promise { const forceNow = options.forceNow ?? false; + await setupDepositGroupRetry(ws, depositGroupId, { resetRetry: forceNow }); + const depositGroup = await ws.db .mktx((x) => ({ depositGroups: x.depositGroups, @@ -165,8 +167,6 @@ async function processDepositGroupImpl( return; } - await setupDepositGroupRetry(ws, depositGroupId, { resetRetry: forceNow }); - const contractData = extractContractData( depositGroup.contractTermsRaw, depositGroup.contractTermsHash, diff --git a/packages/taler-wallet-core/src/operations/exchanges.ts b/packages/taler-wallet-core/src/operations/exchanges.ts index b10505b27..007dad685 100644 --- a/packages/taler-wallet-core/src/operations/exchanges.ts +++ b/packages/taler-wallet-core/src/operations/exchanges.ts @@ -556,6 +556,8 @@ async function updateExchangeFromUrlImpl( }> { const forceNow = options.forceNow ?? false; logger.info(`updating exchange info for ${baseUrl}, forced: ${forceNow}`); + await setupExchangeUpdateRetry(ws, baseUrl, { reset: forceNow }); + const now = AbsoluteTime.now(); baseUrl = canonicalizeBaseUrl(baseUrl); @@ -574,8 +576,6 @@ async function updateExchangeFromUrlImpl( return { exchange, exchangeDetails }; } - await setupExchangeUpdateRetry(ws, baseUrl, { reset: forceNow }); - logger.info("updating exchange /keys info"); const timeout = getExchangeRequestTimeout(); diff --git a/packages/taler-wallet-core/src/operations/pay.ts b/packages/taler-wallet-core/src/operations/pay.ts index ceba7ef8c..ef81d117a 100644 --- a/packages/taler-wallet-core/src/operations/pay.ts +++ b/packages/taler-wallet-core/src/operations/pay.ts @@ -672,6 +672,8 @@ async function processDownloadProposalImpl( } = {}, ): Promise { const forceNow = options.forceNow ?? false; + await setupProposalRetry(ws, proposalId, { reset: forceNow }); + const proposal = await ws.db .mktx((x) => ({ proposals: x.proposals })) .runReadOnly(async (tx) => { @@ -686,8 +688,6 @@ async function processDownloadProposalImpl( return; } - await setupProposalRetry(ws, proposalId, { reset: forceNow }); - const orderClaimUrl = new URL( `orders/${proposal.orderId}/claim`, proposal.merchantBaseUrl, diff --git a/packages/taler-wallet-core/src/operations/refresh.ts b/packages/taler-wallet-core/src/operations/refresh.ts index ce8fd003a..0dfcef427 100644 --- a/packages/taler-wallet-core/src/operations/refresh.ts +++ b/packages/taler-wallet-core/src/operations/refresh.ts @@ -1022,6 +1022,8 @@ export async function autoRefresh( exchangeBaseUrl: string, ): Promise { logger.info(`doing auto-refresh check for '${exchangeBaseUrl}'`); + + //updateExchangeFromUrl will also update retryInfo for this operation await updateExchangeFromUrl(ws, exchangeBaseUrl, { forceNow: true, }); diff --git a/packages/taler-wallet-core/src/operations/tip.ts b/packages/taler-wallet-core/src/operations/tip.ts index da7673f35..9ca1ccb5a 100644 --- a/packages/taler-wallet-core/src/operations/tip.ts +++ b/packages/taler-wallet-core/src/operations/tip.ts @@ -205,23 +205,6 @@ export async function processTip( ); } -async function resetTipRetry( - ws: InternalWalletState, - tipId: string, -): Promise { - await ws.db - .mktx((x) => ({ - tips: x.tips, - })) - .runReadWrite(async (tx) => { - const x = await tx.tips.get(tipId); - if (x) { - x.retryInfo = RetryInfo.reset(); - await tx.tips.put(x); - } - }); -} - async function processTipImpl( ws: InternalWalletState, walletTipId: string, @@ -230,9 +213,8 @@ async function processTipImpl( } = {}, ): Promise { const forceNow = options.forceNow ?? false; - if (forceNow) { - await resetTipRetry(ws, walletTipId); - } + await setupTipRetry(ws, walletTipId, { reset: forceNow }); + const tipRecord = await ws.db .mktx((x) => ({ tips: x.tips,