diff options
author | Florian Dold <florian.dold@gmail.com> | 2017-05-28 23:15:41 +0200 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2017-05-28 23:15:41 +0200 |
commit | b6e774585d32017e5f1ceeeb2b2e2a5e350354d3 (patch) | |
tree | 080cb5afe3b48c0428abd2d7de1ff7fe34d9b9b1 /src/webex/notify.ts | |
parent | 38a74188d759444d7e1abac856f78ae710e2a4c5 (diff) |
move webex specific things in their own directory
Diffstat (limited to 'src/webex/notify.ts')
-rw-r--r-- | src/webex/notify.ts | 571 |
1 files changed, 571 insertions, 0 deletions
diff --git a/src/webex/notify.ts b/src/webex/notify.ts new file mode 100644 index 000000000..733367a59 --- /dev/null +++ b/src/webex/notify.ts @@ -0,0 +1,571 @@ +/* + This file is part of TALER + (C) 2015 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/> + */ + +// tslint:disable:no-unused-expression + +/** + * Module that is injected into (all!) pages to allow them + * to interact with the GNU Taler wallet via DOM Events. + */ + + +/** + * Imports. + */ +import URI = require("urijs"); + +declare var cloneInto: any; + +const PROTOCOL_VERSION = 1; + +let logVerbose: boolean = false; +try { + logVerbose = !!localStorage.getItem("taler-log-verbose"); +} catch (e) { + // can't read from local storage +} + +if (document.documentElement.getAttribute("data-taler-nojs")) { + document.dispatchEvent(new Event("taler-probe-result")); +} + + +function subst(url: string, H_contract: string) { + url = url.replace("${H_contract}", H_contract); + url = url.replace("${$}", "$"); + return url; +} + +interface Handler { + type: string; + listener: (e: CustomEvent) => void|Promise<void>; +} +const handlers: Handler[] = []; + +function hashContract(contract: string): Promise<string> { + const walletHashContractMsg = { + detail: {contract}, + type: "hash-contract", + }; + return new Promise<string>((resolve, reject) => { + chrome.runtime.sendMessage(walletHashContractMsg, (resp: any) => { + if (!resp.hash) { + console.log("error", resp); + reject(Error("hashing failed")); + } + resolve(resp.hash); + }); + }); +} + +function queryPayment(url: string): Promise<any> { + const walletMsg = { + detail: { url }, + type: "query-payment", + }; + return new Promise((resolve, reject) => { + chrome.runtime.sendMessage(walletMsg, (resp: any) => { + resolve(resp); + }); + }); +} + +function putHistory(historyEntry: any): Promise<void> { + const walletMsg = { + detail: { + historyEntry, + }, + type: "put-history-entry", + }; + return new Promise<void>((resolve, reject) => { + chrome.runtime.sendMessage(walletMsg, (resp: any) => { + resolve(); + }); + }); +} + +function saveOffer(offer: any): Promise<number> { + const walletMsg = { + detail: { + offer: { + H_contract: offer.hash, + contract: offer.data, + merchant_sig: offer.sig, + offer_time: new Date().getTime() / 1000, + }, + type: "save-offer", + }, + }; + return new Promise<number>((resolve, reject) => { + chrome.runtime.sendMessage(walletMsg, (resp: any) => { + if (resp && resp.error) { + reject(resp); + } else { + resolve(resp); + } + }); + }); +} + + +let sheet: CSSStyleSheet|null; + +function initStyle() { + logVerbose && console.log("taking over styles"); + const name = "taler-presence-stylesheet"; + const content = "/* Taler stylesheet controlled by JS */"; + let style = document.getElementById(name) as HTMLStyleElement|null; + if (!style) { + style = document.createElement("style"); + // Needed by WebKit + style.appendChild(document.createTextNode(content)); + style.id = name; + document.head.appendChild(style); + sheet = style.sheet as CSSStyleSheet; + } else { + // We've taken over the stylesheet now, + // make it clear by clearing all the rules in it + // and making it obvious in the DOM. + if (style.tagName.toLowerCase() === "style") { + style.innerText = content; + } + if (!style.sheet) { + throw Error("taler-presence-stylesheet should be a style sheet (<link> or <style>)"); + } + sheet = style.sheet as CSSStyleSheet; + while (sheet.cssRules.length > 0) { + sheet.deleteRule(0); + } + } +} + + +function setStyles(installed: boolean) { + if (!sheet || !sheet.cssRules) { + return; + } + while (sheet.cssRules.length > 0) { + sheet.deleteRule(0); + } + if (installed) { + sheet.insertRule(".taler-installed-hide { display: none; }", 0); + sheet.insertRule(".taler-probed-hide { display: none; }", 0); + } else { + sheet.insertRule(".taler-installed-show { display: none; }", 0); + } +} + + +function handlePaymentResponse(walletResp: any) { + /** + * Handle a failed payment. + * + * Try to notify the wallet first, before we show a potentially + * synchronous error message (such as an alert) or leave the page. + */ + function handleFailedPayment(r: XMLHttpRequest) { + let timeoutHandle: number|null = null; + function err() { + // FIXME: proper error reporting! + console.log("pay-failed", {status: r.status, response: r.responseText}); + } + function onTimeout() { + timeoutHandle = null; + err(); + } + talerPaymentFailed(walletResp.H_contract).then(() => { + if (timeoutHandle !== null) { + clearTimeout(timeoutHandle); + timeoutHandle = null; + } + err(); + }); + timeoutHandle = window.setTimeout(onTimeout, 200); + } + + + logVerbose && console.log("handling taler-notify-payment: ", walletResp); + // Payment timeout in ms. + let timeout_ms = 1000; + // Current request. + let r: XMLHttpRequest|null; + let timeoutHandle: number|null = null; + function sendPay() { + r = new XMLHttpRequest(); + r.open("post", walletResp.contract.pay_url); + r.setRequestHeader("Content-Type", "application/json;charset=UTF-8"); + r.send(JSON.stringify(walletResp.payReq)); + r.onload = () => { + if (!r) { + return; + } + switch (r.status) { + case 200: + const merchantResp = JSON.parse(r.responseText); + logVerbose && console.log("got success from pay_url"); + talerPaymentSucceeded({H_contract: walletResp.H_contract, merchantSig: merchantResp.sig}).then(() => { + const nextUrl = walletResp.contract.fulfillment_url; + logVerbose && console.log("taler-payment-succeeded done, going to", nextUrl); + window.location.href = nextUrl; + window.location.reload(true); + }); + break; + default: + handleFailedPayment(r); + break; + } + r = null; + if (timeoutHandle !== null) { + clearTimeout(timeoutHandle!); + timeoutHandle = null; + } + }; + function retry() { + if (r) { + r.abort(); + r = null; + } + timeout_ms = Math.min(timeout_ms * 2, 10 * 1000); + logVerbose && console.log("sendPay timed out, retrying in ", timeout_ms, "ms"); + sendPay(); + } + timeoutHandle = window.setTimeout(retry, timeout_ms); + } + sendPay(); +} + + +function init() { + chrome.runtime.sendMessage({type: "get-tab-cookie"}, (resp) => { + if (chrome.runtime.lastError) { + logVerbose && console.log("extension not yet ready"); + window.setTimeout(init, 200); + return; + } + if (document.documentElement.getAttribute("data-taler-nojs")) { + const onload = () => { + initStyle(); + setStyles(true); + }; + if (document.readyState === "complete") { + onload(); + } else { + document.addEventListener("DOMContentLoaded", onload); + } + } + registerHandlers(); + // Hack to know when the extension is unloaded + const port = chrome.runtime.connect(); + + port.onDisconnect.addListener(() => { + logVerbose && console.log("chrome runtime disconnected, removing handlers"); + if (document.documentElement.getAttribute("data-taler-nojs")) { + setStyles(false); + } + for (const handler of handlers) { + document.removeEventListener(handler.type, handler.listener); + } + }); + + if (resp && resp.type === "pay") { + logVerbose && console.log("doing taler.pay with", resp.payDetail); + talerPay(resp.payDetail).then(handlePaymentResponse); + document.documentElement.style.visibility = "hidden"; + } + }); +} + +type HandlerFn = (detail: any, sendResponse: (msg: any) => void) => void; + +function generateNonce(): Promise<string> { + const walletMsg = { + type: "generate-nonce", + }; + return new Promise<string>((resolve, reject) => { + chrome.runtime.sendMessage(walletMsg, (resp: any) => { + resolve(resp); + }); + }); +} + +function downloadContract(url: string, nonce: string): Promise<any> { + const parsed_url = new URI(url); + url = parsed_url.setQuery({nonce}).href(); + // FIXME: include and check nonce! + return new Promise((resolve, reject) => { + const contract_request = new XMLHttpRequest(); + console.log("downloading contract from '" + url + "'"); + contract_request.open("GET", url, true); + contract_request.onload = (e) => { + if (contract_request.readyState === 4) { + if (contract_request.status === 200) { + console.log("response text:", + contract_request.responseText); + const contract_wrapper = JSON.parse(contract_request.responseText); + if (!contract_wrapper) { + console.error("response text was invalid json"); + const detail = { + body: contract_request.responseText, + hint: "invalid json", + status: contract_request.status, + }; + reject(detail); + return; + } + resolve(contract_wrapper); + } else { + const detail = { + body: contract_request.responseText, + hint: "contract download failed", + status: contract_request.status, + }; + reject(detail); + return; + } + } + }; + contract_request.onerror = (e) => { + const detail = { + body: contract_request.responseText, + hint: "contract download failed", + status: contract_request.status, + }; + reject(detail); + return; + }; + contract_request.send(); + }); +} + +async function processProposal(proposal: any) { + if (!proposal.data) { + console.error("field proposal.data field missing"); + return; + } + + if (!proposal.hash) { + console.error("proposal.hash field missing"); + return; + } + + const contractHash = await hashContract(proposal.data); + + if (contractHash !== proposal.hash) { + console.error("merchant-supplied contract hash is wrong"); + return; + } + + let merchantName = "(unknown)"; + try { + merchantName = proposal.data.merchant.name; + } catch (e) { + // bad contract / name not included + } + + const historyEntry = { + detail: { + contractHash, + merchantName, + }, + subjectId: `contract-${contractHash}`, + timestamp: (new Date()).getTime(), + type: "offer-contract", + }; + await putHistory(historyEntry); + const offerId = await saveOffer(proposal); + + const uri = new URI(chrome.extension.getURL( + "/src/pages/confirm-contract.html")); + const params = { + offerId: offerId.toString(), + }; + const target = uri.query(params).href(); + document.location.replace(target); +} + +function talerPay(msg: any): Promise<any> { + return new Promise(async(resolve, reject) => { + // current URL without fragment + const url = new URI(document.location.href).fragment("").href(); + const res = await queryPayment(url); + logVerbose && console.log("taler-pay: got response", res); + if (res && res.payReq) { + resolve(res); + return; + } + if (msg.contract_url) { + const nonce = await generateNonce(); + const proposal = await downloadContract(msg.contract_url, nonce); + if (proposal.data.nonce !== nonce) { + console.error("stale contract"); + return; + } + await processProposal(proposal); + return; + } + + if (msg.offer_url) { + document.location.href = msg.offer_url; + return; + } + + console.log("can't proceed with payment, no way to get contract specified"); + }); +} + +function talerPaymentFailed(H_contract: string) { + return new Promise(async(resolve, reject) => { + const walletMsg = { + detail: { + contractHash: H_contract, + }, + type: "payment-failed", + }; + chrome.runtime.sendMessage(walletMsg, (resp) => { + resolve(); + }); + }); +} + +function talerPaymentSucceeded(msg: any) { + return new Promise((resolve, reject) => { + if (!msg.H_contract) { + console.error("H_contract missing in taler-payment-succeeded"); + return; + } + if (!msg.merchantSig) { + console.error("merchantSig missing in taler-payment-succeeded"); + return; + } + logVerbose && console.log("got taler-payment-succeeded"); + const walletMsg = { + detail: { + contractHash: msg.H_contract, + merchantSig: msg.merchantSig, + }, + type: "payment-succeeded", + }; + chrome.runtime.sendMessage(walletMsg, (resp) => { + resolve(); + }); + }); +} + + +function registerHandlers() { + /** + * Add a handler for a DOM event, which automatically + * handles adding sequence numbers to responses. + */ + function addHandler(type: string, handler: HandlerFn) { + const handlerWrap = (e: CustomEvent) => { + if (e.type !== type) { + throw Error(`invariant violated`); + } + let callId: number|undefined; + if (e.detail && e.detail.callId !== undefined) { + callId = e.detail.callId; + } + const responder = (msg?: any) => { + const fullMsg = Object.assign({}, msg, {callId}); + let opts = { detail: fullMsg }; + if ("function" === typeof cloneInto) { + opts = cloneInto(opts, document.defaultView); + } + const evt = new CustomEvent(type + "-result", opts); + document.dispatchEvent(evt); + }; + handler(e.detail, responder); + }; + document.addEventListener(type, handlerWrap); + handlers.push({type, listener: handlerWrap}); + } + + + addHandler("taler-query-id", (msg: any, sendResponse: any) => { + // FIXME: maybe include this info in taoer-probe? + sendResponse({id: chrome.runtime.id}); + }); + + addHandler("taler-probe", (msg: any, sendResponse: any) => { + sendResponse(); + }); + + addHandler("taler-create-reserve", (msg: any) => { + const params = { + amount: JSON.stringify(msg.amount), + bank_url: document.location.href, + callback_url: new URI(msg.callback_url) .absoluteTo(document.location.href), + suggested_exchange_url: msg.suggested_exchange_url, + wt_types: JSON.stringify(msg.wt_types), + }; + const uri = new URI(chrome.extension.getURL("/src/pages/confirm-create-reserve.html")); + const redirectUrl = uri.query(params).href(); + window.location.href = redirectUrl; + }); + + addHandler("taler-add-auditor", (msg: any) => { + const params = { + req: JSON.stringify(msg), + }; + const uri = new URI(chrome.extension.getURL("/src/pages/add-auditor.html")); + const redirectUrl = uri.query(params).href(); + window.location.href = redirectUrl; + }); + + addHandler("taler-confirm-reserve", (msg: any, sendResponse: any) => { + const walletMsg = { + detail: { + reservePub: msg.reserve_pub, + }, + type: "confirm-reserve", + }; + chrome.runtime.sendMessage(walletMsg, (resp) => { + sendResponse(); + }); + }); + + + addHandler("taler-confirm-contract", async(msg: any) => { + if (!msg.contract_wrapper) { + console.error("contract wrapper missing"); + return; + } + + const proposal = msg.contract_wrapper; + + processProposal(proposal); + }); + + addHandler("taler-pay", async(msg: any, sendResponse: any) => { + const resp = await talerPay(msg); + sendResponse(resp); + }); + + addHandler("taler-payment-failed", async(msg: any, sendResponse: any) => { + await talerPaymentFailed(msg.H_contract); + sendResponse(); + }); + + addHandler("taler-payment-succeeded", async(msg: any, sendResponse: any) => { + await talerPaymentSucceeded(msg); + sendResponse(); + }); +} + +logVerbose && console.log("loading Taler content script"); +init(); + |