askiiart/microblog.pub
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Partial ghost replies handling

Browse source
This commit is contained in:
Thomas Sileo 2018-07-21 02:06:45 +02:00
parent 8f7ee6f2cd
commit f05eb559f0
1 changed files with 21 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
tasks.py
View file

@ -32,7 +32,7 @@ back = activitypub.MicroblogPubBackend()
ap.use_backend(back) ap.use_backend(back)
@app.task(bind=True, max_retries=12) @app.task(bind=True, max_retries=12) # noqa: C901
def process_new_activity(self, iri: str) -> None: def process_new_activity(self, iri: str) -> None:
"""Process an activity received in the inbox""" """Process an activity received in the inbox"""
try: try:
@ -49,10 +49,28 @@ def process_new_activity(self, iri: str) -> None:
note = activity.get_object() note = activity.get_object()
if note.inReplyTo: if note.inReplyTo:
reply = ap.fetch_remote_activity(note.inReplyTo) reply = ap.fetch_remote_activity(note.inReplyTo)
if reply.id.startswith(ID) and activity.is_public(): if (
reply.id.startswith(ID) or reply.has_mention(ID)
) and activity.is_public():
# The reply is public "local reply", forward the reply (i.e. the original activity) to the original # The reply is public "local reply", forward the reply (i.e. the original activity) to the original
# recipients # recipients
activity.forward(reply.recipients()) activity.forward(back.followers())
# (partial) Ghost replies handling
# [X] This is the first time the server has seen this Activity.
should_forward = False
local_followers = ID + "/followers"
for field in ["to", "cc"]:
if field in activity._data:
if local_followers in activity._data[field]:
# [X] The values of to, cc, and/or audience contain a Collection owned by the server.
should_forward = True
if not (note.inReplyTo and note.inReplyTo.startswith(ID)):
# [X] The values of inReplyTo, object, target and/or tag are objects owned by the server
should_forward = False
if should_forward:
activity.forward(back.followers())
else: else:
tag_stream = True tag_stream = True