diff options
author | Sebastian <sebasjm@gmail.com> | 2023-01-09 08:33:41 -0300 |
---|---|---|
committer | Sebastian <sebasjm@gmail.com> | 2023-01-09 08:33:41 -0300 |
commit | 14f3d1e06dda003d457f2b3531e197011a284244 (patch) | |
tree | ede108e65dba6188b1a7af8d16bd95b957a4c858 /packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts | |
parent | 417c07f3f4866918e1aaa6d42b7d5ec0ca59dd51 (diff) | |
download | wallet-core-14f3d1e06dda003d457f2b3531e197011a284244.tar.xz |
wallet-core pretty
Diffstat (limited to 'packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts')
-rw-r--r-- | packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts b/packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts index b63c9bf11..df2e645a7 100644 --- a/packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts +++ b/packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts @@ -16,11 +16,13 @@ import test from "ava"; import { CryptoDispatcher, CryptoWorkerFactory } from "./crypto-dispatcher.js"; -import { CryptoWorker, CryptoWorkerResponseMessage } from "./cryptoWorkerInterface.js"; +import { + CryptoWorker, + CryptoWorkerResponseMessage, +} from "./cryptoWorkerInterface.js"; import { SynchronousCryptoWorkerFactoryNode } from "./synchronousWorkerFactoryNode.js"; import { processRequestWithImpl } from "./worker-common.js"; - export class MyCryptoWorker implements CryptoWorker { /** * Function to be called when we receive a message from the worker thread. @@ -64,8 +66,8 @@ export class MyCryptoWorker implements CryptoWorker { type: "success", result: { testResult: 42, - } - } + }, + }; } else if (msg.operation === "testError") { responseMsg = { id: msg.id, @@ -73,8 +75,8 @@ export class MyCryptoWorker implements CryptoWorker { error: { code: 42, hint: "bla", - } - } + }, + }; } else if (msg.operation === "testTimeout") { // Don't respond return; @@ -98,8 +100,6 @@ export class MyCryptoWorker implements CryptoWorker { } } - - export class MyCryptoWorkerFactory implements CryptoWorkerFactory { startWorker(): CryptoWorker { return new MyCryptoWorker(); @@ -111,12 +111,10 @@ export class MyCryptoWorkerFactory implements CryptoWorkerFactory { } test("continues after error", async (t) => { - const cryptoDisp = new CryptoDispatcher( - new MyCryptoWorkerFactory(), - ); + const cryptoDisp = new CryptoDispatcher(new MyCryptoWorkerFactory()); const resp1 = await cryptoDisp.doRpc("testSuccess", 0, {}); t.assert((resp1 as any).testResult === 42); - const exc = await t.throwsAsync(async() => { + const exc = await t.throwsAsync(async () => { const resp2 = await cryptoDisp.doRpc("testError", 0, {}); }); |