wallet-core: testing request for reserve history

1 files changed, 34 insertions, 1 deletions

diff --git a/packages/taler-wallet-core/src/wallet.ts b/packages/taler-wallet-core/src/wallet.ts
index ea47ffad7..fe03dbf62 100644
--- a/packages/taler-wallet-core/src/wallet.ts
+++ b/packages/taler-wallet-core/src/wallet.ts
@@ -134,6 +134,7 @@ import {
   codecForSuspendTransaction,
   codecForTestPayArgs,
   codecForTestingGetDenomStatsRequest,
+  codecForTestingGetReserveHistoryRequest,
   codecForTestingListTasksForTransactionRequest,
   codecForTestingSetTimetravelRequest,
   codecForTransactionByIdRequest,
@@ -154,7 +155,10 @@ import {
   setDangerousTimetravel,
   validateIban,
 } from "@gnu-taler/taler-util";
-import type { HttpRequestLibrary } from "@gnu-taler/taler-util/http";
+import {
+  readSuccessResponseJsonOrThrow,
+  type HttpRequestLibrary,
+} from "@gnu-taler/taler-util/http";
 import {
   getUserAttentions,
   getUserAttentionsUnreadCount,
@@ -909,6 +913,35 @@ async function dispatchRequestInternal(
         restrictAge: req.restrictAge,
       });
     }
+    case WalletApiOperation.TestingGetReserveHistory: {
+      const req = codecForTestingGetReserveHistoryRequest().decode(payload);
+      const reserve = await wex.db.runReadOnlyTx(
+        { storeNames: ["reserves"] },
+        async (tx) => {
+          return tx.reserves.indexes.byReservePub.get(req.reservePub);
+        },
+      );
+      if (!reserve) {
+        throw Error("no reserve pub found");
+      }
+      const sigResp = await wex.cryptoApi.signReserveHistoryReq({
+        reservePriv: reserve.reservePriv,
+        startOffset: 0,
+      });
+      const exchangeBaseUrl = req.exchangeBaseUrl;
+      const url = new URL(
+        `reserves/${req.reservePub}/history`,
+        exchangeBaseUrl,
+      );
+      const resp = await wex.http.fetch(url.href, {
+        headers: { ["Taler-Reserve-History-Signature"]: sigResp.sig },
+      });
+      const historyJson = await readSuccessResponseJsonOrThrow(
+        resp,
+        codecForAny(),
+      );
+      return historyJson;
+    }
     case WalletApiOperation.AcceptManualWithdrawal: {
       const req = codecForAcceptManualWithdrawalRequest().decode(payload);
       const res = await createManualWithdrawal(wex, {