bretton.dev / coves
A community based topic aggregation platform built on atproto
fork atom

refactor: update Jetstream consumer config for new namespace

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 <noreply@anthropic.com>

bretton.dev 8a168984 a12bc12e

options
unified split
Changed files
+2 -2
cmd
server
main.go
+2 -2
cmd/server/main.go 
···

       
404

       
 

       
	commentJetstreamURL := os.Getenv("COMMENT_JETSTREAM_URL")


     

       
405

       
 

       
	if commentJetstreamURL == "" {


     

       
406

       
 

       
		// Listen to comment record CREATE/UPDATE/DELETE events from user repositories


     

       
407

       
-

       
		commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.feed.comment"


     

       
408

       
 

       
	}


     

       
409

       
 

       



     

       
410

       
 

       
	commentEventConsumer := jetstream.NewCommentEventConsumer(commentRepo, db)


     
···

       
417

       
 

       
	}()


     

       
418

       
 

       



     

       
419

       
 

       
	log.Printf("Started Jetstream comment consumer: %s", commentJetstreamURL)


     

       
420

       
-

       
	log.Println("  - Indexing: social.coves.feed.comment CREATE/UPDATE/DELETE operations")


     

       
421

       
 

       
	log.Println("  - Updating: Post comment counts and comment reply counts atomically")


     

       
422

       
 

       



     

       
423

       
 

       
	// Register XRPC routes


     
···

       
404

       
 

       
	commentJetstreamURL := os.Getenv("COMMENT_JETSTREAM_URL")


     

       
405

       
 

       
	if commentJetstreamURL == "" {


     

       
406

       
 

       
		// Listen to comment record CREATE/UPDATE/DELETE events from user repositories


     

       
407

       
+

       
		commentJetstreamURL = "ws://localhost:6008/subscribe?wantedCollections=social.coves.community.comment"


     

       
408

       
 

       
	}


     

       
409

       
 

       



     

       
410

       
 

       
	commentEventConsumer := jetstream.NewCommentEventConsumer(commentRepo, db)


     
···

       
417

       
 

       
	}()


     

       
418

       
 

       



     

       
419

       
 

       
	log.Printf("Started Jetstream comment consumer: %s", commentJetstreamURL)


     

       
420

       
+

       
	log.Println("  - Indexing: social.coves.community.comment CREATE/UPDATE/DELETE operations")


     

       
421

       
 

       
	log.Println("  - Updating: Post comment counts and comment reply counts atomically")


     

       
422

       
 

       



     

       
423

       
 

       
	// Register XRPC routes