summaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts
diff options
context:
space:
mode:
authorSebastian <sebasjm@gmail.com>2023-01-09 08:33:41 -0300
committerSebastian <sebasjm@gmail.com>2023-01-09 08:33:41 -0300
commit14f3d1e06dda003d457f2b3531e197011a284244 (patch)
treeede108e65dba6188b1a7af8d16bd95b957a4c858 /packages/taler-wallet-core/src/crypto/workers/crypto-dispatcher.test.ts
parent417c07f3f4866918e1aaa6d42b7d5ec0ca59dd51 (diff)
downloadwallet-core-14f3d1e06dda003d457f2b3531e197011a284244.tar.gz
wallet-core-14f3d1e06dda003d457f2b3531e197011a284244.tar.bz2
wallet-core-14f3d1e06dda003d457f2b3531e197011a284244.zip
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.ts22
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, {});
});