feat: add INFO level logging for Jetstream events

Author: daviddao

internal/jetstream/consumer.go

@@ -135,8 +135,19 @@ func (c *Consumer) processEvents(ctx context.Context) {
 	for event := range c.client.Events() {
 		c.statsMu.Lock()
 		c.stats.EventsReceived++
+		eventCount := c.stats.EventsReceived
 		c.statsMu.Unlock()
 
+		// Log every event received (for debugging)
+		if event.IsCommit() {
+			slog.Info("[jetstream] Event received",
+				"collection", event.Commit.Collection,
+				"operation", event.Commit.Operation,
+				"did", event.DID,
+				"total_events", eventCount,
+			)
+		}
+
 		// Update cursor
 		c.cursorMu.Lock()
 		c.cursor = event.TimeUS
@@ -194,9 +205,9 @@ func (c *Consumer) handleCommit(ctx context.Context, event *Event) error {
 		}
 		c.pubsub.PublishRecord(eventType, uri, commit.CID, event.DID, commit.Collection, commit.Record)
 
-		slog.Debug("Stored record",
+		slog.Info("[jetstream] Stored record",
 			"uri", uri,
-			"cid", commit.CID,
+			"collection", commit.Collection,
 			"operation", commit.Operation,
 		)