summaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/operations
diff options
context:
space:
mode:
authorFlorian Dold <florian@dold.me>2020-11-27 11:23:06 +0100
committerFlorian Dold <florian@dold.me>2020-11-27 11:23:06 +0100
commit0828e65f8845dc4b148c0d3b0697fb589b338239 (patch)
tree800245846e3b28a9dfe89c2893fd0a9bcf47847e /packages/taler-wallet-core/src/operations
parent4e481a51c64084db21d3eea513b13a7a3bd6603a (diff)
downloadwallet-core-0828e65f8845dc4b148c0d3b0697fb589b338239.tar.gz
wallet-core-0828e65f8845dc4b148c0d3b0697fb589b338239.tar.bz2
wallet-core-0828e65f8845dc4b148c0d3b0697fb589b338239.zip
fix static types
Diffstat (limited to 'packages/taler-wallet-core/src/operations')
-rw-r--r--packages/taler-wallet-core/src/operations/balance.ts8
-rw-r--r--packages/taler-wallet-core/src/operations/pending.ts18
-rw-r--r--packages/taler-wallet-core/src/operations/recoup.ts6
-rw-r--r--packages/taler-wallet-core/src/operations/refresh.ts10
-rw-r--r--packages/taler-wallet-core/src/operations/refund.ts6
-rw-r--r--packages/taler-wallet-core/src/operations/reserves.ts11
6 files changed, 36 insertions, 23 deletions
diff --git a/packages/taler-wallet-core/src/operations/balance.ts b/packages/taler-wallet-core/src/operations/balance.ts
index 91c5e639e..b82e4c9d1 100644
--- a/packages/taler-wallet-core/src/operations/balance.ts
+++ b/packages/taler-wallet-core/src/operations/balance.ts
@@ -38,7 +38,13 @@ interface WalletBalance {
*/
export async function getBalancesInsideTransaction(
ws: InternalWalletState,
- tx: TransactionHandle,
+ tx: TransactionHandle<
+ | typeof Stores.reserves
+ | typeof Stores.coins
+ | typeof Stores.reserves
+ | typeof Stores.refreshGroups
+ | typeof Stores.withdrawalGroups
+ >,
): Promise<BalancesResponse> {
const balanceStore: Record<string, WalletBalance> = {};
diff --git a/packages/taler-wallet-core/src/operations/pending.ts b/packages/taler-wallet-core/src/operations/pending.ts
index 4f6477d50..a42d89c9a 100644
--- a/packages/taler-wallet-core/src/operations/pending.ts
+++ b/packages/taler-wallet-core/src/operations/pending.ts
@@ -37,7 +37,7 @@ import {
getDurationRemaining,
durationMin,
} from "../util/time";
-import { TransactionHandle } from "../util/query";
+import { Store, TransactionHandle } from "../util/query";
import { InternalWalletState } from "./state";
import { getBalancesInsideTransaction } from "./balance";
@@ -52,7 +52,7 @@ function updateRetryDelay(
}
async function gatherExchangePending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.exchanges>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -171,7 +171,7 @@ async function gatherExchangePending(
}
async function gatherReservePending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.reserves>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -226,7 +226,7 @@ async function gatherReservePending(
}
async function gatherRefreshPending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.refreshGroups>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -255,7 +255,7 @@ async function gatherRefreshPending(
}
async function gatherWithdrawalPending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.withdrawalGroups>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -295,7 +295,7 @@ async function gatherWithdrawalPending(
}
async function gatherProposalPending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.proposals>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -346,7 +346,7 @@ async function gatherProposalPending(
}
async function gatherTipPending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.tips>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -376,7 +376,7 @@ async function gatherTipPending(
}
async function gatherPurchasePending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.purchases>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
@@ -419,7 +419,7 @@ async function gatherPurchasePending(
}
async function gatherRecoupPending(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.recoupGroups>,
now: Timestamp,
resp: PendingOperationsResponse,
onlyDue = false,
diff --git a/packages/taler-wallet-core/src/operations/recoup.ts b/packages/taler-wallet-core/src/operations/recoup.ts
index 634869ece..585c91a09 100644
--- a/packages/taler-wallet-core/src/operations/recoup.ts
+++ b/packages/taler-wallet-core/src/operations/recoup.ts
@@ -46,7 +46,7 @@ import {
import { Amounts } from "../util/amounts";
import { createRefreshGroup, processRefreshGroup } from "./refresh";
import { RefreshReason, TalerErrorDetails } from "../types/walletTypes";
-import { TransactionHandle } from "../util/query";
+import { Store, StoreParams, TransactionHandle } from "../util/query";
import { encodeCrock, getRandomBytes } from "../crypto/talerCrypto";
import { getTimestampNow } from "../util/time";
import { guardOperationException } from "./errors";
@@ -82,7 +82,7 @@ async function incrementRecoupRetry(
async function putGroupAsFinished(
ws: InternalWalletState,
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.recoupGroups>,
recoupGroup: RecoupGroupRecord,
coinIdx: number,
): Promise<void> {
@@ -366,7 +366,7 @@ async function processRecoupGroupImpl(
export async function createRecoupGroup(
ws: InternalWalletState,
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.recoupGroups | typeof Stores.coins>,
coinPubs: string[],
): Promise<string> {
const recoupGroupId = encodeCrock(getRandomBytes(32));
diff --git a/packages/taler-wallet-core/src/operations/refresh.ts b/packages/taler-wallet-core/src/operations/refresh.ts
index c92ce9209..21c884d48 100644
--- a/packages/taler-wallet-core/src/operations/refresh.ts
+++ b/packages/taler-wallet-core/src/operations/refresh.ts
@@ -52,9 +52,7 @@ import {
durationMax,
durationMul,
} from "../util/time";
-import {
- readSuccessResponseJsonOrThrow,
-} from "../util/http";
+import { readSuccessResponseJsonOrThrow } from "../util/http";
import {
codecForExchangeMeltResponse,
codecForExchangeRevealResponse,
@@ -567,7 +565,11 @@ async function processRefreshSession(
*/
export async function createRefreshGroup(
ws: InternalWalletState,
- tx: TransactionHandle,
+ tx: TransactionHandle<
+ | typeof Stores.denominations
+ | typeof Stores.coins
+ | typeof Stores.refreshGroups
+ >,
oldCoinPubs: CoinPublicKey[],
reason: RefreshReason,
): Promise<RefreshGroupId> {
diff --git a/packages/taler-wallet-core/src/operations/refund.ts b/packages/taler-wallet-core/src/operations/refund.ts
index 49d03ea15..e0d060376 100644
--- a/packages/taler-wallet-core/src/operations/refund.ts
+++ b/packages/taler-wallet-core/src/operations/refund.ts
@@ -103,7 +103,7 @@ function getRefundKey(d: MerchantCoinRefundStatus): string {
}
async function applySuccessfulRefund(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.coins | typeof Stores.denominations>,
p: PurchaseRecord,
refreshCoinsMap: Record<string, { coinPub: string }>,
r: MerchantCoinRefundSuccessStatus,
@@ -162,7 +162,7 @@ async function applySuccessfulRefund(
}
async function storePendingRefund(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.denominations | typeof Stores.coins>,
p: PurchaseRecord,
r: MerchantCoinRefundFailureStatus,
): Promise<void> {
@@ -212,7 +212,7 @@ async function storePendingRefund(
}
async function storeFailedRefund(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.coins | typeof Stores.denominations>,
p: PurchaseRecord,
refreshCoinsMap: Record<string, { coinPub: string }>,
r: MerchantCoinRefundFailureStatus,
diff --git a/packages/taler-wallet-core/src/operations/reserves.ts b/packages/taler-wallet-core/src/operations/reserves.ts
index b20570e09..a2a1b3018 100644
--- a/packages/taler-wallet-core/src/operations/reserves.ts
+++ b/packages/taler-wallet-core/src/operations/reserves.ts
@@ -81,7 +81,11 @@ import {
} from "../util/http";
import { codecForAny } from "../util/codec";
import { URL } from "../util/url";
-import { initRetryInfo, getRetryDuration, updateRetryInfoTimeout } from "../util/retries";
+import {
+ initRetryInfo,
+ getRetryDuration,
+ updateRetryInfoTimeout,
+} from "../util/retries";
const logger = new Logger("reserves.ts");
@@ -523,7 +527,8 @@ async function updateReserve(
if (result.isError) {
if (
resp.status === 404 &&
- result.talerErrorResponse.code === TalerErrorCode.EXCHANGE_RESERVES_GET_STATUS_UNKNOWN
+ result.talerErrorResponse.code ===
+ TalerErrorCode.EXCHANGE_RESERVES_GET_STATUS_UNKNOWN
) {
ws.notify({
type: NotificationType.ReserveNotYetFound,
@@ -863,7 +868,7 @@ export async function createTalerWithdrawReserve(
* Get payto URIs needed to fund a reserve.
*/
export async function getFundingPaytoUris(
- tx: TransactionHandle,
+ tx: TransactionHandle<typeof Stores.reserves | typeof Stores.exchanges>,
reservePub: string,
): Promise<string[]> {
const r = await tx.get(Stores.reserves, reservePub);