1 files changed, 85 insertions, 0 deletions
diff --git a/packages/taler-wallet-core/src/shepherd.ts b/packages/taler-wallet-core/src/shepherd.ts
index e6ea412e3..8fdf2b66b 100644
--- a/packages/taler-wallet-core/src/shepherd.ts
+++ b/packages/taler-wallet-core/src/shepherd.ts
@@ -843,6 +843,91 @@ async function makeExchangeRetryNotification(
   return notif;
 }
 
+export function listTaskForTransactionId(transactionId: string): TaskIdStr[] {
+  const tid = parseTransactionIdentifier(transactionId);
+  if (!tid) {
+    throw Error("invalid task ID");
+  }
+  switch (tid.tag) {
+    case TransactionType.Deposit:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Deposit,
+          depositGroupId: tid.depositGroupId,
+        }),
+      ];
+    case TransactionType.InternalWithdrawal:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Withdraw,
+          withdrawalGroupId: tid.withdrawalGroupId,
+        }),
+      ];
+    case TransactionType.Payment:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Purchase,
+          proposalId: tid.proposalId,
+        }),
+      ];
+    case TransactionType.PeerPullCredit:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.PeerPullCredit,
+          pursePub: tid.pursePub,
+        }),
+      ];
+    case TransactionType.PeerPullDebit:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.PeerPullDebit,
+          peerPullDebitId: tid.peerPullDebitId,
+        }),
+      ];
+    case TransactionType.PeerPushCredit:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.PeerPullCredit,
+          pursePub: tid.peerPushCreditId,
+        }),
+      ];
+    case TransactionType.PeerPushDebit:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.PeerPullCredit,
+          pursePub: tid.pursePub,
+        }),
+      ];
+    case TransactionType.Recoup:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Recoup,
+          recoupGroupId: tid.recoupGroupId,
+        }),
+      ];
+    case TransactionType.Refresh:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Refresh,
+          refreshGroupId: tid.refreshGroupId,
+        }),
+      ];
+    case TransactionType.Refund:
+      return [];
+    case TransactionType.Reward:
+      return [];
+    case TransactionType.Withdrawal:
+      return [
+        constructTaskIdentifier({
+          tag: PendingTaskType.Withdraw,
+          withdrawalGroupId: tid.withdrawalGroupId,
+        }),
+      ];
+    default:
+      assertUnreachable(tid);
+  }
+}
+
 /**
  * Convert the task ID for a task that processes a transaction int
  * the ID for the transaction.