michael/pyfedi
1
0
Fork 0
mirror of https://codeberg.org/rimu/pyfedi synced 2025-02-02 16:21:32 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions

federate auto-deletes

Browse source
This commit is contained in:
rimu 2024-08-16 16:19:23 +12:00
parent 6f4ea028f7
commit 27c41e916a
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
app/cli.py
View file

@ -176,9 +176,9 @@ def register(app):
communities = Community.query.filter(Community.content_retention > 0).all()
for community in communities:
cut_off = utcnow() - timedelta(days=community.content_retention)
old_posts = Post.query.filter_by(sticky=False, community_id=community.id).filter(Post.posted_at < cut_off).all()
old_posts = Post.query.filter_by(deleted=False, sticky=False, community_id=community.id).filter(Post.posted_at < cut_off).all()
for post in old_posts:
post_delete_post(community, post, post.user_id)
post_delete_post(community, post, post.user_id, federate_all_communities=False)
community.post_count -= 1
# Remove activity older than 3 days

9
app/post/routes.py
View file

@ -1195,7 +1195,7 @@ def post_delete(post_id: int):
return redirect(url_for('activitypub.community_profile', actor=community.ap_id if community.ap_id is not None else community.name))
def post_delete_post(community: Community, post: Post, user_id: int):
def post_delete_post(community: Community, post: Post, user_id: int, federate_all_communities=True):
user: User = User.query.get(user_id)
if post.url:
if post.cross_posts is not None:
@ -1228,10 +1228,11 @@ def post_delete_post(community: Community, post: Post, user_id: int):
delete_json['summary'] = 'Deleted by mod'
# Federation
if not community.local_only:
if not post.community.is_local(): # this is a remote community, send it to the instance that hosts it
if not community.local_only: # local_only communities do not federate
# if this is a remote community and we are a mod of that community
if not post.community.is_local() and user.is_local() and (community.is_moderator(user) or community.is_owner(user)):
post_request(post.community.ap_inbox_url, delete_json, user.private_key, user.public_url() + '#main-key')
else: # local community - send it to followers on remote instances
elif post.community.is_local(): # if this is a local community - Announce it to followers on remote instances
announce = {
"id": f"https://{current_app.config['SERVER_NAME']}/activities/announce/{gibberish(15)}",
"type": 'Announce',