1 files changed, 59 insertions, 53 deletions
diff --git a/packages/taler-wallet-core/src/pay-peer-common.ts b/packages/taler-wallet-core/src/pay-peer-common.ts
index 0bb290440..bfd39b657 100644
--- a/packages/taler-wallet-core/src/pay-peer-common.ts
+++ b/packages/taler-wallet-core/src/pay-peer-common.ts
@@ -43,31 +43,34 @@ export async function queryCoinInfosForSelection(
   csel: DbPeerPushPaymentCoinSelection,
 ): Promise<SpendCoinDetails[]> {
   let infos: SpendCoinDetails[] = [];
-  await wex.db.runReadOnlyTx(["coins", "denominations"], async (tx) => {
-    for (let i = 0; i < csel.coinPubs.length; i++) {
-      const coin = await tx.coins.get(csel.coinPubs[i]);
-      if (!coin) {
-        throw Error("coin not found anymore");
-      }
-      const denom = await getDenomInfo(
-        wex,
-        tx,
-        coin.exchangeBaseUrl,
-        coin.denomPubHash,
-      );
-      if (!denom) {
-        throw Error("denom for coin not found anymore");
+  await wex.db.runReadOnlyTx(
+    { storeNames: ["coins", "denominations"] },
+    async (tx) => {
+      for (let i = 0; i < csel.coinPubs.length; i++) {
+        const coin = await tx.coins.get(csel.coinPubs[i]);
+        if (!coin) {
+          throw Error("coin not found anymore");
+        }
+        const denom = await getDenomInfo(
+          wex,
+          tx,
+          coin.exchangeBaseUrl,
+          coin.denomPubHash,
+        );
+        if (!denom) {
+          throw Error("denom for coin not found anymore");
+        }
+        infos.push({
+          coinPriv: coin.coinPriv,
+          coinPub: coin.coinPub,
+          denomPubHash: coin.denomPubHash,
+          denomSig: coin.denomSig,
+          ageCommitmentProof: coin.ageCommitmentProof,
+          contribution: csel.contributions[i],
+        });
       }
-      infos.push({
-        coinPriv: coin.coinPriv,
-        coinPub: coin.coinPub,
-        denomPubHash: coin.denomPubHash,
-        denomSig: coin.denomSig,
-        ageCommitmentProof: coin.ageCommitmentProof,
-        contribution: csel.contributions[i],
-      });
-    }
-  });
+    },
+  );
   return infos;
 }
 
@@ -75,36 +78,39 @@ export async function getTotalPeerPaymentCost(
   wex: WalletExecutionContext,
   pcs: SelectedProspectiveCoin[],
 ): Promise<AmountJson> {
-  return wex.db.runReadOnlyTx(["coins", "denominations"], async (tx) => {
-    const costs: AmountJson[] = [];
-    for (let i = 0; i < pcs.length; i++) {
-      const denomInfo = await getDenomInfo(
-        wex,
-        tx,
-        pcs[i].exchangeBaseUrl,
-        pcs[i].denomPubHash,
-      );
-      if (!denomInfo) {
-        throw Error(
-          "can't calculate payment cost, denomination for coin not found",
+  return wex.db.runReadOnlyTx(
+    { storeNames: ["coins", "denominations"] },
+    async (tx) => {
+      const costs: AmountJson[] = [];
+      for (let i = 0; i < pcs.length; i++) {
+        const denomInfo = await getDenomInfo(
+          wex,
+          tx,
+          pcs[i].exchangeBaseUrl,
+          pcs[i].denomPubHash,
+        );
+        if (!denomInfo) {
+          throw Error(
+            "can't calculate payment cost, denomination for coin not found",
+          );
+        }
+        const amountLeft = Amounts.sub(
+          denomInfo.value,
+          pcs[i].contribution,
+        ).amount;
+        const refreshCost = await getTotalRefreshCost(
+          wex,
+          tx,
+          denomInfo,
+          amountLeft,
         );
+        costs.push(Amounts.parseOrThrow(pcs[i].contribution));
+        costs.push(refreshCost);
       }
-      const amountLeft = Amounts.sub(
-        denomInfo.value,
-        pcs[i].contribution,
-      ).amount;
-      const refreshCost = await getTotalRefreshCost(
-        wex,
-        tx,
-        denomInfo,
-        amountLeft,
-      );
-      costs.push(Amounts.parseOrThrow(pcs[i].contribution));
-      costs.push(refreshCost);
-    }
-    const zero = Amounts.zeroOfAmount(pcs[0].contribution);
-    return Amounts.sum([zero, ...costs]).amount;
-  });
+      const zero = Amounts.zeroOfAmount(pcs[0].contribution);
+      return Amounts.sum([zero, ...costs]).amount;
+    },
+  );
 }
 
 interface ExchangePurseStatus {
@@ -131,7 +137,7 @@ export async function getMergeReserveInfo(
   const newReservePair = await wex.cryptoApi.createEddsaKeypair({});
 
   const mergeReserveRecord: ReserveRecord = await wex.db.runReadWriteTx(
-    ["exchanges", "reserves"],
+    { storeNames: ["exchanges", "reserves"] },
     async (tx) => {
       const ex = await tx.exchanges.get(req.exchangeBaseUrl);
       checkDbInvariant(!!ex);