From 0d31eaf9a7b0ff0742c99011f7c0bc8d99c5a4f3 Mon Sep 17 00:00:00 2001
From: Callum Macdonald <git@callum-macdonald.com>
Date: Sun, 11 Aug 2024 18:13:37 +0200
Subject: [PATCH] Subscribe to all events, skip duplicates.

---
 src/nostr/subscribe.ts | 20 +++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)

diff --git a/src/nostr/subscribe.ts b/src/nostr/subscribe.ts
index 3ddfcf4..08cd4c6 100644
--- a/src/nostr/subscribe.ts
+++ b/src/nostr/subscribe.ts
@@ -89,6 +89,7 @@ export const subscribe = async ({
     return;
   };
 
+  /*
   console.log("#6MgNzq Starting subscription", eventsFilter);
   // NOTE: This just handles events until the EOSE event. It does not maintain
   // an active subscription. So we do that below.
@@ -106,6 +107,7 @@ export const subscribe = async ({
   events.forEach(onNoteEvent);
 
   logStateToConsole();
+  */
 
   backgroundNoteEventsFetching(onNoteEvent);
 };
@@ -133,15 +135,27 @@ function fetchProfileFactory(pubKey) {
 }
 
 async function backgroundNoteEventsFetching(onEventReceived) {
+  const seenEventIdentifiers = new Set<string>();
+
   const relayPool = await _initRelays();
   const filter = {
     kinds: [MAP_NOTE_REPOST_KIND],
     "#L": ["open-location-code"],
-    since: Math.floor(Date.now() / 1000),
+    // since: Math.floor(Date.now() / 1000),
     authors: TRUSTED_VALIDATION_PUBKEYS,
   };
-  for await (const msg of relayPool.req([filter])) {
-    if (msg[0] === "EVENT") onEventReceived(msg[2] as Kind30398Event);
+  for await (const message of relayPool.req([filter])) {
+    const [messageType, subscriptionId, event] = message;
+    if (messageType === "EVENT") {
+      const eventAuthorPublicKey = getPublicKeyFromEvent({ event });
+      const eventDTag = getTagFirstValueFromEvent({ event, tag: "d" });
+      const eventIdentifier = `${eventAuthorPublicKey}.${eventDTag}`;
+      if (seenEventIdentifiers.has(eventIdentifier)) {
+        continue;
+      }
+      seenEventIdentifiers.add(eventIdentifier);
+      onEventReceived(event as Kind30398Event);
+    }
   }
 }