From f928251efef016bfe2ac9bd69f0ca41599e5627b Mon Sep 17 00:00:00 2001 From: Ryan Barrett Date: Sat, 21 Sep 2024 17:34:35 -0700 Subject: [PATCH] atproto_firehose: use decode=False with subscribeRepos for snarfed/lexrpc@677cd0cc1c8ca71a04260d765da5acc9b05c555d --- atproto_firehose.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/atproto_firehose.py b/atproto_firehose.py index 3fcb78cd..b9504465 100644 --- a/atproto_firehose.py +++ b/atproto_firehose.py @@ -139,7 +139,8 @@ def subscribe(): client = Client(f'https://{os.environ["BGS_HOST"]}', headers={'User-Agent': USER_AGENT}) - for frame in client.com.atproto.sync.subscribeRepos(cursor=cursor.cursor): + for frame in client.com.atproto.sync.subscribeRepos(decode=False, + cursor=cursor.cursor): # parse header header = libipld.decode_dag_cbor(frame) if header.get('op') == -1: