parse_rust_server/

lib.rs

//! Parse Server as a library: router, middleware, config.
//!
//! **A library first, with a thin binary on top.** Native Rust triggers require the deployment
//! to compile its own binary, and adapters are registered through a builder rather than resolved
//! from a module name, so the primary artifact is something you link against. `parse-rust-cli`
//! is a separate package rather than a feature of this one: feature unification means a sibling
//! crate enabling a `cli` feature would pull its dependencies back in even for an embedder that
//! set `default-features = false`, and a separate package cannot be re-enabled by anyone else's
//! feature choice.
//!
//! Scope today: `/health` and `/serverInfo`; signup, login, `/users/me` and logout; the five
//! `/classes` verbs and the five `/roles` verbs; the five `/schemas` verbs and
//! `DELETE /purge/:className`, all master-key only; four `/sessions` reads; and `POST /batch`.
//! Everything else answers 404.
//!
//! **Two things are resolved once per HTTP request and shared by every operation in it**: the
//! schema snapshot and the caller's expanded role list. See [`request`]. A `/batch` of twenty
//! writes therefore expands roles once and cannot see two different schemas mid-flight, which is
//! a correctness property rather than a performance one.
//!
//! **An embedder that builds the router itself must call [`AppState::ensure_indexes`] first.**
//! [`serve`] does it for you. Mounting [`router`] into your own axum app does not, and without
//! those indexes duplicate usernames are accepted silently, which is a data problem rather than
//! an error anyone sees.

#![forbid(unsafe_code)]
#![cfg_attr(
    not(test),
    deny(clippy::unwrap_used, clippy::expect_used, clippy::panic)
)]

pub mod auth;
pub mod body_credentials;
pub mod config;
pub mod cors;
pub mod params;
pub mod request;
pub mod response;
pub mod routes;
pub mod state;

use std::sync::Arc;

use axum::extract::FromRequestParts;
use axum::response::{IntoResponse, Response};
use axum::routing::{delete, get, post};
use axum::Router;

pub use auth::{Authority, Credentials, HeaderRejection};
pub use config::{ProtectedFieldsConfig, ServerConfig};
pub use request::RequestContext;
pub use state::AppState;

/// Extract [`Authority`] from request headers.
///
/// Implemented as an extractor so a route cannot forget it: a handler that wants to know who is
/// calling has to name `Authority` in its signature, and one that does not name it cannot
/// accidentally read a half-validated identity off the request.
#[axum::async_trait]
impl<S> FromRequestParts<S> for Authority
where
    Arc<ServerConfig>: axum::extract::FromRef<S>,
    S: Send + Sync,
{
    type Rejection = Response;

    async fn from_request_parts(
        parts: &mut http::request::Parts,
        state: &S,
    ) -> Result<Self, Self::Rejection> {
        let config = <Arc<ServerConfig> as axum::extract::FromRef<S>>::from_ref(state);
        auth::resolve(&config, &parts.headers).map_err(|HeaderRejection::Unauthorized| {
            response::HttpError::unauthorized().into_response()
        })
    }
}

/// Build the router.
///
/// The mount path is applied here, from config, and is never inferred from the request path.
pub fn router(state: AppState) -> Router {
    let mount = state.config().mount_path.clone();
    // Cloned before `with_state` consumes it below, so the CORS layer can read the same config.
    let cors_state = state.clone();

    // The 0.2.0 surface, and nothing else: anything not registered here is a 404. Every route
    // that a client can reach through a `_method` override also accepts `POST`, because the
    // JavaScript SDK transports everything that way.
    let api = Router::new()
        .route("/serverInfo", get(routes::http::server_info))
        // `/health` is credential-free upstream and is the endpoint every bring-up script polls.
        // The SDK transports even a health check as POST with `_method: "GET"`, so accepting
        // only GET returned 405 to `Parse.getServerHealth()`.
        .route(
            "/health",
            get(routes::http::health).post(routes::http::health),
        )
        // Users. `POST /users` is signup and is deliberately not reachable through /classes.
        .route("/users", post(routes::http::users_collection))
        .route(
            "/users/me",
            get(routes::http::users_me).post(routes::http::users_me),
        )
        .route("/login", post(routes::http::login))
        .route("/logout", post(routes::http::logout))
        // Classes.
        .route(
            "/classes/:className",
            get(routes::http::classes_collection).post(routes::http::classes_collection),
        )
        .route(
            "/classes/:className/:objectId",
            get(routes::http::classes_object)
                .put(routes::http::classes_object)
                .delete(routes::http::classes_object)
                .post(routes::http::classes_object),
        )
        // Roles: `ClassesRouter` with `className()` pinned to `_Role` (`RolesRouter.js:3-25`).
        .route(
            "/roles",
            get(routes::http::roles_collection).post(routes::http::roles_collection),
        )
        .route(
            "/roles/:objectId",
            get(routes::http::roles_object)
                .put(routes::http::roles_object)
                .delete(routes::http::roles_object)
                .post(routes::http::roles_object),
        )
        // Sessions. `/sessions/me` is registered before `/sessions/:objectId` because upstream
        // depends on registration order (`SessionsRouter.js:113-121`). axum matches a literal
        // segment ahead of a parameter regardless, which the route tests assert; the order is
        // kept anyway so the two files read the same way.
        .route(
            "/sessions/me",
            get(routes::http::sessions_me).post(routes::http::sessions_me),
        )
        .route(
            "/sessions",
            get(routes::http::sessions_collection).post(routes::http::sessions_collection),
        )
        .route(
            "/sessions/:objectId",
            get(routes::http::sessions_object)
                .delete(routes::http::sessions_object)
                .post(routes::http::sessions_object),
        )
        // Schemas and purge, master key only.
        .route(
            "/schemas",
            get(routes::http::schemas_collection).post(routes::http::schemas_collection),
        )
        .route(
            "/schemas/:className",
            get(routes::http::schemas_class)
                .post(routes::http::schemas_class)
                .put(routes::http::schemas_class)
                .delete(routes::http::schemas_class),
        )
        .route(
            "/purge/:className",
            delete(routes::http::purge).post(routes::http::purge),
        )
        .route("/batch", post(routes::http::batch))
        .with_state(state);

    // The normalization layer wraps the *whole* router rather than the routes inside it, because
    // it rewrites the request method. A layer applied to the inner router runs after axum has
    // already matched on the original method, which turns the SDK's `POST` plus `_method: "PUT"`
    // into a 405 instead of an update.
    // CORS is the outermost layer, matching upstream, where `allowCrossDomain` is the first
    // middleware on the router (`ParseServer.ts:312`). Outermost is what makes the headers appear
    // on error responses too, and what lets an `OPTIONS` preflight be answered before anything
    // downstream can reject it for lacking credentials it is not allowed to send yet.
    Router::new()
        .nest(&mount, api)
        .layer(axum::middleware::from_fn(body_credentials::extract))
        .layer(axum::middleware::from_fn_with_state(
            cors_state,
            cors::layer,
        ))
}

/// Bind and serve. Returns the bound address, which matters when the caller asked for port 0.
///
/// Creates the unique indexes before binding. That used to live in the binary, which meant an
/// embedder got a server whose `_User` collection accepted duplicate usernames: the write
/// succeeded, no error reached the client, and the collision only surfaced later as two accounts
/// answering to one name. Index creation is part of boot upstream too, so doing it here matches
/// rather than extends. A failure is fatal for the same reason it is fatal upstream.
pub async fn serve(
    state: AppState,
    addr: std::net::SocketAddr,
) -> std::io::Result<(
    std::net::SocketAddr,
    impl std::future::Future<Output = std::io::Result<()>>,
)> {
    state
        .ensure_indexes()
        .await
        .map_err(|e| std::io::Error::other(e.to_string()))?;
    let listener = tokio::net::TcpListener::bind(addr).await?;
    let bound = listener.local_addr()?;
    let app = router(state);
    Ok((bound, async move { axum::serve(listener, app).await }))
}