/* 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 */ /** * 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 RegistryEntry { resolve: any; reject: any; workerIndex: number; } interface WorkerState { /** * The actual worker thread. */ w: Worker|null; /** * Are we currently running a task on this worker? */ busy: boolean; /** * Timer to terminate the worker if it's not busy enough. */ terminationTimerHandle: number|null; /** * Index of this worker in the list of workers. */ workerIndex: number; } interface WorkItem { operation: string; args: any[]; resolve: any; reject: any; } /** * 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 rpcRegistry: {[n: number]: RegistryEntry} = {}; private workers: WorkerState[]; private workQueues: WorkItem[][]; /** * Number of busy workers. */ private numBusy: number = 0; /** * Number if pending work items. */ private numWaiting: number = 0; /** * Start a worker (if not started) and set as busy. */ wake(ws: WorkerState) { if (ws.busy) { throw Error("assertion failed"); } ws.busy = true; 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; } if (ws.terminationTimerHandle != null) { clearTimeout(ws.terminationTimerHandle); } let destroy = () => { if (ws.w && !ws.busy) { ws.w!.terminate(); ws.w = null; } } ws.terminationTimerHandle = setTimeout(destroy, 20 * 1000); } handleWorkerError(ws: WorkerState, e: ErrorEvent) { console.error("error in worker", e); try { ws.w!.terminate(); } catch (e) { console.error(e); } if (ws.busy) { ws.busy = false; 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()!; let msg: any = { operation: work.operation, args: work.args, id: this.registerRpcId(work.resolve, work.reject, ws.workerIndex), }; this.wake(ws); ws.w!.postMessage(msg); return; } } } handleWorkerMessage(ws: WorkerState, msg: MessageEvent) { let id = msg.data.id; if (typeof id !== "number") { console.error("rpc id must be number"); return; } if (!this.rpcRegistry[id]) { console.error(`RPC with id ${id} has no registry entry`); return; } let {resolve, workerIndex} = this.rpcRegistry[id]; delete this.rpcRegistry[id]; if (workerIndex != ws.workerIndex) { throw Error("assertion failed"); } if (!ws.busy) { throw Error("assertion failed"); } ws.busy = false; this.numBusy--; resolve(msg.data.result); this.findWork(ws); } constructor() { this.workers = new Array((navigator as any)["hardwareConcurrency"] || 2); for (let i = 0; i < this.workers.length; i++) { this.workers[i] = { w: null, busy: false, terminationTimerHandle: null, workerIndex: i, }; } this.workQueues = []; for (let i = 0; i < NUM_PRIO; i++) { this.workQueues.push([]); } } private registerRpcId(resolve: any, reject: any, workerIndex: number): number { let id = this.nextRpcId++; this.rpcRegistry[id] = {resolve, reject, workerIndex}; return id; } private doRpc(operation: string, priority: number, ...args: any[]): Promise { if (this.numBusy == this.workers.length) { let q = this.workQueues[priority]; if (!q) { throw Error("assertion failed"); } return new Promise((resolve, reject) => { this.workQueues[priority].push({operation, args, resolve, reject}); }); } for (let i = 0; i < this.workers.length; i++) { let ws = this.workers[i]; if (ws.busy) { continue; } this.wake(ws); return new Promise((resolve, reject) => { let msg: any = { operation, args, id: this.registerRpcId(resolve, reject, i), }; ws.w!.postMessage(msg); }); } throw Error("assertion failed"); } createPreCoin(denom: Denomination, reserve: ReserveRecord): Promise { return this.doRpc("createPreCoin", 1, denom, reserve); } hashString(str: string): Promise { return this.doRpc("hashString", 1, str); } hashRsaPub(rsaPub: string): Promise { return this.doRpc("hashRsaPub", 2, rsaPub); } isValidDenom(denom: Denomination, masterPub: string): Promise { return this.doRpc("isValidDenom", 2, denom, masterPub); } signDeposit(offer: Offer, cds: CoinWithDenom[]): Promise { 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 { return this.doRpc("rsaUnblind", 4, sig, bk, pk); } createWithdrawSession(kappa: number, meltCoin: Coin, newCoinDenoms: Denomination[], meltAmount: AmountJson, meltFee: AmountJson): Promise { return this.doRpc("createWithdrawSession", 4, kappa, meltCoin, newCoinDenoms, meltAmount, meltFee); } }