Merge pull request #276 from strideynet/kev-jetstream-limit-wanted-co…

…llections Limit wanted collections on jetstream
strideynet · Nov 20, 2024 · 0c6bac0 · 0c6bac0
2 parents 14c01ac + 1db4dee
commit 0c6bac0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ingester/ingester.go b/ingester/ingester.go
@@ -89,6 +89,12 @@ func (fi *FirehoseIngester) Start(ctx context.Context) (err error) {
 
 	jsCfg := jsclient.DefaultClientConfig()
 	jsCfg.WebsocketURL = fi.jetstreamURL
+	jsCfg.WantedCollections = []string{
+		"app.bsky.actor.profile",
+		"app.bsky.feed.like",
+		"app.bsky.feed.post",
+		"app.bsky.graph.follow",
+	}
 
 	var activeCursor atomic.Int64
 	sched := jsparallel.NewScheduler(