Usa o websocket do Bluesky para captura de posts em realtime
Cada post pode ser texto puro, resposta a outro post, pode conter imagens, link externo, etc.
Ref.: https://atproto.com/specs/event-stream
Tipos atribuidos a variável 'record':
| from atproto import CAR, AtUri | |
| from atproto.firehose import FirehoseSubscribeReposClient, parse_subscribe_repos_message | |
| from atproto.firehose.models import MessageFrame | |
| from atproto.xrpc_client import models | |
| from atproto.xrpc_client.models import get_or_create, ids, is_record_type | |
| client = FirehoseSubscribeReposClient() | |
| def process_commit(commit): | |
| car = CAR.from_bytes(commit.blocks) | |
| for op in commit.ops: | |
| uri = AtUri.from_str(f'at://{commit.repo}/{op.path}') | |
| if op.action == 'create': | |
| if not op.cid: | |
| continue | |
| create_info = {'uri': str(uri), 'cid': str(op.cid), 'author': commit.repo} | |
| record_raw_data = car.blocks.get(op.cid) | |
| if not record_raw_data: | |
| continue | |
| record = get_or_create(record_raw_data, strict=False) | |
| if uri.collection == ids.AppBskyFeedPost and is_record_type(record, ids.AppBskyFeedPost): | |
| print(type(record)) | |
| print({'record': record, **create_info}) | |
| def on_message_handler(message) -> None: | |
| commit = parse_subscribe_repos_message(message) | |
| # we need to be sure that it's commit message with .blocks inside | |
| if not isinstance(commit, models.ComAtprotoSyncSubscribeRepos.Commit): | |
| return | |
| process_commit(commit) | |
| client.start(on_message_handler) |