(&self, server_name: &str)
| 509 | } |
| 510 | |
| 511 | async fn managed_server(&self, server_name: &str) -> Result<ManagedServer, McpOAuthError> { |
| 512 | self.servers |
| 513 | .read() |
| 514 | .await |
| 515 | .get(server_name) |
| 516 | .cloned() |
| 517 | .ok_or_else(|| McpOAuthError::ServerNotFound(server_name.to_string())) |
| 518 | } |
| 519 | |
| 520 | async fn oauth_status_for(&self, server_name: &str) -> Option<McpOAuthStatus> { |
| 521 | self.oauth_states |
no test coverage detected