diff options
Diffstat (limited to 'packages/taler-wallet-core/src/util')
| -rw-r--r-- | packages/taler-wallet-core/src/util/asyncMemo.ts | 87 | ||||
| -rw-r--r-- | packages/taler-wallet-core/src/util/retries.ts | 52 | 
2 files changed, 0 insertions, 139 deletions
diff --git a/packages/taler-wallet-core/src/util/asyncMemo.ts b/packages/taler-wallet-core/src/util/asyncMemo.ts deleted file mode 100644 index 6e88081b6..000000000 --- a/packages/taler-wallet-core/src/util/asyncMemo.ts +++ /dev/null @@ -1,87 +0,0 @@ -/* - This file is part of GNU Taler - (C) 2019 GNUnet e.V. - - GNU Taler is free software; you can redistribute it and/or modify it under the - terms of the GNU General Public License as published by the Free Software - Foundation; either version 3, or (at your option) any later version. - - GNU Taler is distributed in the hope that it will be useful, but WITHOUT ANY - WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR - A PARTICULAR PURPOSE.  See the GNU General Public License for more details. - - You should have received a copy of the GNU General Public License along with - GNU Taler; see the file COPYING.  If not, see <http://www.gnu.org/licenses/> - */ - -interface MemoEntry<T> { -  p: Promise<T>; -  t: number; -  n: number; -} - -export class AsyncOpMemoMap<T> { -  private n = 0; -  private memoMap: { [k: string]: MemoEntry<T> } = {}; - -  private cleanUp(key: string, n: number): void { -    const r = this.memoMap[key]; -    if (r && r.n === n) { -      delete this.memoMap[key]; -    } -  } - -  memo(key: string, pg: () => Promise<T>): Promise<T> { -    const res = this.memoMap[key]; -    if (res) { -      return res.p; -    } -    const n = this.n++; -    // Wrap the operation in case it immediately throws -    const p = Promise.resolve().then(() => pg()); -    this.memoMap[key] = { -      p, -      n, -      t: new Date().getTime(), -    }; -    return p.finally(() => { -      this.cleanUp(key, n); -    }); -  } -  clear(): void { -    this.memoMap = {}; -  } -} - -export class AsyncOpMemoSingle<T> { -  private n = 0; -  private memoEntry: MemoEntry<T> | undefined; - -  private cleanUp(n: number): void { -    if (this.memoEntry && this.memoEntry.n === n) { -      this.memoEntry = undefined; -    } -  } - -  memo(pg: () => Promise<T>): Promise<T> { -    const res = this.memoEntry; -    if (res) { -      return res.p; -    } -    const n = this.n++; -    // Wrap the operation in case it immediately throws -    const p = Promise.resolve().then(() => pg()); -    p.finally(() => { -      this.cleanUp(n); -    }); -    this.memoEntry = { -      p, -      n, -      t: new Date().getTime(), -    }; -    return p; -  } -  clear(): void { -    this.memoEntry = undefined; -  } -} diff --git a/packages/taler-wallet-core/src/util/retries.ts b/packages/taler-wallet-core/src/util/retries.ts deleted file mode 100644 index e602d4702..000000000 --- a/packages/taler-wallet-core/src/util/retries.ts +++ /dev/null @@ -1,52 +0,0 @@ -/* - This file is part of GNU Taler - (C) 2020 Taler Systems S.A. - - GNU Taler is free software; you can redistribute it and/or modify it under the - terms of the GNU General Public License as published by the Free Software - Foundation; either version 3, or (at your option) any later version. - - GNU Taler is distributed in the hope that it will be useful, but WITHOUT ANY - WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR - A PARTICULAR PURPOSE.  See the GNU General Public License for more details. - - You should have received a copy of the GNU General Public License along with - GNU Taler; see the file COPYING.  If not, see <http://www.gnu.org/licenses/> - */ - -/** - * Helpers for dealing with retry timeouts. - */ - -/** - * Imports. - */ -import { -  AbsoluteTime, -  Duration, -  Logger, -  TalerErrorDetail, -} from "@gnu-taler/taler-util"; -import { -  BackupProviderRecord, -  DepositGroupRecord, -  ExchangeRecord, -  PeerPullPaymentIncomingRecord, -  PeerPullPaymentInitiationRecord, -  PeerPushPaymentIncomingRecord, -  PeerPushPaymentInitiationRecord, -  PurchaseRecord, -  RecoupGroupRecord, -  RefreshGroupRecord, -  TipRecord, -  WalletStoresV1, -  WithdrawalGroupRecord, -} from "../db.js"; -import { TalerError } from "@gnu-taler/taler-util"; -import { InternalWalletState } from "../internal-wallet-state.js"; -import { PendingTaskType, TaskId } from "../pending-types.js"; -import { GetReadWriteAccess } from "./query.js"; -import { assertUnreachable } from "./assertUnreachable.js"; - -const logger = new Logger("util/retries.ts"); -  | 
