athena_rs 0.83.0

Database gateway API
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68

//! Public HTTP API routes for Athena RS.
//!
//! This module wires REST endpoints for the router registry and query execution.
//!
//! ## Endpoints
//!
//! - `GET /router/registry` - Retrieve all Athena router registry entries

use actix_files::NamedFile;
use actix_web::{Responder, get};
// use tracing::info;

pub mod admin;
pub mod auth;
pub mod cache;
pub mod gateway;
pub mod headers;
pub mod health;
pub mod metrics;
pub mod pg_meta;
pub mod pipelines;
pub mod query;
pub mod registry;
pub mod response;
pub mod schema;
pub mod supabase;

// crate imports
use crate::data::athena_router::list_athena_router_entries;
use response::{api_ok, internal_error};

/// List Athena router registry entries.
///
/// Fetches all router entries from the Athena router registry and returns them as a JSON response.
///
/// # Returns
///
/// Returns an HTTP response containing either:
/// - Success (200): A JSON array of all router entries
/// - Error (500): An error message if the fetch operation fails
#[get("/router/registry")]
pub async fn athena_router_registry() -> impl Responder {
    match list_athena_router_entries().await {
        Ok(entries) => api_ok(entries),
        Err(err) => internal_error("Failed to list router entries", err),
    }
}

/// Serves the bundled `openapi.yaml` so clients can download the latest spec.
///
/// Returns `500 Internal Server Error` if the file cannot be read (which should not happen
/// in production, since the file is packaged with the binary).
#[get("/openapi.yaml")]
pub async fn athena_openapi_host() -> actix_web::Result<NamedFile> {
    NamedFile::open("openapi.yaml").map_err(|err| {
        actix_web::error::ErrorInternalServerError(format!("Failed to open openapi.yaml: {}", err))
    })
}

/// Redirects `/docs` to the public Athena documentation site.
///
/// Issues a 308 permanent redirect so browsers/crawlers can follow the canonical documentation URL.
#[get("/docs")]
pub async fn athena_docs() -> impl Responder {
    actix_web::HttpResponse::PermanentRedirect()
        .insert_header(("Location", "https://xylex.group/docs/athena"))
        .finish()
}