28 Commity (e4f9966686a1ee0b23aa7899137deb059f0c1967)

Autor	SHA1	Wiadomość	Data
Ryan Barrett	031d8b9cd2	atproto_firehose: re-enable handler	2024-05-14 16:53:15 -07:00
Ryan Barrett	8eeb588d11	atproto_firehose: make its own GAE service, lots of other refactoring ... optimize loading DIDs, move around threads and exception handling, etc. for #978	2024-05-13 22:02:09 -07:00
Ryan Barrett	f2b5f79489	ATProto firehose: add handle wrapper that catches exceptions ... also refactor and simplify load_dids, error reporting. #978	2024-05-10 19:59:12 -07:00
Ryan Barrett	6bc9269ad0	ATProto firehose: load bridged dids from AtpRepo instead of users ... hopefully cuts down on datastore load a bit for #978	2024-05-10 11:31:47 -07:00
Ryan Barrett	741146eb8d	ATProto firehose: encode Object.bsky as compact DAG-JSON ... fixes https://console.cloud.google.com/errors/detail/CIGJnbnCq7fm1gE;time=P30D?project=bridgy-federated and similar	2024-05-10 06:51:58 -07:00
Ryan Barrett	b49fe13e59	ATProto firehose: use report_exception() so we get stack traces	2024-05-09 21:31:41 -07:00
Ryan Barrett	989cd29860	ATProto firehose: bug fix for loading DIDs ... fixes https://console.cloud.google.com/errors/detail/CKKTu6mM0sunXQ;time=P30D?project=bridgy-federated	2024-05-09 21:25:13 -07:00
Ryan Barrett	d56f405c96	ATProto firehose: fix race conditions in loading DIDs ... for #978	2024-05-09 15:39:18 -07:00
Ryan Barrett	5ef4111b4d	ATProto firehose: reload our DIDs every 20s ... for #978	2024-05-09 14:31:57 -07:00
Ryan Barrett	66b8846760	ATProto firehose: refactor and extract out loading our DIDs	2024-05-09 14:05:05 -07:00
Ryan Barrett	940c0e8cae	ATProto firehose: don't assume required fields, handle error reporting errors ... for #978	2024-05-09 13:26:24 -07:00
Ryan Barrett	eea8779872	ATProto firehose: subscribe at stored cursor + 1 ... for #978	2024-05-09 08:44:30 -07:00
Ryan Barrett	87165497f0	misc noop langauge changes in comments and docs, eg BGS => relay	2024-05-09 06:43:51 -07:00
Ryan Barrett	1ecdaf6b34	ATProto firehose: store cursor	2024-05-08 23:11:27 -07:00
Ryan Barrett	b788105a71	ATProto firehose: start implementing cursor ... for #978	2024-05-08 21:35:03 -07:00
Ryan Barrett	1e5fcfda0b	ATProto firehose: error handling, reconnect in subscribe	2024-05-08 20:43:10 -07:00
Ryan Barrett	b8e0fecc3b	atproto_firehose.handle: implement delete ... for #978	2024-05-08 20:19:18 -07:00
Ryan Barrett	b4841f3e60	ATProto firehose: noop refactoring, add Op namedtuple ... for #978	2024-05-08 15:48:39 -07:00
Ryan Barrett	0d24fafefc	ATProto firehose: tests for updates ... for #978	2024-05-08 13:31:08 -07:00
Ryan Barrett	7867326ebe	ATProto firehose: implement deletes ... for #978	2024-05-08 13:26:36 -07:00
Ryan Barrett	5c77f02dba	ATProto firehose: bug fix for quote posts with media embeds ... for #978	2024-05-08 12:13:26 -07:00
Ryan Barrett	20afb59809	ATProto firehose: implement quote posts ... for #978	2024-05-08 11:39:45 -07:00
Ryan Barrett	72ae63f4a0	ATProto firehose: test replies, mentions ... #978	2024-05-08 11:31:31 -07:00
Ryan Barrett	44763ca8ab	ATProto firehose: more tests ... for #978	2024-05-08 11:18:50 -07:00
Ryan Barrett	e214bc0a43	ATProto firehose: more tests ... for #978	2024-05-08 10:39:03 -07:00
Ryan Barrett	7ecf3dc381	ATProto firehose: start tests ... for #978	2024-05-07 17:36:34 -07:00
Ryan Barrett	0f35a2e1a1	ATProto firehose: convert to function we can run in a thread ... for #978	2024-05-07 16:58:52 -07:00
Ryan Barrett	622d07a984	ATProto firehose: move and rename file	2024-05-07 16:24:16 -07:00