Method on_message

src/server/agent_server.py:1185–1194

(message: Any)

            })

        def on_message(message: Any) -> None:
            # Persist into the session conversation so the next turn pairs
            # tool_use ↔ tool_result, then ship the SDK envelope to the client.
            try:
                self.session.conversation.add_message(message.role, message.content)
            except Exception:  # noqa: BLE001
                logger.exception("[agent-server] persist failed")
            env = _sdk_envelope(message, self.session_id)
            if env is not None:
                self._emit(env)

        # /effort: wrap the provider to inject reasoning_effort (default off ⇒
        # the real provider is used unchanged).