(
&self,
server_name: &str,
_code: &str,
)
| 372 | } |
| 373 | |
| 374 | pub async fn handle_callback( |
| 375 | &self, |
| 376 | server_name: &str, |
| 377 | _code: &str, |
| 378 | ) -> Result<McpServerInfo, McpOAuthError> { |
| 379 | self.managed_server(server_name).await?; |
| 380 | |
| 381 | let mut states = self.oauth_states.write().await; |
| 382 | let state = states |
| 383 | .get_mut(server_name) |
| 384 | .ok_or_else(|| McpOAuthError::OAuthFailed("No pending OAuth flow".to_string()))?; |
| 385 | state.status = McpOAuthStatus::Authorized; |
| 386 | drop(states); |
| 387 | self.log_event(server_name, "info", "OAuth callback completed") |
| 388 | .await; |
| 389 | |
| 390 | self.connect(server_name).await |
| 391 | } |
| 392 | |
| 393 | pub async fn authenticate(&self, server_name: &str) -> Result<McpServerInfo, McpOAuthError> { |
| 394 | let managed = self.managed_server(server_name).await?; |
no test coverage detected