1 files changed, 8 insertions, 8 deletions
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) {