diff options
| -rw-r--r-- | packages/taler-wallet-core/src/operations/withdraw.ts | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/packages/taler-wallet-core/src/operations/withdraw.ts b/packages/taler-wallet-core/src/operations/withdraw.ts index c2fcf05e8..c741f7703 100644 --- a/packages/taler-wallet-core/src/operations/withdraw.ts +++ b/packages/taler-wallet-core/src/operations/withdraw.ts @@ -492,7 +492,7 @@ async function processPlanchetExchangeBatchRequest( const batchReq: ExchangeBatchWithdrawRequest = { planchets: [] }; // Indices of coins that are included in the batch request - const coinIdxs: number[] = []; + const requestCoinIdxs: number[] = []; await ws.db .mktx((x) => [ @@ -537,7 +537,7 @@ async function processPlanchetExchangeBatchRequest( coin_ev: planchet.coinEv, }; batchReq.planchets.push(planchetReq); - coinIdxs.push(coinIdx); + requestCoinIdxs.push(coinIdx); } }); @@ -563,7 +563,7 @@ async function processPlanchetExchangeBatchRequest( for (let i = startIdx; i < coinIdxs.length; i++) { let planchet = await tx.planchets.indexes.byGroupAndIndex.get([ withdrawalGroup.withdrawalGroupId, - coinIdxs[i], + requestCoinIdxs[i], ]); if (!planchet) { continue; @@ -623,11 +623,11 @@ async function processPlanchetExchangeBatchRequest( codecForWithdrawBatchResponse(), ); return { - coinIdxs, + coinIdxs: requestCoinIdxs, batchResp: r, }; } catch (e) { - await storeCoinError(e, coinIdxs[0]); + await storeCoinError(e, requestCoinIdxs[0]); return { batchResp: { ev_sigs: [] }, coinIdxs: [], @@ -638,6 +638,7 @@ async function processPlanchetExchangeBatchRequest( const responses: ExchangeWithdrawBatchResponse = { ev_sigs: [], }; + const responseCoinIdxs: number[] = []; for (let i = 0; i < batchReq.planchets.length; i++) { try { const p = batchReq.planchets[i]; @@ -650,7 +651,7 @@ async function processPlanchetExchangeBatchRequest( await handleKycRequired(resp, i); // We still return blinded coins that we could actually withdraw. return { - coinIdxs, + coinIdxs: responseCoinIdxs, batchResp: responses, }; } @@ -659,12 +660,13 @@ async function processPlanchetExchangeBatchRequest( codecForWithdrawResponse(), ); responses.ev_sigs.push(r); + responseCoinIdxs.push(requestCoinIdxs[i]); } catch (e) { - await storeCoinError(e, coinIdxs[i]); + await storeCoinError(e, requestCoinIdxs[i]); } } return { - coinIdxs, + coinIdxs: responseCoinIdxs, batchResp: responses, }; } |