wallet-core: translate transactionId to taskIds

1 files changed, 14 insertions, 1 deletions

diff --git a/packages/taler-wallet-core/src/wallet.ts b/packages/taler-wallet-core/src/wallet.ts
index ea3c4bb83..14f4c85c3 100644
--- a/packages/taler-wallet-core/src/wallet.ts
+++ b/packages/taler-wallet-core/src/wallet.ts
@@ -55,6 +55,7 @@ import {
   TalerErrorCode,
   TalerProtocolTimestamp,
   TalerUriAction,
+  TestingListTasksForTransactionsResponse,
   TestingWaitTransactionRequest,
   TimerAPI,
   TimerGroup,
@@ -121,6 +122,7 @@ import {
   codecForStartRefundQueryRequest,
   codecForSuspendTransaction,
   codecForTestPayArgs,
+  codecForTestingListTasksForTransactionRequest,
   codecForTestingSetTimetravelRequest,
   codecForTransactionByIdRequest,
   codecForTransactionsRequest,
@@ -233,7 +235,11 @@ import {
 } from "./pay-peer-push-debit.js";
 import { DbAccess } from "./query.js";
 import { forceRefresh } from "./refresh.js";
-import { TaskScheduler, TaskSchedulerImpl } from "./shepherd.js";
+import {
+  TaskScheduler,
+  TaskSchedulerImpl,
+  listTaskForTransactionId,
+} from "./shepherd.js";
 import {
   runIntegrationTest,
   runIntegrationTest2,
@@ -717,6 +723,13 @@ async function dispatchRequestInternal<Op extends WalletApiOperation>(
       await withdrawTestBalance(wex, req);
       return {};
     }
+    case WalletApiOperation.TestingListTaskForTransaction: {
+      const req =
+        codecForTestingListTasksForTransactionRequest().decode(payload);
+      return {
+        taskIdList: listTaskForTransactionId(req.transactionId),
+      } satisfies TestingListTasksForTransactionsResponse;
+    }
     case WalletApiOperation.RunIntegrationTest: {
       const req = codecForIntegrationTestArgs().decode(payload);
       await runIntegrationTest(wex, req);