weftgraph 0.1.0

Graph Storage gear: typed, multi-tenant knowledge graph with search and traversal over a pluggable store
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

//! The `OData` binding of the node projection.
//!
//! Filtering, ordering and pagination are the platform's: the filter fields
//! are declared once on the row DTO, mapped to columns here, and
//! `paginate_odata` composes them with the `CursorV1` continuation token. The
//! gear invents no second dialect, so `$filter` can never reach a column this
//! mapping does not name.

use sea_orm::Value;
use toolkit_db::odata::{FieldToColumn, ODataFieldMapping};

use crate::infra::storage::entity::node;
use graph_storage_sdk::models::NodeFilterField as Field;

pub struct NodeODataMapper;

impl FieldToColumn<Field> for NodeODataMapper {
    type Column = node::Column;

    fn map_field(field: Field) -> node::Column {
        match field {
            Field::NodeKey => node::Column::NodeKey,
            Field::Name => node::Column::Name,
            Field::CreatedAt => node::Column::CreatedAt,
            Field::UpdatedAt => node::Column::UpdatedAt,
        }
    }
}

impl ODataFieldMapping<Field> for NodeODataMapper {
    type Entity = node::Entity;

    fn extract_cursor_value(model: &node::Model, field: Field) -> Value {
        match field {
            Field::NodeKey => Value::String(Some(model.node_key.clone())),
            Field::Name => Value::String(Some(model.name.clone())),
            Field::CreatedAt => Value::TimeDateTimeWithTimeZone(Some(model.created_at)),
            Field::UpdatedAt => Value::TimeDateTimeWithTimeZone(Some(model.updated_at)),
        }
    }
}