summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2020-03-26 21:58:38 +0530
committerFlorian Dold <florian.dold@gmail.com>2020-03-26 21:58:38 +0530
commit86c8a8fcf3115fd4957de113a03204ed22afe7e0 (patch)
tree23447c5a88ed737b32645da508743fc7a88a4a6f
parentc2e261e018b96d2966b849a470457090ba073393 (diff)
downloadwallet-core-86c8a8fcf3115fd4957de113a03204ed22afe7e0.tar.gz
wallet-core-86c8a8fcf3115fd4957de113a03204ed22afe7e0.tar.bz2
wallet-core-86c8a8fcf3115fd4957de113a03204ed22afe7e0.zip
another missing store ...
-rw-r--r--src/operations/recoup.ts16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/operations/recoup.ts b/src/operations/recoup.ts
index 7eba8330c..107b90446 100644
--- a/src/operations/recoup.ts
+++ b/src/operations/recoup.ts
@@ -55,7 +55,7 @@ async function incrementRecoupRetry(
recoupGroupId: string,
err: OperationError | undefined,
): Promise<void> {
- await ws.db.runWithWriteTransaction([Stores.recoupGroups], async tx => {
+ await ws.db.runWithWriteTransaction([Stores.recoupGroups], async (tx) => {
const r = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!r) {
return;
@@ -100,7 +100,7 @@ async function recoupTipCoin(
// We can't really recoup a coin we got via tipping.
// Thus we just put the coin to sleep.
// FIXME: somehow report this to the user
- await ws.db.runWithWriteTransaction([Stores.recoupGroups], async tx => {
+ await ws.db.runWithWriteTransaction([Stores.recoupGroups], async (tx) => {
const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) {
return;
@@ -157,7 +157,7 @@ async function recoupWithdrawCoin(
await ws.db.runWithWriteTransaction(
[Stores.coins, Stores.reserves, Stores.recoupGroups],
- async tx => {
+ async (tx) => {
const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) {
return;
@@ -187,7 +187,7 @@ async function recoupWithdrawCoin(
type: NotificationType.RecoupFinished,
});
- forceQueryReserve(ws, reserve.reservePub).catch(e => {
+ forceQueryReserve(ws, reserve.reservePub).catch((e) => {
console.log("re-querying reserve after recoup failed:", e);
});
}
@@ -228,8 +228,8 @@ async function recoupRefreshCoin(
}
const refreshGroupId = await ws.db.runWithWriteTransaction(
- [Stores.coins, Stores.reserves, Stores.recoupGroups],
- async tx => {
+ [Stores.coins, Stores.reserves, Stores.recoupGroups, Stores.refreshGroups],
+ async (tx) => {
const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) {
return;
@@ -261,7 +261,7 @@ async function recoupRefreshCoin(
);
if (refreshGroupId) {
- processRefreshGroup(ws, refreshGroupId.refreshGroupId).then(e => {
+ processRefreshGroup(ws, refreshGroupId.refreshGroupId).then((e) => {
console.error("error while refreshing after recoup", e);
});
}
@@ -271,7 +271,7 @@ async function resetRecoupGroupRetry(
ws: InternalWalletState,
recoupGroupId: string,
) {
- await ws.db.mutate(Stores.recoupGroups, recoupGroupId, x => {
+ await ws.db.mutate(Stores.recoupGroups, recoupGroupId, (x) => {
if (x.retryInfo.active) {
x.retryInfo = initRetryInfo();
}