espresso_api/generated/

espresso.api.v2.rest.rs

// Auto-generated REST routes from proto `google.api.http` annotations.
//
// **Do not edit** - regenerated by `build.rs` when proto files change.
//
// Each handler transcodes HTTP/JSON <-> proto and calls the Tonic service trait,
// sharing auth, validation, and business logic with gRPC handlers.

use std::sync::Arc;

use axum::extract::{Json, Query, State};
use axum::http::HeaderMap;
use axum::Router;

// =============================================================================
// StatusService REST routes
// =============================================================================

/// Build Axum REST routes for `StatusService`.
///
/// Generated from `google.api.http` annotations in `proto.proto`.
pub fn status_service_rest_router<S>(service: Arc<S>) -> Router
where
    S: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
{
    Router::new()
        .route("/v2/status/block-height", axum::routing::get(rest_status_service_get_block_height::<S>))
        .route("/v2/status/success-rate", axum::routing::get(rest_status_service_get_success_rate::<S>))
        .route("/v2/status/time-since-last-decide", axum::routing::get(rest_status_service_get_time_since_last_decide::<S>))
        .route("/v2/status/keys", axum::routing::get(rest_status_service_get_node_keys::<S>))
        .with_state(service)
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetBlockHeight` - JSON endpoint.
///
/// `GET /v2/status/block-height`
async fn rest_status_service_get_block_height<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetBlockHeightRequest>,
) -> Result<Json<crate::proto::BlockHeightResponse>, tonic_rest::RestError>
where
    S: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_block_height(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetSuccessRate` - JSON endpoint.
///
/// `GET /v2/status/success-rate`
async fn rest_status_service_get_success_rate<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetSuccessRateRequest>,
) -> Result<Json<crate::proto::SuccessRateResponse>, tonic_rest::RestError>
where
    S: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_success_rate(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetTimeSinceLastDecide` - JSON endpoint.
///
/// `GET /v2/status/time-since-last-decide`
async fn rest_status_service_get_time_since_last_decide<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetTimeSinceLastDecideRequest>,
) -> Result<Json<crate::proto::TimeSinceLastDecideResponse>, tonic_rest::RestError>
where
    S: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_time_since_last_decide(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetNodeKeys` - JSON endpoint.
///
/// `GET /v2/status/keys`
async fn rest_status_service_get_node_keys<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetNodeKeysRequest>,
) -> Result<Json<crate::proto::NodeKeysResponse>, tonic_rest::RestError>
where
    S: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_node_keys(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

// =============================================================================
// TokenService REST routes
// =============================================================================

/// Build Axum REST routes for `TokenService`.
///
/// Generated from `google.api.http` annotations in `proto.proto`.
pub fn token_service_rest_router<S>(service: Arc<S>) -> Router
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    Router::new()
        .route("/v2/token/total-minted-supply", axum::routing::get(rest_token_service_get_total_minted_supply::<S>))
        .route("/v2/token/circulating-supply", axum::routing::get(rest_token_service_get_circulating_supply::<S>))
        .route("/v2/token/circulating-supply-ethereum", axum::routing::get(rest_token_service_get_circulating_supply_ethereum::<S>))
        .route("/v2/token/total-issued-supply", axum::routing::get(rest_token_service_get_total_issued_supply::<S>))
        .route("/v2/token/total-reward-distributed", axum::routing::get(rest_token_service_get_total_reward_distributed::<S>))
        .with_state(service)
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetTotalMintedSupply` - JSON endpoint.
///
/// `GET /v2/token/total-minted-supply`
async fn rest_token_service_get_total_minted_supply<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetTotalMintedSupplyRequest>,
) -> Result<Json<crate::proto::TotalMintedSupplyResponse>, tonic_rest::RestError>
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_total_minted_supply(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetCirculatingSupply` - JSON endpoint.
///
/// `GET /v2/token/circulating-supply`
async fn rest_token_service_get_circulating_supply<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetCirculatingSupplyRequest>,
) -> Result<Json<crate::proto::CirculatingSupplyResponse>, tonic_rest::RestError>
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_circulating_supply(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetCirculatingSupplyEthereum` - JSON endpoint.
///
/// `GET /v2/token/circulating-supply-ethereum`
async fn rest_token_service_get_circulating_supply_ethereum<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetCirculatingSupplyEthereumRequest>,
) -> Result<Json<crate::proto::CirculatingSupplyEthereumResponse>, tonic_rest::RestError>
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_circulating_supply_ethereum(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetTotalIssuedSupply` - JSON endpoint.
///
/// `GET /v2/token/total-issued-supply`
async fn rest_token_service_get_total_issued_supply<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetTotalIssuedSupplyRequest>,
) -> Result<Json<crate::proto::TotalIssuedSupplyResponse>, tonic_rest::RestError>
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_total_issued_supply(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}

#[expect(clippy::too_many_arguments, clippy::needless_pass_by_value)]
/// `GetTotalRewardDistributed` - JSON endpoint.
///
/// `GET /v2/token/total-reward-distributed`
async fn rest_token_service_get_total_reward_distributed<S>(
    State(service): State<Arc<S>>,
    headers: HeaderMap,
    Query(body): Query<crate::proto::GetTotalRewardDistributedRequest>,
) -> Result<Json<crate::proto::TotalRewardDistributedResponse>, tonic_rest::RestError>
where
    S: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    let req = tonic_rest::build_tonic_request::<_, ()>(body, &headers, None);
    let response = service.get_total_reward_distributed(req).await.map_err(tonic_rest::RestError::from)?;
    Ok(Json(response.into_inner()))
}


// =============================================================================
// Public REST paths (bypass auth middleware)
// =============================================================================

/// REST paths that are marked as public (no authentication required).
///
/// Auto-generated from `google.api.http` annotations on public RPC methods.
/// Used by middleware to identify unauthenticated endpoints.
pub const PUBLIC_REST_PATHS: &[&str] = &[
];

// =============================================================================
// Combined REST router
// =============================================================================

/// Build a combined Axum router with REST routes for all proto services.
///
/// Each service is generic - pass your concrete implementations as `Arc<T>`.
pub fn all_rest_routes<S0, S1>(
    status_service: Arc<S0>,
    token_service: Arc<S1>,
) -> Router
where
    S0: crate::proto::status_service_server::StatusService + Send + Sync + 'static,
    S1: crate::proto::token_service_server::TokenService + Send + Sync + 'static,
{
    Router::new()
        .merge(status_service_rest_router(status_service))
        .merge(token_service_rest_router(token_service))
}