|
@@ -1423,13 +1423,18 @@ class ChattoAdapter(BasePlatformAdapter):
|
|
|
|
|
|
|
|
BasePlatformAdapter override
|
|
BasePlatformAdapter override
|
|
|
"""
|
|
"""
|
|
|
- logger.info("self.chatto_config.reactions.value: %s", self.chatto_config.reactions.value)
|
|
|
|
|
if not self.chatto_config.reactions.value:
|
|
if not self.chatto_config.reactions.value:
|
|
|
return
|
|
return
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
chat_id, message_id = self._event_room_and_message_id(event)
|
|
chat_id, message_id = self._event_room_and_message_id(event)
|
|
|
if not chat_id or not message_id:
|
|
if not chat_id or not message_id:
|
|
|
- logger.warning("Chatto: on_processing_start — empty chat_id or message_id, skipping reaction")
|
|
|
|
|
|
|
+ # Routine, not a fault: the gateway runs agent-initiated turns
|
|
|
|
|
+ # (heartbeat polls, goal continuations) through the same pipeline
|
|
|
|
|
+ # with message_id=None, and there is no inbound message to mark.
|
|
|
|
|
+ logger.debug(
|
|
|
|
|
+ "Chatto: nothing to react to (chat_id=%r, message_id=%r)",
|
|
|
|
|
+ chat_id, message_id,
|
|
|
|
|
+ )
|
|
|
return
|
|
return
|
|
|
await self.add_reaction(chat_id, message_id, "👀")
|
|
await self.add_reaction(chat_id, message_id, "👀")
|
|
|
|
|
|