feat: auto-start Jetstream consumer from registered lexicons

Author: daviddao

cmd/hypergoat/main.go

@@ -459,8 +459,24 @@ func run() error {
 	// Start Jetstream consumer if collections are configured
 	var jsConsumer *jetstream.Consumer
 	jsCollections := os.Getenv("JETSTREAM_COLLECTIONS")
+
+	// If no env var, try to get collections from registered lexicons
+	var collections []string
 	if jsCollections != "" {
-		collections := jetstream.ParseCollections(jsCollections)
+		collections = jetstream.ParseCollections(jsCollections)
+	} else {
+		// Read from database lexicons
+		lexicons, err := lexiconsRepo.GetAll(ctx)
+		if err != nil {
+			slog.Warn("Failed to get lexicons for Jetstream", "error", err)
+		} else {
+			for _, lex := range lexicons {
+				collections = append(collections, lex.ID)
+			}
+		}
+	}
+
+	if len(collections) > 0 {
 		jsURL := os.Getenv("JETSTREAM_URL")
 		if jsURL == "" {
 			jsURL = jetstream.DefaultJetstreamURL
@@ -493,7 +509,7 @@ func run() error {
 			}
 		}()
 	} else {
-		slog.Info("Jetstream consumer disabled (set JETSTREAM_COLLECTIONS to enable)")
+		slog.Info("Jetstream consumer disabled (no collections - register lexicons or set JETSTREAM_COLLECTIONS)")
 	}
 
 	// Run backfill if enabled