aboutsummaryrefslogtreecommitdiff
path: root/src/wallet.ts
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-11-20 20:02:48 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-11-20 20:02:48 +0100
commit035b3fdae2961bd0b1d48e8119a64f4d340cd696 (patch)
treea479f1939606a33c766adfc0ddc9089cd6cfcc44 /src/wallet.ts
parent7974a76228f6474a781524664a455efb3b6faf7b (diff)
version upgrade and formatting
Diffstat (limited to 'src/wallet.ts')
-rw-r--r--src/wallet.ts580
1 files changed, 396 insertions, 184 deletions
diff --git a/src/wallet.ts b/src/wallet.ts
index 32b0833cd..71e058fd9 100644
--- a/src/wallet.ts
+++ b/src/wallet.ts
@@ -409,8 +409,10 @@ export class Wallet {
}
public async processPending(): Promise<void> {
-
- const exchangeBaseUrlList = await oneShotIter(this.db, Stores.exchanges).map((x) => x.baseUrl);
+ const exchangeBaseUrlList = await oneShotIter(
+ this.db,
+ Stores.exchanges,
+ ).map(x => x.baseUrl);
for (let exchangeBaseUrl of exchangeBaseUrlList) {
await this.updateExchangeFromUrl(exchangeBaseUrl);
@@ -436,9 +438,12 @@ export class Wallet {
* already been applied.
*/
async fillDefaults() {
- await runWithWriteTransaction(this.db, [Stores.config, Stores.currencies], async (tx) => {
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.config, Stores.currencies],
+ async tx => {
let applied = false;
- await tx.iter(Stores.config).forEach((x) => {
+ await tx.iter(Stores.config).forEach(x => {
if (x.key == "currencyDefaultsApplied" && x.value == true) {
applied = true;
}
@@ -448,7 +453,8 @@ export class Wallet {
await tx.put(Stores.currencies, c);
}
}
- });
+ },
+ );
}
private startOperation(operationId: string) {
@@ -464,7 +470,9 @@ export class Wallet {
}
async updateExchanges(): Promise<void> {
- const exchangeUrls = await oneShotIter(this.db, Stores.exchanges).map((e) => e.baseUrl);
+ const exchangeUrls = await oneShotIter(this.db, Stores.exchanges).map(
+ e => e.baseUrl,
+ );
for (const url of exchangeUrls) {
this.updateExchangeFromUrl(url).catch(e => {
@@ -481,9 +489,9 @@ export class Wallet {
Wallet.enableTracing && console.log("resuming pending operations from db");
oneShotIter(this.db, Stores.reserves).forEach(reserve => {
- Wallet.enableTracing &&
- console.log("resuming reserve", reserve.reserve_pub);
- this.processReserve(reserve.reserve_pub);
+ Wallet.enableTracing &&
+ console.log("resuming reserve", reserve.reserve_pub);
+ this.processReserve(reserve.reserve_pub);
});
oneShotIter(this.db, Stores.precoins).forEach(preCoin => {
@@ -495,27 +503,41 @@ export class Wallet {
this.continueRefreshSession(r);
});
- oneShotIter(this.db, Stores.coinsReturns).forEach((r: CoinsReturnRecord) => {
- this.depositReturnedCoins(r);
- });
+ oneShotIter(this.db, Stores.coinsReturns).forEach(
+ (r: CoinsReturnRecord) => {
+ this.depositReturnedCoins(r);
+ },
+ );
}
private async getCoinsForReturn(
exchangeBaseUrl: string,
amount: AmountJson,
): Promise<CoinWithDenom[] | undefined> {
- const exchange = await oneShotGet(this.db, Stores.exchanges, exchangeBaseUrl);
+ const exchange = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ exchangeBaseUrl,
+ );
if (!exchange) {
throw Error(`Exchange ${exchangeBaseUrl} not known to the wallet`);
}
- const coins: CoinRecord[] = await oneShotIterIndex(this.db, Stores.coins.exchangeBaseUrlIndex, exchange.baseUrl).toArray();
+ const coins: CoinRecord[] = await oneShotIterIndex(
+ this.db,
+ Stores.coins.exchangeBaseUrlIndex,
+ exchange.baseUrl,
+ ).toArray();
if (!coins || !coins.length) {
return [];
}
- const denoms = await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex, exchange.baseUrl).toArray();
+ const denoms = await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ exchange.baseUrl,
+ ).toArray();
// Denomination of the first coin, we assume that all other
// coins have the same currency
@@ -621,9 +643,17 @@ export class Wallet {
continue;
}
- const coins = await oneShotIterIndex(this.db, Stores.coins.exchangeBaseUrlIndex, exchange.baseUrl).toArray();
+ const coins = await oneShotIterIndex(
+ this.db,
+ Stores.coins.exchangeBaseUrlIndex,
+ exchange.baseUrl,
+ ).toArray();
- const denoms = await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex, exchange.baseUrl).toArray();
+ const denoms = await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ exchange.baseUrl,
+ ).toArray();
if (!coins || coins.length === 0) {
continue;
@@ -726,12 +756,16 @@ export class Wallet {
timestamp_refund: 0,
};
- await runWithWriteTransaction(this.db, [Stores.coins, Stores.purchases], async (tx) => {
- await tx.put(Stores.purchases, t);
- for (let c of payCoinInfo.updatedCoins) {
- await tx.put(Stores.coins, c);
- }
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coins, Stores.purchases],
+ async tx => {
+ await tx.put(Stores.purchases, t);
+ for (let c of payCoinInfo.updatedCoins) {
+ await tx.put(Stores.coins, c);
+ }
+ },
+ );
this.badge.showNotification();
this.notifier.notify();
@@ -812,7 +846,11 @@ export class Wallet {
}
// First check if we already payed for it.
- const purchase = await oneShotGet(this.db, Stores.purchases, proposal.contractTermsHash);
+ const purchase = await oneShotGet(
+ this.db,
+ Stores.purchases,
+ proposal.contractTermsHash,
+ );
if (!purchase) {
const paymentAmount = Amounts.parseOrThrow(proposal.contractTerms.amount);
@@ -894,7 +932,11 @@ export class Wallet {
* downloaded in the context of a session ID.
*/
async downloadProposal(url: string, sessionId?: string): Promise<number> {
- const oldProposal = await oneShotGetIndexed(this.db, Stores.proposals.urlIndex, url);
+ const oldProposal = await oneShotGetIndexed(
+ this.db,
+ Stores.proposals.urlIndex,
+ url,
+ );
if (oldProposal) {
return oldProposal.id!;
}
@@ -940,9 +982,11 @@ export class Wallet {
throw Error(`proposal with id ${proposalId} not found`);
}
- const purchase = await oneShotGet(this.db,
+ const purchase = await oneShotGet(
+ this.db,
Stores.purchases,
- proposal.contractTermsHash);
+ proposal.contractTermsHash,
+ );
if (!purchase) {
throw Error("purchase not found for proposal");
@@ -957,7 +1001,11 @@ export class Wallet {
contractTermsHash: string,
sessionId: string | undefined,
): Promise<ConfirmPayResult> {
- const purchase = await oneShotGet(this.db, Stores.purchases, contractTermsHash);
+ const purchase = await oneShotGet(
+ this.db,
+ Stores.purchases,
+ contractTermsHash,
+ );
if (!purchase) {
throw Error("Purchase not found: " + contractTermsHash);
}
@@ -1004,12 +1052,16 @@ export class Wallet {
modifiedCoins.push(c);
}
- await runWithWriteTransaction(this.db, [Stores.coins, Stores.purchases], async (tx) => {
- for (let c of modifiedCoins) {
- tx.put(Stores.coins, c);
- }
- tx.put(Stores.purchases, purchase);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coins, Stores.purchases],
+ async tx => {
+ for (let c of modifiedCoins) {
+ tx.put(Stores.coins, c);
+ }
+ tx.put(Stores.purchases, purchase);
+ },
+ );
for (const c of purchase.payReq.coins) {
this.refresh(c.coin_pub);
@@ -1065,9 +1117,11 @@ export class Wallet {
const sessionId = sessionIdOverride || proposal.downloadSessionId;
- let purchase = await oneShotGet(this.db,
+ let purchase = await oneShotGet(
+ this.db,
Stores.purchases,
- proposal.contractTermsHash,);
+ proposal.contractTermsHash,
+ );
if (purchase) {
return this.submitPay(purchase.contractTermsHash, sessionId);
@@ -1167,9 +1221,7 @@ export class Wallet {
* Send reserve details
*/
private async sendReserveInfoToBank(reservePub: string) {
- const reserve = await oneShotGet(this.db,
- Stores.reserves,
- reservePub);
+ const reserve = await oneShotGet(this.db, Stores.reserves, reservePub);
if (!reserve) {
throw Error("reserve not in db");
}
@@ -1190,7 +1242,7 @@ export class Wallet {
}
if (status.transfer_done) {
- await oneShotMutate(this.db, Stores.reserves, reservePub, (r) => {
+ await oneShotMutate(this.db, Stores.reserves, reservePub, r => {
r.timestamp_confirmed = now;
return r;
});
@@ -1206,7 +1258,7 @@ export class Wallet {
console.log("bank error response", e);
throw e;
}
- await oneShotMutate(this.db, Stores.reserves, reservePub, (r) => {
+ await oneShotMutate(this.db, Stores.reserves, reservePub, r => {
r.timestamp_reserve_info_posted = now;
return r;
});
@@ -1321,9 +1373,11 @@ export class Wallet {
this.processPreCoinConcurrent++;
try {
- const exchange = await oneShotGet(this.db,
+ const exchange = await oneShotGet(
+ this.db,
Stores.exchanges,
- preCoin.exchangeBaseUrl,);
+ preCoin.exchangeBaseUrl,
+ );
if (!exchange) {
console.error("db inconsistent: exchange for precoin not found");
return;
@@ -1353,11 +1407,15 @@ export class Wallet {
return r;
};
- await runWithWriteTransaction(this.db, [Stores.reserves, Stores.precoins, Stores.coins], async (tx) => {
- await tx.mutate(Stores.reserves, preCoin.reservePub, mutateReserve);
- await tx.delete(Stores.precoins, coin.coinPub);
- await tx.add(Stores.coins, coin);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.reserves, Stores.precoins, Stores.coins],
+ async tx => {
+ await tx.mutate(Stores.reserves, preCoin.reservePub, mutateReserve);
+ await tx.delete(Stores.precoins, coin.coinPub);
+ await tx.add(Stores.coins, coin);
+ },
+ );
this.badge.showNotification();
@@ -1441,7 +1499,11 @@ export class Wallet {
throw Error("exchange not updated");
}
const { isAudited, isTrusted } = await this.getExchangeTrust(exchangeInfo);
- let currencyRecord = await oneShotGet(this.db, Stores.currencies, exchangeDetails.currency);
+ let currencyRecord = await oneShotGet(
+ this.db,
+ Stores.currencies,
+ exchangeDetails.currency,
+ );
if (!currencyRecord) {
currencyRecord = {
auditors: [],
@@ -1460,10 +1522,14 @@ export class Wallet {
const cr: CurrencyRecord = currencyRecord;
- runWithWriteTransaction(this.db, [Stores.currencies, Stores.reserves], async (tx) => {
- await tx.put(Stores.currencies, cr);
- await tx.put(Stores.reserves, reserveRecord);
- });
+ runWithWriteTransaction(
+ this.db,
+ [Stores.currencies, Stores.reserves],
+ async tx => {
+ await tx.put(Stores.currencies, cr);
+ await tx.put(Stores.reserves, reserveRecord);
+ },
+ );
if (req.bankWithdrawStatusUrl) {
this.processReserve(keypair.pub);
@@ -1611,13 +1677,17 @@ export class Wallet {
// This will fail and throw an exception if the remaining amount in the
// reserve is too low to create a pre-coin.
try {
- await runWithWriteTransaction(this.db, [Stores.precoins, Stores.withdrawals, Stores.reserves], async (tx) => {
- for (let pcr of preCoinRecords) {
- await tx.put(Stores.precoins, pcr);
- }
- await tx.mutate(Stores.reserves, reserve.reserve_pub, mutateReserve);
- await tx.put(Stores.withdrawals, withdrawalRecord);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.precoins, Stores.withdrawals, Stores.reserves],
+ async tx => {
+ for (let pcr of preCoinRecords) {
+ await tx.put(Stores.precoins, pcr);
+ }
+ await tx.mutate(Stores.reserves, reserve.reserve_pub, mutateReserve);
+ await tx.put(Stores.withdrawals, withdrawalRecord);
+ },
+ );
} catch (e) {
return;
}
@@ -1661,10 +1731,18 @@ export class Wallet {
return reserve;
}
- async getPossibleDenoms(exchangeBaseUrl: string): Promise<DenominationRecord[]> {
- return await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex, exchangeBaseUrl).filter((d) => {
- return d.status === DenominationStatus.Unverified ||
- d.status === DenominationStatus.VerifiedGood;
+ async getPossibleDenoms(
+ exchangeBaseUrl: string,
+ ): Promise<DenominationRecord[]> {
+ return await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ exchangeBaseUrl,
+ ).filter(d => {
+ return (
+ d.status === DenominationStatus.Unverified ||
+ d.status === DenominationStatus.VerifiedGood
+ );
});
}
@@ -1677,7 +1755,11 @@ export class Wallet {
async getVerifiedSmallestWithdrawAmount(
exchangeBaseUrl: string,
): Promise<AmountJson> {
- const exchange = await oneShotGet(this.db, Stores.exchanges, exchangeBaseUrl);
+ const exchange = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ exchangeBaseUrl,
+ );
if (!exchange) {
throw Error(`exchange ${exchangeBaseUrl} not found`);
}
@@ -1726,7 +1808,11 @@ export class Wallet {
exchangeBaseUrl: string,
amount: AmountJson,
): Promise<DenominationRecord[]> {
- const exchange = await oneShotGet(this.db, Stores.exchanges, exchangeBaseUrl);
+ const exchange = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ exchangeBaseUrl,
+ );
if (!exchange) {
throw Error(`exchange ${exchangeBaseUrl} not found`);
}
@@ -1780,9 +1866,11 @@ export class Wallet {
if (!exchangeDetails) {
throw Error(`exchange ${exchangeInfo.baseUrl} details not available`);
}
- const currencyRecord = await oneShotGet(this.db,
+ const currencyRecord = await oneShotGet(
+ this.db,
Stores.currencies,
- exchangeDetails.currency);
+ exchangeDetails.currency,
+ );
if (currencyRecord) {
for (const trustedExchange of currencyRecord.exchanges) {
if (trustedExchange.exchangePub === exchangeDetails.masterPublicKey) {
@@ -1868,11 +1956,15 @@ export class Wallet {
const possibleDenoms = await oneShotIterIndex(
this.db,
Stores.denominations.exchangeBaseUrlIndex,
- baseUrl)
- .filter((d) => d.isOffered);
+ baseUrl,
+ ).filter(d => d.isOffered);
const trustedAuditorPubs = [];
- const currencyRecord = await oneShotGet(this.db, Stores.currencies, amount.currency);
+ const currencyRecord = await oneShotGet(
+ this.db,
+ Stores.currencies,
+ amount.currency,
+ );
if (currencyRecord) {
trustedAuditorPubs.push(
...currencyRecord.auditors.map(a => a.auditorPub),
@@ -1927,7 +2019,11 @@ export class Wallet {
exchangeBaseUrl: string,
supportedTargetTypes: string[],
): Promise<string> {
- const exchangeRecord = await oneShotGet(this.db, Stores.exchanges, exchangeBaseUrl);
+ const exchangeRecord = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ exchangeBaseUrl,
+ );
if (!exchangeRecord) {
throw Error(`Exchange '${exchangeBaseUrl}' not found.`);
}
@@ -1967,7 +2063,7 @@ export class Wallet {
};
await oneShotPut(this.db, Stores.exchanges, newExchangeRecord);
} else {
- runWithWriteTransaction(this.db, [Stores.exchanges], async (t) => {
+ runWithWriteTransaction(this.db, [Stores.exchanges], async t => {
const rec = await t.get(Stores.exchanges, baseUrl);
if (!rec) {
return;
@@ -1984,7 +2080,11 @@ export class Wallet {
await this.updateExchangeWithKeys(baseUrl);
await this.updateExchangeWithWireInfo(baseUrl);
- const updatedExchange = await oneShotGet(this.db, Stores.exchanges, baseUrl);
+ const updatedExchange = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ baseUrl,
+ );
if (!updatedExchange) {
// This should practically never happen
@@ -2011,9 +2111,15 @@ export class Wallet {
* in the pending operations.
*/
private async updateExchangeWithKeys(baseUrl: string): Promise<void> {
- const existingExchangeRecord = await oneShotGet(this.db, Stores.exchanges, baseUrl);
+ const existingExchangeRecord = await oneShotGet(
+ this.db,
+ Stores.exchanges,
+ baseUrl,
+ );
- if (existingExchangeRecord?.updateStatus != ExchangeUpdateStatus.FETCH_KEYS) {
+ if (
+ existingExchangeRecord?.updateStatus != ExchangeUpdateStatus.FETCH_KEYS
+ ) {
return;
}
const keysUrl = new URI("keys")
@@ -2111,7 +2217,6 @@ export class Wallet {
const wireInfo = ExchangeWireJson.checked(wiJson);
}
-
/**
* Get detailed balance information, sliced by exchange and by currency.
*/
@@ -2155,71 +2260,100 @@ export class Wallet {
byExchange: {},
};
- await runWithWriteTransaction(this.db, [Stores.coins, Stores.refresh, Stores.reserves, Stores.purchases], async (tx) => {
- await tx.iter(Stores.coins).forEach((c) => {
- if (c.suspended) {
- return;
- }
- if (c.status === CoinStatus.Fresh) {
- addTo(balanceStore, "available", c.currentAmount, c.exchangeBaseUrl);
- }
- if (c.status === CoinStatus.Dirty) {
- addTo(balanceStore, "pendingIncoming", c.currentAmount, c.exchangeBaseUrl);
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coins, Stores.refresh, Stores.reserves, Stores.purchases],
+ async tx => {
+ await tx.iter(Stores.coins).forEach(c => {
+ if (c.suspended) {
+ return;
+ }
+ if (c.status === CoinStatus.Fresh) {
+ addTo(
+ balanceStore,
+ "available",
+ c.currentAmount,
+ c.exchangeBaseUrl,
+ );
+ }
+ if (c.status === CoinStatus.Dirty) {
+ addTo(
+ balanceStore,
+ "pendingIncoming",
+ c.currentAmount,
+ c.exchangeBaseUrl,
+ );
+ addTo(
+ balanceStore,
+ "pendingIncomingDirty",
+ c.currentAmount,
+ c.exchangeBaseUrl,
+ );
+ }
+ });
+ await tx.iter(Stores.refresh).forEach(r => {
+ // Don't count finished refreshes, since the refresh already resulted
+ // in coins being added to the wallet.
+ if (r.finished) {
+ return;
+ }
addTo(
balanceStore,
- "pendingIncomingDirty",
- c.currentAmount,
- c.exchangeBaseUrl,
+ "pendingIncoming",
+ r.valueOutput,
+ r.exchangeBaseUrl,
);
- }
- });
- await tx.iter(Stores.refresh).forEach((r) => {
- // Don't count finished refreshes, since the refresh already resulted
- // in coins being added to the wallet.
- if (r.finished) {
- return;
- }
- addTo(balanceStore, "pendingIncoming", r.valueOutput, r.exchangeBaseUrl);
- addTo(
- balanceStore,
- "pendingIncomingRefresh",
- r.valueOutput,
- r.exchangeBaseUrl,
- );
- });
-
- await tx.iter(Stores.reserves).forEach((r) => {
- if (!r.timestamp_confirmed) {
- return;
- }
- let amount = Amounts.getZero(r.requested_amount.currency);
- amount = Amounts.add(amount, r.precoin_amount).amount;
- addTo(balanceStore, "pendingIncoming", amount, r.exchange_base_url);
- addTo(balanceStore, "pendingIncomingWithdraw", amount, r.exchange_base_url);
- });
+ addTo(
+ balanceStore,
+ "pendingIncomingRefresh",
+ r.valueOutput,
+ r.exchangeBaseUrl,
+ );
+ });
- await tx.iter(Stores.reserves).forEach((r) => {
- if (!r.hasPayback) {
- return;
- }
- addTo(balanceStore, "paybackAmount", r.current_amount!, r.exchange_base_url);
- return balanceStore;
- });
+ await tx.iter(Stores.reserves).forEach(r => {
+ if (!r.timestamp_confirmed) {
+ return;
+ }
+ let amount = Amounts.getZero(r.requested_amount.currency);
+ amount = Amounts.add(amount, r.precoin_amount).amount;
+ addTo(balanceStore, "pendingIncoming", amount, r.exchange_base_url);
+ addTo(
+ balanceStore,
+ "pendingIncomingWithdraw",
+ amount,
+ r.exchange_base_url,
+ );
+ });
- await tx.iter(Stores.purchases).forEach((t) => {
- if (t.finished) {
- return;
- }
- for (const c of t.payReq.coins) {
+ await tx.iter(Stores.reserves).forEach(r => {
+ if (!r.hasPayback) {
+ return;
+ }
addTo(
balanceStore,
- "pendingPayment",
- Amounts.parseOrThrow(c.contribution),
- c.exchange_url,
+ "paybackAmount",
+ r.current_amount!,
+ r.exchange_base_url,
);
- }
- });
- });
+ return balanceStore;
+ });
+
+ await tx.iter(Stores.purchases).forEach(t => {
+ if (t.finished) {
+ return;
+ }
+ for (const c of t.payReq.coins) {
+ addTo(
+ balanceStore,
+ "pendingPayment",
+ Amounts.parseOrThrow(c.contribution),
+ c.exchange_url,
+ );
+ }
+ });
+ },
+ );
Wallet.enableTracing && console.log("computed balances:", balanceStore);
return balanceStore;
@@ -2253,7 +2387,11 @@ export class Wallet {
throw Error("db inconsistent");
}
- const availableDenoms: DenominationRecord[] = await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex, exchange.baseUrl).toArray();
+ const availableDenoms: DenominationRecord[] = await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ exchange.baseUrl,
+ ).toArray();
const availableAmount = Amounts.sub(coin.currentAmount, oldDenom.feeRefresh)
.amount;
@@ -2302,10 +2440,14 @@ export class Wallet {
// Store refresh session and subtract refreshed amount from
// coin in the same transaction.
- await runWithWriteTransaction(this.db, [Stores.refresh, Stores.coins], async (tx) => {
- key = await tx.put(Stores.refresh, refreshSession);
- await tx.mutate(Stores.coins, coin.coinPub, mutateCoin);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.refresh, Stores.coins],
+ async tx => {
+ key = await tx.put(Stores.refresh, refreshSession);
+ await tx.mutate(Stores.coins, coin.coinPub, mutateCoin);
+ },
+ );
this.notifier.notify();
if (!key || typeof key !== "number") {
@@ -2319,7 +2461,10 @@ export class Wallet {
async refresh(oldCoinPub: string): Promise<void> {
const refreshImpl = async () => {
- const oldRefreshSessions = await oneShotIter(this.db, Stores.refresh).toArray();
+ const oldRefreshSessions = await oneShotIter(
+ this.db,
+ Stores.refresh,
+ ).toArray();
for (const session of oldRefreshSessions) {
if (session.finished) {
continue;
@@ -2395,7 +2540,11 @@ export class Wallet {
return;
}
- const coin = await oneShotGet(this.db, Stores.coins, refreshSession.meltCoinPub);
+ const coin = await oneShotGet(
+ this.db,
+ Stores.coins,
+ refreshSession.meltCoinPub,
+ );
if (!coin) {
console.error("can't melt coin, it does not exist");
@@ -2451,7 +2600,11 @@ export class Wallet {
throw Error("refresh index error");
}
- const meltCoinRecord = await oneShotGet(this.db, Stores.coins, refreshSession.meltCoinPub);
+ const meltCoinRecord = await oneShotGet(
+ this.db,
+ Stores.coins,
+ refreshSession.meltCoinPub,
+ );
if (!meltCoinRecord) {
throw Error("inconsistent database");
}
@@ -2549,16 +2702,22 @@ export class Wallet {
refreshSession.finished = true;
- await runWithWriteTransaction(this.db, [Stores.coins, Stores.refresh], async (tx) => {
- for (let coin of coins) {
- await tx.put(Stores.coins, coin);
- }
- await tx.put(Stores.refresh, refreshSession);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coins, Stores.refresh],
+ async tx => {
+ for (let coin of coins) {
+ await tx.put(Stores.coins, coin);
+ }
+ await tx.put(Stores.refresh, refreshSession);
+ },
+ );
this.notifier.notify();
}
- async findExchange(exchangeBaseUrl: string): Promise<ExchangeRecord | undefined> {
+ async findExchange(
+ exchangeBaseUrl: string,
+ ): Promise<ExchangeRecord | undefined> {
return await oneShotGet(this.db, Stores.exchanges, exchangeBaseUrl);
}
@@ -2588,7 +2747,10 @@ export class Wallet {
});
}
- const withdrawals = await oneShotIter(this.db, Stores.withdrawals).toArray();
+ const withdrawals = await oneShotIter(
+ this.db,
+ Stores.withdrawals,
+ ).toArray();
for (const w of withdrawals) {
history.push({
detail: {
@@ -2721,7 +2883,11 @@ export class Wallet {
}
async getDenoms(exchangeUrl: string): Promise<DenominationRecord[]> {
- const denoms = await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex, exchangeUrl).toArray();
+ const denoms = await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ exchangeUrl,
+ ).toArray();
return denoms;
}
@@ -2747,15 +2913,21 @@ export class Wallet {
}
async getReserves(exchangeBaseUrl: string): Promise<ReserveRecord[]> {
- return await oneShotIter(this.db, Stores.reserves).filter((r) => r.exchange_base_url === exchangeBaseUrl);
+ return await oneShotIter(this.db, Stores.reserves).filter(
+ r => r.exchange_base_url === exchangeBaseUrl,
+ );
}
async getCoins(exchangeBaseUrl: string): Promise<CoinRecord[]> {
- return await oneShotIter(this.db, Stores.coins).filter((c) => c.exchangeBaseUrl === exchangeBaseUrl);
+ return await oneShotIter(this.db, Stores.coins).filter(
+ c => c.exchangeBaseUrl === exchangeBaseUrl,
+ );
}
async getPreCoins(exchangeBaseUrl: string): Promise<PreCoinRecord[]> {
- return await oneShotIter(this.db, Stores.precoins).filter((c) => c.exchangeBaseUrl === exchangeBaseUrl);
+ return await oneShotIter(this.db, Stores.precoins).filter(
+ c => c.exchangeBaseUrl === exchangeBaseUrl,
+ );
}
private async hashContract(contract: ContractTerms): Promise<string> {
@@ -2789,10 +2961,14 @@ export class Wallet {
// technically we might update reserve status before we get the response
// from the reserve for the payback request.
reserve.hasPayback = true;
- await runWithWriteTransaction(this.db, [Stores.coins, Stores.reserves], async (tx) => {
- await tx.put(Stores.coins, coin!!);
- await tx.put(Stores.reserves, reserve);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coins, Stores.reserves],
+ async tx => {
+ await tx.put(Stores.coins, coin!!);
+ await tx.put(Stores.reserves, reserve);
+ },
+ );
this.notifier.notify();
const paybackRequest = await this.cryptoApi.createPaybackRequest(coin);
@@ -2851,7 +3027,9 @@ export class Wallet {
}
async getPaybackReserves(): Promise<ReserveRecord[]> {
- return await oneShotIter(this.db, Stores.reserves).filter(r => r.hasPayback);
+ return await oneShotIter(this.db, Stores.reserves).filter(
+ r => r.hasPayback,
+ );
}
/**
@@ -2865,7 +3043,7 @@ export class Wallet {
async getSenderWireInfos(): Promise<SenderWireInfos> {
const m: { [url: string]: Set<string> } = {};
- await oneShotIter(this.db, Stores.exchanges).forEach((x) => {
+ await oneShotIter(this.db, Stores.exchanges).forEach(x => {
const wi = x.wireInfo;
if (!wi) {
return;
@@ -2881,7 +3059,7 @@ export class Wallet {
});
const senderWiresSet: Set<string> = new Set();
- await oneShotIter(this.db, Stores.senderWires).forEach((x) => {
+ await oneShotIter(this.db, Stores.senderWires).forEach(x => {
senderWiresSet.add(x.paytoUri);
});
@@ -2974,12 +3152,16 @@ export class Wallet {
wire: req.senderWire,
};
- await runWithWriteTransaction(this.db, [Stores.coinsReturns, Stores.coins], async (tx) => {
- await tx.put(Stores.coinsReturns, coinsReturnRecord);
- for (let c of payCoinInfo.updatedCoins) {
- await tx.put(Stores.coins, c);
- }
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.coinsReturns, Stores.coins],
+ async tx => {
+ await tx.put(Stores.coinsReturns, coinsReturnRecord);
+ for (let c of payCoinInfo.updatedCoins) {
+ await tx.put(Stores.coins, c);
+ }
+ },
+ );
this.badge.showNotification();
this.notifier.notify();
@@ -3029,7 +3211,11 @@ export class Wallet {
// FIXME: verify signature
// For every successful deposit, we replace the old record with an updated one
- const currentCrr = await oneShotGet(this.db, Stores.coinsReturns, coinsReturnRecord.contractTermsHash);
+ const currentCrr = await oneShotGet(
+ this.db,
+ Stores.coinsReturns,
+ coinsReturnRecord.contractTermsHash,
+ );
if (!currentCrr) {
console.error("database inconsistent");
continue;
@@ -3114,7 +3300,11 @@ export class Wallet {
}
private async submitRefunds(contractTermsHash: string): Promise<void> {
- const purchase = await oneShotGet(this.db, Stores.purchases, contractTermsHash);
+ const purchase = await oneShotGet(
+ this.db,
+ Stores.purchases,
+ contractTermsHash,
+ );
if (!purchase) {
console.error(
"not submitting refunds, contract terms not found:",
@@ -3177,10 +3367,18 @@ export class Wallet {
return c;
};
- await runWithWriteTransaction(this.db, [Stores.purchases, Stores.coins], async (tx) => {
- await tx.mutate(Stores.purchases, contractTermsHash, transformPurchase);
- await tx.mutate(Stores.coins, perm.coin_pub, transformCoin);
- });
+ await runWithWriteTransaction(
+ this.db,
+ [Stores.purchases, Stores.coins],
+ async tx => {
+ await tx.mutate(
+ Stores.purchases,
+ contractTermsHash,
+ transformPurchase,
+ );
+ await tx.mutate(Stores.coins, perm.coin_pub, transformCoin);
+ },
+ );
this.refresh(perm.coin_pub);
}
@@ -3200,7 +3398,11 @@ export class Wallet {
if (refundPermissions.length === 0) {
throw Error("no refunds given");
}
- const coin0 = await oneShotGet(this.db, Stores.coins, refundPermissions[0].coin_pub);
+ const coin0 = await oneShotGet(
+ this.db,
+ Stores.coins,
+ refundPermissions[0].coin_pub,
+ );
if (!coin0) {
throw Error("coin not found");
}
@@ -3208,8 +3410,11 @@ export class Wallet {
Amounts.parseOrThrow(refundPermissions[0].refund_amount).currency,
);
- const denoms = await oneShotIterIndex(this.db, Stores.denominations.exchangeBaseUrlIndex,
- coin0.exchangeBaseUrl).toArray()
+ const denoms = await oneShotIterIndex(
+ this.db,
+ Stores.denominations.exchangeBaseUrlIndex,
+ coin0.exchangeBaseUrl,
+ ).toArray();
for (const rp of refundPermissions) {
const coin = await oneShotGet(this.db, Stores.coins, rp.coin_pub);
@@ -3258,7 +3463,10 @@ export class Wallet {
tipId: string,
merchantOrigin: string,
): Promise<void> {
- let tipRecord = await oneShotGet(this.db, Stores.tips, [tipId, merchantOrigin]);
+ let tipRecord = await oneShotGet(this.db, Stores.tips, [
+ tipId,
+ merchantOrigin,
+ ]);
if (!tipRecord) {
throw Error("tip not in database");
}
@@ -3282,7 +3490,7 @@ export class Wallet {
);
const coinPubs: string[] = planchets.map(x => x.coinPub);
- await oneShotMutate(this.db, Stores.tips, [tipId, merchantOrigin], (r) => {
+ await oneShotMutate(this.db, Stores.tips, [tipId, merchantOrigin], r => {
if (!r.planchets) {
r.planchets = planchets;
r.coinPubs = coinPubs;
@@ -3376,7 +3584,7 @@ export class Wallet {
let tipRecord = await oneShotGet(this.db, Stores.tips, [
res.tipId,
res.merchantOrigin,
- ])
+ ]);
if (!tipRecord) {
const withdrawDetails = await this.getWithdrawDetailsForAmount(
@@ -3423,7 +3631,11 @@ export class Wallet {
}
async abortFailedPayment(contractTermsHash: string): Promise<void> {
- const purchase = await oneShotGet(this.db, Stores.purchases, contractTermsHash);
+ const purchase = await oneShotGet(
+ this.db,
+ Stores.purchases,
+ contractTermsHash,
+ );
if (!purchase) {
throw Error("Purchase not found, unable to abort with refund");
}
@@ -3461,7 +3673,7 @@ export class Wallet {
const refundResponse = MerchantRefundResponse.checked(resp.responseJson);
await this.acceptRefundResponse(refundResponse);
- await runWithWriteTransaction(this.db, [Stores.purchases], async (tx) => {
+ await runWithWriteTransaction(this.db, [Stores.purchases], async tx => {
const p = await tx.get(Stores.purchases, purchase.contractTermsHash);
if (!p) {
return;
@@ -3535,9 +3747,9 @@ export class Wallet {
const refundsDoneAmounts = Object.values(purchase.refundsDone).map(x =>
Amounts.parseOrThrow(x.refund_amount),
);
- const refundsPendingAmounts = Object.values(purchase.refundsPending).map(
- x => Amounts.parseOrThrow(x.refund_amount),
- );
+ const refundsPendingAmounts = Object.values(
+ purchase.refundsPending,
+ ).map(x => Amounts.parseOrThrow(x.refund_amount));
const totalRefundAmount = Amounts.sum([
...refundsDoneAmounts,
...refundsPendingAmounts,