mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 03:19:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

close deno kv on policy worker close

Browse source
This commit is contained in:
Siddharth Singh 2025-05-08 12:45:57 +05:30
parent b613334312
commit 3462df8e6a
No known key found for this signature in database
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
packages/ditto/workers/policy.worker.ts
View file

@ -23,6 +23,7 @@ interface PolicyInit {
export class CustomPolicy implements NPolicy { export class CustomPolicy implements NPolicy {
private policy: NPolicy = new ReadOnlyPolicy(); private policy: NPolicy = new ReadOnlyPolicy();
registryKv: Deno.Kv | undefined;
// deno-lint-ignore require-await // deno-lint-ignore require-await
async call(event: NostrEvent, signal?: AbortSignal): Promise<NostrRelayOK> { async call(event: NostrEvent, signal?: AbortSignal): Promise<NostrRelayOK> {
@ -62,7 +63,8 @@ export class CustomPolicy implements NPolicy {
}); });
} }
} }
const registry = new PolicyRegistry({ store, antiDuplicationPolicyStore: await Deno.openKv() }); this.registryKv = await Deno.openKv();
const registry = new PolicyRegistry({ store, antiDuplicationPolicyStore: this.registryKv });
const event = await store const event = await store
.query([{ kinds: [11984], authors: [await conf.signer.getPublicKey()] }]) .query([{ kinds: [11984], authors: [await conf.signer.getPublicKey()] }])
.then((results) => results[0]); .then((results) => results[0]);
@ -87,6 +89,7 @@ export class CustomPolicy implements NPolicy {
} }
close() { close() {
this.registryKv?.close();
self.close(); self.close();
} }
} }