authx_storage/memory/

mod.rs

use std::collections::HashMap;
use std::sync::{Arc, RwLock};

#[cfg(test)]
mod tests;

use async_trait::async_trait;
use chrono::Utc;
use uuid::Uuid;

use authx_core::{
    error::{AuthError, Result, StorageError},
    models::{
        ApiKey, AuditLog, AuthorizationCode, CreateApiKey, CreateAuditLog, CreateAuthorizationCode,
        CreateCredential, CreateDeviceCode, CreateInvite, CreateOidcClient,
        CreateOidcFederationProvider, CreateOidcToken, CreateOrg, CreateSession, CreateUser,
        Credential, CredentialKind, DeviceCode, Invite, Membership, OAuthAccount, OidcClient,
        OidcFederationProvider, OidcToken, Organization, Role, Session, UpdateUser,
        UpsertOAuthAccount, User,
    },
};

use crate::ports::{
    ApiKeyRepository, AuditLogRepository, AuthorizationCodeRepository, CredentialRepository,
    DeviceCodeRepository, InviteRepository, OAuthAccountRepository, OidcClientRepository,
    OidcFederationProviderRepository, OidcTokenRepository, OrgRepository, SessionRepository,
    UserRepository,
};

/// Acquire a read guard, recovering from a poisoned lock instead of panicking.
macro_rules! rlock {
    ($lock:expr, $label:literal) => {
        match $lock.read() {
            Ok(g) => g,
            Err(e) => {
                tracing::error!(concat!(
                    "memory store read-lock poisoned (",
                    $label,
                    ") — recovering"
                ));
                e.into_inner()
            }
        }
    };
}

/// Acquire a write guard, recovering from a poisoned lock instead of panicking.
macro_rules! wlock {
    ($lock:expr, $label:literal) => {
        match $lock.write() {
            Ok(g) => g,
            Err(e) => {
                tracing::error!(concat!(
                    "memory store write-lock poisoned (",
                    $label,
                    ") — recovering"
                ));
                e.into_inner()
            }
        }
    };
}

#[derive(Clone, Default)]
pub struct MemoryStore {
    users: Arc<RwLock<HashMap<Uuid, User>>>,
    sessions: Arc<RwLock<HashMap<Uuid, Session>>>,
    credentials: Arc<RwLock<Vec<Credential>>>,
    audit_logs: Arc<RwLock<Vec<AuditLog>>>,
    orgs: Arc<RwLock<HashMap<Uuid, Organization>>>,
    roles: Arc<RwLock<HashMap<Uuid, Role>>>,
    memberships: Arc<RwLock<Vec<Membership>>>,
    api_keys: Arc<RwLock<Vec<ApiKey>>>,
    oauth_accounts: Arc<RwLock<Vec<OAuthAccount>>>,
    invites: Arc<RwLock<Vec<Invite>>>,
    oidc_clients: Arc<RwLock<Vec<OidcClient>>>,
    authorization_codes: Arc<RwLock<Vec<AuthorizationCode>>>,
    oidc_tokens: Arc<RwLock<Vec<OidcToken>>>,
    oidc_federation_providers: Arc<RwLock<Vec<OidcFederationProvider>>>,
    device_codes: Arc<RwLock<Vec<DeviceCode>>>,
}

impl MemoryStore {
    pub fn new() -> Self {
        Self::default()
    }
}

// ── UserRepository ────────────────────────────────────────────────────────────

#[async_trait]
impl UserRepository for MemoryStore {
    async fn find_by_id(&self, id: Uuid) -> Result<Option<User>> {
        Ok(rlock!(self.users, "users").get(&id).cloned())
    }

    async fn find_by_email(&self, email: &str) -> Result<Option<User>> {
        Ok(rlock!(self.users, "users")
            .values()
            .find(|u| u.email == email)
            .cloned())
    }

    async fn find_by_username(&self, username: &str) -> Result<Option<User>> {
        Ok(rlock!(self.users, "users")
            .values()
            .find(|u| u.username.as_deref() == Some(username))
            .cloned())
    }

    async fn list(&self, offset: u32, limit: u32) -> Result<Vec<User>> {
        let users = rlock!(self.users, "users");
        let mut sorted: Vec<User> = users.values().cloned().collect();
        sorted.sort_by_key(|u| u.created_at);
        Ok(sorted
            .into_iter()
            .skip(offset as usize)
            .take(limit as usize)
            .collect())
    }

    async fn create(&self, data: CreateUser) -> Result<User> {
        let mut users = wlock!(self.users, "users");
        if users.values().any(|u| u.email == data.email) {
            return Err(AuthError::EmailTaken);
        }
        if let Some(ref uname) = data.username {
            if users
                .values()
                .any(|u| u.username.as_deref() == Some(uname.as_str()))
            {
                return Err(AuthError::Storage(StorageError::Conflict(format!(
                    "username '{}' already taken",
                    uname
                ))));
            }
        }
        let user = User {
            id: Uuid::new_v4(),
            email: data.email,
            email_verified: false,
            username: data.username,
            created_at: Utc::now(),
            updated_at: Utc::now(),
            metadata: data.metadata.unwrap_or(serde_json::Value::Null),
        };
        users.insert(user.id, user.clone());
        Ok(user)
    }

    async fn update(&self, id: Uuid, data: UpdateUser) -> Result<User> {
        let mut users = wlock!(self.users, "users");
        let user = users.get_mut(&id).ok_or(AuthError::UserNotFound)?;
        if let Some(email) = data.email {
            user.email = email;
        }
        if let Some(verified) = data.email_verified {
            user.email_verified = verified;
        }
        if let Some(uname) = data.username {
            user.username = Some(uname);
        }
        if let Some(meta) = data.metadata {
            user.metadata = meta;
        }
        user.updated_at = Utc::now();
        Ok(user.clone())
    }

    async fn delete(&self, id: Uuid) -> Result<()> {
        wlock!(self.users, "users")
            .remove(&id)
            .ok_or(AuthError::UserNotFound)?;
        Ok(())
    }
}

// ── SessionRepository ─────────────────────────────────────────────────────────

#[async_trait]
impl SessionRepository for MemoryStore {
    async fn create(&self, data: CreateSession) -> Result<Session> {
        let session = Session {
            id: Uuid::new_v4(),
            user_id: data.user_id,
            token_hash: data.token_hash,
            device_info: data.device_info,
            ip_address: data.ip_address,
            org_id: data.org_id,
            expires_at: data.expires_at,
            created_at: Utc::now(),
        };
        wlock!(self.sessions, "sessions").insert(session.id, session.clone());
        Ok(session)
    }

    async fn find_by_token_hash(&self, hash: &str) -> Result<Option<Session>> {
        Ok(rlock!(self.sessions, "sessions")
            .values()
            .find(|s| s.token_hash == hash && s.expires_at > Utc::now())
            .cloned())
    }

    async fn find_by_user(&self, user_id: Uuid) -> Result<Vec<Session>> {
        Ok(rlock!(self.sessions, "sessions")
            .values()
            .filter(|s| s.user_id == user_id)
            .cloned()
            .collect())
    }

    async fn invalidate(&self, session_id: Uuid) -> Result<()> {
        wlock!(self.sessions, "sessions")
            .remove(&session_id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        Ok(())
    }

    async fn invalidate_all_for_user(&self, user_id: Uuid) -> Result<()> {
        wlock!(self.sessions, "sessions").retain(|_, s| s.user_id != user_id);
        Ok(())
    }

    async fn set_org(&self, session_id: Uuid, org_id: Option<Uuid>) -> Result<Session> {
        let mut sessions = wlock!(self.sessions, "sessions");
        let session = sessions
            .get_mut(&session_id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        session.org_id = org_id;
        Ok(session.clone())
    }
}

// ── CredentialRepository ──────────────────────────────────────────────────────

#[async_trait]
impl CredentialRepository for MemoryStore {
    async fn create(&self, data: CreateCredential) -> Result<Credential> {
        let cred = Credential {
            id: Uuid::new_v4(),
            user_id: data.user_id,
            kind: data.kind,
            credential_hash: data.credential_hash,
            metadata: data.metadata.unwrap_or(serde_json::Value::Null),
        };
        wlock!(self.credentials, "credentials").push(cred.clone());
        Ok(cred)
    }

    async fn find_password_hash(&self, user_id: Uuid) -> Result<Option<String>> {
        Ok(rlock!(self.credentials, "credentials")
            .iter()
            .find(|c| c.user_id == user_id && c.kind == CredentialKind::Password)
            .map(|c| c.credential_hash.clone()))
    }

    async fn find_by_user_and_kind(
        &self,
        user_id: Uuid,
        kind: CredentialKind,
    ) -> Result<Option<Credential>> {
        Ok(rlock!(self.credentials, "credentials")
            .iter()
            .find(|c| c.user_id == user_id && c.kind == kind)
            .cloned())
    }

    async fn delete_by_user_and_kind(&self, user_id: Uuid, kind: CredentialKind) -> Result<()> {
        let mut creds = wlock!(self.credentials, "credentials");
        let before = creds.len();
        creds.retain(|c| !(c.user_id == user_id && c.kind == kind));
        if creds.len() == before {
            return Err(AuthError::Storage(StorageError::NotFound));
        }
        Ok(())
    }
}

// ── OrgRepository ─────────────────────────────────────────────────────────────

#[async_trait]
impl OrgRepository for MemoryStore {
    async fn create(&self, data: CreateOrg) -> Result<Organization> {
        let mut orgs = wlock!(self.orgs, "orgs");
        if orgs.values().any(|o| o.slug == data.slug) {
            return Err(AuthError::Storage(StorageError::Conflict(format!(
                "slug '{}' already taken",
                data.slug
            ))));
        }
        let org = Organization {
            id: Uuid::new_v4(),
            name: data.name,
            slug: data.slug,
            metadata: data.metadata.unwrap_or(serde_json::Value::Null),
            created_at: Utc::now(),
        };
        orgs.insert(org.id, org.clone());
        Ok(org)
    }

    async fn find_by_id(&self, id: Uuid) -> Result<Option<Organization>> {
        Ok(rlock!(self.orgs, "orgs").get(&id).cloned())
    }

    async fn find_by_slug(&self, slug: &str) -> Result<Option<Organization>> {
        Ok(rlock!(self.orgs, "orgs")
            .values()
            .find(|o| o.slug == slug)
            .cloned())
    }

    async fn add_member(&self, org_id: Uuid, user_id: Uuid, role_id: Uuid) -> Result<Membership> {
        let role = rlock!(self.roles, "roles")
            .get(&role_id)
            .cloned()
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        let membership = Membership {
            id: Uuid::new_v4(),
            user_id,
            org_id,
            role,
            created_at: Utc::now(),
        };
        wlock!(self.memberships, "memberships").push(membership.clone());
        Ok(membership)
    }

    async fn remove_member(&self, org_id: Uuid, user_id: Uuid) -> Result<()> {
        let mut memberships = wlock!(self.memberships, "memberships");
        let before = memberships.len();
        memberships.retain(|m| !(m.org_id == org_id && m.user_id == user_id));
        if memberships.len() == before {
            return Err(AuthError::Storage(StorageError::NotFound));
        }
        Ok(())
    }

    async fn get_members(&self, org_id: Uuid) -> Result<Vec<Membership>> {
        Ok(rlock!(self.memberships, "memberships")
            .iter()
            .filter(|m| m.org_id == org_id)
            .cloned()
            .collect())
    }

    async fn find_roles(&self, org_id: Uuid) -> Result<Vec<Role>> {
        Ok(rlock!(self.roles, "roles")
            .values()
            .filter(|r| r.org_id == org_id)
            .cloned()
            .collect())
    }

    async fn create_role(
        &self,
        org_id: Uuid,
        name: String,
        permissions: Vec<String>,
    ) -> Result<Role> {
        let role = Role {
            id: Uuid::new_v4(),
            org_id,
            name,
            permissions,
        };
        wlock!(self.roles, "roles").insert(role.id, role.clone());
        Ok(role)
    }

    async fn update_member_role(
        &self,
        org_id: Uuid,
        user_id: Uuid,
        role_id: Uuid,
    ) -> Result<Membership> {
        let role = rlock!(self.roles, "roles")
            .get(&role_id)
            .cloned()
            .ok_or(AuthError::Storage(StorageError::NotFound))?;

        let mut memberships = wlock!(self.memberships, "memberships");
        let m = memberships
            .iter_mut()
            .find(|m| m.org_id == org_id && m.user_id == user_id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        m.role = role;
        Ok(m.clone())
    }
}

// ── AuditLogRepository ────────────────────────────────────────────────────────

#[async_trait]
impl AuditLogRepository for MemoryStore {
    async fn append(&self, entry: CreateAuditLog) -> Result<AuditLog> {
        let log = AuditLog {
            id: Uuid::new_v4(),
            user_id: entry.user_id,
            org_id: entry.org_id,
            action: entry.action,
            resource_type: entry.resource_type,
            resource_id: entry.resource_id,
            ip_address: entry.ip_address,
            metadata: entry.metadata.unwrap_or(serde_json::Value::Null),
            created_at: Utc::now(),
        };
        wlock!(self.audit_logs, "audit_logs").push(log.clone());
        Ok(log)
    }

    async fn find_by_user(&self, user_id: Uuid, limit: u32) -> Result<Vec<AuditLog>> {
        Ok(rlock!(self.audit_logs, "audit_logs")
            .iter()
            .filter(|l| l.user_id == Some(user_id))
            .take(limit as usize)
            .cloned()
            .collect())
    }

    async fn find_by_org(&self, org_id: Uuid, limit: u32) -> Result<Vec<AuditLog>> {
        Ok(rlock!(self.audit_logs, "audit_logs")
            .iter()
            .filter(|l| l.org_id == Some(org_id))
            .take(limit as usize)
            .cloned()
            .collect())
    }
}

// ── ApiKeyRepository ──────────────────────────────────────────────────────────

#[async_trait]
impl ApiKeyRepository for MemoryStore {
    async fn create(&self, data: CreateApiKey) -> Result<ApiKey> {
        let key = ApiKey {
            id: Uuid::new_v4(),
            user_id: data.user_id,
            org_id: data.org_id,
            key_hash: data.key_hash,
            prefix: data.prefix,
            name: data.name,
            scopes: data.scopes,
            expires_at: data.expires_at,
            last_used_at: None,
        };
        wlock!(self.api_keys, "api_keys").push(key.clone());
        Ok(key)
    }

    async fn find_by_hash(&self, key_hash: &str) -> Result<Option<ApiKey>> {
        Ok(rlock!(self.api_keys, "api_keys")
            .iter()
            .find(|k| k.key_hash == key_hash)
            .cloned())
    }

    async fn find_by_user(&self, user_id: Uuid) -> Result<Vec<ApiKey>> {
        Ok(rlock!(self.api_keys, "api_keys")
            .iter()
            .filter(|k| k.user_id == user_id)
            .cloned()
            .collect())
    }

    async fn revoke(&self, key_id: Uuid, user_id: Uuid) -> Result<()> {
        let mut keys = wlock!(self.api_keys, "api_keys");
        let before = keys.len();
        keys.retain(|k| !(k.id == key_id && k.user_id == user_id));
        if keys.len() == before {
            return Err(AuthError::Storage(StorageError::NotFound));
        }
        Ok(())
    }

    async fn touch_last_used(&self, key_id: Uuid, at: chrono::DateTime<Utc>) -> Result<()> {
        let mut keys = wlock!(self.api_keys, "api_keys");
        if let Some(k) = keys.iter_mut().find(|k| k.id == key_id) {
            k.last_used_at = Some(at);
        }
        Ok(())
    }
}

// ── OAuthAccountRepository ────────────────────────────────────────────────────

#[async_trait]
impl OAuthAccountRepository for MemoryStore {
    async fn upsert(&self, data: UpsertOAuthAccount) -> Result<OAuthAccount> {
        let mut accounts = wlock!(self.oauth_accounts, "oauth_accounts");
        if let Some(existing) = accounts
            .iter_mut()
            .find(|a| a.provider == data.provider && a.provider_user_id == data.provider_user_id)
        {
            existing.access_token_enc = data.access_token_enc;
            existing.refresh_token_enc = data.refresh_token_enc;
            existing.expires_at = data.expires_at;
            return Ok(existing.clone());
        }
        let account = OAuthAccount {
            id: Uuid::new_v4(),
            user_id: data.user_id,
            provider: data.provider,
            provider_user_id: data.provider_user_id,
            access_token_enc: data.access_token_enc,
            refresh_token_enc: data.refresh_token_enc,
            expires_at: data.expires_at,
        };
        accounts.push(account.clone());
        Ok(account)
    }

    async fn find_by_provider(
        &self,
        provider: &str,
        provider_user_id: &str,
    ) -> Result<Option<OAuthAccount>> {
        Ok(rlock!(self.oauth_accounts, "oauth_accounts")
            .iter()
            .find(|a| a.provider == provider && a.provider_user_id == provider_user_id)
            .cloned())
    }

    async fn find_by_user(&self, user_id: Uuid) -> Result<Vec<OAuthAccount>> {
        Ok(rlock!(self.oauth_accounts, "oauth_accounts")
            .iter()
            .filter(|a| a.user_id == user_id)
            .cloned()
            .collect())
    }

    async fn delete(&self, id: Uuid) -> Result<()> {
        let mut accounts = wlock!(self.oauth_accounts, "oauth_accounts");
        let before = accounts.len();
        accounts.retain(|a| a.id != id);
        if accounts.len() == before {
            return Err(AuthError::Storage(StorageError::NotFound));
        }
        Ok(())
    }
}

// ── InviteRepository ──────────────────────────────────────────────────────────

#[async_trait]
impl InviteRepository for MemoryStore {
    async fn create(&self, data: CreateInvite) -> Result<Invite> {
        let invite = Invite {
            id: Uuid::new_v4(),
            org_id: data.org_id,
            email: data.email,
            role_id: data.role_id,
            token_hash: data.token_hash,
            expires_at: data.expires_at,
            accepted_at: None,
        };
        wlock!(self.invites, "invites").push(invite.clone());
        Ok(invite)
    }

    async fn find_by_token_hash(&self, hash: &str) -> Result<Option<Invite>> {
        Ok(rlock!(self.invites, "invites")
            .iter()
            .find(|i| i.token_hash == hash)
            .cloned())
    }

    async fn accept(&self, invite_id: Uuid) -> Result<Invite> {
        let mut invites = wlock!(self.invites, "invites");
        let invite = invites
            .iter_mut()
            .find(|i| i.id == invite_id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        invite.accepted_at = Some(Utc::now());
        Ok(invite.clone())
    }

    async fn delete_expired(&self) -> Result<u64> {
        let mut invites = wlock!(self.invites, "invites");
        let before = invites.len();
        let now = Utc::now();
        invites.retain(|i| i.accepted_at.is_some() || i.expires_at > now);
        Ok((before - invites.len()) as u64)
    }
}

// ── OidcClientRepository ───────────────────────────────────────────────────────

#[async_trait]
impl OidcClientRepository for MemoryStore {
    async fn create(&self, data: CreateOidcClient) -> Result<OidcClient> {
        let client_id = Uuid::new_v4().to_string();
        let client = OidcClient {
            id: Uuid::new_v4(),
            client_id: client_id.clone(),
            secret_hash: data.secret_hash,
            name: data.name,
            redirect_uris: data.redirect_uris,
            grant_types: data.grant_types,
            response_types: data.response_types,
            allowed_scopes: data.allowed_scopes,
            created_at: Utc::now(),
        };
        wlock!(self.oidc_clients, "oidc_clients").push(client.clone());
        Ok(client)
    }

    async fn find_by_client_id(&self, client_id: &str) -> Result<Option<OidcClient>> {
        Ok(rlock!(self.oidc_clients, "oidc_clients")
            .iter()
            .find(|c| c.client_id == client_id)
            .cloned())
    }

    async fn list(&self, offset: u32, limit: u32) -> Result<Vec<OidcClient>> {
        let clients = rlock!(self.oidc_clients, "oidc_clients");
        Ok(clients
            .iter()
            .skip(offset as usize)
            .take(limit as usize)
            .cloned()
            .collect())
    }
}

// ── AuthorizationCodeRepository ────────────────────────────────────────────────

#[async_trait]
impl AuthorizationCodeRepository for MemoryStore {
    async fn create(&self, data: CreateAuthorizationCode) -> Result<AuthorizationCode> {
        let code = AuthorizationCode {
            id: Uuid::new_v4(),
            code_hash: data.code_hash,
            client_id: data.client_id,
            user_id: data.user_id,
            redirect_uri: data.redirect_uri,
            scope: data.scope,
            nonce: data.nonce,
            code_challenge: data.code_challenge,
            expires_at: data.expires_at,
            used: false,
        };
        wlock!(self.authorization_codes, "authorization_codes").push(code.clone());
        Ok(code)
    }

    async fn find_by_code_hash(&self, hash: &str) -> Result<Option<AuthorizationCode>> {
        let now = Utc::now();
        Ok(rlock!(self.authorization_codes, "authorization_codes")
            .iter()
            .find(|c| c.code_hash == hash && c.expires_at > now && !c.used)
            .cloned())
    }

    async fn mark_used(&self, id: Uuid) -> Result<()> {
        let mut codes = wlock!(self.authorization_codes, "authorization_codes");
        let code = codes
            .iter_mut()
            .find(|c| c.id == id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        code.used = true;
        Ok(())
    }

    async fn delete_expired(&self) -> Result<u64> {
        let mut codes = wlock!(self.authorization_codes, "authorization_codes");
        let before = codes.len();
        let now = Utc::now();
        codes.retain(|c| c.expires_at > now);
        Ok((before - codes.len()) as u64)
    }
}

// ── OidcTokenRepository ────────────────────────────────────────────────────────

#[async_trait]
impl OidcTokenRepository for MemoryStore {
    async fn create(&self, data: CreateOidcToken) -> Result<OidcToken> {
        let token = OidcToken {
            id: Uuid::new_v4(),
            token_hash: data.token_hash,
            client_id: data.client_id,
            user_id: data.user_id,
            scope: data.scope,
            token_type: data.token_type,
            expires_at: data.expires_at,
            revoked: false,
            created_at: Utc::now(),
        };
        wlock!(self.oidc_tokens, "oidc_tokens").push(token.clone());
        Ok(token)
    }

    async fn find_by_token_hash(&self, hash: &str) -> Result<Option<OidcToken>> {
        let now = Utc::now();
        Ok(rlock!(self.oidc_tokens, "oidc_tokens")
            .iter()
            .find(|t| {
                t.token_hash == hash && !t.revoked && t.expires_at.map(|e| e > now).unwrap_or(true)
            })
            .cloned())
    }

    async fn revoke(&self, id: Uuid) -> Result<()> {
        let mut tokens = wlock!(self.oidc_tokens, "oidc_tokens");
        let t = tokens
            .iter_mut()
            .find(|t| t.id == id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        t.revoked = true;
        Ok(())
    }

    async fn revoke_all_for_user_client(&self, user_id: Uuid, client_id: &str) -> Result<()> {
        for t in wlock!(self.oidc_tokens, "oidc_tokens")
            .iter_mut()
            .filter(|t| t.user_id == user_id && t.client_id == client_id)
        {
            t.revoked = true;
        }
        Ok(())
    }
}

// ── OidcFederationProviderRepository ──────────────────────────────────────────

#[async_trait]
impl OidcFederationProviderRepository for MemoryStore {
    async fn create(&self, data: CreateOidcFederationProvider) -> Result<OidcFederationProvider> {
        let provider = OidcFederationProvider {
            id: Uuid::new_v4(),
            name: data.name,
            issuer: data.issuer,
            client_id: data.client_id,
            secret_enc: data.secret_enc,
            scopes: data.scopes,
            org_id: data.org_id,
            enabled: true,
            created_at: Utc::now(),
            claim_mapping: data.claim_mapping,
        };
        wlock!(self.oidc_federation_providers, "oidc_federation_providers").push(provider.clone());
        Ok(provider)
    }

    async fn find_by_id(&self, id: Uuid) -> Result<Option<OidcFederationProvider>> {
        Ok(
            rlock!(self.oidc_federation_providers, "oidc_federation_providers")
                .iter()
                .find(|p| p.id == id)
                .cloned(),
        )
    }

    async fn find_by_name(&self, name: &str) -> Result<Option<OidcFederationProvider>> {
        Ok(
            rlock!(self.oidc_federation_providers, "oidc_federation_providers")
                .iter()
                .find(|p| p.name == name)
                .cloned(),
        )
    }

    async fn list_enabled(&self) -> Result<Vec<OidcFederationProvider>> {
        Ok(
            rlock!(self.oidc_federation_providers, "oidc_federation_providers")
                .iter()
                .filter(|p| p.enabled)
                .cloned()
                .collect(),
        )
    }
}

// ── DeviceCodeRepository ─────────────────────────────────────────────────────

#[async_trait]
impl DeviceCodeRepository for MemoryStore {
    async fn create(&self, data: CreateDeviceCode) -> Result<DeviceCode> {
        let dc = DeviceCode {
            id: Uuid::new_v4(),
            device_code_hash: data.device_code_hash,
            user_code_hash: data.user_code_hash,
            user_code: data.user_code,
            client_id: data.client_id,
            scope: data.scope,
            expires_at: data.expires_at,
            interval_secs: data.interval_secs,
            authorized: false,
            denied: false,
            user_id: None,
            last_polled_at: None,
        };
        wlock!(self.device_codes, "device_codes").push(dc.clone());
        Ok(dc)
    }

    async fn find_by_device_code_hash(&self, hash: &str) -> Result<Option<DeviceCode>> {
        let now = Utc::now();
        Ok(rlock!(self.device_codes, "device_codes")
            .iter()
            .find(|d| d.device_code_hash == hash && d.expires_at > now)
            .cloned())
    }

    async fn find_by_user_code_hash(&self, hash: &str) -> Result<Option<DeviceCode>> {
        let now = Utc::now();
        Ok(rlock!(self.device_codes, "device_codes")
            .iter()
            .find(|d| d.user_code_hash == hash && d.expires_at > now && !d.authorized && !d.denied)
            .cloned())
    }

    async fn authorize(&self, id: Uuid, user_id: Uuid) -> Result<()> {
        let mut codes = wlock!(self.device_codes, "device_codes");
        let dc = codes
            .iter_mut()
            .find(|d| d.id == id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        dc.authorized = true;
        dc.user_id = Some(user_id);
        Ok(())
    }

    async fn deny(&self, id: Uuid) -> Result<()> {
        let mut codes = wlock!(self.device_codes, "device_codes");
        let dc = codes
            .iter_mut()
            .find(|d| d.id == id)
            .ok_or(AuthError::Storage(StorageError::NotFound))?;
        dc.denied = true;
        Ok(())
    }

    async fn update_last_polled(&self, id: Uuid, interval_secs: u32) -> Result<()> {
        let mut codes = wlock!(self.device_codes, "device_codes");
        if let Some(dc) = codes.iter_mut().find(|d| d.id == id) {
            dc.last_polled_at = Some(Utc::now());
            dc.interval_secs = interval_secs;
        }
        Ok(())
    }

    async fn delete(&self, id: Uuid) -> Result<()> {
        let mut codes = wlock!(self.device_codes, "device_codes");
        codes.retain(|d| d.id != id);
        Ok(())
    }

    async fn delete_expired(&self) -> Result<u64> {
        let mut codes = wlock!(self.device_codes, "device_codes");
        let before = codes.len();
        let now = Utc::now();
        codes.retain(|d| d.expires_at > now);
        Ok((before - codes.len()) as u64)
    }

    async fn list_by_client(
        &self,
        client_id: &str,
        offset: u32,
        limit: u32,
    ) -> Result<Vec<DeviceCode>> {
        Ok(rlock!(self.device_codes, "device_codes")
            .iter()
            .filter(|d| d.client_id == client_id)
            .skip(offset as usize)
            .take(limit as usize)
            .cloned()
            .collect())
    }
}