diff options
author | Florian Dold <florian@dold.me> | 2023-01-12 16:57:51 +0100 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2023-01-12 16:57:51 +0100 |
commit | 1e378e4499906e466e933e40464727fb1c1cbf5e (patch) | |
tree | 49f01bfe3a505208f1463e00f9bbe77f15a9d0cd /packages/taler-wallet-core/src/wallet.ts | |
parent | 24694eae736763ea6e026c8839b7ba119db10bb4 (diff) | |
download | wallet-core-1e378e4499906e466e933e40464727fb1c1cbf5e.tar.xz |
wallet-core: retries for peer pull payments
Diffstat (limited to 'packages/taler-wallet-core/src/wallet.ts')
-rw-r--r-- | packages/taler-wallet-core/src/wallet.ts | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/packages/taler-wallet-core/src/wallet.ts b/packages/taler-wallet-core/src/wallet.ts index 73b86c8c6..a5c092b59 100644 --- a/packages/taler-wallet-core/src/wallet.ts +++ b/packages/taler-wallet-core/src/wallet.ts @@ -195,10 +195,11 @@ import { checkPeerPullPayment, checkPeerPushPayment, initiatePeerPullPayment, - initiatePeerToPeerPush, + initiatePeerPushPayment, preparePeerPullPayment, preparePeerPushPayment, - processPeerPushOutgoing, + processPeerPullInitiation, + processPeerPushInitiation, } from "./operations/pay-peer.js"; import { getPendingOperations } from "./operations/pending.js"; import { @@ -318,8 +319,10 @@ async function callOperationHandler( } case PendingTaskType.Backup: return await processBackupForProvider(ws, pending.backupProviderBaseUrl); - case PendingTaskType.PeerPushOutgoing: - return await processPeerPushOutgoing(ws, pending.pursePub); + case PendingTaskType.PeerPushInitiation: + return await processPeerPushInitiation(ws, pending.pursePub); + case PendingTaskType.PeerPullInitiation: + return await processPeerPullInitiation(ws, pending.pursePub); default: return assertUnreachable(pending); } @@ -1381,7 +1384,7 @@ async function dispatchRequestInternal<Op extends WalletApiOperation>( } case WalletApiOperation.InitiatePeerPushPayment: { const req = codecForInitiatePeerPushPaymentRequest().decode(payload); - return await initiatePeerToPeerPush(ws, req); + return await initiatePeerPushPayment(ws, req); } case WalletApiOperation.CheckPeerPushPayment: { const req = codecForCheckPeerPushPaymentRequest().decode(payload); |