entertainarr-adapter-http 0.1.1

use entertainarr_domain::auth::prelude::{AuthenticationService, VerifyError};

use crate::server::handler::error::ApiErrorResponse;

#[derive(Clone, Copy, Debug)]
pub struct CurrentUser(pub u64);

impl<S> axum::extract::FromRequestParts<S> for CurrentUser
where
    S: crate::server::prelude::ServerState,
{
    type Rejection = ApiErrorResponse;

    async fn from_request_parts(
        parts: &mut axum::http::request::Parts,
        state: &S,
    ) -> Result<Self, Self::Rejection> {
        if let Some(authorization) = parts.headers.get(axum::http::header::AUTHORIZATION) {
            let authorization = authorization.to_str().map_err(|err| {
                tracing::warn!(error = ?err, "unable to read authorization token");
                ApiErrorResponse::unauthorized("unable to read authorization header")
            })?;
            let authorization = authorization.strip_prefix("Bearer ").ok_or_else(|| {
                ApiErrorResponse::unauthorized("authorization header format invalid")
            })?;
            state
                .authentication_service()
                .verify(authorization)
                .await
                .map(|profile| CurrentUser(profile.id))
                .map_err(|err| match err {
                    VerifyError::ExpiredToken => {
                        ApiErrorResponse::unauthorized("authorization token expired")
                    }
                    VerifyError::InvalidToken => {
                        ApiErrorResponse::unauthorized("authorization token invalid")
                    }
                    VerifyError::Internal(inner) => {
                        tracing::error!(error = ?inner, "unable to verify token");
                        ApiErrorResponse::unauthorized("authorization token invalid")
                    }
                })
        } else {
            Err(ApiErrorResponse::unauthorized(
                "authorization header not found",
            ))
        }
    }
}