diff options
author | Florian Dold <florian@dold.me> | 2023-05-05 10:56:42 +0200 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2023-05-05 13:21:58 +0200 |
commit | 60805f3ff88d7ecd149a88ec7cea846384155c5b (patch) | |
tree | 0767a7ed20c4879ab35447039fd7e3be8fdecb94 /packages/taler-wallet-core/src/operations/pending.ts | |
parent | 1b0bec0363793996eff6483d36b844cfa2381404 (diff) | |
download | wallet-core-60805f3ff88d7ecd149a88ec7cea846384155c5b.tar.xz |
DD37 wip
Diffstat (limited to 'packages/taler-wallet-core/src/operations/pending.ts')
-rw-r--r-- | packages/taler-wallet-core/src/operations/pending.ts | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/packages/taler-wallet-core/src/operations/pending.ts b/packages/taler-wallet-core/src/operations/pending.ts index 5e14721f8..084f807f2 100644 --- a/packages/taler-wallet-core/src/operations/pending.ts +++ b/packages/taler-wallet-core/src/operations/pending.ts @@ -364,14 +364,14 @@ async function gatherPeerPullInitiationPending( resp: PendingOperationsResponse, ): Promise<void> { await tx.peerPullPaymentInitiations.iter().forEachAsync(async (pi) => { - if (pi.status === PeerPullPaymentInitiationStatus.PurseDeposited) { + if (pi.status === PeerPullPaymentInitiationStatus.DonePurseDeposited) { return; } const opId = TaskIdentifiers.forPeerPullPaymentInitiation(pi); const retryRecord = await tx.operationRetries.get(opId); const timestampDue = retryRecord?.retryInfo.nextRetry ?? AbsoluteTime.now(); resp.pendingOperations.push({ - type: PendingTaskType.PeerPullInitiation, + type: PendingTaskType.PeerPullCredit, ...getPendingCommon(ws, opId, timestampDue), givesLifeness: true, retryInfo: retryRecord?.retryInfo, @@ -421,14 +421,14 @@ async function gatherPeerPushInitiationPending( resp: PendingOperationsResponse, ): Promise<void> { await tx.peerPushPaymentInitiations.iter().forEachAsync(async (pi) => { - if (pi.status === PeerPushPaymentInitiationStatus.PurseCreated) { + if (pi.status === PeerPushPaymentInitiationStatus.Done) { return; } const opId = TaskIdentifiers.forPeerPushPaymentInitiation(pi); const retryRecord = await tx.operationRetries.get(opId); const timestampDue = retryRecord?.retryInfo.nextRetry ?? AbsoluteTime.now(); resp.pendingOperations.push({ - type: PendingTaskType.PeerPushInitiation, + type: PendingTaskType.PeerPushDebit, ...getPendingCommon(ws, opId, timestampDue), givesLifeness: true, retryInfo: retryRecord?.retryInfo, @@ -450,7 +450,7 @@ async function gatherPeerPushCreditPending( switch (pi.status) { case PeerPushPaymentIncomingStatus.Proposed: return; - case PeerPushPaymentIncomingStatus.WithdrawalCreated: + case PeerPushPaymentIncomingStatus.Done: return; } const opId = TaskIdentifiers.forPeerPushCredit(pi); |