atproto_firehose: use decode=False with subscribeRepos

for snarfed/lexrpc@677cd0cc1c
pull/1343/head
Ryan Barrett 2024-09-21 17:34:35 -07:00
rodzic 83a03c7536
commit f928251efe
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 6BE31FDF4776E9D4
1 zmienionych plików z 2 dodań i 1 usunięć

Wyświetl plik

@ -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: