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

chore: add worker-relay readme

Browse Source
This commit is contained in:
Kieran
2024-01-30 20:32:43 +00:00
parent a14a5fa96b
commit a7c0cf7397
3 changed files with 41 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
packages/worker-relay/src/worker.ts
View File

@ -3,15 +3,7 @@
import { InMemoryRelay } from "./memory-relay";
import { WorkQueueItem, barrierQueue, processWorkQueue } from "./queue";
import { SqliteRelay } from "./sqlite-relay";
import { NostrEvent, RelayHandler, ReqCommand, ReqFilter, WorkerMessage, eventMatchesFilter, unixNowMs } from "./types";
interface PortedFilter {
filters: Array<ReqFilter>;
port: MessagePort;
}
// Active open subscriptions awaiting new events
const ActiveSubscriptions = new Map<string, PortedFilter>();
import { NostrEvent, RelayHandler, ReqCommand, ReqFilter, WorkerMessage, unixNowMs } from "./types";
let relay: RelayHandler | undefined;
@ -77,23 +69,6 @@ globalThis.onmessage = async ev => {
} else {
relay = new InMemoryRelay();
}
relay.on("event", evs => {
for (const pf of ActiveSubscriptions.values()) {
const pfSend = [];
for (const ev of evs) {
for (const fx of pf.filters) {
if (eventMatchesFilter(ev, fx)) {
pfSend.push(ev);
continue;
}
}
}
if (pfSend.length > 0) {
pf.port.postMessage(pfSend);
}
}
});
await relay.init(msg.args as string);
reply(msg.id, true);
});