1 files changed, 3 insertions, 27 deletions
diff --git a/main.go b/main.go
index dbc7bc8..63b1a4d 100644
--- a/main.go
+++ b/main.go
@@ -68,33 +68,9 @@ func main() {
 		log.Fatalf("failed to connect: %v", err)
 	}
 
-	// // Process events
-	// err = jc.ConnectAndRead(context.Background(), func(evt *parallel.StreamEvent) error {
-
-	// 	// Process specific event types
-	// 	switch collection {
-	// 	case "app.bsky.feed.post":
-	// 		var post bsky.FeedPost
-	// 		if err := json.Unmarshal(evt.Commit.Record, &post); err != nil {
-	// 			log.Printf("Error unmarshaling post: %v", err)
-	// 			return nil
-	// 		}
-	// 		log.Printf("Received post: %s", post.Text)
-	// 	case "app.bsky.feed.like":
-	// 		var like bsky.FeedLike
-	// 		if err := json.Unmarshal(evt.Commit.Record, &like); err != nil {
-	// 			log.Printf("Error unmarshaling like: %v", err)
-	// 			return nil
-	// 		}
-	// 		log.Printf("Received like for: %s", like.Subject.Uri)
-	// 	}
-
-	// 	return nil
-	// })
-
-	// if err != nil {
-	// 	log.Fatalf("Error reading from Jetstream: %v", err)
-	// }
+	if err != nil {
+		log.Fatalf("Error reading from Jetstream: %v", err)
+	}
 
 	// Keep the program running
 	select {}