(
&self,
request: AgentSubmissionRequest,
)
| 761 | } |
| 762 | |
| 763 | async fn submit_message( |
| 764 | &self, |
| 765 | request: AgentSubmissionRequest, |
| 766 | ) -> PortResult<AgentSubmissionResult> { |
| 767 | self.submitted_messages |
| 768 | .lock() |
| 769 | .unwrap() |
| 770 | .push(request.clone()); |
| 771 | Ok(AgentSubmissionResult { |
| 772 | turn_id: request |
| 773 | .turn_id |
| 774 | .unwrap_or_else(|| "generated_turn".to_string()), |
| 775 | accepted: true, |
| 776 | }) |
| 777 | } |
| 778 | |
| 779 | async fn resolve_session_agent_type( |
| 780 | &self, |
no test coverage detected