|
63 | 63 | use std::{collections::HashMap, pin::Pin}; |
64 | 64 |
|
65 | 65 | use futures::{AsyncRead, AsyncWrite, SinkExt, StreamExt, channel::mpsc}; |
66 | | -use sacp::{InitializeRequest, InitializeResponse, NewSessionRequest, NewSessionResponse}; |
| 66 | +use sacp::schema::{InitializeRequest, InitializeResponse, NewSessionRequest, NewSessionResponse}; |
67 | 67 | use sacp_proxy::{ |
68 | 68 | McpConnectRequest, McpConnectResponse, McpDisconnectNotification, McpOverAcpNotification, |
69 | 69 | McpOverAcpRequest, SuccessorNotification, SuccessorRequest, |
70 | 70 | }; |
71 | 71 |
|
| 72 | +use sacp::handler::NullHandler; |
72 | 73 | use sacp::{ |
73 | 74 | JrConnection, JrConnectionCx, JrNotification, JrRequest, JrRequestCx, JrResponse, MessageAndCx, |
74 | | - MetaCapabilityExt, NullHandler, Proxy, UntypedMessage, |
| 75 | + MetaCapabilityExt, Proxy, UntypedMessage, |
75 | 76 | util::{TypeNotification, TypeRequest}, |
76 | 77 | }; |
77 | 78 | use tokio_util::compat::{TokioAsyncReadCompatExt, TokioAsyncWriteCompatExt}; |
@@ -732,7 +733,7 @@ impl Conductor { |
732 | 733 | async fn forward_session_new_request( |
733 | 734 | &mut self, |
734 | 735 | target_component_index: usize, |
735 | | - mut request: sacp::NewSessionRequest, |
| 736 | + mut request: NewSessionRequest, |
736 | 737 | conductor_tx: &mpsc::Sender<ConductorMessage>, |
737 | 738 | request_cx: JrRequestCx<NewSessionResponse>, |
738 | 739 | ) -> Result<(), sacp::Error> { |
|
0 commit comments