atproto_firehose.subscribe: dark read memcache to compare against DIDs in memory

for #1341
main
Ryan Barrett 2025-01-09 18:32:01 -08:00
rodzic e8b201dc33
commit 708cef0ab0
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 6BE31FDF4776E9D4
1 zmienionych plików z 3 dodań i 0 usunięć

Wyświetl plik

@ -171,6 +171,9 @@ def subscribe():
if not repo: if not repo:
logger.warning(f'Payload missing repo! {payload}') logger.warning(f'Payload missing repo! {payload}')
continue continue
# TODO: remove
elif repo in atproto_dids and not ATProto.get_by_id(repo, use_datastore=False):
report_error('ATProto user missing from memcache', user=repo)
seq = payload.get('seq') seq = payload.get('seq')
if not seq: if not seq: