diff options
| -rw-r--r-- | main.go | 30 |
1 files changed, 3 insertions, 27 deletions
@@ -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 {} |