aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--packages/taler-integrationtests/src/harness.ts177
-rw-r--r--packages/taler-integrationtests/src/test-timetravel.ts64
2 files changed, 219 insertions, 22 deletions
diff --git a/packages/taler-integrationtests/src/harness.ts b/packages/taler-integrationtests/src/harness.ts
index f4429d43f..5fd642e33 100644
--- a/packages/taler-integrationtests/src/harness.ts
+++ b/packages/taler-integrationtests/src/harness.ts
@@ -511,16 +511,10 @@ export namespace BankAccessApi {
bank: BankServiceInterface,
bankUser: BankUser,
): Promise<BankAccountBalanceResponse> {
- const url = new URL(
- `accounts/${bankUser.username}/balance`,
- bank.baseUrl,
- );
- const resp = await axios.get(
- url.href,
- {
- auth: bankUser,
- },
- );
+ const url = new URL(`accounts/${bankUser.username}/balance`, bank.baseUrl);
+ const resp = await axios.get(url.href, {
+ auth: bankUser,
+ });
return resp.data;
}
@@ -636,7 +630,6 @@ export namespace BankApi {
},
);
}
-
}
export class BankService implements BankServiceInterface {
@@ -813,11 +806,41 @@ export class ExchangeService implements ExchangeServiceInterface {
return new ExchangeService(gc, ec, cfgFilename, keyPair);
}
+ private currentTimetravel: Duration | undefined;
+
+ setTimetravel(t: Duration | undefined): void {
+ if (this.isRunning()) {
+ throw Error("can't set time travel while the exchange is running");
+ }
+ this.currentTimetravel = t;
+ }
+
+ private get timetravelArg(): string | undefined {
+ if (this.currentTimetravel && this.currentTimetravel.d_ms !== "forever") {
+ // Convert to microseconds
+ return `--timetravel=+${this.currentTimetravel.d_ms * 1000}`;
+ }
+ return undefined;
+ }
+
+ /**
+ * Return an empty array if no time travel is set,
+ * and an array with the time travel command line argument
+ * otherwise.
+ */
+ private get timetravelArgArr(): string[] {
+ const tta = this.timetravelArg;
+ if (tta) {
+ return [tta];
+ }
+ return [];
+ }
+
async runWirewatchOnce() {
await sh(
this.globalState,
"wirewatch-test",
- `taler-exchange-wirewatch -c '${this.configFilename}' -t`,
+ `taler-exchange-wirewatch ${this.timetravelArg} -c '${this.configFilename}' -t`,
);
}
@@ -965,20 +988,64 @@ export class ExchangeService implements ExchangeServiceInterface {
return `http://localhost:${this.exchangeConfig.httpPort}/`;
}
+ isRunning(): boolean {
+ return !!this.exchangeWirewatchProc || !!this.exchangeHttpProc;
+ }
+
+ async stop(): Promise<void> {
+ const wirewatch = this.exchangeWirewatchProc;
+ if (wirewatch) {
+ wirewatch.proc.kill("SIGTERM");
+ await wirewatch.wait();
+ this.exchangeWirewatchProc = undefined;
+ }
+ const httpd = this.exchangeHttpProc;
+ if (httpd) {
+ httpd.proc.kill("SIGTERM");
+ await httpd.wait();
+ this.exchangeHttpProc = undefined;
+ }
+ }
+
+ async keyup(): Promise<void> {
+ await sh(
+ this.globalState,
+ "exchange-keyup",
+ `taler-exchange-keyup ${this.timetravelArg} -c "${this.configFilename}"`,
+ );
+ }
+
async start(): Promise<void> {
- await exec(`taler-exchange-dbinit -c "${this.configFilename}"`);
- await exec(`taler-exchange-wire -c "${this.configFilename}"`);
- await exec(`taler-exchange-keyup -c "${this.configFilename}"`);
+ if (this.isRunning()) {
+ throw Error("exchange is already running");
+ }
+ await sh(
+ this.globalState,
+ "exchange-dbinit",
+ `taler-exchange-dbinit -c "${this.configFilename}"`,
+ );
+ await this.keyup();
+ await sh(
+ this.globalState,
+ "exchange-wire",
+ `taler-exchange-wire ${this.timetravelArg} -c "${this.configFilename}"`
+ )
this.exchangeWirewatchProc = this.globalState.spawnService(
"taler-exchange-wirewatch",
- ["-c", this.configFilename],
+ ["-c", this.configFilename, ...this.timetravelArgArr],
`exchange-wirewatch-${this.name}`,
);
this.exchangeHttpProc = this.globalState.spawnService(
"taler-exchange-httpd",
- ["-c", this.configFilename, "--num-threads", "1"],
+ [
+ "-c",
+ this.configFilename,
+ "--num-threads",
+ "1",
+ ...this.timetravelArgArr,
+ ],
`exchange-httpd-${this.name}`,
);
}
@@ -1079,6 +1146,40 @@ export class MerchantService implements MerchantServiceInterface {
private configFilename: string,
) {}
+ private currentTimetravel: Duration | undefined;
+
+ private isRunning(): boolean {
+ return !!this.proc;
+ }
+
+ setTimetravel(t: Duration | undefined): void {
+ if (this.isRunning()) {
+ throw Error("can't set time travel while the exchange is running");
+ }
+ this.currentTimetravel = t;
+ }
+
+ private get timetravelArg(): string | undefined {
+ if (this.currentTimetravel && this.currentTimetravel.d_ms !== "forever") {
+ // Convert to microseconds
+ return `--timetravel=+${this.currentTimetravel.d_ms * 1000}`;
+ }
+ return undefined;
+ }
+
+ /**
+ * Return an empty array if no time travel is set,
+ * and an array with the time travel command line argument
+ * otherwise.
+ */
+ private get timetravelArgArr(): string[] {
+ const tta = this.timetravelArg;
+ if (tta) {
+ return [tta];
+ }
+ return [];
+ }
+
get port(): number {
return this.merchantConfig.httpPort;
}
@@ -1087,12 +1188,21 @@ export class MerchantService implements MerchantServiceInterface {
return this.merchantConfig.name;
}
+ async stop(): Promise<void> {
+ const httpd = this.proc;
+ if (httpd) {
+ httpd.proc.kill("SIGTERM");
+ await httpd.wait();
+ this.proc = undefined;
+ }
+ }
+
async start(): Promise<void> {
await exec(`taler-merchant-dbinit -c "${this.configFilename}"`);
this.proc = this.globalState.spawnService(
"taler-merchant-httpd",
- ["-LINFO", "-c", this.configFilename],
+ ["-LINFO", "-c", this.configFilename, ...this.timetravelArgArr],
`merchant-${this.merchantConfig.name}`,
);
}
@@ -1266,7 +1376,24 @@ function shellWrap(s: string) {
}
export class WalletCli {
- constructor(private globalTestState: GlobalTestState, private name: string = "default") {}
+ private currentTimetravel: Duration | undefined;
+
+ setTimetravel(d: Duration | undefined) {
+ this.currentTimetravel = d;
+ }
+
+ private get timetravelArg(): string | undefined {
+ if (this.currentTimetravel && this.currentTimetravel.d_ms !== "forever") {
+ // Convert to microseconds
+ return `--timetravel=${this.currentTimetravel.d_ms * 1000}`;
+ }
+ return undefined;
+ }
+
+ constructor(
+ private globalTestState: GlobalTestState,
+ private name: string = "default",
+ ) {}
get dbfile(): string {
return this.globalTestState.testDir + `/walletdb-${this.name}.json`;
@@ -1283,7 +1410,9 @@ export class WalletCli {
const resp = await sh(
this.globalTestState,
`wallet-${this.name}`,
- `taler-wallet-cli --no-throttle --wallet-db '${this.dbfile}' api '${request}' ${shellWrap(
+ `taler-wallet-cli ${
+ this.timetravelArg ?? ""
+ } --no-throttle --wallet-db '${this.dbfile}' api '${request}' ${shellWrap(
JSON.stringify(payload),
)}`,
);
@@ -1295,7 +1424,9 @@ export class WalletCli {
await sh(
this.globalTestState,
`wallet-${this.name}`,
- `taler-wallet-cli --no-throttle --wallet-db ${this.dbfile} run-until-done`,
+ `taler-wallet-cli ${this.timetravelArg ?? ""} --no-throttle --wallet-db ${
+ this.dbfile
+ } run-until-done`,
);
}
@@ -1303,7 +1434,9 @@ export class WalletCli {
await sh(
this.globalTestState,
`wallet-${this.name}`,
- `taler-wallet-cli --no-throttle --wallet-db ${this.dbfile} run-pending`,
+ `taler-wallet-cli ${this.timetravelArg ?? ""} --no-throttle --wallet-db ${
+ this.dbfile
+ } run-pending`,
);
}
diff --git a/packages/taler-integrationtests/src/test-timetravel.ts b/packages/taler-integrationtests/src/test-timetravel.ts
new file mode 100644
index 000000000..acc770d5d
--- /dev/null
+++ b/packages/taler-integrationtests/src/test-timetravel.ts
@@ -0,0 +1,64 @@
+/*
+ This file is part of GNU Taler
+ (C) 2020 Taler Systems S.A.
+
+ GNU 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.
+
+ GNU 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
+ GNU Taler; see the file COPYING. If not, see <http://www.gnu.org/licenses/>
+ */
+
+/**
+ * Imports.
+ */
+import { runTest, GlobalTestState, MerchantPrivateApi, WalletCli } from "./harness";
+import { createSimpleTestkudosEnvironment, withdrawViaBank } from "./helpers";
+import { PreparePayResultType, durationMin, Duration } from "taler-wallet-core";
+
+/**
+ * Basic time travel test.
+ */
+runTest(async (t: GlobalTestState) => {
+ // Set up test environment
+
+ const {
+ wallet,
+ bank,
+ exchange,
+ merchant,
+ } = await createSimpleTestkudosEnvironment(t);
+
+ // Withdraw digital cash into the wallet.
+
+ await withdrawViaBank(t, { wallet, bank, exchange, amount: "TESTKUDOS:20" });
+
+ // Travel 400 days into the future,
+ // as the deposit expiration is two years
+ // into the future.
+ const timetravelDuration: Duration = {
+ d_ms: 1000 * 60 * 60 * 24 * 400,
+ };
+
+ await exchange.stop();
+ exchange.setTimetravel(timetravelDuration);
+ await exchange.start();
+ await exchange.pingUntilAvailable();
+
+ await merchant.stop();
+ merchant.setTimetravel(timetravelDuration);
+ await merchant.start();
+ await merchant.pingUntilAvailable();
+
+ // This should fail, as the wallet didn't time travel yet.
+ await withdrawViaBank(t, { wallet, bank, exchange, amount: "TESTKUDOS:20" });
+
+ const bal = await wallet.getBalances();
+
+ console.log(bal);
+});