aboutsummaryrefslogtreecommitdiff
path: root/src/operations
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2020-05-11 20:51:45 +0530
committerFlorian Dold <florian.dold@gmail.com>2020-05-11 20:51:45 +0530
commitd7ee78669d4ab25f5f883cc3858ccba4e409c354 (patch)
tree8a206537cc2afa6534766543551070baa0cf7395 /src/operations
parent4c614429a0602557273c4783dc0df54ba3687200 (diff)
create planchets only in one place
Diffstat (limited to 'src/operations')
-rw-r--r--src/operations/reserves.ts37
-rw-r--r--src/operations/withdraw.ts1
2 files changed, 1 insertions, 37 deletions
diff --git a/src/operations/reserves.ts b/src/operations/reserves.ts
index 786f4f51a..a3c6d56a4 100644
--- a/src/operations/reserves.ts
+++ b/src/operations/reserves.ts
@@ -647,40 +647,6 @@ async function depleteReserve(
const withdrawalGroupId = encodeCrock(randomBytes(32));
- const planchets: PlanchetRecord[] = [];
- let coinIdx = 0;
- for (let i = 0; i < denomsForWithdraw.selectedDenoms.length; i++) {
- const d = denomsForWithdraw.selectedDenoms[i];
- const denom = d.denom;
- for (let j = 0; j < d.count; j++) {
- const r = await ws.cryptoApi.createPlanchet({
- denomPub: denom.denomPub,
- feeWithdraw: denom.feeWithdraw,
- reservePriv: reserve.reservePriv,
- reservePub: reserve.reservePub,
- value: denom.value,
- });
- const planchet: PlanchetRecord = {
- blindingKey: r.blindingKey,
- coinEv: r.coinEv,
- coinEvHash: r.coinEvHash,
- coinIdx,
- coinPriv: r.coinPriv,
- coinPub: r.coinPub,
- coinValue: r.coinValue,
- denomPub: r.denomPub,
- denomPubHash: r.denomPubHash,
- isFromTip: false,
- reservePub: r.reservePub,
- withdrawalDone: false,
- withdrawSig: r.withdrawSig,
- withdrawalGroupId: withdrawalGroupId,
- };
- planchets.push(planchet);
- coinIdx++;
- }
- }
-
logger.trace("created plachets");
const withdrawalRecord: WithdrawalGroupRecord = {
@@ -747,9 +713,6 @@ async function depleteReserve(
newReserve.retryInfo = initRetryInfo(false);
await tx.put(Stores.reserves, newReserve);
await tx.put(Stores.withdrawalGroups, withdrawalRecord);
- for (const p of planchets) {
- await tx.put(Stores.planchets, p);
- }
return true;
},
);
diff --git a/src/operations/withdraw.ts b/src/operations/withdraw.ts
index b89dac776..91e4ff1d8 100644
--- a/src/operations/withdraw.ts
+++ b/src/operations/withdraw.ts
@@ -522,6 +522,7 @@ async function processInBatches(workGen: Iterator<Promise<void>>, batchSize: num
if (batch.length == 0) {
break;
}
+ logger.trace(`processing withdrawal batch of ${batch.length} elements`);
await Promise.all(batch);
}
}