From 3462df8e6a4b4b59c3c41ebbcf70906dc99de58e Mon Sep 17 00:00:00 2001
From: Siddharth Singh <me@shantaram.xyz>
Date: Thu, 8 May 2025 12:45:57 +0530
Subject: [PATCH] close deno kv on policy worker close

---
 packages/ditto/workers/policy.worker.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/packages/ditto/workers/policy.worker.ts b/packages/ditto/workers/policy.worker.ts
index 8df16b45..a6065d0b 100644
--- a/packages/ditto/workers/policy.worker.ts
+++ b/packages/ditto/workers/policy.worker.ts
@@ -23,6 +23,7 @@ interface PolicyInit {
 
 export class CustomPolicy implements NPolicy {
   private policy: NPolicy = new ReadOnlyPolicy();
+  registryKv: Deno.Kv | undefined;
 
   // deno-lint-ignore require-await
   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
       .query([{ kinds: [11984], authors: [await conf.signer.getPublicKey()] }])
       .then((results) => results[0]);
@@ -87,6 +89,7 @@ export class CustomPolicy implements NPolicy {
   }
 
   close() {
+    this.registryKv?.close();
     self.close();
   }
 }