athena_rs 3.18.0

Hyper performant polyglot Database driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! Shared request context helpers for schema catalog route handlers.
//!
//! This module centralizes request-scoped schema-client pool resolution so
//! endpoint handlers stay focused on input normalization and response flow.

use actix_web::{HttpRequest, HttpResponse};
use sqlx::{Pool, Postgres};

use crate::AppState;

use super::context_pool_resolver::require_schema_client_pool;

/// Resolves and returns the schema client pool for request-scoped catalog calls.
pub(super) async fn require_schema_pool(
    req: &HttpRequest,
    app_state: &AppState,
) -> Result<Pool<Postgres>, HttpResponse> {
    let (_client_name, pool): (String, Pool<Postgres>) =
        match require_schema_client_pool(req, app_state).await {
            Ok(resolved) => resolved,
            Err(resp) => return Err(resp),
        };
    Ok(pool)
}