taler-typescript-core

commit 3c9ddf6e764aa5da62ea5deff35ac215510e455d
parent 985eb10f31bee73924a34304c0eb0aafcf6420d5
Author: Florian Dold <dold@taler.net>
Date:   Sun, 19 Jul 2026 01:55:06 +0200

db: move dev-experiments.ts behind the DAL

Diffstat:
M
packages/taler-wallet-core/src/dev-experiments.ts
 | 
54
+++++++++++++++++++++++++++---------------------------

1 file changed, 27 insertions(+), 27 deletions(-)
diff --git a/packages/taler-wallet-core/src/dev-experiments.ts b/packages/taler-wallet-core/src/dev-experiments.ts
@@ -183,7 +183,7 @@ export async function applyDevExperiment(
     }
     case "insert-pending-refresh": {
       const refreshGroupId = encodeCrock(getRandomBytes(32));
-      await wex.runLegacyWalletDbTx(async (tx) => {
+      await wex.runWalletDbTx(async (tx) => {
         const newRg: WalletRefreshGroup = {
           currency: "TESTKUDOS",
           expectedOutputPerCoin: [],
@@ -199,9 +199,9 @@ export async function applyDevExperiment(
           infoPerExchange: {},
           refundRequests: {},
         };
-        await tx.wtx.upsertRefreshGroup(newRg);
+        await tx.upsertRefreshGroup(newRg);
         const ctx = new RefreshTransactionContext(wex, refreshGroupId);
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       wex.taskScheduler.startShepherdTask(
         constructTaskIdentifier({
@@ -212,7 +212,7 @@ export async function applyDevExperiment(
       return;
     }
     case "insert-denom-loss": {
-      await wex.runLegacyWalletDbTx(async (tx) => {
+      await wex.runWalletDbTx(async (tx) => {
         const eventId = encodeCrock(getRandomBytes(32));
         const newRg: WalletDenomLossEvent = {
           amount: "TESTKUDOS:42",
@@ -227,12 +227,12 @@ export async function applyDevExperiment(
           status: DenomLossStatus.Done,
           timestampCreated: timestampPreciseToDb(TalerPreciseTimestamp.now()),
         };
-        await tx.wtx.upsertDenomLossEvent(newRg);
+        await tx.upsertDenomLossEvent(newRg);
         const ctx = new DenomLossTransactionContext(
           wex,
           newRg.denomLossEventId,
         );
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       return;
     }
@@ -340,16 +340,16 @@ export async function applyDevExperiment(
       return;
     }
     case "rebuild-transactions": {
-      await wex.runLegacyWalletDbTx(async (tx) => {
+      await wex.runWalletDbTx(async (tx) => {
         // Re-build / fix up info about exchanges for purchase transactions.
-        await tx.purchases.iter().forEachAsync(async (rec) => {
+        for (const rec of await tx.listAllPurchases()) {
           let exchangeSet = new Set<string>();
           if (!rec.exchanges || rec.exchanges.length === 0) {
             if (rec.payInfo?.payCoinSelection) {
               const coinPubs = rec.payInfo.payCoinSelection.coinPubs;
 
               for (const pub of coinPubs) {
-                const coin = await tx.coins.get(pub);
+                const coin = await tx.getCoin(pub);
                 if (!coin) {
                   logger.warn(
                     `coin ${coinPubs} not found, unable to compute full scope`,
@@ -361,10 +361,10 @@ export async function applyDevExperiment(
             }
             rec.exchanges = [...exchangeSet];
             rec.exchanges.sort();
-            await tx.wtx.upsertPurchase(rec);
+            await tx.upsertPurchase(rec);
           }
-        });
-        await rematerializeTransactions(wex, tx.wtx);
+        }
+        await rematerializeTransactions(wex, tx);
       });
       return;
     }
@@ -566,8 +566,8 @@ async function addFakeTx(
       } else {
         timestamp = AbsoluteTime.now();
       }
-      await wex.runLegacyWalletDbTx(async (tx) => {
-        await tx.wtx.upsertWithdrawalGroup({
+      await wex.runWalletDbTx(async (tx) => {
+        await tx.upsertWithdrawalGroup({
           reservePriv: reservePair.priv,
           reservePub: reservePair.pub,
           secretSeed,
@@ -600,7 +600,7 @@ async function addFakeTx(
           effectiveWithdrawalAmount: Amounts.stringify(amountEffective),
           rawWithdrawalAmount: Amounts.stringify(amountEffective),
         });
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       break;
     }
@@ -660,12 +660,12 @@ async function addFakeTx(
         wire_transfer_deadline: AbsoluteTime.toProtocolTimestamp(timestamp),
       };
       const contractTermsHash = ContractTermsUtil.hashContractTerms(ct);
-      await wex.runLegacyWalletDbTx(async (tx) => {
-        await tx.wtx.upsertContractTerms({
+      await wex.runWalletDbTx(async (tx) => {
+        await tx.upsertContractTerms({
           contractTermsRaw: ct,
           h: contractTermsHash,
         });
-        await tx.wtx.upsertPurchase({
+        await tx.upsertPurchase({
           autoRefundDeadline: undefined,
           claimToken: encodeCrock(getRandomBytes(32)),
           downloadSessionId: encodeCrock(getRandomBytes(32)),
@@ -703,7 +703,7 @@ async function addFakeTx(
           ),
           refundAmountAwaiting: undefined,
         });
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       break;
     }
@@ -742,12 +742,12 @@ async function addFakeTx(
       const contractTermsHash = ContractTermsUtil.hashContractTerms(ct);
       const contractPair = await wex.cryptoApi.createEddsaKeypair({});
       const mergePair = await wex.cryptoApi.createEddsaKeypair({});
-      await wex.runLegacyWalletDbTx(async (tx) => {
-        await tx.wtx.upsertContractTerms({
+      await wex.runWalletDbTx(async (tx) => {
+        await tx.upsertContractTerms({
           contractTermsRaw: ct,
           h: contractTermsHash,
         });
-        await tx.peerPushDebit.put({
+        await tx.upsertPeerPushDebit({
           amount: Amounts.stringify(amountEffective),
           contractEncNonce: encodeCrock(getRandomBytes(32)),
           contractPriv: contractPair.priv,
@@ -765,7 +765,7 @@ async function addFakeTx(
           ),
           totalCost: Amounts.stringify(amountEffective),
         });
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       break;
     }
@@ -805,12 +805,12 @@ async function addFakeTx(
       const contractTermsHash = ContractTermsUtil.hashContractTerms(ct);
       const contractPair = await wex.cryptoApi.createEddsaKeypair({});
       const mergePair = await wex.cryptoApi.createEddsaKeypair({});
-      await wex.runLegacyWalletDbTx(async (tx) => {
-        await tx.wtx.upsertContractTerms({
+      await wex.runWalletDbTx(async (tx) => {
+        await tx.upsertContractTerms({
           contractTermsRaw: ct,
           h: contractTermsHash,
         });
-        await tx.peerPushCredit.put({
+        await tx.upsertPeerPushCredit({
           contractPriv: contractPair.priv,
           contractTermsHash,
           currency: Amounts.currencyOf(amountEffective),
@@ -825,7 +825,7 @@ async function addFakeTx(
           ),
           withdrawalGroupId: undefined,
         });
-        await ctx.updateTransactionMeta(tx.wtx);
+        await ctx.updateTransactionMeta(tx);
       });
       break;
     }