wallet-core: trust exchange for exchange benchmark

packages/taler-wallet-cli/src/bench1.ts

@@ -105,6 +105,8 @@ export async function runBench1(configJson: any): Promise<void> {
       logger.info(`Finished deposit amount=10 time=${Date.now() - start}`);
     }
   }
+
+  wallet.stop();
 }
 
 /**

packages/taler-wallet-core/src/common.ts

@@ -133,6 +133,8 @@ export interface InternalWalletState {
   timerGroup: TimerGroup;
   stopped: boolean;
 
+  insecureTrustExchange: boolean;
+
   /**
    * Asynchronous condition to interrupt the sleep of the
    * retry loop.

packages/taler-wallet-core/src/crypto/workers/synchronousWorker.ts

@@ -25,7 +25,7 @@ import { CryptoWorker } from "./cryptoWorkerInterface.js";
 import child_process from "child_process";
 import type internal from "stream";
 import { OpenedPromise, openPromise } from "../../index.js";
-import { FreshCoin, Logger } from "@gnu-taler/taler-util";
+import { Logger } from "@gnu-taler/taler-util";
 
 const logger = new Logger("synchronousWorker.ts");
 

packages/taler-wallet-core/src/operations/exchanges.ts

@@ -218,19 +218,24 @@ export async function acceptExchangeTermsOfService(
 }
 
 async function validateWireInfo(
+  ws: InternalWalletState,
   versionCurrent: number,
   wireInfo: ExchangeWireJson,
   masterPublicKey: string,
-  cryptoApi: CryptoApi,
 ): Promise<WireInfo> {
   for (const a of wireInfo.accounts) {
     logger.trace("validating exchange acct");
-    const isValid = await cryptoApi.isValidWireAccount(
+    let isValid = false;
+    if (ws.insecureTrustExchange) {
+      isValid = true;
+    } else {
+      isValid = await ws.cryptoApi.isValidWireAccount(
         versionCurrent,
         a.payto_uri,
         a.master_sig,
         masterPublicKey,
       );
+    }
     if (!isValid) {
       throw Error("exchange acct signature invalid");
     }
@@ -248,11 +253,16 @@ async function validateWireInfo(
         startStamp,
         wireFee: Amounts.parseOrThrow(x.wire_fee),
       };
-      const isValid = await cryptoApi.isValidWireFee(
+      let isValid = false;
+      if (ws.insecureTrustExchange) {
+        isValid = true;
+      } else {
+        isValid = await ws.cryptoApi.isValidWireFee(
           wireMethod,
           fee,
           masterPublicKey,
         );
+      }
       if (!isValid) {
         throw Error("exchange wire fee signature invalid");
       }
@@ -488,10 +498,10 @@ async function updateExchangeFromUrlImpl(
   }
 
   const wireInfo = await validateWireInfo(
+    ws,
     version.current,
     wireInfoDownload,
     keysInfo.masterPublicKey,
-    ws.cryptoApi,
   );
 
   logger.info("finished validating exchange /wire info");

packages/taler-wallet-core/src/operations/withdraw.ts

@@ -777,10 +777,15 @@ export async function updateWithdrawalDenoms(
             denominations.length
           }) signature of ${denom.denomPubHash}`,
         );
-        const valid = await ws.cryptoApi.isValidDenom(
+        let valid: boolean = false;
+        if (ws.insecureTrustExchange) {
+          valid = true;
+        } else {
+          valid = await ws.cryptoApi.isValidDenom(
             denom,
             exchangeDetails.masterPublicKey,
           );
+        }
         logger.trace(`Done validating ${denom.denomPubHash}`);
         if (!valid) {
           logger.warn(

packages/taler-wallet-core/src/wallet.ts

@@ -1037,6 +1037,14 @@ export class Wallet {
     return this._client;
   }
 
+  /**
+   * Trust the exchange, do not validate signatures.
+   * Only used to benchmark the exchange.
+   */
+  setInsecureTrustExchange() {
+    this.ws.insecureTrustExchange = true;
+  }
+
   static async create(
     db: DbAccess<typeof WalletStoresV1>,
     http: HttpRequestLibrary,
@@ -1089,6 +1097,8 @@ class InternalWalletStateImpl implements InternalWalletState {
 
   merchantInfoCache: Record<string, MerchantInfo> = {};
 
+  insecureTrustExchange: boolean = false;
+
   timerGroup: TimerGroup = new TimerGroup();
   latch = new AsyncCondition();
   stopped = false;