aboutsummaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts')
-rw-r--r--packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts b/packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts
index 8568f0db8..85f9acddc 100644
--- a/packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts
+++ b/packages/taler-wallet-core/src/crypto/workers/cryptoDispatcher.ts
@@ -29,7 +29,7 @@ import { timer, performanceNow, TimerHandle } from "../../util/timer.js";
import { nullCrypto, TalerCryptoInterface } from "../cryptoImplementation.js";
import { CryptoWorker } from "./cryptoWorkerInterface.js";
-const logger = new Logger("cryptoApi.ts");
+const logger = new Logger("cryptoDispatcher.ts");
/**
* State of a crypto worker.
@@ -238,7 +238,7 @@ export class CryptoDispatcher {
}
handleWorkerMessage(ws: WorkerInfo, msg: any): void {
- const id = msg.data.id;
+ const id = msg.id;
if (typeof id !== "number") {
logger.error("rpc id must be number");
return;
@@ -256,12 +256,12 @@ export class CryptoDispatcher {
if (currentWorkItem.state === WorkItemState.Running) {
this.numBusy--;
currentWorkItem.state = WorkItemState.Finished;
- if (msg.data.type === "success") {
- currentWorkItem.resolve(msg.data.result);
- } else if (msg.data.type === "error") {
+ if (msg.type === "success") {
+ currentWorkItem.resolve(msg.result);
+ } else if (msg.type === "error") {
currentWorkItem.reject(
TalerError.fromDetail(TalerErrorCode.WALLET_CRYPTO_WORKER_ERROR, {
- innerError: msg.data.error,
+ innerError: msg.error,
}),
);
} else {