diff options
author | Florian Dold <florian@dold.me> | 2023-02-20 20:14:37 +0100 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2023-02-20 20:14:46 +0100 |
commit | 3daa4dbb3fc5199fb05d58b40c0d7c9ee287595e (patch) | |
tree | bdf3bcd9af71ce9cc77a8c4dc32ff0537654e83f /packages/taler-wallet-core/src/operations/backup | |
parent | 7bb81a008b7148cfd3fd656f858e4cbd755531ac (diff) | |
download | wallet-core-3daa4dbb3fc5199fb05d58b40c0d7c9ee287595e.tar.xz |
wallet-core: fix retryTransaction, improve tx/op identifier parsing/construction
Diffstat (limited to 'packages/taler-wallet-core/src/operations/backup')
-rw-r--r-- | packages/taler-wallet-core/src/operations/backup/index.ts | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/packages/taler-wallet-core/src/operations/backup/index.ts b/packages/taler-wallet-core/src/operations/backup/index.ts index 3dae26087..59e99b505 100644 --- a/packages/taler-wallet-core/src/operations/backup/index.ts +++ b/packages/taler-wallet-core/src/operations/backup/index.ts @@ -99,7 +99,7 @@ import { import { OperationAttemptResult, OperationAttemptResultType, - RetryTags, + TaskIdentifiers, scheduleRetryInTx, } from "../../util/retries.js"; import { addAttentionRequest, removeAttentionRequest } from "../attention.js"; @@ -379,7 +379,7 @@ async function runBackupCycleForProvider( logger.warn("backup provider not found anymore"); return; } - const opId = RetryTags.forBackup(prov); + const opId = TaskIdentifiers.forBackup(prov); await scheduleRetryInTx(ws, tx, opId); prov.shouldRetryFreshProposal = true; prov.state = { @@ -405,7 +405,7 @@ async function runBackupCycleForProvider( logger.warn("backup provider not found anymore"); return; } - const opId = RetryTags.forBackup(prov); + const opId = TaskIdentifiers.forBackup(prov); await scheduleRetryInTx(ws, tx, opId); prov.currentPaymentProposalId = result.proposalId; prov.shouldRetryFreshProposal = false; @@ -479,7 +479,7 @@ async function runBackupCycleForProvider( prov.lastBackupHash = encodeCrock(hash(backupEnc)); // FIXME: Allocate error code for this situation? // FIXME: Add operation retry record! - const opId = RetryTags.forBackup(prov); + const opId = TaskIdentifiers.forBackup(prov); await scheduleRetryInTx(ws, tx, opId); prov.state = { tag: BackupProviderStateTag.Retrying, @@ -920,7 +920,7 @@ export async function getBackupInfo( .mktx((x) => [x.backupProviders, x.operationRetries]) .runReadOnly(async (tx) => { return await tx.backupProviders.iter().mapAsync(async (bp) => { - const opId = RetryTags.forBackup(bp); + const opId = TaskIdentifiers.forBackup(bp); const retryRecord = await tx.operationRetries.get(opId); return { provider: bp, |