diff --git a/relay/processors.py b/relay/processors.py index ff0d0af..824a975 100644 --- a/relay/processors.py +++ b/relay/processors.py @@ -43,8 +43,8 @@ async def handle_relay(view: ActorView, conn: Connection) -> None: async def handle_forward(view: ActorView, conn: Connection) -> None: try: - view.cache.get('handle-relay', view.message.object_id) - logging.verbose('already forwarded %s', view.message.object_id) + view.cache.get('handle-relay', view.message.id) + logging.verbose('already forwarded %s', view.message.id) return except KeyError: @@ -56,7 +56,7 @@ async def handle_forward(view: ActorView, conn: Connection) -> None: for inbox in conn.distill_inboxes(view.message): 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: