oxigdal-services 0.1.4

OGC Web Services (WFS, WCS, WPS, CSW) for OxiGDAL
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

//! CSW (Catalog Service for the Web) 2.0.2 implementation
//!
//! Provides OGC-compliant Catalog Service supporting:
//! - GetCapabilities: Service metadata
//! - GetRecords: Metadata search
//! - GetRecordById: Metadata retrieval
//!
//! # Standards
//!
//! - OGC CSW 2.0.2

pub mod capabilities;
pub mod records;

use crate::error::{ServiceError, ServiceResult};
use axum::{
    extract::{Query, State},
    response::Response,
};
use serde::Deserialize;
use std::sync::Arc;

/// CSW service state
#[derive(Clone)]
pub struct CswState {
    /// Service metadata
    pub service_info: Arc<ServiceInfo>,
    /// Metadata records
    pub records: Arc<dashmap::DashMap<String, MetadataRecord>>,
}

/// Service metadata
#[derive(Debug, Clone)]
pub struct ServiceInfo {
    /// Service title
    pub title: String,
    /// Service abstract/description
    pub abstract_text: Option<String>,
    /// Service provider
    pub provider: String,
    /// Service URL
    pub service_url: String,
    /// Supported versions
    pub versions: Vec<String>,
}

/// Metadata record
#[derive(Debug, Clone)]
pub struct MetadataRecord {
    /// Record identifier
    pub identifier: String,
    /// Record title
    pub title: String,
    /// Record abstract/description
    pub abstract_text: Option<String>,
    /// Keywords
    pub keywords: Vec<String>,
    /// Bounding box (minx, miny, maxx, maxy)
    pub bbox: Option<(f64, f64, f64, f64)>,
}

/// CSW request parameters
#[derive(Debug, Deserialize)]
#[serde(rename_all = "UPPERCASE")]
pub struct CswRequest {
    /// Service name (must be "CSW")
    pub service: Option<String>,
    /// CSW version
    pub version: Option<String>,
    /// Request operation
    pub request: String,
    /// Additional parameters
    #[serde(flatten)]
    pub params: serde_json::Value,
}

impl CswState {
    /// Create new CSW service state
    pub fn new(service_info: ServiceInfo) -> Self {
        Self {
            service_info: Arc::new(service_info),
            records: Arc::new(dashmap::DashMap::new()),
        }
    }

    /// Add a metadata record
    pub fn add_record(&self, record: MetadataRecord) -> ServiceResult<()> {
        self.records.insert(record.identifier.clone(), record);
        Ok(())
    }
}

/// Main CSW request handler
pub async fn handle_csw_request(
    State(state): State<CswState>,
    Query(params): Query<CswRequest>,
) -> Result<Response, ServiceError> {
    if let Some(ref service) = params.service {
        if service.to_uppercase() != "CSW" {
            return Err(ServiceError::InvalidParameter(
                "SERVICE".to_string(),
                format!("Expected 'CSW', got '{}'", service),
            ));
        }
    }

    match params.request.to_uppercase().as_str() {
        "GETCAPABILITIES" => {
            let version = params.version.as_deref().unwrap_or("2.0.2");
            capabilities::handle_get_capabilities(&state, version).await
        }
        "GETRECORDS" => {
            let version = params.version.as_deref().unwrap_or("2.0.2");
            records::handle_get_records(&state, version, &params.params).await
        }
        "GETRECORDBYID" => {
            let version = params.version.as_deref().unwrap_or("2.0.2");
            records::handle_get_record_by_id(&state, version, &params.params).await
        }
        _ => Err(ServiceError::UnsupportedOperation(params.request.clone())),
    }
}