From ec5a9a3162a2cdcf0e1d24785fe8e5be8e99a95d Mon Sep 17 00:00:00 2001
From: pippellia-btc <pippellia@gmail.com>
Date: Tue, 22 Jul 2025 11:01:22 +0200
Subject: [PATCH] added limit to fetcher DB

---
 pkg/pipe/intake.go | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/pkg/pipe/intake.go b/pkg/pipe/intake.go
index 5c27429..cca8b3b 100644
--- a/pkg/pipe/intake.go
+++ b/pkg/pipe/intake.go
@@ -282,7 +282,13 @@ func FetcherDB(
 				continue
 			}
 
-			events, err := store.Query(ctx, nostr.Filter{Kinds: Kinds, Authors: batch})
+			filter := nostr.Filter{
+				Kinds:   Kinds,
+				Authors: batch,
+				Limit:   len(Kinds) * len(batch),
+			}
+
+			events, err := store.Query(ctx, filter)
 			if err != nil {
 				log.Printf("FetcherDB: %v", err)
 			}
@@ -301,7 +307,13 @@ func FetcherDB(
 				continue
 			}
 
-			events, err := store.Query(ctx, nostr.Filter{Kinds: Kinds, Authors: batch})
+			filter := nostr.Filter{
+				Kinds:   Kinds,
+				Authors: batch,
+				Limit:   len(Kinds) * len(batch),
+			}
+
+			events, err := store.Query(ctx, filter)
 			if err != nil {
 				log.Printf("FetcherDB: %v", err)
 			}