zaklaus
/
microblog
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Debug share dedup

main
Thomas Sileo 2022-08-27 11:21:42 +02:00
parent 7283ba134c
commit 00004a3239
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
app/boxes.py
View File

@ -1655,18 +1655,23 @@ async def _handle_announce_activity(
# stream if it's not already there, from an followed actor
# and if we haven't seen it recently
skip_delta = timedelta(hours=1)
if (
now() - as_utc(relates_to_inbox_object.ap_published_at) # type: ignore
) < skip_delta or (
delta_from_original = now() - as_utc(
relates_to_inbox_object.ap_published_at # type: ignore
)
if (delta_from_original) < skip_delta or (
dup_count := (
await db_session.scalar(
select(func.count(func.distinct(models.InboxObject.id))).where(
select(func.count(models.InboxObject.id)).where(
models.InboxObject.ap_type == "Announce",
models.InboxObject.ap_published_at > now() - skip_delta,
models.InboxObject.relates_to_inbox_object_id
== relates_to_inbox_object.id,
models.InboxObject.is_hidden_from_stream.is_(False),
)
)
)
) > 0:
logger.info(f"Deduping Announce {delta_from_original=}/{dup_count=}")
announce_activity.is_hidden_from_stream = True
else:
announce_activity.is_hidden_from_stream = not is_from_following