1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
This file is part of GNU Taler
(C) 2022 Taler Systems SA
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/>
*/
/**
* Implementation of dev experiments, i.e. scenarios
* triggered by taler://dev-experiment URIs.
*
* @author Florian Dold <dold@taler.net>
*/
/**
* Imports.
*/
import {
Logger,
RefreshReason,
TalerPreciseTimestamp,
encodeCrock,
getRandomBytes,
parseDevExperimentUri,
} from "@gnu-taler/taler-util";
import {
HttpRequestLibrary,
HttpRequestOptions,
HttpResponse,
} from "@gnu-taler/taler-util/http";
import {
RefreshGroupRecord,
RefreshOperationStatus,
timestampPreciseToDb,
} from "./db.js";
import { WalletExecutionContext } from "./wallet.js";
const logger = new Logger("dev-experiments.ts");
/**
* Apply a dev experiment to the wallet database / state.
*/
export async function applyDevExperiment(
wex: WalletExecutionContext,
uri: string,
): Promise<void> {
logger.info(`applying dev experiment ${uri}`);
const parsedUri = parseDevExperimentUri(uri);
if (!parsedUri) {
logger.info("unable to parse dev experiment URI");
return;
}
if (!wex.ws.config.testing.devModeActive) {
throw Error(
"can't handle devmode URI (other than enable-devmode) unless devmode is active",
);
}
if (parsedUri.devExperimentId == "insert-pending-refresh") {
await wex.db.runReadWriteTx(["refreshGroups"], async (tx) => {
const refreshGroupId = encodeCrock(getRandomBytes(32));
const newRg: RefreshGroupRecord = {
currency: "TESTKUDOS",
expectedOutputPerCoin: [],
inputPerCoin: [],
oldCoinPubs: [],
operationStatus: RefreshOperationStatus.Pending,
reason: RefreshReason.Manual,
refreshGroupId,
statusPerCoin: [],
timestampCreated: timestampPreciseToDb(TalerPreciseTimestamp.now()),
timestampFinished: undefined,
originatingTransactionId: undefined,
infoPerExchange: {},
};
await tx.refreshGroups.put(newRg);
});
return;
}
throw Error(`dev-experiment id not understood ${parsedUri.devExperimentId}`);
}
export class DevExperimentHttpLib implements HttpRequestLibrary {
_isDevExperimentLib = true;
underlyingLib: HttpRequestLibrary;
constructor(lib: HttpRequestLibrary) {
this.underlyingLib = lib;
}
fetch(
url: string,
opt?: HttpRequestOptions | undefined,
): Promise<HttpResponse> {
logger.trace(`devexperiment httplib ${url}`);
return this.underlyingLib.fetch(url, opt);
}
}
|
