From 8a168984b2d15bba3c102067fc968bdc436deb93 Mon Sep 17 00:00:00 2001 From: Bretton May Date: Sun, 16 Nov 2025 17:57:35 -0800 Subject: [PATCH] refactor: update Jetstream consumer config for new namespace MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Update Jetstream comment consumer configuration to subscribe to social.coves.community.comment collection instead of social.coves.feed.comment. Changes: - Update COMMENT_JETSTREAM_URL wantedCollections parameter - Update log message to reflect new collection name The consumer will now listen for CREATE/UPDATE/DELETE operations on the community.comment collection from the Jetstream firehose. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- cmd/server/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/server/main.go b/cmd/server/main.go index b7ddac6..0a5991d 100644 --- a/cmd/server/main.go +++ b/cmd/server/main.go @@ -404,7 +404,7 @@ func main() { commentJetstreamURL := os.Getenv("COMMENT_JETSTREAM_URL") if commentJetstreamURL == "" { // Listen to comment record CREATE/UPDATE/DELETE events from user repositories - commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.feed.comment" + commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.community.comment" } commentEventConsumer := jetstream.NewCommentEventConsumer(commentRepo, db) @@ -417,7 +417,7 @@ func main() { }() log.Printf("Started Jetstream comment consumer: %s", commentJetstreamURL) - log.Println(" - Indexing: social.coves.feed.comment CREATE/UPDATE/DELETE operations") + log.Println(" - Indexing: social.coves.community.comment CREATE/UPDATE/DELETE operations") log.Println(" - Updating: Post comment counts and comment reply counts atomically") // Register XRPC routes -- 2.51.2