Struct AuthenticationManager

pub struct AuthenticationManager { /* private fields */ }

Authentication manager with comprehensive key management

Implementations

impl AuthenticationManager

pub async fn new(config: AuthConfig) -> Result<AuthenticationManager, AuthError>

pub async fn new_with_validation( config: AuthConfig, validation_config: ValidationConfig, ) -> Result<AuthenticationManager, AuthError>

pub async fn create_api_key( &self, name: String, role: Role, expires_at: Option<DateTime<Utc>>, ip_whitelist: Option<Vec<String>>, ) -> Result<ApiKey, AuthError>

Create a new API key

pub async fn validate_api_key( &self, key_secret: &str, client_ip: Option<&str>, ) -> Result<Option<AuthContext>, AuthError>

Validate an API key with comprehensive security checks

pub async fn validate_api_key_legacy( &self, key_secret: &str, ) -> Result<Option<AuthContext>, AuthError>

Validate an API key (legacy method without IP checking)

pub async fn list_keys(&self) -> Vec<ApiKey>

List all API keys

pub async fn get_key(&self, key_id: &str) -> Option<ApiKey>

Get a specific API key by ID

pub async fn update_key(&self, key: ApiKey) -> Result<(), AuthError>

Update an existing API key

pub async fn revoke_key(&self, key_id: &str) -> Result<bool, AuthError>

Revoke/delete an API key

pub async fn get_rate_limit_stats(&self) -> RateLimitStats

Get current rate limit statistics

pub async fn cleanup_rate_limits(&self)

Clean up old rate limit entries (should be called periodically)

pub async fn check_role_rate_limit( &self, role: &Role, client_ip: &str, ) -> Result<bool, AuthError>

Check if a role-based request should be rate limited

pub async fn update_role_rate_limit( &self, role_key: String, config: RoleRateLimitConfig, ) -> Result<(), AuthError>

Update role rate limit configuration

pub async fn cleanup_role_rate_limits(&self)

Clean up old role rate limit entries

pub async fn disable_key(&self, key_id: &str) -> Result<bool, AuthError>

Disable/enable an API key without deleting it

pub async fn enable_key(&self, key_id: &str) -> Result<bool, AuthError>

Enable a previously disabled API key

pub async fn update_key_expiration( &self, key_id: &str, expires_at: Option<DateTime<Utc>>, ) -> Result<bool, AuthError>

Update key expiration date

pub async fn update_key_ip_whitelist( &self, key_id: &str, ip_whitelist: Vec<String>, ) -> Result<bool, AuthError>

Update key IP whitelist

pub async fn list_keys_by_role(&self, role: &Role) -> Vec<ApiKey>

Get keys by role

pub async fn list_active_keys(&self) -> Vec<ApiKey>

Get active keys only

pub async fn list_expired_keys(&self) -> Vec<ApiKey>

Get expired keys

pub async fn bulk_revoke_keys( &self, key_ids: &[String], ) -> Result<Vec<String>, AuthError>

Bulk revoke keys (useful for security incidents)

pub async fn cleanup_expired_keys(&self) -> Result<u32, AuthError>

Clean up expired keys

pub async fn get_key_usage_stats(&self) -> Result<KeyUsageStats, AuthError>

Get key usage statistics

pub async fn bulk_create_keys( &self, requests: Vec<KeyCreationRequest>, ) -> Result<Vec<Result<ApiKey, AuthError>>, AuthError>

Create multiple API keys for bulk provisioning

pub fn check_api_completeness(&self) -> ApiCompletenessCheck

Check if the authentication manager has all required methods for production use

pub async fn start_background_tasks(&self) -> Result<(), AuthError>

pub async fn stop_background_tasks(&self) -> Result<(), AuthError>

pub async fn health_check(&self) -> Result<(), AuthError>

pub async fn process_request( &self, request: Request, _context: &RequestContext, ) -> Result<Request, AuthError>

pub async fn process_response( &self, response: Response, _context: &RequestContext, ) -> Result<Response, AuthError>

pub async fn generate_token_for_key( &self, key_id: &str, client_ip: Option<String>, session_id: Option<String>, scope: Vec<String>, ) -> Result<TokenPair, AuthError>

Generate a JWT token pair for an API key

pub async fn validate_jwt_token( &self, token: &str, ) -> Result<AuthContext, AuthError>

Validate a JWT token and return auth context

pub async fn refresh_jwt_token( &self, refresh_token: &str, client_ip: Option<String>, scope: Vec<String>, ) -> Result<String, AuthError>

Refresh an access token using a refresh token

pub async fn revoke_jwt_token(&self, token: &str) -> Result<(), AuthError>

Revoke a JWT token

pub async fn cleanup_jwt_blacklist(&self) -> Result<usize, AuthError>

Clean up expired tokens from blacklist

pub fn decode_jwt_token_info( &self, token: &str, ) -> Result<TokenClaims, AuthError>

Get token info without validation (for debugging)