diff options
author | Florian Dold <florian.dold@gmail.com> | 2019-12-19 20:42:49 +0100 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2019-12-19 20:42:49 +0100 |
commit | 0c9358c1b2bd80e25940022e86bd8daef8184ad7 (patch) | |
tree | a8c8ca0134bd886d8151633aff4c85e9513ad32c /src/operations/reserves.ts | |
parent | 49e3b3e5b9bbf1ce356ef68f301d50c689ceecb9 (diff) | |
download | wallet-core-0c9358c1b2bd80e25940022e86bd8daef8184ad7.tar.xz |
new date format, replace checkable annotations with codecs
Diffstat (limited to 'src/operations/reserves.ts')
-rw-r--r-- | src/operations/reserves.ts | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/operations/reserves.ts b/src/operations/reserves.ts index 7be927824..2dedf17de 100644 --- a/src/operations/reserves.ts +++ b/src/operations/reserves.ts @@ -17,7 +17,6 @@ import { CreateReserveRequest, CreateReserveResponse, - getTimestampNow, ConfirmReserveRequest, OperationError, AcceptWithdrawalResponse, @@ -42,7 +41,7 @@ import { getExchangeTrust, getExchangePaytoUri, } from "./exchanges"; -import { WithdrawOperationStatusResponse } from "../types/talerTypes"; +import { WithdrawOperationStatusResponse, codecForWithdrawOperationStatusResponse } from "../types/talerTypes"; import { assertUnreachable } from "../util/assertUnreachable"; import { encodeCrock, getRandomBytes } from "../crypto/talerCrypto"; import { randomBytes } from "../crypto/primitives/nacl-fast"; @@ -57,6 +56,7 @@ import { } from "./errors"; import { NotificationType } from "../types/notifications"; import { codecForReserveStatus } from "../types/ReserveStatus"; +import { getTimestampNow } from "../util/time"; const logger = new Logger("reserves.ts"); @@ -289,7 +289,7 @@ async function processReserveBankStatusImpl( `unexpected status ${statusResp.status} for bank status query`, ); } - status = WithdrawOperationStatusResponse.checked(await statusResp.json()); + status = codecForWithdrawOperationStatusResponse().decode(await statusResp.json()); } catch (e) { throw e; } @@ -390,6 +390,7 @@ async function updateReserve( let resp; try { resp = await ws.http.get(reqUrl.href); + console.log("got reserve/status response", await resp.json()); if (resp.status === 404) { const m = "The exchange does not know about this reserve (yet)."; await incrementReserveRetry(ws, reservePub, undefined); @@ -408,7 +409,7 @@ async function updateReserve( throw new OperationFailedAndReportedError(m); } const respJson = await resp.json(); - const reserveInfo = codecForReserveStatus.decode(respJson); + const reserveInfo = codecForReserveStatus().decode(respJson); const balance = Amounts.parseOrThrow(reserveInfo.balance); await ws.db.runWithWriteTransaction( [Stores.reserves, Stores.reserveUpdatedEvents], |