Function geometry_to_value

nodedb/src/data/executor/handlers/spatial_sync.rs:205–268

Convert a `Geometry` into a `nodedb_types::Value` for msgpack serialisation. Produces a JSON-compatible nested structure matching what a pgwire INSERT with a GeoJSON geometry value would produce.

(geometry: &Geometry)

/// Produces a JSON-compatible nested structure matching what a pgwire INSERT
/// with a GeoJSON geometry value would produce.
fn geometry_to_value(geometry: &Geometry) -> nodedb_types::Value {
    use nodedb_types::Value;
    use nodedb_types::geometry::Geometry::*;

    match geometry {
        Point { coordinates } => {
            let mut m = std::collections::HashMap::new();
            m.insert("type".to_string(), Value::String("Point".to_string()));
            m.insert(
                "coordinates".to_string(),
                Value::Array(vec![
                    Value::Float(coordinates[0]),
                    Value::Float(coordinates[1]),
                ]),
            );
            Value::Object(m)
        }
        LineString { coordinates } => {
            let mut m = std::collections::HashMap::new();
            m.insert("type".to_string(), Value::String("LineString".to_string()));
            m.insert(
                "coordinates".to_string(),
                Value::Array(
                    coordinates
                        .iter()
                        .map(|c| Value::Array(vec![Value::Float(c[0]), Value::Float(c[1])]))
                        .collect(),
                ),
            );
            Value::Object(m)
        }
        Polygon { coordinates } => {
            let mut m = std::collections::HashMap::new();
            m.insert("type".to_string(), Value::String("Polygon".to_string()));
            m.insert(
                "coordinates".to_string(),
                Value::Array(
                    coordinates
                        .iter()
                        .map(|ring| {
                            Value::Array(
                                ring.iter()
                                    .map(|c| {
                                        Value::Array(vec![Value::Float(c[0]), Value::Float(c[1])])
                                    })
                                    .collect(),
                            )
                        })
                        .collect(),
                ),
            );
            Value::Object(m)
        }
        // For other geometry types, fall back to JSON serialisation then
        // parse as Value. These are less common in sync workloads.
        other => match sonic_rs::to_string(other) {
            Ok(json) => match sonic_rs::from_str::<serde_json::Value>(&json) {
                Ok(v) => nodedb_types::conversion::json_to_value(v),