wallet-core/src/webex/notify.ts

432 lines
13 KiB
TypeScript
Raw Normal View History

2015-12-25 22:42:14 +01:00
/*
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
2016-07-07 17:59:29 +02:00
TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/>
2015-12-25 22:42:14 +01:00
*/
2017-05-28 01:10:54 +02:00
// tslint:disable:no-unused-expression
2016-02-10 02:03:31 +01:00
2016-02-09 21:56:06 +01:00
/**
2017-05-24 16:14:23 +02:00
* Module that is injected into (all!) pages to allow them
2016-02-09 21:56:06 +01:00
* to interact with the GNU Taler wallet via DOM Events.
*/
2017-05-24 16:14:23 +02:00
/**
* Imports.
*/
import URI = require("urijs");
2017-05-30 18:33:28 +02:00
import wxApi = require("./wxApi");
2017-06-01 18:46:07 +02:00
import { QueryPaymentResult } from "../types";
2016-10-05 00:09:54 +02:00
declare var cloneInto: any;
let logVerbose: boolean = false;
try {
logVerbose = !!localStorage.getItem("taler-log-verbose");
} catch (e) {
// can't read from local storage
}
2016-10-18 01:16:31 +02:00
if (document.documentElement.getAttribute("data-taler-nojs")) {
document.dispatchEvent(new Event("taler-probe-result"));
}
interface Handler {
type: string;
listener: (e: CustomEvent) => void|Promise<void>;
}
const handlers: Handler[] = [];
let sheet: CSSStyleSheet|null;
function initStyle() {
logVerbose && console.log("taking over styles");
const name = "taler-presence-stylesheet";
const content = "/* Taler stylesheet controlled by JS */";
2017-05-28 01:10:54 +02:00
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);
}
2017-02-13 00:44:44 +01:00
}
}
2017-02-13 00:44:44 +01:00
function setStyles(installed: boolean) {
if (!sheet || !sheet.cssRules) {
return;
}
while (sheet.cssRules.length > 0) {
sheet.deleteRule(0);
2016-09-29 01:40:29 +02:00
}
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);
}
}
2016-09-29 01:40:29 +02:00
2017-06-01 18:46:07 +02:00
function handlePaymentResponse(maybeFoundResponse: QueryPaymentResult) {
if (!maybeFoundResponse.found) {
console.log("pay-failed", {hint: "payment not found in the wallet"});
return;
}
const walletResp = maybeFoundResponse;
/**
* 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.
*/
async 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() {
2017-05-28 01:10:54 +02:00
timeoutHandle = null;
err();
}
2017-05-30 18:33:28 +02:00
timeoutHandle = window.setTimeout(onTimeout, 200);
2017-06-01 18:46:07 +02:00
await wxApi.paymentFailed(walletResp.contractTermsHash);
if (timeoutHandle !== null) {
clearTimeout(timeoutHandle);
timeoutHandle = null;
}
err();
2016-11-13 10:17:39 +01:00
}
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();
2017-06-01 18:46:07 +02:00
r.open("post", walletResp.contractTerms.pay_url);
r.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
r.send(JSON.stringify(walletResp.payReq));
r.onload = async () => {
if (!r) {
2016-04-27 04:10:26 +02:00
return;
}
switch (r.status) {
case 200:
const merchantResp = JSON.parse(r.responseText);
logVerbose && console.log("got success from pay_url");
2017-06-01 18:46:07 +02:00
await wxApi.paymentSucceeded(walletResp.contractTermsHash, merchantResp.sig);
const nextUrl = walletResp.contractTerms.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;
2017-05-28 01:10:54 +02:00
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();
}
2017-05-24 15:10:37 +02:00
timeoutHandle = window.setTimeout(retry, timeout_ms);
}
sendPay();
}
2016-09-08 17:26:31 +02:00
function init() {
// Only place where we don't use the nicer RPC wrapper, since the wallet
// backend might not be ready (during install, upgrade, etc.)
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")) {
2017-04-27 02:31:32 +02:00
const onload = () => {
initStyle();
setStyles(true);
};
2017-05-28 01:10:54 +02:00
if (document.readyState === "complete") {
2017-04-27 02:31:32 +02:00
onload();
} else {
document.addEventListener("DOMContentLoaded", onload);
}
}
registerHandlers();
// Hack to know when the extension is unloaded
2017-05-28 01:10:54 +02:00
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);
}
2017-05-28 01:10:54 +02:00
for (const handler of handlers) {
document.removeEventListener(handler.type, handler.listener);
2016-09-08 17:26:31 +02:00
}
2016-04-27 04:10:26 +02:00
});
2017-05-28 01:10:54 +02:00
if (resp && resp.type === "pay") {
logVerbose && console.log("doing taler.pay with", resp.payDetail);
talerPay(resp.payDetail).then(handlePaymentResponse);
document.documentElement.style.visibility = "hidden";
}
});
}
2016-03-02 15:33:23 +01:00
2017-05-28 01:10:54 +02:00
type HandlerFn = (detail: any, sendResponse: (msg: any) => void) => void;
function downloadContract(url: string, nonce: string): Promise<any> {
2017-05-28 01:10:54 +02:00
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();
2017-05-28 01:10:54 +02:00
console.log("downloading contract from '" + url + "'");
contract_request.open("GET", url, true);
2017-05-28 01:10:54 +02:00
contract_request.onload = (e) => {
if (contract_request.readyState === 4) {
if (contract_request.status === 200) {
console.log("response text:",
contract_request.responseText);
2017-05-28 01:10:54 +02:00
const contract_wrapper = JSON.parse(contract_request.responseText);
if (!contract_wrapper) {
console.error("response text was invalid json");
2017-05-28 01:10:54 +02:00
const detail = {
body: contract_request.responseText,
hint: "invalid json",
status: contract_request.status,
};
2017-02-13 00:44:44 +01:00
reject(detail);
return;
}
resolve(contract_wrapper);
} else {
2017-05-28 01:10:54 +02:00
const detail = {
body: contract_request.responseText,
hint: "contract download failed",
status: contract_request.status,
};
reject(detail);
return;
2017-02-13 00:44:44 +01:00
}
}
};
2017-05-28 01:10:54 +02:00
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;
2017-02-13 00:44:44 +01:00
}
if (!proposal.hash) {
console.error("proposal.hash field missing");
return;
}
2017-05-30 18:33:28 +02:00
const contractHash = await wxApi.hashContract(proposal.data);
2017-05-28 01:10:54 +02:00
if (contractHash !== proposal.hash) {
console.error(`merchant-supplied contract hash is wrong (us: ${contractHash}, merchant: ${proposal.hash})`);
console.dir(proposal.data);
return;
}
let merchantName = "(unknown)";
try {
merchantName = proposal.data.merchant.name;
} catch (e) {
// bad contract / name not included
}
2017-05-28 01:10:54 +02:00
const historyEntry = {
detail: {
contractHash,
merchantName,
2017-05-28 01:10:54 +02:00
},
subjectId: `contract-${contractHash}`,
timestamp: (new Date()).getTime(),
type: "offer-contract",
};
await wxApi.putHistory(historyEntry);
let proposalId = await wxApi.saveProposal(proposal);
const uri = new URI(chrome.extension.getURL("/src/webex/pages/confirm-contract.html"));
const params = {
proposalId: proposalId.toString(),
};
const target = uri.query(params).href();
document.location.replace(target);
}
2017-02-13 00:44:44 +01:00
function talerPay(msg: any): Promise<any> {
return new Promise(async(resolve, reject) => {
// current URL without fragment
2017-05-28 01:10:54 +02:00
const url = new URI(document.location.href).fragment("").href();
const res = await wxApi.queryPayment(url);
logVerbose && console.log("taler-pay: got response", res);
2017-06-01 18:46:07 +02:00
if (res && res.found && res.payReq) {
resolve(res);
2017-02-13 00:44:44 +01:00
return;
}
if (msg.contract_url) {
const nonce = await wxApi.generateNonce();
2017-05-28 01:10:54 +02:00
const proposal = await downloadContract(msg.contract_url, nonce);
if (proposal.data.nonce !== nonce) {
console.error("stale contract");
return;
}
await processProposal(proposal);
2017-02-13 00:44:44 +01:00
return;
}
if (msg.offer_url) {
document.location.href = msg.offer_url;
return;
2017-02-13 00:44:44 +01:00
}
console.log("can't proceed with payment, no way to get contract specified");
});
}
2017-02-13 00:44:44 +01:00
2016-02-09 21:56:06 +01:00
function registerHandlers() {
/**
* Add a handler for a DOM event, which automatically
* handles adding sequence numbers to responses.
*/
function addHandler(type: string, handler: HandlerFn) {
2017-05-28 01:10:54 +02:00
const handlerWrap = (e: CustomEvent) => {
if (e.type !== type) {
throw Error(`invariant violated`);
}
2017-05-28 01:10:54 +02:00
let callId: number|undefined;
if (e.detail && e.detail.callId !== undefined) {
callId = e.detail.callId;
}
2017-05-28 01:10:54 +02:00
const responder = (msg?: any) => {
const fullMsg = Object.assign({}, msg, {callId});
let opts = { detail: fullMsg };
2017-05-28 01:10:54 +02:00
if ("function" === typeof cloneInto) {
opts = cloneInto(opts, document.defaultView);
}
2017-05-28 01:10:54 +02:00
const evt = new CustomEvent(type + "-result", opts);
document.dispatchEvent(evt);
2016-09-07 17:10:02 +02:00
};
handler(e.detail, responder);
};
document.addEventListener(type, handlerWrap);
handlers.push({type, listener: handlerWrap});
}
2016-02-01 15:10:20 +01:00
2017-03-28 09:47:22 +02:00
addHandler("taler-query-id", (msg: any, sendResponse: any) => {
2017-05-30 18:33:28 +02:00
// FIXME: maybe include this info in taler-probe?
2017-05-28 01:10:54 +02:00
sendResponse({id: chrome.runtime.id});
});
2016-02-23 14:07:53 +01:00
addHandler("taler-probe", (msg: any, sendResponse: any) => {
sendResponse();
});
2016-09-07 17:10:02 +02:00
addHandler("taler-create-reserve", (msg: any) => {
2017-05-28 01:10:54 +02:00
const params = {
amount: JSON.stringify(msg.amount),
bank_url: document.location.href,
2017-05-28 01:10:54 +02:00
callback_url: new URI(msg.callback_url) .absoluteTo(document.location.href),
suggested_exchange_url: msg.suggested_exchange_url,
2017-05-28 01:10:54 +02:00
wt_types: JSON.stringify(msg.wt_types),
};
const uri = new URI(chrome.extension.getURL("/src/webex/pages/confirm-create-reserve.html"));
2017-05-28 01:10:54 +02:00
const redirectUrl = uri.query(params).href();
window.location.href = redirectUrl;
});
addHandler("taler-add-auditor", (msg: any) => {
2017-05-28 01:10:54 +02:00
const params = {
req: JSON.stringify(msg),
};
const uri = new URI(chrome.extension.getURL("/src/webex/pages/add-auditor.html"));
2017-05-28 01:10:54 +02:00
const redirectUrl = uri.query(params).href();
window.location.href = redirectUrl;
});
2017-05-30 18:33:28 +02:00
addHandler("taler-confirm-reserve", async (msg: any, sendResponse: any) => {
const reservePub = msg.reserve_pub;
if (typeof reservePub !== "string") {
console.error("taler-confirm-reserve expects parameter reserve_pub of type 'string'");
return;
}
2017-05-30 18:33:28 +02:00
await wxApi.confirmReserve(msg.reserve_pub);
sendResponse();
});
2016-09-29 01:40:29 +02:00
addHandler("taler-pay", async(msg: any, sendResponse: any) => {
2017-05-28 01:10:54 +02:00
const resp = await talerPay(msg);
sendResponse(resp);
});
}
logVerbose && console.log("loading Taler content script");
init();