foundry-rs 0.6.9

Configuration-driven REST backend library for Rust with PostgreSQL — define schemas, tables, and APIs in JSON, get a production-grade REST service.
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! Extract tenant id from request (e.g. X-Tenant-ID header).

use async_trait::async_trait;
use axum::{extract::FromRequestParts, http::request::Parts};

/// Header name for tenant id. Default: `X-Tenant-ID`.
pub const TENANT_ID_HEADER: &str = "X-Tenant-ID";

/// Header name for Platform-Admin tenant impersonation. Default: `X-Act-As-Tenant`.
pub const ACT_AS_TENANT_HEADER: &str = "X-Act-As-Tenant";

/// Read, trim, and non-empty-filter a header value.
fn header_value(parts: &Parts, name: &str) -> Option<String> {
    parts
        .headers
        .get(name)
        .and_then(|v: &axum::http::HeaderValue| v.to_str().ok())
        .map(|s: &str| s.trim().to_string())
        .filter(|s: &String| !s.is_empty())
}

/// Extractor for optional tenant id from `X-Tenant-ID` header.
#[derive(Clone, Debug)]
pub struct TenantId(pub Option<String>);

#[async_trait]
impl<S> FromRequestParts<S> for TenantId
where
    S: Send + Sync,
{
    type Rejection = std::convert::Infallible;

    async fn from_request_parts(parts: &mut Parts, _state: &S) -> Result<Self, Self::Rejection> {
        Ok(TenantId(header_value(parts, TENANT_ID_HEADER)))
    }
}

/// Extractor for the optional Platform-Admin impersonation header `X-Act-As-Tenant`. When set by the
/// Platform Admin, the request runs as the named tenant (see `resolve_tenant_context`). Ignored for
/// non-admin callers (rejected there with 403).
#[derive(Clone, Debug)]
pub struct ActAsTenant(pub Option<String>);

#[async_trait]
impl<S> FromRequestParts<S> for ActAsTenant
where
    S: Send + Sync,
{
    type Rejection = std::convert::Infallible;

    async fn from_request_parts(parts: &mut Parts, _state: &S) -> Result<Self, Self::Rejection> {
        Ok(ActAsTenant(header_value(parts, ACT_AS_TENANT_HEADER)))
    }
}