ceres-server 0.7.0

REST API server for Ceres harvesting, embedding, and search workflows
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! Dataset endpoints.

use axum::{
    Json,
    extract::{Path, State},
};
use uuid::Uuid;

use ceres_core::DatasetStore;

use crate::dto::{DatasetResponse, DatasetSchemaResponse};
use crate::error::ApiError;
use crate::state::AppState;

/// Get a dataset by ID.
///
/// Returns dataset details including source-specific raw metadata after
/// configured sensitive keys are removed recursively. The `metadata` shape is
/// source-specific and best-effort, and is not a stable resource/distribution
/// contract. Use `GET /api/v1/datasets/{id}/schema` for normalized resource
/// metadata.
#[utoipa::path(
    get,
    path = "/api/v1/datasets/{id}",
    params(
        ("id" = Uuid, Path, description = "Dataset UUID")
    ),
    responses(
        (status = 200, description = "Dataset found", body = DatasetResponse),
        (status = 404, description = "Dataset not found"),
        (status = 500, description = "Internal server error"),
    ),
    tag = "datasets"
)]
pub async fn get_dataset_by_id(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
) -> Result<Json<DatasetResponse>, ApiError> {
    let dataset = state
        .dataset_repo
        .get_by_id(id)
        .await
        .map_err(ApiError::from)?
        .ok_or_else(|| ApiError::NotFound(format!("Dataset not found: {}", id)))?;

    let mut response = DatasetResponse::from(dataset);
    state.metadata_redactor.redact(&mut response.metadata);

    Ok(Json(response))
}

/// Get the resource schema for a dataset.
///
/// Returns the supported, normalized resource/distribution contract (format,
/// media type, access URL, description, and column-level fields when the
/// portal exposed them), derived on read from harvested raw metadata.
#[utoipa::path(
    get,
    path = "/api/v1/datasets/{id}/schema",
    params(
        ("id" = Uuid, Path, description = "Dataset UUID")
    ),
    responses(
        (status = 200, description = "Normalized resource schema", body = DatasetSchemaResponse),
        (status = 404, description = "Dataset not found"),
        (status = 500, description = "Internal server error"),
    ),
    tag = "datasets"
)]
pub async fn get_dataset_schema(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
) -> Result<Json<DatasetSchemaResponse>, ApiError> {
    let dataset = state
        .dataset_repo
        .get_by_id(id)
        .await
        .map_err(ApiError::from)?
        .ok_or_else(|| ApiError::NotFound(format!("Dataset not found: {}", id)))?;

    Ok(Json(DatasetSchemaResponse::from(dataset)))
}