Method connect_sse

crates/opencode-mcp/src/client.rs:301–323

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

        Ok(())
    }
    pub async fn connect_sse(
        &self,
        url: String,
        headers: Option<HashMap<String, String>>,
    ) -> Result<(), McpClientError> {
        let result = self.connect_sse_inner(url, headers).await;
        match &result {
            Ok(()) => self.set_status(McpStatus::Connected).await,
            Err(McpClientError::Unauthorized) => {
                self.set_status(McpStatus::NeedsAuth).await;
            }
            Err(e) => {
                let msg = e.to_string();
                if msg.contains("registration") || msg.contains("client_id") {
                    self.set_status(McpStatus::NeedsClientRegistration { error: msg })
                        .await;
                } else {
                    self.set_status(McpStatus::Failed { error: msg }).await;
                }
            }
        }
        result
    }

    async fn connect_sse_inner(
        &self,