diff options
author | Florian Dold <florian@dold.me> | 2022-08-09 15:00:45 +0200 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2022-08-16 17:55:12 +0200 |
commit | ac8f116780a860c8f4acfdf5553bf90d76afe236 (patch) | |
tree | 38abecb5ad3a3660161909ee9ca229d4ce08eb4a /packages/taler-wallet-core/src/operations/pending.ts | |
parent | fb8372dfbf27b7b4e8b2fe4f81aa2ba18bfcf638 (diff) | |
download | wallet-core-ac8f116780a860c8f4acfdf5553bf90d76afe236.tar.gz wallet-core-ac8f116780a860c8f4acfdf5553bf90d76afe236.tar.bz2 wallet-core-ac8f116780a860c8f4acfdf5553bf90d76afe236.zip |
implement peer to peer push payments
Diffstat (limited to 'packages/taler-wallet-core/src/operations/pending.ts')
-rw-r--r-- | packages/taler-wallet-core/src/operations/pending.ts | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/packages/taler-wallet-core/src/operations/pending.ts b/packages/taler-wallet-core/src/operations/pending.ts index 0a262d3bb..ae93711f9 100644 --- a/packages/taler-wallet-core/src/operations/pending.ts +++ b/packages/taler-wallet-core/src/operations/pending.ts @@ -70,44 +70,6 @@ async function gatherExchangePending( }); } -async function gatherReservePending( - tx: GetReadOnlyAccess<{ reserves: typeof WalletStoresV1.reserves }>, - now: AbsoluteTime, - resp: PendingOperationsResponse, -): Promise<void> { - const reserves = await tx.reserves.indexes.byStatus.getAll( - OperationStatus.Pending, - ); - for (const reserve of reserves) { - const reserveType = reserve.bankInfo - ? ReserveType.TalerBankWithdraw - : ReserveType.Manual; - switch (reserve.reserveStatus) { - case ReserveRecordStatus.Dormant: - // nothing to report as pending - break; - case ReserveRecordStatus.WaitConfirmBank: - case ReserveRecordStatus.QueryingStatus: - case ReserveRecordStatus.RegisteringBank: { - resp.pendingOperations.push({ - type: PendingTaskType.Reserve, - givesLifeness: true, - timestampDue: reserve.retryInfo?.nextRetry ?? AbsoluteTime.now(), - stage: reserve.reserveStatus, - timestampCreated: reserve.timestampCreated, - reserveType, - reservePub: reserve.reservePub, - retryInfo: reserve.retryInfo, - }); - break; - } - default: - // FIXME: report problem! - break; - } - } -} - async function gatherRefreshPending( tx: GetReadOnlyAccess<{ refreshGroups: typeof WalletStoresV1.refreshGroups }>, now: AbsoluteTime, @@ -336,7 +298,6 @@ export async function getPendingOperations( backupProviders: x.backupProviders, exchanges: x.exchanges, exchangeDetails: x.exchangeDetails, - reserves: x.reserves, refreshGroups: x.refreshGroups, coins: x.coins, withdrawalGroups: x.withdrawalGroups, @@ -352,7 +313,6 @@ export async function getPendingOperations( pendingOperations: [], }; await gatherExchangePending(tx, now, resp); - await gatherReservePending(tx, now, resp); await gatherRefreshPending(tx, now, resp); await gatherWithdrawalPending(tx, now, resp); await gatherProposalPending(tx, now, resp); |