Production-ready β’ Enterprise-grade β’ Security-first β’ Bulletproof
No Rust installation required! Use our precompiled binaries:
# Linux/macOS - One-line installation
curl -sSL https://raw.githubusercontent.com/ciresnave/auth-framework/main/scripts/install.sh | bash
# Windows PowerShell - One command
iwr -useb https://raw.githubusercontent.com/ciresnave/auth-framework/main/scripts/install.ps1 | iex
# Docker - Instant deployment
docker run -p 8080:8080 ghcr.io/ciresnave/auth-framework:latestThat's it! Server running at http://localhost:8080 π
π Full Deployment Guide β’ π³ Docker Deployment β’ π οΈ Configuration Guide
Auth Framework is the definitive authentication and authorization solution for Rust applications, trusted by enterprises and developers worldwide. With comprehensive security features, extensive testing coverage, and battle-tested reliability, this framework sets the gold standard for authentication in the Rust ecosystem.
If you are integrating the Rust library directly, start with these entry points:
auth_framework::AuthFramework: recommended default entry point for most applications.auth_framework::ModularAuthFramework: advanced entry point when you need direct access to individual managers.auth_framework::prelude::*: ergonomic imports for application code.auth_framework::AppConfigBuilder: simple in-process configuration builder.auth_framework::LayeredConfigBuilderandauth_framework::ConfigManager: layered configuration from files and environment variables.
This split exists to support both simple app integration and advanced composition, but new users should usually start with AuthFramework plus the prelude.
- π’ Complete Client & Server Solution: The ONLY Rust framework providing both client authentication AND full OAuth 2.0 authorization server capabilities
- π‘οΈ Enterprise Security: Military-grade security with comprehensive audit trails, rate limiting, and multi-factor authentication
- π§ Unmatched Feature Set: OAuth 2.0 server, OIDC provider, JWT server, SAML SP, WebAuthn RP, API gateway, and more
- π Production Proven: Extensively tested with 514 passing tests and real-world battle testing
- β‘ High Performance: Optimized for speed with async-first design and efficient memory usage
- π Framework Agnostic: Seamless integration with Axum, Actix Web, Warp, and any Rust web framework
- π Zero-Trust Architecture: Built from the ground up with security-first principles and defense in depth
- π Developer Experience: Comprehensive documentation, examples, and testing utilities for rapid development
π Security Notice: This framework requires a JWT secret to be configured before use. See
SECURITY_GUIDE.mdfor critical security requirements and best practices.
β οΈ Database Recommendation: We strongly recommend using PostgreSQL instead of MySQL to avoid the RUSTSEC-2023-0071 vulnerability (Marvin Attack on RSA). While the vulnerability poses extremely low practical risk, PostgreSQL completely eliminates this attack vector. SeeSECURITY.mdfor details.
v0.5.0-rc18 - Security Hardening & Comprehensive Audit:
- π WebAuthn credential endpoints secured - List/delete credential endpoints now require authentication with owner-only authorization
- π JWT validation hardened - Removed dangerous
verify_signatureparameter; signature verification is now always enforced - π Content-Security-Policy header added - Complete security headers suite now includes CSP
- π‘οΈ Production panic prevention - Replaced all
unwrap()/expect()on mutex/RwLock operations with graceful fallback handling - π SAML integration tests guarded - Added
#[cfg(feature = "saml")]to SAML-specific tests
Previous: v0.5.0-rc6 - Storage Backend Correctness (audit cycle 13):
- π PostgreSQL
migrate()DDL fixes - The existingmigrate()method contained two bugs: all threeCREATE TABLEstatements were passed to a singlesqlx::query()call (sqlx accepts exactly one statement per call), and inlineINDEXclauses were used insideCREATE TABLE(valid MySQL syntax but not PostgreSQL). Fixed by splitting into individualexecute()calls and replacing inline indexes with separateCREATE INDEX IF NOT EXISTSstatements. - π MySQL
migrate()added -MySqlStoragelacked amigrate()method entirely; a new empty database would immediately fail on first use ("Table doesn't exist"). AddedMySqlStorage::migrate()with proper MySQL DDL (DATETIME(6),JSON,LONGTEXT,ENGINE=InnoDB utf8mb4), matching the PostgreSQL API exactly. - π§ͺ 985 tests, 0 clippy warnings
Previous: v0.5.0-rc5 - Integration Fixes & Lint Compliance (audit cycle 12):
- π Integration compile fixes -
PermissionβAbacPermissionin actix-web and warp integration modules (broken since rc2 type rename; previously hidden by feature gates) - π CHANGELOG date corrections - rc3 and rc4 entries were dated 2025-10-07 (before rc2); all corrected to 2026-03-12
- π§ Idiomatic
_configfields - Removed#[allow(dead_code)]suppressions in analytics structs; replaced with underscore-prefix convention - π
.markdownlint.json- Added project-level config to allow repeated subsection headings across CHANGELOG version sections (Keep a Changelog standard) - π§ͺ 985 tests, 0 clippy warnings
Previous: v0.5.0-rc4 - Code Quality & Version Sync (audit cycle 11):
- π§ Mutex Safety - All
.lock().unwrap()calls in production code replaced with.expect("mutex poisoned")for clearer diagnostics if a mutex is poisoned - π Documented Initialize Stubs -
initialize()methods inJwtServer,ApiGateway, andSamlIdentityProvidernow have doc comments explaining they are intentionally empty (all async setup is done innew()) - π’ Version Consistency -
Cargo.tomlandREADME.mdnow correctly reflect the current release candidate (were stale at rc1) - π README Fix - Corrected a markdown fence that was touching a blockquote on the same line, causing MD040 lint errors
- π§ͺ 985 tests, 0 clippy warnings
Previous: v0.5.0-rc3 - CIBA Spec Compliance & Quality Improvements:
- π CIBA Spec Β§7.1 / Β§11 Conformance -
client_notification_tokenis now forwarded asAuthorization: Bearerin ping/push mode notifications, with validation that the token is present when required - π§ Production-Grade Implementations - Replaced all development stubs in auth.rs and authorization.rs with real implementations (TOTP secret retrieval, security metrics, instance ID, UTC time-range checks)
- π Doc-Test Completeness - 41 documentation examples now compiled with
no_run(up from 0 passing doc-tests in rc2) - π§ͺ Test Suite Excellence - 985 tests total, 100% passing (483 unit + integration + 41 doctests)
- π Code Quality - All production
.unwrap()calls replaced with.expect()with descriptive messages;initialize()stubs documented
Previous: v0.5.0-rc2 - Security Audit Cycle:
- Comprehensive security audit with 9 audit cycles; all critical/high findings resolved
- 483 tests, 0 clippy warnings, full OWASP Top 10 compliance
Previous: v0.5.0-rc1 - OAuth 2.1 Complete Implementation & Enhanced Security:
- π OAuth 2.1 Full Compliance - Complete OAuth 2.1 authorization server implementation
- Token Introspection (RFC 7662) - 9 comprehensive tests
- Pushed Authorization Requests / PAR (RFC 9126) - 9 comprehensive tests
- Device Authorization Flow (RFC 8628) - 14 comprehensive tests
- End-to-end OAuth 2.1 flows - 9 integration tests
- 41 OAuth tests total, 100% passing
- π‘οΈ Advanced Security Features - Production-grade security enhancements
- Rate Limiting - 12 tests covering burst protection and distributed systems
- DoS Protection - 10 tests including Slowloris defense and resource exhaustion
- IP Blacklisting - 12 tests for threat prevention and geolocation blocking
- MFA Flows - 18 tests covering TOTP, enrollment, and recovery
- 52 security tests total, 100% passing
- π Test Suite Excellence - 93 comprehensive tests (100% passing)
- ποΈ Production Ready - Complete authorization server capabilities
Previous Release (v0.5.0-alpha) - Phase 2: Password & Email Validation Complete:
- π Enhanced Password Validation - Completely overhauled password validation system with granular complexity requirements
- Added 8 new SecurityConfig fields for fine-grained password policy control
- Advanced minimum complexity criteria system (meet N of 4 possible criteria)
- Individual requirement toggles for maximum flexibility
- Maintains full backward compatibility
- οΏ½ RFC 5322 Email Validation - Industry-standard email validation using
email_addresscrate- Full RFC 5322 compliance for professional-grade email format validation
- Advanced parsing with configurable options
- Comprehensive edge case handling for production use
- βοΈ Configuration System Overhaul - Enhanced SecurityConfig with comprehensive security controls
- Added
LockoutConfigstructure for account lockout management - Added
OAuth2SecurityConfigfor OAuth2-specific security settings - Enhanced helper methods with all new security fields
- Added
- π§ͺ Enhanced Test Suite - 405 passing tests with comprehensive validation coverage
- 12 new validation tests covering all enhancement scenarios
- Password complexity criteria testing with various combinations
- Email validation testing with valid/invalid cases and edge cases
Previous Release (v0.4.2):
- 393 passing tests with 100% success rate, comprehensive error handling improvements
- Security utilities rebuild, enhanced email validation, improved password security
Previous Major Features (v0.3.0):
- π§ Flexible Configuration Management - Complete integration with
configcrate for multi-format configuration support - π Modular Configuration System - Include directives for breaking configuration into logical components
- π Environment Variable Support - Comprehensive environment variable mapping with precedence control
- βοΈ CLI Integration - Command-line argument parsing with clap integration
- ποΈ Parent App Integration - Seamless nesting of auth-framework config into larger applications
- π Configuration Layering - Smart precedence: CLI β Environment β Files β Defaults
- π¨ Automated Threat Intelligence - Real-time threat feed updates with MaxMind GeoIP2 integration
- π‘οΈ Enhanced Security Features - Advanced rate limiting, IP geolocation tracking, and threat detection
- π Comprehensive Documentation - Configuration guides, integration examples, and best practices
- π§ͺ Production-Ready Examples - Docker, Kubernetes, and multi-environment configuration patterns
Configuration Highlights:
- Multiple Format Support: TOML, YAML, JSON configuration files
- Environment Integration: Full environment variable mapping with customizable prefixes
- Modular Architecture: Include files for organized, maintainable configuration
- Parent App Friendly: Easy integration into existing application configuration systems
- Client & Server Capabilities: Full OAuth 2.0/2.1 client AND authorization server, OpenID Connect provider, JWT server
- Multiple Authentication Methods: OAuth 2.0/OIDC, JWT, API keys, password-based, SAML, WebAuthn, and custom methods
- Enhanced Device Flow: Complete OAuth device flow support (client & server) with
oauth-device-flowsintegration - Multi-Factor Authentication: TOTP, SMS, email, hardware keys, and backup codes with configurable policies
- Enterprise Identity Providers: GitHub, Google, Microsoft, Discord, and custom OAuth providers with automatic profile mapping
- OAuth 2.0 Authorization Server: Complete RFC 6749 implementation with all grant types (authorization code, client credentials, refresh token, device flow)
- OpenID Connect Provider: Full OIDC 1.0 provider with ID tokens, UserInfo endpoint, and discovery
- Dynamic Client Registration: RFC 7591 compliant client registration and management
- Advanced Grant Types: Device authorization flow (RFC 8628), JWT bearer tokens (RFC 7523), SAML bearer assertions (RFC 7522)
- Enterprise Features: Token introspection (RFC 7662), token revocation (RFC 7009), PKCE (RFC 7636), and consent management
- Advanced Token Management: Secure issuance, validation, refresh, and revocation with JWT/JWE support
- Zero-Trust Session Management: Secure session handling with rotation, fingerprinting, and concurrent session limits
- Comprehensive Rate Limiting: Built-in protection against brute force, credential stuffing, and abuse
- Audit & Compliance: Detailed audit logging, GDPR compliance features, and security event monitoring
- Cryptographic Security: bcrypt password hashing, secure random generation, and constant-time comparisons
- Complete Server Stack: OAuth 2.0 server, OIDC provider, JWT server, SAML SP, WebAuthn RP, and API gateway
- Multiple Storage Backends: PostgreSQL (recommended), Redis (high-performance), MySQL, in-memory (development) with connection pooling
- Framework Integration: Native middleware for Axum, Actix Web, Warp, and extensible for any framework
- Distributed Architecture: Cross-node authentication validation and distributed rate limiting
- Permission System: Role-based access control (RBAC) with fine-grained permissions and attribute-based access control (ABAC)
- Performance Optimized: Async-first design, efficient memory usage, and optimized for high-throughput applications
- Comprehensive Testing: 514 passing tests with 100% success rate and extensive coverage of OAuth 2.1, security, and integration scenarios
- Mock Testing Framework: Built-in testing utilities with configurable mocks and test helpers
- Rich Documentation: Complete API docs, security guides, and real-world examples
- Type Safety: Leverages Rust's type system for compile-time security guarantees
- Error Handling: Comprehensive error types with detailed context and recovery suggestions
- Enhanced Reliability: OAuth 2.1 compliance, advanced security features, and comprehensive validation
AuthFramework exposes its surface through focused, discoverable accessor methods so common operations
are easy to find and autocomplete works effectively:
use auth_framework::prelude::*;
# async fn example(auth: &AuthFramework) -> Result<(), Box<dyn std::error::Error>> {
// User management
let user_id = auth.users().register("alice", "alice@example.com", "hunter2").await?;
let profile = auth.users().profile(&user_id).await?;
// Token lifecycle
let token = auth.tokens().create(&user_id, vec!["read".into()], "jwt", None).await?;
let valid = auth.tokens().validate(&token).await?;
// Authorization
let allowed = auth.authorization().check(&token, "read", "documents").await?;
// Multi-factor authentication
let secret = auth.mfa().generate_totp_secret(&user_id).await?;
// Monitoring and health
let health = auth.monitoring().health_check().await?;
// Audit log
let logs = auth.audit().permission_logs(&user_id, "read", "documents", Some(20)).await?;
# Ok(())
# }The full set of accessor groups is:
| Accessor | Purpose |
|---|---|
auth.users() |
Register, look up, and manage user accounts |
auth.sessions() |
Create, retrieve, and delete sessions |
auth.tokens() |
Issue, validate, refresh, and revoke tokens and API keys |
auth.authorization() |
Permission checks, role and policy management |
auth.mfa() |
TOTP, SMS, email, and backup-code MFA flows |
auth.monitoring() |
Health, metrics, rate-limit status |
auth.audit() |
Permission logs and security statistics |
auth.admin() |
ABAC policies, role inheritance, resource delegation |
Import auth_framework::prelude::* to bring all types into scope at once.
- π Security Audited: Comprehensive security review with no critical vulnerabilities
- π§ͺ Battle Tested: 514 passing tests with extensive integration and security testing
- β‘ Performance Validated: Benchmarked for high-throughput production environments
- π‘οΈ CVE-Free: Clean security record with proactive vulnerability management
- π Compliance Ready: GDPR, SOC 2, and enterprise compliance features built-in
- π₯ Most Complete: The ONLY Rust auth framework with full client AND server capabilities (OAuth 2.0 server, OIDC provider, SAML SP)
- π’ Enterprise Ready: Complete authorization server solution rivaling commercial products like Auth0, Okta, and AWS Cognito
- π§ Developer Friendly: Extensive documentation, examples, and testing utilities for both client and server implementations
- π Production Scale: Used by enterprises for mission-critical applications requiring custom authorization servers
- π Performance Leader: Outperforms commercial solutions with Rust's speed and memory efficiency
- π Future Proof: Designed for extensibility with support for emerging standards and protocols
Convenience constructors for device flow credentials:
use auth_framework::{Credential, OAuthProvider};
// Create device flow credential with minimal code
let credential = Credential::enhanced_device_flow(
OAuthProvider::GitHub,
"client_id",
vec!["user", "repo"]
);
// Or with a client secret if needed
let credential = Credential::enhanced_device_flow_with_secret(
OAuthProvider::Google,
"client_id",
"client_secret",
vec!["email", "profile"]
);
// Complete a device flow with a device code
let credential = Credential::enhanced_device_flow_complete(
OAuthProvider::Microsoft,
"client_id",
"device_code",
vec!["user.read"]
);Add this to your Cargo.toml:
[dependencies]
auth-framework = "0.5.0-rc18"
tokio = { version = "1.0", features = ["full"] }use auth_framework::{AuthFramework, AuthConfig};
use auth_framework::methods::{JwtMethod, AuthMethodEnum};
use std::time::Duration;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// Set environment for development/testing (allows memory storage)
std::env::set_var("ENVIRONMENT", "development");
// Configure the auth framework with required JWT secret
let jwt_secret = std::env::var("JWT_SECRET")
.unwrap_or_else(|_| "your-secure-jwt-secret-at-least-32-characters-long".to_string());
let config = AuthConfig::new()
.token_lifetime(Duration::from_secs(3600))
.refresh_token_lifetime(Duration::from_secs(86400 * 7))
.secret(jwt_secret);
// Create the auth framework (storage is handled internally)
let mut auth = AuthFramework::new(config);
// Register a JWT authentication method
let jwt_method = JwtMethod::new()
.secret_key("your-secure-jwt-secret-at-least-32-characters-long")
.issuer("your-service");
auth.register_method("jwt", AuthMethodEnum::Jwt(jwt_method));
// Initialize the framework
auth.initialize().await?;
// Create a JWT token for testing
let token = auth.create_auth_token(
"user123",
vec!["read".to_string(), "write".to_string()],
"jwt",
None,
).await?;
// Validate the token
if auth.validate_token(&token).await? {
println!("Token is valid!");
// Check permissions
if auth.check_permission(&token, "read", "documents").await? {
println!("User has permission to read documents");
}
}
Ok(())
}Build your own OAuth 2.0 authorization server in minutes:
use auth_framework::{
server::oauth::oauth2::{OAuth2Server, OAuth2ServerConfig},
storage::memory::InMemoryStorage,
client::ClientConfig,
};
use std::sync::Arc;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// Configure the OAuth 2.0 authorization server
let oauth2_config = OAuth2ServerConfig {
issuer: "https://auth.yourcompany.com".to_string(),
supported_scopes: vec![
"openid".to_string(),
"profile".to_string(),
"email".to_string(),
],
supported_response_types: vec!["code".to_string()],
supported_grant_types: vec![
"authorization_code".to_string(),
"refresh_token".to_string(),
],
};
// Create storage backend
let storage = Arc::new(InMemoryStorage::new());
// Create the OAuth 2.0 server with custom configuration
let oauth2_server = OAuth2Server::new_with_config(
storage.clone(),
oauth2_config,
).await?;
// Register a client application
let client_config = ClientConfig {
client_id: uuid::Uuid::new_v4().to_string(),
client_secret: Some("my-client-secret".to_string()),
client_type: auth_framework::ClientType::Confidential,
redirect_uris: vec!["https://myapp.com/callback".to_string()],
authorized_scopes: vec!["openid".to_string(), "profile".to_string(), "email".to_string()],
authorized_grant_types: vec!["authorization_code".to_string(), "refresh_token".to_string()],
authorized_response_types: vec!["code".to_string()],
client_name: Some("My Web App".to_string()),
client_description: Some("My company's web application".to_string()),
..Default::default()
};
let registered = oauth2_server.register_client(client_config).await?;
println!("Client registered: {}", registered.client_id);
// Get server discovery metadata
let discovery = oauth2_server.get_server_configuration().await?;
println!("Discovery: {}", discovery);
Ok(())
}Provide OpenID Connect authentication for your applications:
use auth_framework::{
server::oidc::core::{OidcConfig, OidcProvider, SubjectType},
storage::memory::InMemoryStorage,
tokens::TokenManager,
};
use std::sync::Arc;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let storage = Arc::new(InMemoryStorage::new());
let oidc_config = OidcConfig {
issuer: "https://oidc.yourcompany.com".to_string(),
subject_types_supported: vec![SubjectType::Public, SubjectType::Pairwise],
scopes_supported: vec![
"openid".to_string(),
"profile".to_string(),
"email".to_string(),
"address".to_string(),
"phone".to_string(),
],
..Default::default()
};
// Create token manager and OIDC provider
let token_manager = Arc::new(TokenManager::new("your-jwt-secret-at-least-32-chars-long!"));
let oidc_provider = OidcProvider::new(oidc_config, token_manager, storage).await?;
// Get OpenID Connect discovery document
let discovery = oidc_provider.get_discovery_document();
println!("Issuer: {}", discovery["issuer"]);
Ok(())
}Note: OAuth authentication is currently implemented through provider configurations and server components. For complete OAuth client flows, see the server examples in
examples/oauth2_authorization_server.rsandexamples/complete_oauth2_server_axum.rs.
use auth_framework::providers::OAuthProvider;
// OAuth providers are available for server implementations
let github_provider = OAuthProvider::GitHub;
let google_provider = OAuthProvider::Google;
// Build authorization URLs for OAuth flows
let auth_url = github_provider.build_authorization_url(
"your-client-id",
"<https://your-app.com/callback>",
"random-state",
Some(&["user:email".to_string()]),
None
)?;
println!("Authorization URL: {}", auth_url);
// Exchange code for tokens (server-side)
let token_response = github_provider.exchange_code(
"your-client-id",
"your-client-secret",
"authorization-code-from-callback",
"<https://your-app.com/callback>",
None
).await?;
println!("Access token: {}", token_response.access_token);use auth_framework::methods::{ApiKeyMethod, AuthMethodEnum};
// Set up API key authentication
let api_key_method = ApiKeyMethod::new()
.key_prefix("ak_")
.header_name("X-API-Key");
auth.register_method("api-key", AuthMethodEnum::ApiKey(api_key_method));
// Create an API key for a user
let api_key = auth.create_api_key("user123", Some(Duration::from_secs(86400 * 30))).await?;
println!("New API key: {}", api_key);
// Authenticate with API key
let credential = auth_framework::credentials::Credential::api_key(&api_key);
let result = auth.authenticate("api-key", credential).await?;// Enable MFA in configuration
let config = AuthConfig::new()
.enable_multi_factor(true);
// Authentication with MFA
let credential = auth_framework::credentials::Credential::password("username", "password");
let result = auth.authenticate("password", credential).await?;
match result {
auth_framework::AuthResult::MfaRequired(challenge) => {
println!("MFA required. Challenge ID: {}", challenge.id());
// User provides MFA code
let mfa_code = "123456";
let token = auth.complete_mfa(challenge, mfa_code).await?;
println!("MFA successful!");
}
auth_framework::AuthResult::Success(token) => {
println!("Direct authentication successful!");
}
auth_framework::AuthResult::Failure(reason) => {
println!("Authentication failed: {}", reason);
}
}use auth_framework::permissions::{Permission, Role, PermissionChecker};
// Permission checking is built into the AuthFramework
// Create a test token first
let token = auth.create_auth_token(
"user123",
vec!["read".to_string(), "write".to_string()],
"jwt",
None,
).await?;
// Check permissions
let can_read = auth.check_permission(&token, "read", "documents").await?;
let can_write = auth.check_permission(&token, "write", "documents").await?;
let can_delete = auth.check_permission(&token, "delete", "documents").await?;
println!("Can read: {}, Can write: {}, Can delete: {}", can_read, can_write, can_delete);Security Recommendation: Use PostgreSQL for optimal security. PostgreSQL eliminates the RUSTSEC-2023-0071 vulnerability present in MySQL storage.
use auth_framework::config::{AuthConfig, StorageConfig};
let config = AuthConfig::new()
.storage(StorageConfig::PostgreSQL {
url: "postgresql://user:password@localhost:5432/auth_db".to_string(),
max_connections: 100,
});use auth_framework::config::{AuthConfig, StorageConfig};
let config = AuthConfig::new()
.storage(StorageConfig::Redis {
url: "redis://localhost:6379".to_string(),
key_prefix: "auth:".to_string(),
});use auth_framework::storage::AuthStorage;
use auth_framework::tokens::AuthToken;
#[derive(Clone)]
struct MyCustomStorage;
#[async_trait::async_trait]
impl AuthStorage for MyCustomStorage {
async fn store_token(&self, token: &AuthToken) -> Result<()> {
// Your custom storage implementation
Ok(())
}
async fn get_token(&self, token_id: &str) -> Result<Option<AuthToken>> {
// Your implementation
Ok(None)
}
async fn delete_token(&self, token_id: &str) -> Result<()> {
// Your implementation
Ok(())
}
// Implement other required methods...
}
// Use your custom storage
let storage = Arc::new(MyCustomStorage);
let auth = AuthFramework::new(config, storage);use auth_framework::config::RateLimitConfig;
let config = AuthConfig::new()
.rate_limiting(RateLimitConfig::new(
100, // max requests
Duration::from_secs(60), // per minute
));use axum::{
extract::{Request, State},
http::StatusCode,
middleware::Next,
response::Response,
};
async fn auth_middleware(
State(auth): State<Arc<AuthFramework>>,
mut request: Request,
next: Next,
) -> Result<Response, StatusCode> {
let auth_header = request.headers()
.get("Authorization")
.and_then(|h| h.to_str().ok())
.and_then(|s| s.strip_prefix("Bearer "));
if let Some(token_str) = auth_header {
// In a real implementation, you'd need to parse the token string back to AuthToken
// This is simplified for demonstration
if token_str.starts_with("valid_") {
return Ok(next.run(request).await);
}
}
Err(StatusCode::UNAUTHORIZED)
}use actix_web::{dev::ServiceRequest, Error, HttpMessage};
use actix_web_httpauth::extractors::bearer::BearerAuth;
async fn auth_validator(
req: ServiceRequest,
credentials: BearerAuth,
) -> Result<ServiceRequest, Error> {
let auth = req.app_data::<web::Data<AuthFramework>>().unwrap();
if let Ok(Some(token)) = auth.storage.get_token_by_access_token(credentials.token()).await {
if auth.validate_token(&token).await.unwrap_or(false) {
req.extensions_mut().insert(token);
return Ok(req);
}
}
Err(AuthError::auth_method("bearer", "Invalid token").into())
}Device flow is supported through the provider implementations. See the OAuth server examples for complete device flow implementations:
use auth_framework::providers::OAuthProvider;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// Device flow is available through provider implementations
// For complete examples, see:
// - examples/oauth2_authorization_server.rs
// - examples/complete_oauth2_server_axum.rs
let provider = OAuthProvider::GitHub;
// Device flow methods are available on providers:
// provider.start_device_authorization()
// provider.poll_device_token()
// See server examples for complete implementation
println!("Check server examples for complete device flow implementation");
Ok(())
}Auth-framework provides flexible configuration management using the config crate, supporting multiple formats, environment variables, and modular organization.
- Configuration Files - TOML, YAML, JSON formats supported
- Environment Variables - Automatic mapping with customizable prefixes
- Command Line Arguments - CLI overrides using clap integration
- Include Directives - Modular configuration organization
# auth-framework.toml
[jwt]
secret_key = "${JWT_SECRET_KEY:development-secret}"
algorithm = "HS256"
expiry = "1h"
[session]
name = "AUTH_SESSION"
secure = true
domain = "myapp.com"
# Include method-specific configurations
include = [
"methods/oauth2.toml",
"methods/mfa.toml",
"methods/jwt.toml"
]use auth_framework::config::{ConfigManager, AuthFrameworkConfigManager};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// Load configuration from files and environment
let config = AuthFrameworkConfigManager::builder()
.with_file("config/auth-framework.toml")
.with_env_prefix("AUTH") // Maps AUTH_JWT_SECRET_KEY etc.
.with_cli_args() // Command line overrides
.build()?;
// Use the configuration in your auth service
let auth_service = AuthService::new(config);
Ok(())
}The framework automatically maps environment variables:
# JWT Configuration
export AUTH_JWT_SECRET_KEY="production-secret"
export AUTH_JWT_ALGORITHM="RS256"
export AUTH_JWT_EXPIRY="15m"
# OAuth2 Configuration
export AUTH_OAUTH2_GOOGLE_CLIENT_ID="your-client-id"
export AUTH_OAUTH2_GOOGLE_CLIENT_SECRET="your-secret"
# Session Configuration
export AUTH_SESSION_SECURE="true"
export AUTH_SESSION_DOMAIN="myapp.com"Organize configuration into logical modules:
config/
βββ auth-framework.toml # Main configuration with includes
βββ threat-intel.toml # Threat intelligence settings
βββ session.toml # Session management configuration
βββ methods/ # Authentication method configs
βββ oauth2.toml # OAuth2 provider settings
βββ jwt.toml # JWT method configuration
βββ mfa.toml # Multi-factor authentication
βββ api_key.toml # API key authentication
Auth-framework configuration seamlessly integrates into larger application configs:
# your-app.toml
[app]
name = "MyApplication"
version = "1.0.0"
# Include auth-framework configuration
[auth]
include = ["auth-framework.toml"]
# Override specific auth settings
[auth.jwt]
secret_key = "production-secret"
issuer = "myapp.com"For complete configuration documentation, see:
config/INTEGRATION_GUIDE.md- Parent app integration patternsconfig/EXAMPLES.md- Practical configuration examplesconfig/directory - Example modular configuration files
- Secret Management: Never hardcode secrets. Use environment variables or secure vaults.
- Token Storage: Use secure storage backends in production (PostgreSQL recommended, Redis for sessions).
- HTTPS: Always use HTTPS in production to protect tokens in transit.
- Rate Limiting: Enable rate limiting to prevent brute force attacks.
- Token Expiration: Set appropriate token lifetimes based on your security requirements.
- Audit Logging: Enable comprehensive audit logging for security monitoring.
When using RSA keys for JWT signing and verification, the framework supports both standard PEM formats:
-
PKCS#1 Format (Traditional RSA format):
-----BEGIN RSA PRIVATE KEY----- -----END RSA PRIVATE KEY----- -
PKCS#8 Format (Modern standard format, recommended):
-----BEGIN PRIVATE KEY----- -----END PRIVATE KEY-----
Both formats are automatically detected and work seamlessly with the TokenManager:
use auth_framework::tokens::TokenManager;
// Load your RSA keys (either PKCS#1 or PKCS#8 format)
let private_key = std::fs::read("private.pem")?;
let public_key = std::fs::read("public.pem")?;
// Create token manager - format is auto-detected
let token_manager = TokenManager::new_rsa(
&private_key,
&public_key,
"your-issuer",
"your-audience"
)?;Generate RSA keys in your preferred format:
# Generate PKCS#1 format (traditional)
openssl genrsa -out private.pem 2048
openssl rsa -in private.pem -pubout -out public.pem
# Generate PKCS#8 format (recommended)
openssl genpkey -algorithm RSA -out private_pkcs8.pem -pkcs8
openssl pkey -in private_pkcs8.pem -pubout -out public_spki.pemNote: No format conversion is required - the framework handles both formats automatically.
See the examples/ directory for complete client examples:
basic_usage_corrected.rs- Basic authentication setup (β working)cli_auth_tool.rs- Complete CLI authentication tool (β working)
Full OAuth 2.0 Authorization Server Examples:
oauth2_authorization_server.rs- Complete OAuth 2.0 server setup with client registrationcomplete_oauth2_server_axum.rs- Production-ready server with Axum web framework integrationproduction_deployments.rs- Enterprise deployment configurations for different environments
Server Features Demonstrated:
- β OAuth 2.0 Authorization Server - Complete RFC 6749 implementation with all grant types
- β OpenID Connect Provider - Full OIDC 1.0 support with UserInfo endpoint
- β Dynamic Client Registration - RFC 7591 compliant client management
- β Device Authorization Grant - RFC 8628 device flow for CLI applications
- β Token Introspection - RFC 7662 token introspection endpoint
- β PKCE Support - RFC 7636 for enhanced security
- β Web Framework Integration - Ready-to-use Axum, Actix Web, and Warp examples
- β Production Deployments - Enterprise, high-availability, and microservices configurations
Choose the deployment that fits your needs:
| Deployment Type | Use Case | Storage | Features |
|---|---|---|---|
| Development | Local testing | In-memory | Relaxed security, test clients |
| Single Server | Small-medium apps | PostgreSQL + Redis | Standard production features |
| High Availability | Large applications | PostgreSQL cluster + Redis | Load balancing, shared state |
| Enterprise | Fortune 500 | Encrypted storage + HSM | Advanced security, compliance |
| Microservices | Service mesh | Service discovery | Health checks, circuit breakers |
# Run a complete OAuth 2.0 authorization server
cargo run --example oauth2_authorization_server
# Run with Axum web framework integration
cargo run --example complete_oauth2_server_axum --features axum-integration
# Run enterprise deployment
DEPLOYMENT_TYPE=enterprise cargo run --example production_deploymentsNote: All server examples are production-ready and include comprehensive security features, rate limiting, audit logging, and enterprise compliance capabilities.
Contributions are welcome! Please read our Contributing Guide for details on our development process, coding standards, and how to submit pull requests.
Security is our top priority. Please review our Security Policy for:
- Reporting security vulnerabilities
- Security best practices
- Supported versions
- Compliance information
For security issues, please email security@example.com instead of using the issue tracker.
This project is licensed under the MIT OR Apache-2.0 license.
The framework provides comprehensive testing utilities to make testing your authentication logic easy:
[dev-dependencies]
auth-framework = { version = "0.5.0-rc18", features = ["testing"] }use auth_framework::{
testing::{MockAuthMethod, MockStorage, helpers},
AuthFramework, AuthConfig, Credential,
};
#[tokio::test]
async fn test_user_authentication() {
// Create a test auth framework
let mut auth = helpers::create_test_auth_framework();
// Set up a mock authentication method
let mock_method = MockAuthMethod::new_success()
.with_user("testuser".to_string(), helpers::create_test_user_profile("testuser"));
auth.register_method("mock", Box::new(mock_method));
auth.initialize().await.unwrap();
// Test authentication
let credential = Credential::password("testuser", "password");
let result = auth.authenticate("mock", credential).await.unwrap();
match result {
auth_framework::AuthResult::Success(token) => {
assert_eq!(token.user_id, "testuser");
assert!(token.scopes.contains(&"read".to_string()));
}
_ => panic!("Expected successful authentication"),
}
}
#[tokio::test]
async fn test_authentication_failure() {
let mut auth = helpers::create_test_auth_framework();
// Mock method that always fails
let mock_method = MockAuthMethod::new_failure();
auth.register_method("mock", Box::new(mock_method));
auth.initialize().await.unwrap();
let credential = Credential::password("testuser", "wrong_password");
let result = auth.authenticate("mock", credential).await.unwrap();
match result {
auth_framework::AuthResult::Failure(_) => {
// Expected
}
_ => panic!("Expected authentication failure"),
}
}
#[tokio::test]
async fn test_token_storage() {
let storage = MockStorage::new();
let token = helpers::create_test_token("testuser");
// Store and retrieve token
storage.store_token(&token).await.unwrap();
let retrieved = storage.get_token(&token.id).await.unwrap();
assert!(retrieved.is_some());
assert_eq!(retrieved.unwrap().user_id, "testuser");
}Testing Features:
MockAuthMethod- Configurable mock authenticationMockStorage- In-memory storage for testinghelpers::create_test_*- Helper functions for test data- Configurable delays and failures for testing edge cases
- Comprehensive test coverage examples
The framework provides specific error types for better error handling:
use auth_framework::{AuthError, DeviceFlowError, OAuthProviderError};
async fn handle_auth_errors() {
// Device flow specific errors
match some_device_flow_operation().await {
Err(AuthError::DeviceFlow(DeviceFlowError::AuthorizationPending)) => {
println!("User hasn't completed authorization yet");
}
Err(AuthError::DeviceFlow(DeviceFlowError::SlowDown)) => {
println!("Polling too frequently, slowing down");
}
Err(AuthError::DeviceFlow(DeviceFlowError::ExpiredToken)) => {
println!("Device code expired, need to restart flow");
}
Err(AuthError::DeviceFlow(DeviceFlowError::AccessDenied)) => {
println!("User denied authorization");
}
_ => {}
}
// OAuth provider specific errors
match some_oauth_operation().await {
Err(AuthError::OAuthProvider(OAuthProviderError::InvalidAuthorizationCode)) => {
println!("Authorization code is invalid or expired");
}
Err(AuthError::OAuthProvider(OAuthProviderError::InsufficientScope { required, granted })) => {
println!("Insufficient permissions: need '{}', got '{}'", required, granted);
}
Err(AuthError::OAuthProvider(OAuthProviderError::RateLimited { message })) => {
println!("Rate limited by provider: {}", message);
}
_ => {}
}
// General auth errors
match some_auth_operation().await {
Err(AuthError::InvalidCredential { credential_type, message }) => {
println!("Invalid {}: {}", credential_type, message);
}
Err(AuthError::Timeout { timeout_seconds }) => {
println!("Operation timed out after {} seconds", timeout_seconds);
}
Err(AuthError::ProviderNotConfigured { provider }) => {
println!("Provider '{}' is not configured", provider);
}
_ => {}
}
}OAuth providers are available for server-side implementations. See the server examples for complete provider usage:
use auth_framework::providers::{OAuthProvider, OAuthProviderConfig, UserProfile};
use std::collections::HashMap;
// Available providers for OAuth server implementations
let github_provider = OAuthProvider::GitHub;
let google_provider = OAuthProvider::Google;
let microsoft_provider = OAuthProvider::Microsoft;
// Custom provider configuration
let custom_provider = OAuthProvider::Custom {
name: "My Provider".to_string(),
config: OAuthProviderConfig {
authorization_url: "https://auth.example.com/authorize".to_string(),
token_url: "https://auth.example.com/token".to_string(),
device_authorization_url: Some("https://auth.example.com/device".to_string()),
userinfo_url: Some("https://auth.example.com/userinfo".to_string()),
revocation_url: Some("https://auth.example.com/revoke".to_string()),
default_scopes: vec!["read".to_string(), "profile".to_string()],
supports_pkce: true,
supports_refresh: true,
supports_device_flow: true,
additional_params: HashMap::new(),
},
};
// For complete OAuth server implementation examples, see:
// - examples/oauth2_authorization_server.rs
// - examples/complete_oauth2_server_axum.rsThe framework provides a standardized UserProfile type that works across all providers:
use auth_framework::providers::UserProfile;
// Creating user profiles
let profile = UserProfile::new("user123", "github")
.with_name("John Doe")
.with_email("john@example.com")
.with_email_verified(true)
.with_picture("https://github.com/avatar.jpg")
.with_locale("en-US")
.with_additional_data("github_login".to_string(), serde_json::Value::String("johndoe".to_string()));
// Converting to your application's user type
#[derive(serde::Deserialize)]
struct AppUser {
id: String,
name: String,
email: String,
avatar_url: Option<String>,
}
impl From<UserProfile> for AppUser {
fn from(profile: UserProfile) -> Self {
Self {
id: profile.id,
name: profile.name.unwrap_or_default(),
email: profile.email.unwrap_or_default(),
avatar_url: profile.picture,
}
}
}
// Usage
let app_user: AppUser = user_profile.into();Understanding the relationship between credentials and authentication methods:
use auth_framework::Credential;
// Password credentials -> PasswordMethod
let password_cred = Credential::password("username", "password");
// API key -> ApiKeyMethod
let api_key_cred = Credential::api_key("your_api_key_here");
// JWT token -> JwtMethod
let jwt_cred = Credential::jwt("jwt.token.string");
// OAuth flows are handled by the OAuth server implementation
// See server examples for complete OAuth credential handling
let device_cred = Credential::Custom {
method: "device_code".to_string(),
data: {
let mut data = HashMap::new();
data.insert("device_code".to_string(), "device_code_string".to_string());
data.insert("client_id".to_string(), "your_client_id".to_string());
data
}
};
// Multi-factor authentication
let mfa_cred = Credential::Mfa {
primary_credential: Box::new(password_cred),
mfa_code: "123456".to_string(),
challenge_id: "mfa_challenge_id".to_string(),
};
// Custom credentials for custom auth methods
let custom_cred = Credential::Custom {
method: "custom_auth".to_string(),
data: {
let mut data = HashMap::new();
data.insert("token".to_string(), "custom_token".to_string());
data.insert("signature".to_string(), "signature_string".to_string());
data
}
};Helper utilities for integrating with CLI frameworks:
[dependencies]
auth-framework = "0.5.0-rc18"
clap = "4.0"
tokio = { version = "1.0", features = ["full"] }use auth_framework::{AuthFramework, AuthConfig, Credential};
use auth_framework::providers::OAuthProvider;
use clap::{Arg, Command};
fn create_auth_command() -> Command {
Command::new("myapp")
.subcommand(
Command::new("auth")
.about("Authenticate with OAuth provider")
.arg(
Arg::new("provider")
.short('p')
.long("provider")
.value_name("PROVIDER")
.help("OAuth provider (github, google, microsoft)")
.default_value("github")
)
.arg(
Arg::new("client-id")
.long("client-id")
.value_name("CLIENT_ID")
.help("OAuth client ID")
.env("OAUTH_CLIENT_ID")
.required(true)
)
.arg(
Arg::new("device-flow")
.long("device-flow")
.help("Use device flow authentication")
.action(clap::ArgAction::SetTrue)
)
)
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let matches = create_auth_command().get_matches();
if let Some(auth_matches) = matches.subcommand_matches("auth") {
let provider = auth_matches.get_one::<String>("provider").unwrap();
let client_id = auth_matches.get_one::<String>("client-id").unwrap();
let use_device_flow = auth_matches.get_flag("device-flow");
if use_device_flow {
perform_device_flow_auth(provider, client_id).await?;
} else {
perform_web_flow_auth(provider, client_id).await?;
}
}
Ok(())
}
async fn perform_device_flow_auth(provider: &str, client_id: &str) -> Result<(), Box<dyn std::error::Error>> {
println!("π Starting device flow authentication with {}...", provider);
// Set up auth framework
let config = AuthConfig::new();
let mut auth = AuthFramework::new(config);
// OAuth providers are available for server-side implementations
let oauth_provider = match provider {
"github" => OAuthProvider::GitHub,
"google" => OAuthProvider::Google,
"microsoft" => OAuthProvider::Microsoft,
_ => return Err("Unsupported provider".into()),
};
println!("Selected provider: {:?}", oauth_provider);
// For complete OAuth server implementation, see:
// - examples/oauth2_authorization_server.rs
// - examples/complete_oauth2_server_axum.rs
println!("β
Provider configuration complete!");
Ok(())
}
async fn perform_web_flow_auth(provider: &str, client_id: &str) -> Result<(), Box<dyn std::error::Error>> {
println!("π Starting web flow authentication with {}...", provider);
// Generate authorization URL and open browser
// Implementation details...
Ok(())
}