Add workaround to stop saving duplicate events

Author: dtonon

archive.go

@@ -77,7 +77,7 @@ func archiveEvent(ctx context.Context, relay *khatru.Relay, event nostr.Event) {
 	if acceptedEvent(event) {
 		addEventToRootList(event)
 		fetchQuotedEvents(event)
-		wdb.Publish(ctx, event)
+		saveEvent(ctx, event)
 		relay.BroadcastEvent(&event)
 		trustedNotes++
 	} else {

main.go

@@ -340,7 +340,7 @@ func fetchConversation(event nostr.Event) {
 		}
 
 		for ev := range pool.SubMany(timeout, append([]string{eventRelay}, seedRelays...), filters) {
-			wdb.Publish(ctx, *ev.Event)
+			saveEvent(ctx, *ev.Event)
 			go fetchQuotedEvents(*ev.Event)
 		}
 	}()
@@ -384,7 +384,7 @@ func fetchQuotedEvents(event nostr.Event) {
 		}
 
 		for ev := range pool.SubManyEose(timeout, append(quoteRelays, seedRelays...), filters) {
-			wdb.Publish(ctx, *ev.Event)
+			saveEvent(ctx, *ev.Event)
 		}
 	}()
 
@@ -443,3 +443,16 @@ func addEventToRootList(event nostr.Event) {
 	}
 	rootNotesList.Add(rootReferenceValue)
 }
+
+func saveEvent(ctx context.Context, event nostr.Event) bool {
+	filter := nostr.Filter{IDs: []string{event.ID}}
+	eventChan, err := wdb.QueryEvents(ctx, filter)
+	if err != nil {
+		return false
+	}
+	for range eventChan {
+		return true
+	}
+	wdb.Publish(ctx, event)
+	return true
+}

wot.go

@@ -48,7 +48,7 @@ func refreshProfiles(ctx context.Context) {
 		}}
 
 		for ev := range pool.SubManyEose(timeout, seedRelays, filters) {
-			wdb.Publish(ctx, *ev.Event)
+			relay.AddEvent(ctx, ev.Event)
 		}
 	}
 	log.Println("👤 WoT: profiles refreshed: ", len(trustNetwork))
@@ -98,7 +98,7 @@ func refreshTrustNetwork(ctx context.Context, relay *khatru.Relay) {
 			}
 
 			if ev.Event.Kind == nostr.KindProfileMetadata {
-				wdb.Publish(ctx, *ev.Event)
+				relay.AddEvent(ctx, ev.Event)
 			}
 		}
 	}