Method connect_sse_inner

crates/opencode-mcp/src/client.rs:325–350

(
        &self,
        url: String,
        headers: Option<HashMap<String, String>>,
    )

    }

    async fn connect_sse_inner(
        &self,
        url: String,
        headers: Option<HashMap<String, String>>,
    ) -> Result<(), McpClientError> {
        let mut merged_headers = headers.unwrap_or_default();
        if let Some(mgr) = self.oauth_manager.read().await.as_ref() {
            match mgr.get_token().await {
                Ok(Some(token)) => {
                    merged_headers.insert("Authorization".to_string(), format!("Bearer {token}"));
                }
                Ok(None) => return Err(McpClientError::Unauthorized),
                Err(e) => return Err(McpClientError::OAuthError(e.to_string())),
            }
        }

        let transport = SseTransport::new(url, Some(merged_headers));
        transport.connect().await?;
        {
            let mut t = self.transport.lock().await;
            *t = Some(Box::new(transport));
        }
        self.initialize().await?;
        self.load_tools().await?;
        Ok(())
    }

    // -- Internal helpers ----------------------------------------------------