pch_xyz/sedi-relay
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

announce forwarded messages

Browse source
This commit is contained in:
Izalia Mae 2022-11-06 01:11:36 -05:00
parent dcb7980c50
commit f713f54306
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
relay/processors.py
View file

@ -44,15 +44,26 @@ async def handle_forward(actor, data, request):
logging.verbose(f'already forwarded {object_id}') logging.verbose(f'already forwarded {object_id}')
return return
activity_id = f"https://{request.host}/activities/{uuid4()}"
message = {
"@context": "https://www.w3.org/ns/activitystreams",
"type": "Announce",
"to": [f"https://{request.host}/followers"],
"actor": f"https://{request.host}/actor",
"object": data,
"id": activity_id
}
logging.verbose(f'Forwarding post from {actor["id"]}') logging.verbose(f'Forwarding post from {actor["id"]}')
logging.debug(f'>> Relay {data}') logging.debug(f'>> Relay {data}')
inboxes = misc.distill_inboxes(actor, object_id) inboxes = misc.distill_inboxes(actor, object_id)
futures = [misc.request(inbox, data=data) for inbox in inboxes] futures = [misc.request(inbox, data=message) for inbox in inboxes]
asyncio.ensure_future(asyncio.gather(*futures)) asyncio.ensure_future(asyncio.gather(*futures))
cache[object_id] = object_id cache[object_id] = activity_id
async def handle_follow(actor, data, request): async def handle_follow(actor, data, request):