Skip to content

Conversation

@aronchick
Copy link

Summary

  • Add new bluesky_jetstream input component for streaming AT Protocol events
  • Connects to Bluesky Jetstream WebSocket service for real-time firehose data
  • Supports filtering by collections and DIDs, zstd compression, cursor-based resumption

Features

  • WebSocket-based streaming from Jetstream public endpoints
  • Support for custom PDS endpoints
  • Collection and DID filtering (up to 100 collections, 10,000 DIDs)
  • zstd compression support for reduced bandwidth
  • Cursor-based resumption via cache resource
  • Automatic endpoint failover
  • Configurable ping/pong keepalive

Event Types

  • commit: Repository changes (posts, likes, follows, blocks, etc.)
  • identity: Handle and identity changes
  • account: Account status changes

Test plan

  • Unit tests pass locally (9 tests)
  • Build succeeds
  • CI validation

🤖 Generated with Claude Code

aronchick and others added 2 commits December 28, 2025 15:03
Add a new input component that connects to Bluesky's Jetstream service
to consume real-time events from the AT Protocol network.

Features:
- WebSocket-based streaming from Jetstream public endpoints
- Support for custom PDS endpoints
- Collection and DID filtering
- zstd compression support for reduced bandwidth
- Cursor-based resumption via cache resource
- Automatic endpoint failover
- Configurable ping/pong keepalive

Event types supported:
- commit: Repository changes (posts, likes, follows, blocks, etc.)
- identity: Handle and identity changes
- account: Account status changes

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
@CLAassistant
Copy link

CLAassistant commented Dec 28, 2025

CLA assistant check
All committers have signed the CLA.

@CLAassistant
Copy link

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.

@aronchick aronchick marked this pull request as ready for review December 28, 2025 23:39
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

2 participants