wallet-core: retries for peer pull payments

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);