From ac8f116780a860c8f4acfdf5553bf90d76afe236 Mon Sep 17 00:00:00 2001 From: Florian Dold Date: Tue, 9 Aug 2022 15:00:45 +0200 Subject: implement peer to peer push payments --- .../taler-wallet-core/src/operations/pending.ts | 40 ---------------------- 1 file changed, 40 deletions(-) (limited to 'packages/taler-wallet-core/src/operations/pending.ts') 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 { - 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); -- cgit v1.2.3