/* This file is part of TALER (C) 2019 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 */ import { MemoryBackend, BridgeIDBFactory, shimIndexedDB } from "idb-bridge"; import { Wallet } from "../wallet"; import { Notifier, Badge } from "../walletTypes"; import { openTalerDb, exportDb } from "../db"; import { HttpRequestLibrary } from "../http"; import * as amounts from "../amounts"; import Axios from "axios"; import URI = require("urijs"); import querystring = require("querystring"); import { CheckPaymentResponse } from "../talerTypes"; import { NodeCryptoWorkerFactory } from "../crypto/cryptoApi"; const enableTracing = false; class ConsoleNotifier implements Notifier { notify(): void { // nothing to do. } } class ConsoleBadge implements Badge { startBusy(): void { enableTracing && console.log("NOTIFICATION: busy"); } stopBusy(): void { enableTracing && console.log("NOTIFICATION: busy end"); } showNotification(): void { enableTracing && console.log("NOTIFICATION: show"); } clearNotification(): void { enableTracing && console.log("NOTIFICATION: cleared"); } } export class NodeHttpLib implements HttpRequestLibrary { async get(url: string): Promise { enableTracing && console.log("making GET request to", url); const resp = await Axios({ method: "get", url: url, responseType: "json", }); enableTracing && console.log("got response", resp.data); enableTracing && console.log("resp type", typeof resp.data); return { responseJson: resp.data, status: resp.status, }; } async postJson( url: string, body: any, ): Promise { enableTracing && console.log("making POST request to", url); const resp = await Axios({ method: "post", url: url, responseType: "json", data: body, }); enableTracing && console.log("got response", resp.data); enableTracing && console.log("resp type", typeof resp.data); return { responseJson: resp.data, status: resp.status, }; } async postForm( url: string, form: any, ): Promise { enableTracing && console.log("making POST request to", url); const resp = await Axios({ method: "post", url: url, data: querystring.stringify(form), responseType: "json", }); enableTracing && console.log("got response", resp.data); enableTracing && console.log("resp type", typeof resp.data); return { responseJson: resp.data, status: resp.status, }; } } interface BankUser { username: string; password: string; } function makeId(length: number): string { let result = ""; const characters = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"; for (let i = 0; i < length; i++) { result += characters.charAt(Math.floor(Math.random() * characters.length)); } return result; } async function registerBankUser( bankBaseUrl: string, httpLib: HttpRequestLibrary, ): Promise { const reqUrl = new URI("register").absoluteTo(bankBaseUrl).href(); const randId = makeId(8); const bankUser: BankUser = { username: `testuser-${randId}`, password: `testpw-${randId}`, }; const result = await httpLib.postForm(reqUrl, bankUser); if (result.status != 200) { throw Error("could not register bank user"); } return bankUser; } async function createBankReserve( bankBaseUrl: string, bankUser: BankUser, amount: string, reservePub: string, exchangePaytoUri: string, httpLib: HttpRequestLibrary, ) { const reqUrl = new URI("taler/withdraw").absoluteTo(bankBaseUrl).href(); const body = { auth: { type: "basic" }, username: bankUser, amount, reserve_pub: reservePub, exchange_wire_detail: exchangePaytoUri, }; const resp = await Axios({ method: "post", url: reqUrl, data: body, responseType: "json", headers: { "X-Taler-Bank-Username": bankUser.username, "X-Taler-Bank-Password": bankUser.password, }, }); if (resp.status != 200) { throw Error("failed to create bank reserve"); } } class MerchantBackendConnection { constructor( public merchantBaseUrl: string, public merchantInstance: string, public apiKey: string, ) {} async createOrder( amount: string, summary: string, fulfillmentUrl: string, ): Promise<{ orderId: string }> { const reqUrl = new URI("order").absoluteTo(this.merchantBaseUrl).href(); const orderReq = { order: { amount, summary, fulfillment_url: fulfillmentUrl, instance: this.merchantInstance, }, }; const resp = await Axios({ method: "post", url: reqUrl, data: orderReq, responseType: "json", headers: { Authorization: `ApiKey ${this.apiKey}`, }, }); if (resp.status != 200) { throw Error("failed to create bank reserve"); } const orderId = resp.data.order_id; if (!orderId) { throw Error("no order id in response"); } return { orderId }; } async checkPayment(orderId: string): Promise { const reqUrl = new URI("check-payment") .absoluteTo(this.merchantBaseUrl) .href(); const resp = await Axios({ method: "get", url: reqUrl, params: { order_id: orderId, instance: this.merchantInstance }, responseType: "json", headers: { Authorization: `ApiKey ${this.apiKey}`, }, }); if (resp.status != 200) { throw Error("failed to check payment"); } return CheckPaymentResponse.checked(resp.data); } } export async function main() { const myNotifier = new ConsoleNotifier(); const myBadge = new ConsoleBadge(); const myBackend = new MemoryBackend(); myBackend.enableTracing = false; BridgeIDBFactory.enableTracing = false; const myBridgeIdbFactory = new BridgeIDBFactory(myBackend); const myIdbFactory: IDBFactory = (myBridgeIdbFactory as any) as IDBFactory; const myHttpLib = new NodeHttpLib(); const myVersionChange = () => { console.error("version change requested, should not happen"); throw Error(); }; const myUnsupportedUpgrade = () => { console.error("unsupported database migration"); throw Error(); }; shimIndexedDB(myBridgeIdbFactory); const exchangeBaseUrl = "https://exchange.test.taler.net/"; const bankBaseUrl = "https://bank.test.taler.net/"; const myDb = await openTalerDb( myIdbFactory, myVersionChange, myUnsupportedUpgrade, ); const myWallet = new Wallet(myDb, myHttpLib, myBadge, myNotifier, new NodeCryptoWorkerFactory()); const reserveResponse = await myWallet.createReserve({ amount: amounts.parseOrThrow("TESTKUDOS:10.0"), exchange: exchangeBaseUrl, }); const bankUser = await registerBankUser(bankBaseUrl, myHttpLib); console.log("bank user", bankUser); const exchangePaytoUri = await myWallet.getExchangePaytoUri( "https://exchange.test.taler.net/", ["x-taler-bank"], ); await createBankReserve( bankBaseUrl, bankUser, "TESTKUDOS:10.0", reserveResponse.reservePub, exchangePaytoUri, myHttpLib, ); await myWallet.confirmReserve({ reservePub: reserveResponse.reservePub }); await myWallet.processReserve(reserveResponse.reservePub); console.log("process reserve returned"); const balance = await myWallet.getBalances(); console.log(JSON.stringify(balance, null, 2)); const myMerchant = new MerchantBackendConnection( "https://backend.test.taler.net/", "default", "sandbox", ); const orderResp = await myMerchant.createOrder( "TESTKUDOS:5", "hello world", "https://example.com/", ); console.log("created order with orderId", orderResp.orderId); const paymentStatus = await myMerchant.checkPayment(orderResp.orderId); console.log("payment status", paymentStatus); const contractUrl = paymentStatus.contract_url; if (!contractUrl) { throw Error("no contract URL in payment response"); } const proposalId = await myWallet.downloadProposal(contractUrl); console.log("proposal id", proposalId); const checkPayResult = await myWallet.checkPay(proposalId); console.log("check pay result", checkPayResult); const confirmPayResult = await myWallet.confirmPay(proposalId, undefined); console.log("confirmPayResult", confirmPayResult); const paymentStatus2 = await myMerchant.checkPayment(orderResp.orderId); console.log("payment status after wallet payment:", paymentStatus2); if (!paymentStatus2.paid) { throw Error("payment did not succeed"); } myWallet.stop(); } if (require.main === module) { main().catch(err => { console.error("Failed with exception:"); console.error(err); }); }