1 files changed, 64 insertions, 0 deletions
diff --git a/packages/taler-wallet-core/src/exchanges.ts b/packages/taler-wallet-core/src/exchanges.ts
index d501789a8..152bc76ce 100644
--- a/packages/taler-wallet-core/src/exchanges.ts
+++ b/packages/taler-wallet-core/src/exchanges.ts
@@ -309,6 +309,8 @@ async function makeExchangeListItem(
   return {
     exchangeBaseUrl: r.baseUrl,
     masterPub: exchangeDetails?.masterPublicKey,
+    noFees: r.noFees ?? false,
+    peerPaymentsDisabled: r.peerPaymentsDisabled ?? false,
     currency: exchangeDetails?.currency ?? r.presetCurrencyHint,
     exchangeUpdateStatus: getExchangeUpdateStatusFromRecord(r),
     exchangeEntryStatus: getExchangeEntryStatusFromRecord(r),
@@ -1177,6 +1179,61 @@ async function waitReadyExchange(
   }
 }
 
+function checkPeerPaymentsDisabled(
+  keysInfo: ExchangeKeysDownloadResult,
+): boolean {
+  const now = AbsoluteTime.now();
+  for (let gf of keysInfo.globalFees) {
+    const isActive = AbsoluteTime.isBetween(
+      now,
+      AbsoluteTime.fromProtocolTimestamp(gf.start_date),
+      AbsoluteTime.fromProtocolTimestamp(gf.end_date),
+    );
+    if (!isActive) {
+      continue;
+    }
+    return false;
+  }
+  // No global fees, we can't do p2p payments!
+  return true;
+}
+
+function checkNoFees(keysInfo: ExchangeKeysDownloadResult): boolean {
+  for (const gf of keysInfo.globalFees) {
+    if (!Amounts.isZero(gf.account_fee)) {
+      return false;
+    }
+    if (!Amounts.isZero(gf.history_fee)) {
+      return false;
+    }
+    if (!Amounts.isZero(gf.purse_fee)) {
+      return false;
+    }
+  }
+  for (const denom of keysInfo.currentDenominations) {
+    if (!Amounts.isZero(denom.fees.feeWithdraw)) {
+      return false;
+    }
+    if (!Amounts.isZero(denom.fees.feeDeposit)) {
+      return false;
+    }
+    if (!Amounts.isZero(denom.fees.feeRefund)) {
+      return false;
+    }
+    if (!Amounts.isZero(denom.fees.feeRefresh)) {
+      return false;
+    }
+  }
+  for (const wft of Object.values(keysInfo.wireFees)) {
+    for (const wf of wft) {
+      if (!Amounts.isZero(wf.wire_fee)) {
+        return false;
+      }
+    }
+  }
+  return true;
+}
+
 /**
  * Update an exchange entry in the wallet's database
  * by fetching the /keys and /wire information.
@@ -1305,6 +1362,7 @@ export async function updateExchangeFromUrlHandler(
     keysInfo.globalFees,
     keysInfo.masterPublicKey,
   );
+
   if (keysInfo.baseUrl != exchangeBaseUrl) {
     logger.warn("exchange base URL mismatch");
     const errorDetail: TalerErrorDetail = makeErrorDetail(
@@ -1349,6 +1407,10 @@ export async function updateExchangeFromUrlHandler(
     }
   }
 
+  const now = AbsoluteTime.now();
+  let noFees = checkNoFees(keysInfo);
+  let peerPaymentsDisabled = checkPeerPaymentsDisabled(keysInfo);
+
   const updated = await wex.db.runReadWriteTx(
     [
       "exchanges",
@@ -1390,6 +1452,8 @@ export async function updateExchangeFromUrlHandler(
         wireInfo,
         ageMask,
       };
+      r.noFees = noFees;
+      r.peerPaymentsDisabled = peerPaymentsDisabled;
       r.tosCurrentEtag = tosDownload.tosEtag;
       if (existingDetails?.rowId) {
         newDetails.rowId = existingDetails.rowId;