diff options
author | Florian Dold <florian.dold@gmail.com> | 2020-05-11 20:51:45 +0530 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2020-05-11 20:51:45 +0530 |
commit | d7ee78669d4ab25f5f883cc3858ccba4e409c354 (patch) | |
tree | 8a206537cc2afa6534766543551070baa0cf7395 /src/operations | |
parent | 4c614429a0602557273c4783dc0df54ba3687200 (diff) |
create planchets only in one place
Diffstat (limited to 'src/operations')
-rw-r--r-- | src/operations/reserves.ts | 37 | ||||
-rw-r--r-- | src/operations/withdraw.ts | 1 |
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); } } |