pch_xyz/relay
1
0
Fork 0
mirror of https://git.pleroma.social/pleroma/relay.git synced 2024-11-27 16:51:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

cache correct id for deletes

Browse source
This commit is contained in:
Izalia Mae 2024-02-19 23:05:26 -05:00
parent dd9f17cd56
commit fad4b7ce82
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
relay/processors.py
View file

@ -43,8 +43,8 @@ async def handle_relay(view: ActorView, conn: Connection) -> None:
async def handle_forward(view: ActorView, conn: Connection) -> None: async def handle_forward(view: ActorView, conn: Connection) -> None:
try: try:
view.cache.get('handle-relay', view.message.object_id) view.cache.get('handle-relay', view.message.id)
logging.verbose('already forwarded %s', view.message.object_id) logging.verbose('already forwarded %s', view.message.id)
return return
except KeyError: except KeyError:
@ -56,7 +56,7 @@ async def handle_forward(view: ActorView, conn: Connection) -> None:
for inbox in conn.distill_inboxes(view.message): for inbox in conn.distill_inboxes(view.message):
view.app.push_message(inbox, message, view.instance) view.app.push_message(inbox, message, view.instance)
view.cache.set('handle-relay', view.message.object_id, message.id, 'str') view.cache.set('handle-relay', view.message.id, message.id, 'str')
async def handle_follow(view: ActorView, conn: Connection) -> None: async def handle_follow(view: ActorView, conn: Connection) -> None: