diff options
Diffstat (limited to 'extension/background/wallet.js')
| -rw-r--r-- | extension/background/wallet.js | 497 |
1 files changed, 216 insertions, 281 deletions
diff --git a/extension/background/wallet.js b/extension/background/wallet.js index 91b6de0d4..4f245588b 100644 --- a/extension/background/wallet.js +++ b/extension/background/wallet.js @@ -1,322 +1,257 @@ +/// <reference path="../decl/urijs/URIjs.d.ts" /> +/// <reference path="../decl/chrome/chrome.d.ts" /> 'use strict'; - const DB_NAME = "taler"; const DB_VERSION = 1; - - /** * Return a promise that resolves * to the taler wallet db. */ -function openTalerDb(cont) { - return new Promise((resolve, reject) => { - let req = indexedDB.open(DB_NAME, DB_VERSION); - req.addEventListener("error", (e) => { - reject(e); +function openTalerDb() { + return new Promise((resolve, reject) => { + let req = indexedDB.open(DB_NAME, DB_VERSION); + req.onerror = (e) => { + reject(e); + }; + req.onsuccess = (e) => { + resolve(e.target.result); + }; + req.onupgradeneeded = (event) => { + let db = event.target.result; + console.log("DB: upgrade needed: oldVersion = " + event.oldVersion); + db = event.target.result; + switch (event.oldVersion) { + case 0: + db.createObjectStore("mints", { keyPath: "baseUrl" }); + db.createObjectStore("reserves", { keyPath: "reserve_pub" }); + db.createObjectStore("denoms", { keyPath: "denom_pub" }); + db.createObjectStore("coins", { keyPath: "coin_pub" }); + db.createObjectStore("withdrawals", { keyPath: "id", autoIncrement: true }); + db.createObjectStore("transactions", { keyPath: "id", autoIncrement: true }); + break; + } + }; }); - req.addEventListener("success", (e) => { - resolve(e.target.result); - }); - req.addEventListener("upgradeneeded", (e) => { - let db = e.target.result; - console.log ("DB: upgrade needed: oldVersion = " + event.oldVersion); - db = event.target.result; - switch (event.oldVersion) { - case 0: // DB does not exist yet - db.createObjectStore("mints", { keyPath: "baseUrl" }); - db.createObjectStore("reserves", { keyPath: "reserve_pub"}); - db.createObjectStore("denoms", { keyPath: "denom_pub" }); - db.createObjectStore("coins", { keyPath: "coin_pub" }); - db.createObjectStore("withdrawals", { keyPath: "id", autoIncrement: true }); - db.createObjectStore("transactions", { keyPath: "id", autoIncrement: true }); - break; - } - }); - }); } - - function canonicalizeBaseUrl(url) { - let x = new URI(url); - if (!x.protocol()) { - x.protocol("https"); - } - x.path(x.path() + "/").normalizePath(); - x.fragment(); - x.query(); - return x.href() -} - - -function confirmReserve(db, detail, sendResponse) { - console.log('detail: ' + JSON.stringify(detail)); - let keypair = createEddsaKeyPair(); - let form = new FormData(); - let now = (new Date()).toString(); - form.append(detail.field_amount, detail.amount_str); - form.append(detail.field_reserve_pub, keypair.pub); - form.append(detail.field_mint, detail.mint); - // XXX: set bank-specified fields. - let myRequest = new XMLHttpRequest(); - console.log("making request to " + detail.post_url); - myRequest.open('post', detail.post_url); - myRequest.send(form); - let mintBaseUrl = canonicalizeBaseUrl(detail.mint); - myRequest.addEventListener('readystatechange', (e) => { - if (myRequest.readyState == XMLHttpRequest.DONE) { - let resp = {}; - resp.status = myRequest.status; - resp.text = myRequest.responseText; - let reserveRecord = { - reserve_pub: keypair.pub, - reserve_priv: keypair.priv, - mint_base_url: mintBaseUrl, - created: now, - last_query: null, - current_amount: null, - // XXX: set to actual amount - initial_amount: null - }; - // XXX: insert into db. - switch (myRequest.status) { - case 200: - resp.success = true; - // We can't show the page directly, so - // we show some generic page from the wallet. - resp.backlink = chrome.extension.getURL("pages/reserve-success.html"); - let tx = db.transaction(['reserves'], 'readwrite'); - tx.objectStore('reserves').add(reserveRecord); - tx.addEventListener('complete', (e) => { - console.log('tx complete, pk was ' + reserveRecord.reserve_pub); - sendResponse(resp); - var mint; - updateMintFromUrl(db, reserveRecord.mint_base_url) - .then((m) => { mint = m; return updateReserve(db, keypair.pub, mint); }) - .then((reserve) => depleteReserve(db, reserve, mint)); - }); - break; - default: - resp.success = false; - sendResponse(resp); - } + let x = new URI(url); + if (!x.protocol()) { + x.protocol("https"); } - }); - // Allow async response - return true; + x.path(x.path() + "/").normalizePath(); + x.fragment(); + x.query(); + return x.href(); } - - -function sumAmounts() { - let v = 0; - let f = 0; - let c; - let xs = arguments; - if (xs.length == 0) { - throw "no arguments given"; - } - for (let x of xs) { - v = (v + x.value) + Math.floor((f + x.value) / 10e6); - f = (f + x.fraction) % 10e6; - c = x.currency; - } - return {value: v, fraction:f, currency: c}; -} - -function subtractAmount(a1, a2) { - if (compareAmount(a1, a2) < 0) { - throw "negative result"; - } - let r = { - currency: a1.currency, - value: a1.value, - fraction: a1.fraction - }; - if (a2.fraction > a1.fraction) { - r.value--; - r.fraction += 1000000; - } - r.value -= a2.value; - r.fraction -= a2.fraction; - return r; -} - - -function compareAmount(a1, a2) { - if (a1.currency !== a2.currency) { - throw "can't compare different currencies"; - } - let v1 = [a1.value + Math.floor(a1.fraction / 10e6), a1.fraction % 10e6]; - let v2 = [a2.value + Math.floor(a2.fraction / 10e6), a2.fraction % 10e6]; - for (let i in v1) { - if (v1[i] < v2[i]) { - return -1; - } - if (v1[i] > v2[i]) { - return 1; - } - } - return 0; +function confirmReserve(db, detail, sendResponse) { + console.log('detail: ' + JSON.stringify(detail)); + let reservePriv = EddsaPrivateKey.create(); + let reservePub = reservePriv.getPublicKey(); + let form = new FormData(); + let now = (new Date()).toString(); + form.append(detail.field_amount, detail.amount_str); + form.append(detail.field_reserve_pub, reservePub.encode()); + form.append(detail.field_mint, detail.mint); + // XXX: set bank-specified fields. + let myRequest = new XMLHttpRequest(); + console.log("making request to " + detail.post_url); + myRequest.open('post', detail.post_url); + myRequest.send(form); + let mintBaseUrl = canonicalizeBaseUrl(detail.mint); + myRequest.addEventListener('readystatechange', (e) => { + if (myRequest.readyState == XMLHttpRequest.DONE) { + // TODO: extract as interface + let resp = { + status: myRequest.status, + text: myRequest.responseText, + success: undefined, + backlink: undefined + }; + let reserveRecord = { + reserve_pub: reservePub.encode(), + reserve_priv: reservePriv.encode(), + mint_base_url: mintBaseUrl, + created: now, + last_query: null, + current_amount: null, + // XXX: set to actual amount + initial_amount: null + }; + // XXX: insert into db. + switch (myRequest.status) { + case 200: + resp.success = true; + // We can't show the page directly, so + // we show some generic page from the wallet. + resp.backlink = chrome.extension.getURL("pages/reserve-success.html"); + let tx = db.transaction(['reserves'], 'readwrite'); + tx.objectStore('reserves').add(reserveRecord); + tx.addEventListener('complete', (e) => { + console.log('tx complete, pk was ' + reserveRecord.reserve_pub); + sendResponse(resp); + var mint; + updateMintFromUrl(db, reserveRecord.mint_base_url) + .then((m) => { mint = m; return updateReserve(db, reservePub, mint); }) + .then((reserve) => depleteReserve(db, reserve, mint)); + }); + break; + default: + resp.success = false; + sendResponse(resp); + } + } + }); + // Allow async response + return true; } - function copy(o) { - return JSON.parse(JSON.stringify(o)); + return JSON.parse(JSON.stringify(o)); } - - function rankDenom(o1, o2) { - return (-1) * compareAmount(o1.value, o2.value); + return (-1) * o1.cmp(o2); } - - function withdraw(denom, reserve, mint) { - let wd = {}; - wd.denom_pub = denom.denom_pub; - wd.reserve_pub = reserve.reserve_pub; - let coin_key = createEddsaKeyPair(); - // create RSA blinding key - // blind coin - // generate signature + let wd = { + denom_pub: denom.denom_pub, + reserve_pub: reserve.reserve_pub, + }; + let coinPub = EddsaPrivateKey.create(); + // create RSA blinding key + // blind coin + // generate signature } - - /** * Withdraw coins from a reserve until it is empty. */ function depleteReserve(db, reserve, mint) { - let denoms = copy(mint.keys.denoms); - let remaining = copy(reserve.current_amount); - denoms.sort(rankDenom); - for (let i = 0; i < 1000; i++) { - let found = false; - for (let d of denoms) { - let cost = sumAmounts(d.value, d.fee_withdraw); - if (compareAmount (remaining, cost) < 0) { - continue; - } - found = true; - remaining = subtractAmount(remaining, cost); - withdraw(d, reserve, mint); - } - if (!found) { - break; + let denoms = copy(mint.keys.denoms); + let remaining = new Amount(reserve.current_amount); + denoms.sort(rankDenom); + for (let i = 0; i < 1000; i++) { + let found = false; + for (let d of denoms) { + let cost = new Amount(); + cost.add(new Amount(d.value)); + cost.add(new Amount(d.fee_withdraw)); + if (remaining.cmp(cost) < 0) { + continue; + } + found = true; + remaining.sub(cost); + withdraw(d, reserve, mint); + } + if (!found) { + break; + } } - } - } - - function updateReserve(db, reservePub, mint) { - let reserve; - return new Promise((resolve, reject) => { - let tx = db.transaction(['reserves']); - tx.objectStore('reserves').get(reservePub).onsuccess = (e) => { - let reserve = e.target.result; - let reqUrl = URI("reserve/status").absoluteTo(mint.baseUrl); - reqUrl.query({'reserve_pub': reservePub}); - let myRequest = new XMLHttpRequest(); - console.log("making request to " + reqUrl.href()); - myRequest.open('get', reqUrl.href()); - myRequest.send(); - myRequest.addEventListener('readystatechange', (e) => { - if (myRequest.readyState == XMLHttpRequest.DONE) { - if (myRequest.status != 200) { - reject(); - return; - } - let reserveInfo = JSON.parse(myRequest.responseText); - console.log("got response " + JSON.stringify(reserveInfo)); - reserve.current_amount = reserveInfo.balance; - let tx = db.transaction(['reserves'], 'readwrite'); - console.log("putting updated reserve " + JSON.stringify(reserve)); - tx.objectStore('reserves').put(reserve); - tx.oncomplete = (e) => { - resolve(reserve); - }; - } - }); - }; - }); - + let reserve; + return new Promise((resolve, reject) => { + let tx = db.transaction(['reserves']); + tx.objectStore('reserves').get(reservePub).onsuccess = (e) => { + let reserve = e.target.result; + let reqUrl = URI("reserve/status").absoluteTo(mint.baseUrl); + reqUrl.query({ 'reserve_pub': reservePub }); + let myRequest = new XMLHttpRequest(); + console.log("making request to " + reqUrl.href()); + myRequest.open('get', reqUrl.href()); + myRequest.send(); + myRequest.addEventListener('readystatechange', (e) => { + if (myRequest.readyState == XMLHttpRequest.DONE) { + if (myRequest.status != 200) { + reject(); + return; + } + let reserveInfo = JSON.parse(myRequest.responseText); + console.log("got response " + JSON.stringify(reserveInfo)); + reserve.current_amount = reserveInfo.balance; + let tx = db.transaction(['reserves'], 'readwrite'); + console.log("putting updated reserve " + JSON.stringify(reserve)); + tx.objectStore('reserves').put(reserve); + tx.oncomplete = (e) => { + resolve(reserve); + }; + } + }); + }; + }); } - - /** * Update or add mint DB entry by fetching the /keys information. * Optionally link the reserve entry to the new or existing * mint entry in then DB. */ function updateMintFromUrl(db, baseUrl) { - console.log("base url is " + baseUrl); - let reqUrl = URI("keys").absoluteTo(baseUrl); - let myRequest = new XMLHttpRequest(); - myRequest.open('get', reqUrl.href()); - myRequest.send(); - return new Promise((resolve, reject) => { - myRequest.addEventListener('readystatechange', (e) => { - console.log("state change to " + myRequest.readyState); - if (myRequest.readyState == XMLHttpRequest.DONE) { - if (myRequest.status == 200) { - console.log("got /keys"); - let mintKeysJson = JSON.parse(myRequest.responseText); - if (!mintKeysJson) { - console.log("keys invalid"); - reject(); - } else { - let mint = {}; - mint.baseUrl = baseUrl; - mint.keys = mintKeysJson; - let tx = db.transaction(['mints'], 'readwrite'); - tx.objectStore('mints').put(mint); - tx.oncomplete = (e) => { - resolve(mint); - }; - } - } else { - console.log("/keys request failed with status " + myRequest.status); - // XXX: also write last error to DB to show in the UI - reject(); - } - } + console.log("base url is " + baseUrl); + let reqUrl = URI("keys").absoluteTo(baseUrl); + let myRequest = new XMLHttpRequest(); + myRequest.open('get', reqUrl.href()); + myRequest.send(); + return new Promise((resolve, reject) => { + myRequest.addEventListener('readystatechange', (e) => { + console.log("state change to " + myRequest.readyState); + if (myRequest.readyState == XMLHttpRequest.DONE) { + if (myRequest.status == 200) { + console.log("got /keys"); + let mintKeysJson = JSON.parse(myRequest.responseText); + if (!mintKeysJson) { + console.log("keys invalid"); + reject(); + } + else { + let mint = { + baseUrl: baseUrl, + keys: mintKeysJson + }; + let tx = db.transaction(['mints'], 'readwrite'); + tx.objectStore('mints').put(mint); + tx.oncomplete = (e) => { + resolve(mint); + }; + } + } + else { + console.log("/keys request failed with status " + myRequest.status); + // XXX: also write last error to DB to show in the UI + reject(); + } + } + }); }); - }); } - - function dumpDb(db, detail, sendResponse) { - let dump = {}; - dump.name = db.name; - dump.version = db.version; - dump.stores = {}; - console.log("stores: " + JSON.stringify(db.objectStoreNames)); - let tx = db.transaction(db.objectStoreNames); - tx.addEventListener('complete', (e) => { - sendResponse(dump); - }); - for (let i = 0; i < db.objectStoreNames.length; i++) { - let name = db.objectStoreNames[i]; - let storeDump = {}; - dump.stores[name] = storeDump; - let store = tx.objectStore(name).openCursor().addEventListener('success', (e) => { - let cursor = event.target.result; - if (cursor) { - storeDump[cursor.key] = cursor.value; - cursor.continue(); - } + let dump = { + name: db.name, + version: db.version, + stores: {} + }; + console.log("stores: " + JSON.stringify(db.objectStoreNames)); + let tx = db.transaction(db.objectStoreNames); + tx.addEventListener('complete', (e) => { + sendResponse(dump); }); - } - return true; + for (let i = 0; i < db.objectStoreNames.length; i++) { + let name = db.objectStoreNames[i]; + let storeDump = {}; + dump.stores[name] = storeDump; + let store = tx.objectStore(name).openCursor().addEventListener('success', (e) => { + let cursor = e.target.result; + if (cursor) { + storeDump[cursor.key] = cursor.value; + cursor.continue(); + } + }); + } + return true; } - - openTalerDb().then((db) => { - console.log("db loaded"); - chrome.runtime.onMessage.addListener( - function (req, sender, onresponse) { - let dispatch = { - "confirm-reserve": confirmReserve, - "dump-db": dumpDb - } - return dispatch[req.type](db, req.detail, onresponse); + console.log("db loaded"); + chrome.runtime.onMessage.addListener(function (req, sender, onresponse) { + let dispatch = { + "confirm-reserve": confirmReserve, + "dump-db": dumpDb + }; + return dispatch[req.type](db, req.detail, onresponse); }); }); - |