robotech 1.5.0

Backend service implementation for the RoboTech platform, providing RESTful APIs and business logic for web applications.
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

use axum::extract::ConnectInfo;
use axum::{
    extract::{Request, State},
    http::StatusCode,
    middleware::Next,
    response::{IntoResponse, Response},
};
use std::net::SocketAddr;
use std::sync::Arc;
use wheel_rs::urn_utils::Urn;

#[derive(Clone)]
pub struct LocalOnlyUrnsState {
    pub(crate) local_only_urns: Arc<Vec<Urn>>,
}

pub async fn local_only_urns_middleware(
    State(state): State<LocalOnlyUrnsState>,
    ConnectInfo(addr): ConnectInfo<SocketAddr>,
    request: Request,
    next: Next,
) -> Response {
    let request_method = request.method().to_string().to_uppercase();
    let request_uri = request.uri().path();

    if !addr.ip().is_loopback()
        && state
            .local_only_urns
            .iter()
            .any(|local_only_urn| local_only_urn.matches(&request_method, request_uri))
    {
        return StatusCode::FORBIDDEN.into_response();
    }

    next.run(request).await
}