atproto_firehose

class atproto_firehose.AsyncFirehoseSubscribeLabelsClient(params: dict | Params | None = None, base_uri: str | None = 'wss://mod.bsky.app/xrpc')

Bases: _AsyncWebsocketClient

Async firehose subscribe labels client.

Parameters:

  • params – Parameters model.

  • base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.

class atproto_firehose.AsyncFirehoseSubscribeReposClient(params: dict | Params | None = None, base_uri: str | None = 'wss://bsky.network/xrpc')

Bases: _AsyncWebsocketClient

Async firehose subscribe repos client.

Parameters:

  • params – Parameters model.

  • base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.

class atproto_firehose.FirehoseSubscribeLabelsClient(params: dict | Params | None = None, base_uri: str | None = 'wss://mod.bsky.app/xrpc')

Bases: _WebsocketClient

Firehose subscribe labels client.

Parameters:

  • params – Parameters model.

  • base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.

class atproto_firehose.FirehoseSubscribeReposClient(params: dict | Params | None = None, base_uri: str | None = 'wss://bsky.network/xrpc')

Bases: _WebsocketClient

Firehose subscribe repos client.

Parameters:

  • params – Parameters model.

  • base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.

atproto_firehose.parse_subscribe_labels_message(message: MessageFrame) → Labels | Info

Parse Firehose labels message to the corresponding model.

Parameters:

message – Message frame.

Returns:

Corresponding message model.

Return type:

SubscribeLabelsMessage

atproto_firehose.parse_subscribe_repos_message(message: MessageFrame) → Commit | Handle | Migrate | Tombstone | Info | Identity

Parse Firehose repositories message to the corresponding model.

Note

Use decode_inner_cbor only when required to increase performance.

Parameters:

message – Message frame.

Returns:

Corresponding message model.

Return type:

SubscribeReposMessage

Submodules