From f4587c44fd6a6d76384cd671550890255c3fe650 Mon Sep 17 00:00:00 2001
From: Florian Dold <florian@dold.me>
Date: Wed, 13 Sep 2023 16:08:51 +0200
Subject: wallet-core: use typed microsecond timestamps in DB

---
 .../taler-wallet-core/src/operations/withdraw.ts   | 29 ++++++++++------------
 1 file changed, 13 insertions(+), 16 deletions(-)

(limited to 'packages/taler-wallet-core/src/operations/withdraw.ts')

diff --git a/packages/taler-wallet-core/src/operations/withdraw.ts b/packages/taler-wallet-core/src/operations/withdraw.ts
index 32e63f4f6..fb503d75f 100644
--- a/packages/taler-wallet-core/src/operations/withdraw.ts
+++ b/packages/taler-wallet-core/src/operations/withdraw.ts
@@ -131,6 +131,7 @@ import {
   ExchangeEntryDbUpdateStatus,
   PendingTaskType,
   isWithdrawableDenom,
+  timestampPreciseToDb,
 } from "../index.js";
 import {
   TransitionInfo,
@@ -1325,7 +1326,7 @@ async function processWithdrawalGroupAbortingBank(
       }
       const txStatusOld = computeWithdrawalTransactionStatus(wg);
       wg.status = WithdrawalGroupStatus.AbortedBank;
-      wg.timestampFinish = TalerPreciseTimestamp.now();
+      wg.timestampFinish = timestampPreciseToDb(TalerPreciseTimestamp.now());
       const txStatusNew = computeWithdrawalTransactionStatus(wg);
       await tx.withdrawalGroups.put(wg);
       return {
@@ -1458,7 +1459,7 @@ async function processWithdrawalGroupPendingReady(
         }
         const txStatusOld = computeWithdrawalTransactionStatus(wg);
         wg.status = WithdrawalGroupStatus.Done;
-        wg.timestampFinish = TalerPreciseTimestamp.now();
+        wg.timestampFinish = timestampPreciseToDb(TalerPreciseTimestamp.now());
         const txStatusNew = computeWithdrawalTransactionStatus(wg);
         await tx.withdrawalGroups.put(wg);
         return {
@@ -1554,7 +1555,7 @@ async function processWithdrawalGroupPendingReady(
       const oldTxState = computeWithdrawalTransactionStatus(wg);
       logger.info(`now withdrawn ${numFinished} of ${numTotalCoins} coins`);
       if (wg.timestampFinish === undefined && numFinished === numTotalCoins) {
-        wg.timestampFinish = TalerPreciseTimestamp.now();
+        wg.timestampFinish = timestampPreciseToDb(TalerPreciseTimestamp.now());
         wg.status = WithdrawalGroupStatus.Done;
         await makeCoinsVisible(ws, tx, transactionId);
       }
@@ -2047,8 +2048,9 @@ async function registerReserveWithBank(
       if (r.wgInfo.withdrawalType !== WithdrawalRecordType.BankIntegrated) {
         throw Error("invariant failed");
       }
-      r.wgInfo.bankInfo.timestampReserveInfoPosted =
-        AbsoluteTime.toPreciseTimestamp(AbsoluteTime.now());
+      r.wgInfo.bankInfo.timestampReserveInfoPosted = timestampPreciseToDb(
+        AbsoluteTime.toPreciseTimestamp(AbsoluteTime.now()),
+      );
       const oldTxState = computeWithdrawalTransactionStatus(r);
       r.status = WithdrawalGroupStatus.PendingWaitConfirmBank;
       const newTxState = computeWithdrawalTransactionStatus(r);
@@ -2130,7 +2132,7 @@ async function processReserveBankStatus(
         }
         const now = AbsoluteTime.toPreciseTimestamp(AbsoluteTime.now());
         const oldTxState = computeWithdrawalTransactionStatus(r);
-        r.wgInfo.bankInfo.timestampBankConfirmed = now;
+        r.wgInfo.bankInfo.timestampBankConfirmed = timestampPreciseToDb(now);
         r.status = WithdrawalGroupStatus.FailedBankAborted;
         const newTxState = computeWithdrawalTransactionStatus(r);
         await tx.withdrawalGroups.put(r);
@@ -2179,7 +2181,7 @@ async function processReserveBankStatus(
       if (status.transfer_done) {
         logger.info("withdrawal: transfer confirmed by bank.");
         const now = AbsoluteTime.toPreciseTimestamp(AbsoluteTime.now());
-        r.wgInfo.bankInfo.timestampBankConfirmed = now;
+        r.wgInfo.bankInfo.timestampBankConfirmed = timestampPreciseToDb(now);
         r.status = WithdrawalGroupStatus.PendingQueryingStatus;
       } else {
         logger.info("withdrawal: transfer not yet confirmed by bank");
@@ -2285,7 +2287,7 @@ export async function internalPrepareCreateWithdrawalGroup(
     denomsSel: initialDenomSel,
     exchangeBaseUrl: canonExchange,
     instructedAmount: Amounts.stringify(amount),
-    timestampStart: now,
+    timestampStart: timestampPreciseToDb(now),
     rawWithdrawalAmount: initialDenomSel.totalWithdrawCost,
     effectiveWithdrawalAmount: initialDenomSel.totalCoinValue,
     secretSeed,
@@ -2339,8 +2341,7 @@ export async function internalPerformCreateWithdrawalGroup(
   if (!prep.creationInfo) {
     return { withdrawalGroup, transitionInfo: undefined };
   }
-  const { amount, canonExchange, exchangeDetails } =
-    prep.creationInfo;
+  const { amount, canonExchange, exchangeDetails } = prep.creationInfo;
 
   await tx.withdrawalGroups.add(withdrawalGroup);
   await tx.reserves.put({
@@ -2350,7 +2351,7 @@ export async function internalPerformCreateWithdrawalGroup(
 
   const exchange = await tx.exchanges.get(withdrawalGroup.exchangeBaseUrl);
   if (exchange) {
-    exchange.lastWithdrawal = TalerPreciseTimestamp.now();
+    exchange.lastWithdrawal = timestampPreciseToDb(TalerPreciseTimestamp.now());
     exchange.entryStatus = ExchangeEntryDbRecordStatus.Used;
     await tx.exchanges.put(exchange);
   }
@@ -2541,11 +2542,7 @@ export async function createManualWithdrawal(
   });
 
   const exchangePaytoUris = await ws.db
-    .mktx((x) => [
-      x.withdrawalGroups,
-      x.exchanges,
-      x.exchangeDetails,
-    ])
+    .mktx((x) => [x.withdrawalGroups, x.exchanges, x.exchangeDetails])
     .runReadOnly(async (tx) => {
       return await getFundingPaytoUris(tx, withdrawalGroup.withdrawalGroupId);
     });
-- 
cgit v1.2.3