diff options
Diffstat (limited to 'packages/taler-wallet-core/src/operations/backup/index.ts')
| -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, |