diff options
author | Florian Dold <florian@dold.me> | 2021-02-08 13:02:12 +0100 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2021-02-08 13:02:55 +0100 |
commit | 883637d3f287e5026de5bcafb559ff3e6ba1f3bb (patch) | |
tree | cac64b97186a18c071c3e51e2ae74e74802d8235 /packages/taler-wallet-cli/src/integrationtests/faultInjection.ts | |
parent | 48fa2ccea16e1d0e11d5ac93049bc33df8d47119 (diff) |
allow fault injection callbacks to run async code
Diffstat (limited to 'packages/taler-wallet-cli/src/integrationtests/faultInjection.ts')
-rw-r--r-- | packages/taler-wallet-cli/src/integrationtests/faultInjection.ts | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/packages/taler-wallet-cli/src/integrationtests/faultInjection.ts b/packages/taler-wallet-cli/src/integrationtests/faultInjection.ts index a2d4836d9..60549154b 100644 --- a/packages/taler-wallet-cli/src/integrationtests/faultInjection.ts +++ b/packages/taler-wallet-cli/src/integrationtests/faultInjection.ts @@ -28,17 +28,10 @@ import { URL } from "url"; import { GlobalTestState, ExchangeService, - BankService, ExchangeServiceInterface, MerchantServiceInterface, MerchantService, - PrivateOrderStatusQuery, } from "./harness"; -import { - PostOrderRequest, - PostOrderResponse, - MerchantOrderPrivateStatusResponse, -} from "./merchantApiTypes"; export interface FaultProxyConfig { inboundPort: number; @@ -65,8 +58,8 @@ export interface FaultInjectionResponseContext { } export interface FaultSpec { - modifyRequest?: (ctx: FaultInjectionRequestContext) => void; - modifyResponse?: (ctx: FaultInjectionResponseContext) => void; + modifyRequest?: (ctx: FaultInjectionRequestContext) => Promise<void>; + modifyResponse?: (ctx: FaultInjectionResponseContext) => Promise<void>; } export class FaultProxy { @@ -85,7 +78,7 @@ export class FaultProxy { req.on("data", (chunk) => { requestChunks.push(chunk); }); - req.on("end", () => { + req.on("end", async () => { console.log("end of data"); let requestBuffer: Buffer | undefined; if (requestChunks.length > 0) { @@ -103,7 +96,7 @@ export class FaultProxy { for (const faultSpec of this.currentFaultSpecs) { if (faultSpec.modifyRequest) { - faultSpec.modifyRequest(faultReqContext); + await faultSpec.modifyRequest(faultReqContext); } } @@ -138,7 +131,7 @@ export class FaultProxy { proxyResp.on("data", (proxyRespData) => { respChunks.push(proxyRespData); }); - proxyResp.on("end", () => { + proxyResp.on("end", async () => { console.log("end of target response"); let responseBuffer: Buffer | undefined; if (respChunks.length > 0) { @@ -154,7 +147,7 @@ export class FaultProxy { for (const faultSpec of this.currentFaultSpecs) { const modResponse = faultSpec.modifyResponse; if (modResponse) { - modResponse(faultRespContext); + await modResponse(faultRespContext); } } if (faultRespContext.dropResponse) { |