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

Add/Remove moderators (incoming AP)

Browse source
This commit is contained in:
freamon 2024-03-21 23:21:28 +00:00
parent 43f0998391
commit f7074d2edd
1 changed files with 34 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
app/activitypub/routes.py
View file

@ -666,24 +666,48 @@ def process_inbox_request(request_json, activitypublog_id, ip_address):
target_ap_id = request_json['object']['object']['object'] # object object object! target_ap_id = request_json['object']['object']['object'] # object object object!
post = undo_vote(activity_log, comment, post, target_ap_id, user) post = undo_vote(activity_log, comment, post, target_ap_id, user)
activity_log.result = 'success' activity_log.result = 'success'
elif request_json['object']['type'] == 'Add': elif request_json['object']['type'] == 'Add' and 'target' in request_json['object']:
activity_log.activity_type = request_json['object']['type'] activity_log.activity_type = request_json['object']['type']
featured_url = Community.query.filter(Community.ap_public_url == request_json['actor']).first().ap_featured_url target = request_json['object']['target']
if featured_url: community = Community.query.filter_by(ap_public_url=request_json['actor']).first()
if 'target' in request_json['object'] and featured_url == request_json['object']['target']: if community:
post = Post.query.filter(Post.ap_id == request_json['object']['object']).first() featured_url = community.ap_featured_url
moderators_url = community.ap_moderators_url
if target == featured_url:
post = Post.query.filter_by(ap_id=request_json['object']['object']).first()
if post: if post:
post.sticky = True post.sticky = True
activity_log.result = 'success' activity_log.result = 'success'
elif request_json['object']['type'] == 'Remove': if target == moderators_url:
user = find_actor_or_create(request_json['object']['object'])
if user:
existing_membership = CommunityMember.query.filter_by(community_id=community.id, user_id=user.id).first()
if existing_membership:
existing_membership.is_moderator = True
else:
new_membership = CommunityMember(community_id=community.id, user_id=user.id, is_moderator=True)
db.session.add(new_membership)
db.session.commit()
activity_log.result = 'success'
elif request_json['object']['type'] == 'Remove' and 'target' in request_json['object']:
activity_log.activity_type = request_json['object']['type'] activity_log.activity_type = request_json['object']['type']
featured_url = Community.query.filter(Community.ap_public_url == request_json['actor']).first().ap_featured_url target = request_json['object']['target']
if featured_url: community = Community.query.filter_by(ap_public_url=request_json['actor']).first()
if 'target' in request_json['object'] and featured_url == request_json['object']['target']: if community:
post = Post.query.filter(Post.ap_id == request_json['object']['object']).first() featured_url = community.ap_featured_url
moderators_url = community.ap_moderators_url
if target == featured_url:
post = Post.query.filter_by(ap_id=request_json['object']['object']).first()
if post: if post:
post.sticky = False post.sticky = False
activity_log.result = 'success' activity_log.result = 'success'
if target == moderators_url:
user = find_actor_or_create(request_json['object']['object'], create_if_not_found=False)
if user:
existing_membership = CommunityMember.query.filter_by(community_id=community.id, user_id=user.id).first()
if existing_membership:
existing_membership.is_moderator = False
activity_log.result = 'success'
else: else:
activity_log.exception_message = 'Invalid type for Announce' activity_log.exception_message = 'Invalid type for Announce'