taler/wallet-core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Activity

another missing store ...

Browse Source
This commit is contained in:
Florian Dold 2020-03-26 21:58:38 +05:30
parent c2e261e018
commit 86c8a8fcf3
No known key found for this signature in database
GPG Key ID: D2E4F00F29D02A4B
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/operations/recoup.ts
View File

@ -55,7 +55,7 @@ async function incrementRecoupRetry(
recoupGroupId: string, recoupGroupId: string,
err: OperationError | undefined, err: OperationError | undefined,
): Promise<void> { ): 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); const r = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!r) { if (!r) {
return; return;
@ -100,7 +100,7 @@ async function recoupTipCoin(
// We can't really recoup a coin we got via tipping. // We can't really recoup a coin we got via tipping.
// Thus we just put the coin to sleep. // Thus we just put the coin to sleep.
// FIXME: somehow report this to the user // 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); const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) { if (!recoupGroup) {
return; return;
@ -157,7 +157,7 @@ async function recoupWithdrawCoin(
await ws.db.runWithWriteTransaction( await ws.db.runWithWriteTransaction(
[Stores.coins, Stores.reserves, Stores.recoupGroups], [Stores.coins, Stores.reserves, Stores.recoupGroups],
async tx => { async (tx) => {
const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId); const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) { if (!recoupGroup) {
return; return;
@ -187,7 +187,7 @@ async function recoupWithdrawCoin(
type: NotificationType.RecoupFinished, type: NotificationType.RecoupFinished,
}); });
forceQueryReserve(ws, reserve.reservePub).catch(e => { forceQueryReserve(ws, reserve.reservePub).catch((e) => {
console.log("re-querying reserve after recoup failed:", e); console.log("re-querying reserve after recoup failed:", e);
}); });
} }
@ -228,8 +228,8 @@ async function recoupRefreshCoin(
} }
const refreshGroupId = await ws.db.runWithWriteTransaction( const refreshGroupId = await ws.db.runWithWriteTransaction(
[Stores.coins, Stores.reserves, Stores.recoupGroups], [Stores.coins, Stores.reserves, Stores.recoupGroups, Stores.refreshGroups],
async tx => { async (tx) => {
const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId); const recoupGroup = await tx.get(Stores.recoupGroups, recoupGroupId);
if (!recoupGroup) { if (!recoupGroup) {
return; return;
@ -261,7 +261,7 @@ async function recoupRefreshCoin(
); );
if (refreshGroupId) { if (refreshGroupId) {
processRefreshGroup(ws, refreshGroupId.refreshGroupId).then(e => { processRefreshGroup(ws, refreshGroupId.refreshGroupId).then((e) => {
console.error("error while refreshing after recoup", e); console.error("error while refreshing after recoup", e);
}); });
} }
@ -271,7 +271,7 @@ async function resetRecoupGroupRetry(
ws: InternalWalletState, ws: InternalWalletState,
recoupGroupId: string, recoupGroupId: string,
) { ) {
await ws.db.mutate(Stores.recoupGroups, recoupGroupId, x => { await ws.db.mutate(Stores.recoupGroups, recoupGroupId, (x) => {
if (x.retryInfo.active) { if (x.retryInfo.active) {
x.retryInfo = initRetryInfo(); x.retryInfo = initRetryInfo();
} }