restructuring

1 files changed, 0 insertions, 256 deletions

diff --git a/lib/wallet/cryptoApi.ts b/lib/wallet/cryptoApi.ts
deleted file mode 100644
index 31407b74a..000000000
--- a/lib/wallet/cryptoApi.ts
+++ /dev/null
@@ -1,256 +0,0 @@
-/*
- This file is part of TALER
- (C) 2016 GNUnet e.V.
-
- TALER is free software; you can redistribute it and/or modify it under the
- terms of the GNU General Public License as published by the Free Software
- Foundation; either version 3, or (at your option) any later version.
-
- TALER is distributed in the hope that it will be useful, but WITHOUT ANY
- WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
- A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License along with
- TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
- */
-
-
-/**
- * API to access the Taler crypto worker thread.
- * @author Florian Dold
- */
-
-
-import {PreCoin, Coin, ReserveRecord, AmountJson} from "./types";
-import {Denomination} from "./types";
-import {Offer} from "./wallet";
-import {CoinWithDenom} from "./wallet";
-import {PayCoinInfo} from "./types";
-import {RefreshSession} from "./types";
-
-
-interface WorkerState {
-  /**
-   * The actual worker thread.
-   */
-  w: Worker|null;
-
-  /**
-   * Work we're currently executing or null if not busy.
-   */
-  currentWorkItem: WorkItem|null;
-
-  /**
-   * Timer to terminate the worker if it's not busy enough.
-   */
-  terminationTimerHandle: number|null;
-}
-
-interface WorkItem {
-  operation: string;
-  args: any[];
-  resolve: any;
-  reject: any;
-
-  /**
-   * Serial id to identify a matching response.
-   */
-  rpcId: number;
-}
-
-
-/**
- * Number of different priorities. Each priority p
- * must be 0 <= p < NUM_PRIO.
- */
-const NUM_PRIO = 5;
-
-export class CryptoApi {
-  private nextRpcId: number = 1;
-  private workers: WorkerState[];
-  private workQueues: WorkItem[][];
-  /**
-   * Number of busy workers.
-   */
-  private numBusy: number = 0;
-
-  /**
-   * Start a worker (if not started) and set as busy.
-   */
-  wake<T>(ws: WorkerState, work: WorkItem): void {
-    if (ws.currentWorkItem != null) {
-      throw Error("assertion failed");
-    }
-    ws.currentWorkItem = work;
-    this.numBusy++;
-    if (!ws.w) {
-      let w = new Worker("/lib/wallet/cryptoWorker.js");
-      w.onmessage = (m: MessageEvent) => this.handleWorkerMessage(ws, m);
-      w.onerror = (e: ErrorEvent) => this.handleWorkerError(ws, e);
-      ws.w = w;
-    }
-
-    let msg: any = {
-      operation: work.operation, args: work.args,
-      id: work.rpcId
-    };
-    this.resetWorkerTimeout(ws);
-    ws.w!.postMessage(msg);
-  }
-
-  resetWorkerTimeout(ws: WorkerState) {
-    if (ws.terminationTimerHandle != null) {
-      clearTimeout(ws.terminationTimerHandle);
-    }
-    let destroy = () => {
-      // terminate worker if it's idle
-      if (ws.w && ws.currentWorkItem == null) {
-        ws.w!.terminate();
-        ws.w = null;
-      }
-    };
-    ws.terminationTimerHandle = setTimeout(destroy, 20 * 1000);
-  }
-
-  handleWorkerError(ws: WorkerState, e: ErrorEvent) {
-    if (ws.currentWorkItem) {
-      console.error(`error in worker during ${ws.currentWorkItem!.operation}`,
-                    e);
-    } else {
-      console.error("error in worker", e);
-    }
-    console.error(e.message);
-    try {
-      ws.w!.terminate();
-      ws.w = null;
-    } catch (e) {
-      console.error(e);
-    }
-    if (ws.currentWorkItem != null) {
-      ws.currentWorkItem.reject(e);
-      ws.currentWorkItem = null;
-      this.numBusy--;
-    }
-    this.findWork(ws);
-  }
-
-  findWork(ws: WorkerState) {
-    // try to find more work for this worker
-    for (let i = 0; i < NUM_PRIO; i++) {
-      let q = this.workQueues[NUM_PRIO - i - 1];
-      if (q.length != 0) {
-        let work: WorkItem = q.shift()!;
-        this.wake(ws, work);
-        return;
-      }
-    }
-  }
-
-  handleWorkerMessage(ws: WorkerState, msg: MessageEvent) {
-    let id = msg.data.id;
-    if (typeof id !== "number") {
-      console.error("rpc id must be number");
-      return;
-    }
-    let currentWorkItem = ws.currentWorkItem;
-    ws.currentWorkItem = null;
-    this.numBusy--;
-    this.findWork(ws);
-    if (!currentWorkItem) {
-      console.error("unsolicited response from worker");
-      return;
-    }
-    if (id != currentWorkItem.rpcId) {
-      console.error(`RPC with id ${id} has no registry entry`);
-      return;
-    }
-    currentWorkItem.resolve(msg.data.result);
-  }
-
-  constructor() {
-    this.workers = new Array<WorkerState>((navigator as any)["hardwareConcurrency"] || 2);
-
-    for (let i = 0; i < this.workers.length; i++) {
-      this.workers[i] = {
-        w: null,
-        terminationTimerHandle: null,
-        currentWorkItem: null,
-      };
-    }
-    this.workQueues = [];
-    for (let i = 0; i < NUM_PRIO; i++) {
-      this.workQueues.push([]);
-    }
-  }
-
-  private doRpc<T>(operation: string, priority: number,
-                   ...args: any[]): Promise<T> {
-
-    return new Promise((resolve, reject) => {
-      let rpcId = this.nextRpcId++;
-      let workItem: WorkItem = {operation, args, resolve, reject, rpcId};
-
-      if (this.numBusy == this.workers.length) {
-        let q = this.workQueues[priority];
-        if (!q) {
-          throw Error("assertion failed");
-        }
-        this.workQueues[priority].push(workItem);
-        return;
-      }
-
-      for (let i = 0; i < this.workers.length; i++) {
-        let ws = this.workers[i];
-        if (ws.currentWorkItem != null) {
-          continue;
-        }
-
-        this.wake<T>(ws, workItem);
-        return;
-      }
-
-      throw Error("assertion failed");
-    });
-  }
-
-
-  createPreCoin(denom: Denomination, reserve: ReserveRecord): Promise<PreCoin> {
-    return this.doRpc("createPreCoin", 1, denom, reserve);
-  }
-
-  hashString(str: string): Promise<string> {
-    return this.doRpc("hashString", 1, str);
-  }
-
-  isValidDenom(denom: Denomination,
-               masterPub: string): Promise<boolean> {
-    return this.doRpc("isValidDenom", 2, denom, masterPub);
-  }
-
-  signDeposit(offer: Offer,
-              cds: CoinWithDenom[]): Promise<PayCoinInfo> {
-    return this.doRpc("signDeposit", 3, offer, cds);
-  }
-
-  createEddsaKeypair(): Promise<{priv: string, pub: string}> {
-    return this.doRpc("createEddsaKeypair", 1);
-  }
-
-  rsaUnblind(sig: string, bk: string, pk: string): Promise<string> {
-    return this.doRpc("rsaUnblind", 4, sig, bk, pk);
-  }
-
-  createRefreshSession(exchangeBaseUrl: string,
-                       kappa: number,
-                       meltCoin: Coin,
-                       newCoinDenoms: Denomination[],
-                       meltFee: AmountJson): Promise<RefreshSession> {
-    return this.doRpc("createRefreshSession",
-                      4,
-                      exchangeBaseUrl,
-                      kappa,
-                      meltCoin,
-                      newCoinDenoms,
-                      meltFee);
-  }
-}