atproto_firehose

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

Bases: _AsyncWebsocketClient

Async firehose subscribe labels client.

Parameters:

  • params – Parameters model.

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

  • recv_timeout – Reconnect to the server after this many seconds of inactivity. Default is 300 seconds (5 minutes).

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

Bases: _AsyncWebsocketClient

Async firehose subscribe repos client.

Parameters:

  • params – Parameters model.

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

  • recv_timeout – Reconnect to the server after this many seconds of inactivity. Default is 30 seconds.

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

Bases: _WebsocketClient

Firehose subscribe labels client.

Parameters:

  • params – Parameters model.

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

  • recv_timeout – Reconnect to the server after this many seconds of inactivity. Default is 300 seconds (5 minutes).

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

Bases: _WebsocketClient

Firehose subscribe repos client.

Parameters:

  • params – Parameters model.

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

  • recv_timeout – Reconnect to the server after this many seconds of inactivity. Default is 30 seconds.

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 | Info | Identity | Account | Sync

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