Merge branch 'main' of https://git.v0l.io/Kieran/snort

packages/app/src/Cache/index.ts

@@ -9,7 +9,7 @@ import { ProfileCacheRelayWorker } from "./ProfileWorkerCache";
 import { UserFollowsWorker } from "./UserFollowsWorker";
 
 export const Relay = new WorkerRelayInterface(
-  import.meta.env.DEV ? new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url) : new WorkerVite()
+  import.meta.env.DEV ? new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url) : new WorkerVite(),
 );
 export async function initRelayWorker() {
   try {

packages/app/src/translations/de_DE.json

@@ -208,7 +208,7 @@
   "J+dIsA": "Abonnements",
   "J1iLmb": "Benachrichtigungen nicht erlaubt",
   "J2HeQ+": "Benutze Kommas um Wörter zu trennen, z.B. Wort1, Wort2, Wort3",
-  "JA+tz3": "Looking up thread...",
+  "JA+tz3": "Thread wird gesucht...",
   "JCIgkj": "Benutzername",
   "JGrt9q": "Sats an {name} senden",
   "JHEHCk": "Zaps ({n})",

packages/app/src/translations/hu_HU.json

@@ -208,7 +208,7 @@
   "J+dIsA": "Előfizetések",
   "J1iLmb": "Az értesítések nincsenek engedélyezve",
   "J2HeQ+": "Szavak elválasztása vesszőkkel, pl. word1, word2, word3.",
-  "JA+tz3": "Looking up thread...",
+  "JA+tz3": "Keresem a fonalat...",
   "JCIgkj": "Felhasználónév",
   "JGrt9q": "Sat-ok küldése {name}",
   "JHEHCk": "Zap-ek ({n})",

packages/app/vite.config.ts

@@ -54,6 +54,6 @@ export default defineConfig({
     global: {}, // needed for custom-event lib
   },
   worker: {
-    format: "es"
+    format: "es",
   },
 });

packages/system/src/nostr-system.ts

@@ -197,7 +197,7 @@ export class NostrSystem extends EventEmitter<NostrSystemEvents> implements Syst
     if (this.#config.cachingRelay) {
       this.on("event", async (_, ev) => {
         await this.#config.cachingRelay?.event(ev);
-      })
+      });
     }
 
     // Hook on-event when building follow graph

packages/worker-relay/README.md

@@ -12,12 +12,12 @@ Worker relay is a Nostr relay built on `sqlite-wasm`
 import { WorkerRelayInterface } from "@snort/worker-relay";
 
 // when using Vite import the worker script directly (for production)
-import WorkerVite from "@snort/worker-relay/src/worker?worker"
+import WorkerVite from "@snort/worker-relay/src/worker?worker";
 
 // in dev mode import esm module, i have no idea why it has to work like this
-const workerScript = import.meta.env.DEV ?
+const workerScript = import.meta.env.DEV
-    new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url) :
+  ? new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url)
-    new WorkerVite();
+  : new WorkerVite();
 
 const workerRelay = new WorkerRelayInterface(workerScript);
 
@@ -29,12 +29,12 @@ const results = await workerRelay.query(["REQ", "1", { kinds: [1], limit: 10 }])
 
 // publish a new event to the relay
 const myEvent = {
-    kind: 1,
+  kind: 1,
-    created_at: Math.floor(new Date().getTime() / 1000),
+  created_at: Math.floor(new Date().getTime() / 1000),
-    content: "test",
+  content: "test",
-    tags: []
+  tags: [],
 };
 if (await workerRelay.event(myEvent)) {
-    console.log("Success");
+  console.log("Success");
 }
 ```

packages/worker-relay/example/basic.ts

@@ -1,12 +1,12 @@
 import { WorkerRelayInterface } from "@snort/worker-relay";
 
 // when using Vite import the worker script directly (for production)
-import WorkerVite from "@snort/worker-relay/src/worker?worker"
+import WorkerVite from "@snort/worker-relay/src/worker?worker";
 
 // in dev mode import esm module, i have no idea why it has to work like this
-const workerScript = import.meta.env.DEV ?
+const workerScript = import.meta.env.DEV
-    new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url) :
+  ? new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url)
-    new WorkerVite();
+  : new WorkerVite();
 
 const workerRelay = new WorkerRelayInterface(workerScript);
 
@@ -18,11 +18,11 @@ const results = await workerRelay.query(["REQ", "1", { kinds: [1], limit: 10 }])
 
 // publish a new event to the relay
 const myEvent = {
-    kind: 1,
+  kind: 1,
-    created_at: Math.floor(new Date().getTime() / 1000),
+  created_at: Math.floor(new Date().getTime() / 1000),
-    content: "test",
+  content: "test",
-    tags: []
+  tags: [],
 };
 if (await workerRelay.event(myEvent)) {
-    console.log("Success");
+  console.log("Success");
-}
+}

packages/worker-relay/src/custom.d.ts

@@ -5,4 +5,4 @@ declare module "*.wasm" {
 declare module "*.wasm?url" {
   const value: string;
   export default value;
-}
+}

packages/worker-relay/src/debug.ts

@@ -1,10 +1,9 @@
-
 let debug = false;
 export function debugLog(scope: string, msg: string, ...args: Array<any>) {
-    if (!debug) return;
+  if (!debug) return;
-    console.log(scope, msg, ...args);
+  console.log(scope, msg, ...args);
 }
 
 export function setLogging(v: boolean) {
-    debug = v;
+  debug = v;
-}
+}

packages/worker-relay/src/index.ts

@@ -1 +1 @@
-export * from "./interface";
+export * from "./interface";

packages/worker-relay/src/interface.ts

@@ -17,14 +17,14 @@ export class WorkerRelayInterface {
       this.#worker = scriptPath;
     } else {
       const sp = scriptPath ? scriptPath : new URL("@snort/worker-relay/dist/esm/worker.mjs", import.meta.url);
-      this.#worker = new Worker(sp, { type: "module" })
+      this.#worker = new Worker(sp, { type: "module" });
-    };
+    }
     this.#worker.onerror = e => {
       console.error(e.message, e);
-    }
+    };
     this.#worker.onmessageerror = e => {
       console.error(e);
-    }
+    };
     this.#worker.onmessage = e => {
       const cmd = e.data as WorkerMessage<any>;
       if (cmd.cmd === "reply") {

packages/worker-relay/src/sqlite-relay.ts

@@ -26,7 +26,7 @@ export class SqliteRelay extends EventEmitter<RelayHandlerEvents> implements Rel
         return prefix + path;
       },
       print: msg => this.#log(msg),
-      printErr: msg => this.#log(msg)
+      printErr: msg => this.#log(msg),
     });
     this.#log(`Got SQLite version: ${this.#sqlite.version.libVersion}`);
     await this.#open(path);

packages/worker-relay/src/worker.ts

@@ -162,20 +162,20 @@ const handleMsg = async (port: MessagePort | DedicatedWorkerGlobalScope, ev: Mes
     } else if (typeof e === "string") {
       reply(msg.id, { error: e });
     } else {
-      reply(msg.id, "Unknown error")
+      reply(msg.id, "Unknown error");
     }
   }
-}
+};
 
 if ("SharedWorkerGlobalScope" in globalThis) {
-  onconnect = (e) => {
+  onconnect = e => {
     const port = e.ports[0];
-    port.onmessage = (msg) => handleMsg(port, msg);
+    port.onmessage = msg => handleMsg(port, msg);
     port.start();
-  }
+  };
 }
 if ("DedicatedWorkerGlobalScope" in globalThis) {
   onmessage = e => {
-    handleMsg(self as DedicatedWorkerGlobalScope, e)
+    handleMsg(self as DedicatedWorkerGlobalScope, e);
-  }
+  };
-}
+}