mirror
/
bridgy-fed
kopia lustrzana https://github.com/snarfed/bridgy-fed
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

ATProto firehose: implement quote posts 

for #978
in-reply-to-bridged
Ryan Barrett 2024-05-08 11:39:45 -07:00
rodzic 72ae63f4a0
commit 20afb59809
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 6BE31FDF4776E9D4
2 zmienionych plików z 39 dodań i 16 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

10
atproto_firehose.py
Wyświetl plik

@ -115,11 +115,11 @@ def subscribe():
if feature['$type'] == 'app.bsky.richtext.facet#mention':
maybe_add(feature['did'])
# TODO: quote posts
# if embed = record.get('embed'):
# if embed['$type'] in ('app.bsky.embed.record',
# 'app.bsky.embed.recordWithMedia'):
# if embed['record']
# quote posts
if embed := record.get('embed'):
if embed['$type'] in ('app.bsky.embed.record',
'app.bsky.embed.recordWithMedia'):
maybe_add(embed['record'])
if subjects:
logger.info(f'Got one re our ATProto users {subjects}: {action} {repo} {path}')

45
tests/test_atproto_firehose.py
Wyświetl plik

@ -131,17 +131,16 @@ class ATProtoFirehoseSubscribeTest(TestCase):
self.assert_enqueues(POST_BSKY)
def test_post_by_other(self):
self.store_object(id='did:plc:bob', raw={**DID_DOC, 'id': 'did:plc:bob'})
self.make_user('did:plc:bob', cls=ATProto, enabled_protocols=['eefake'])
self.store_object(id='did:plc:eve', raw={**DID_DOC, 'id': 'did:plc:eve'})
self.make_user('did:plc:eve', cls=ATProto, enabled_protocols=['eefake'])
self.assert_doesnt_enqueue(POST_BSKY)
def test_reply_direct_to_our_user(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.post',
'text': 'I hereby reply',
'reply': {
'$type': 'app.bsky.feed.post#replyRef',
'parent': {'uri': 'at://did:alice/app.bsky.feed.post/parent-tid'},
'parent': {'uri': 'at://did:alice/app.bsky.feed.post/tid'},
'root': {'uri': '-'},
},
})
@ -149,10 +148,9 @@ class ATProtoFirehoseSubscribeTest(TestCase):
def test_reply_indirect_to_our_user(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.post',
'text': 'I hereby reply',
'reply': {
'$type': 'app.bsky.feed.post#replyRef',
'root': {'uri': 'at://did:alice/app.bsky.feed.post/parent-tid'},
'root': {'uri': 'at://did:alice/app.bsky.feed.post/tid'},
'parent': {'uri': '-'},
},
})
@ -160,10 +158,9 @@ class ATProtoFirehoseSubscribeTest(TestCase):
def test_reply_indirect_to_other(self):
self.assert_doesnt_enqueue({
'$type': 'app.bsky.feed.post',
'text': 'I hereby reply',
'reply': {
'$type': 'app.bsky.feed.post#replyRef',
'parent': {'uri': 'at://did:bob/app.bsky.feed.post/parent-tid'},
'parent': {'uri': 'at://did:eve/app.bsky.feed.post/tid'},
'root': {'uri': '-'},
},
})
@ -171,7 +168,6 @@ class ATProtoFirehoseSubscribeTest(TestCase):
def test_mention_our_user(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.post',
'text': 'foo @alice bar',
'facets': [{
'$type': 'app.bsky.richtext.facet',
'features': [{
@ -184,16 +180,43 @@ class ATProtoFirehoseSubscribeTest(TestCase):
def test_mention_other(self):
self.assert_doesnt_enqueue({
'$type': 'app.bsky.feed.post',
'text': 'foo @bob bar',
'facets': [{
'$type': 'app.bsky.richtext.facet',
'features': [{
'$type': 'app.bsky.richtext.facet#mention',
'did': 'did:bob',
'did': 'did:eve',
}],
}],
})
def test_quote_of_our_user(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.post',
'embed': {
'$type': 'app.bsky.embed.record',
'record': {'uri': 'at://did:alice/app.bsky.feed.post/tid'},
},
})
def test_quote_of_our_user_with_image(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.post',
'embed': {
'$type': 'app.bsky.embed.recordWithMedia',
'record': {'uri': 'at://did:alice/app.bsky.feed.post/tid'},
'media': {'$type': 'app.bsky.embed.images'},
},
})
def test_quote_of_other(self):
self.assert_doesnt_enqueue({
'$type': 'app.bsky.feed.post',
'embed': {
'$type': 'app.bsky.embed.record',
'record': {'uri': 'at://did:eve/app.bsky.feed.post/tid'},
},
})
def test_like_of_our_user(self):
self.assert_enqueues({
'$type': 'app.bsky.feed.like',