From c660db82c12e08020661828f1d8383baa7ef0e02 Mon Sep 17 00:00:00 2001
From: Florian Dold <florian@dold.me>
Date: Thu, 7 Sep 2023 20:35:46 +0200
Subject: wallet-core: address DB FIXMEs, systematic state numbering

---
 packages/taler-wallet-core/src/wallet.ts | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

(limited to 'packages/taler-wallet-core/src/wallet.ts')

diff --git a/packages/taler-wallet-core/src/wallet.ts b/packages/taler-wallet-core/src/wallet.ts
index cb82a3a43..11fb3f739 100644
--- a/packages/taler-wallet-core/src/wallet.ts
+++ b/packages/taler-wallet-core/src/wallet.ts
@@ -354,9 +354,9 @@ async function callOperationHandler(
     case PendingTaskType.PeerPullCredit:
       return await processPeerPullCredit(ws, pending.pursePub);
     case PendingTaskType.PeerPullDebit:
-      return await processPeerPullDebit(ws, pending.peerPullPaymentIncomingId);
+      return await processPeerPullDebit(ws, pending.peerPullDebitId);
     case PendingTaskType.PeerPushCredit:
-      return await processPeerPushCredit(ws, pending.peerPushPaymentIncomingId);
+      return await processPeerPushCredit(ws, pending.peerPushCreditId);
     default:
       return assertUnreachable(pending);
   }
@@ -1876,7 +1876,7 @@ class InternalWalletStateImpl implements InternalWalletState {
         return computeRefundTransactionState(rec);
       }
       case TransactionType.PeerPullCredit:
-        const rec = await tx.peerPullPaymentInitiations.get(
+        const rec = await tx.peerPullCredit.get(
           parsedTxId.pursePub,
         );
         if (!rec) {
@@ -1884,8 +1884,8 @@ class InternalWalletStateImpl implements InternalWalletState {
         }
         return computePeerPullCreditTransactionState(rec);
       case TransactionType.PeerPullDebit: {
-        const rec = await tx.peerPullPaymentIncoming.get(
-          parsedTxId.peerPullPaymentIncomingId,
+        const rec = await tx.peerPullDebit.get(
+          parsedTxId.peerPullDebitId,
         );
         if (!rec) {
           return undefined;
@@ -1893,8 +1893,8 @@ class InternalWalletStateImpl implements InternalWalletState {
         return computePeerPullDebitTransactionState(rec);
       }
       case TransactionType.PeerPushCredit: {
-        const rec = await tx.peerPushPaymentIncoming.get(
-          parsedTxId.peerPushPaymentIncomingId,
+        const rec = await tx.peerPushCredit.get(
+          parsedTxId.peerPushCreditId,
         );
         if (!rec) {
           return undefined;
@@ -1902,7 +1902,7 @@ class InternalWalletStateImpl implements InternalWalletState {
         return computePeerPushCreditTransactionState(rec);
       }
       case TransactionType.PeerPushDebit: {
-        const rec = await tx.peerPushPaymentInitiations.get(
+        const rec = await tx.peerPushDebit.get(
           parsedTxId.pursePub,
         );
         if (!rec) {
-- 
cgit v1.2.3