Function extract_user

src/middleware.rs:25–58

(
    State(state): State<Arc<AppState>>,
    cookies: Cookies,
    mut req: Request<B>,
    next: Next<B>,
)

}

pub async fn extract_user<B>(
    State(state): State<Arc<AppState>>,
    cookies: Cookies,
    mut req: Request<B>,
    next: Next<B>,
) -> Result<Response, StatusCode>
where
    B: Send + 'static,
{
    let session = cookies.get("rust-gpt-session");

    let id = session.map_or(-1, |x| x.value().parse::<i64>().unwrap_or(-1));

    // Get the user
    match sqlx::query_as!(
        User,
        "SELECT users.*, settings.openai_api_key FROM users LEFT JOIN settings ON settings.user_id=users.id WHERE users.id = $1",
        id
    )
    .fetch_one(&*state.pool)
    .await
    {
        Ok(current_user) => {
            // insert the current user into a request extension so the handler can
            // extract it, and make sure `user` is not used after this point
            req.extensions_mut().insert(Some(current_user));
            Ok(next.run(req).await)
        }
        _ => {
            req.extensions_mut().insert(None::<User>);
            Ok(next.run(req).await)
        }
    }
}

pub async fn auth<B>(
    Extension(current_user): Extension<Option<User>>,