Kieran/snort
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: worker-relay: add logging to interface

Browse Source
This commit is contained in:
kieran 2024-12-21 13:41:55 +00:00
parent 201f194f02
commit 609361d40c
No known key found for this signature in database
GPG Key ID: DE71CEB3925BE941
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/worker-relay/src/interface.ts
View File

@ -1,4 +1,5 @@
import { EventMetadata, NostrEvent, OkResponse, ReqCommand, WorkerMessage, WorkerMessageCommand } from "./types"; import { debugLog, setLogging } from "./debug";
import { EventMetadata, NostrEvent, OkResponse, ReqCommand, WorkerMessage, WorkerMessageCommand, unixNowMs } from "./types";
import { v4 as uuid } from "uuid"; import { v4 as uuid } from "uuid";
export interface InitAargs { export interface InitAargs {
@ -92,6 +93,7 @@ export class WorkerRelayInterface {
} }
async debug(v: string) { async debug(v: string) {
setLogging(true);
return await this.#workerRpc<string, boolean>("debug", v); return await this.#workerRpc<string, boolean>("debug", v);
} }
@ -102,6 +104,7 @@ export class WorkerRelayInterface {
cmd, cmd,
args, args,
} as WorkerMessage<T>; } as WorkerMessage<T>;
const start = unixNowMs();
return await new Promise<R>((resolve, reject) => { return await new Promise<R>((resolve, reject) => {
this.#worker.postMessage(msg); this.#worker.postMessage(msg);
const t = setTimeout(() => { const t = setTimeout(() => {
@ -115,6 +118,7 @@ export class WorkerRelayInterface {
reject(cmdReply.args.error); reject(cmdReply.args.error);
return; return;
} }
debugLog("interface", `${cmd} took ${(unixNowMs() - start).toFixed(1)}ms`, args);
resolve(cmdReply.args); resolve(cmdReply.args);
}); });
}); });