logging
This commit is contained in:
parent
5d6192b0cd
commit
d9433a2116
@ -77,9 +77,8 @@ async function makePayment(
|
||||
|
||||
paymentStatus = await merchant.checkPayment(orderResp.orderId);
|
||||
|
||||
console.log("payment status after wallet payment:", paymentStatus);
|
||||
|
||||
if (!paymentStatus.paid) {
|
||||
console.log("payment status:", paymentStatus);
|
||||
throw Error("payment did not succeed");
|
||||
}
|
||||
|
||||
@ -112,10 +111,6 @@ export async function runIntegrationTest(args: IntegrationTestArgs): Promise<voi
|
||||
);
|
||||
logger.info("done withdrawing test balance");
|
||||
|
||||
const balance = await myWallet.getBalances();
|
||||
|
||||
console.log(JSON.stringify(balance, null, 2));
|
||||
|
||||
const myMerchant = new MerchantBackendConnection(
|
||||
args.merchantBaseUrl,
|
||||
args.merchantApiKey,
|
||||
|
@ -355,7 +355,6 @@ async function refreshReveal(
|
||||
`refreshes/${refreshSession.hash}/reveal`,
|
||||
refreshSession.exchangeBaseUrl,
|
||||
);
|
||||
logger.trace("reveal request:", req);
|
||||
|
||||
let resp;
|
||||
try {
|
||||
@ -366,9 +365,6 @@ async function refreshReveal(
|
||||
return;
|
||||
}
|
||||
|
||||
logger.trace("session:", refreshSession);
|
||||
logger.trace("reveal response:", resp);
|
||||
|
||||
if (resp.status !== 200) {
|
||||
console.error("error: /refresh/reveal returned status " + resp.status);
|
||||
return;
|
||||
|
@ -361,16 +361,10 @@ export async function getVerifiedWithdrawDenomList(
|
||||
for (const denomSel of selectedDenoms.selectedDenoms) {
|
||||
const denom = denomSel.denom;
|
||||
if (denom.status === DenominationStatus.Unverified) {
|
||||
console.log(
|
||||
"checking validity",
|
||||
denom,
|
||||
exchangeDetails.masterPublicKey,
|
||||
);
|
||||
const valid = await ws.cryptoApi.isValidDenom(
|
||||
denom,
|
||||
exchangeDetails.masterPublicKey,
|
||||
);
|
||||
console.log("done checking validity");
|
||||
if (!valid) {
|
||||
denom.status = DenominationStatus.VerifiedBad;
|
||||
allValid = false;
|
||||
|
@ -436,9 +436,6 @@ export function openDatabase(
|
||||
throw Error("upgrade needed, but new version unknown");
|
||||
}
|
||||
onUpgradeNeeded(db, e.oldVersion, newVersion);
|
||||
console.log(
|
||||
`DB: upgrade needed: oldVersion=${e.oldVersion}, newVersion=${e.newVersion}`,
|
||||
);
|
||||
};
|
||||
});
|
||||
}
|
||||
|
@ -252,14 +252,19 @@ export class Wallet {
|
||||
* returns without resolving to an exception.
|
||||
*/
|
||||
public async runUntilDone(): Promise<void> {
|
||||
let done = false;
|
||||
const p = new Promise((resolve, reject) => {
|
||||
// Run this asynchronously
|
||||
this.addNotificationListener((n) => {
|
||||
if (done) {
|
||||
return;
|
||||
}
|
||||
if (
|
||||
n.type === NotificationType.WaitingForRetry &&
|
||||
n.numGivingLiveness == 0
|
||||
) {
|
||||
logger.trace("no liveness-giving operations left, returning");
|
||||
done = true;
|
||||
logger.trace("no liveness-giving operations left");
|
||||
resolve();
|
||||
}
|
||||
});
|
||||
@ -277,23 +282,9 @@ export class Wallet {
|
||||
* returns without resolving to an exception.
|
||||
*/
|
||||
public async runUntilDoneAndStop(): Promise<void> {
|
||||
const p = new Promise((resolve, reject) => {
|
||||
// Run this asynchronously
|
||||
this.addNotificationListener((n) => {
|
||||
if (
|
||||
n.type === NotificationType.WaitingForRetry &&
|
||||
n.numGivingLiveness == 0
|
||||
) {
|
||||
logger.trace("no liveness-giving operations left, stopping");
|
||||
this.stop();
|
||||
}
|
||||
});
|
||||
this.runRetryLoop().catch((e) => {
|
||||
console.log("exception in wallet retry loop");
|
||||
reject(e);
|
||||
});
|
||||
});
|
||||
await p;
|
||||
await this.runUntilDone();
|
||||
logger.trace("stopping after liveness-giving operations done");
|
||||
this.stop();
|
||||
}
|
||||
|
||||
/**
|
||||
@ -314,9 +305,7 @@ export class Wallet {
|
||||
|
||||
private async runRetryLoopImpl(): Promise<void> {
|
||||
while (!this.stopped) {
|
||||
console.log("running wallet retry loop iteration");
|
||||
const pending = await this.getPendingOperations({ onlyDue: true });
|
||||
console.log("pending ops", JSON.stringify(pending, undefined, 2));
|
||||
if (pending.pendingOperations.length === 0) {
|
||||
const allPending = await this.getPendingOperations({ onlyDue: false });
|
||||
let numPending = 0;
|
||||
@ -346,12 +335,10 @@ export class Wallet {
|
||||
await Promise.race([timeout, this.latch.wait()]);
|
||||
console.log("timeout done");
|
||||
} else {
|
||||
logger.trace("running pending operations that are due");
|
||||
// FIXME: maybe be a bit smarter about executing these
|
||||
// operations in parallel?
|
||||
for (const p of pending.pendingOperations) {
|
||||
try {
|
||||
console.log("running", p);
|
||||
await this.processOnePendingOperation(p);
|
||||
} catch (e) {
|
||||
console.error(e);
|
||||
|
Loading…
Reference in New Issue
Block a user