convert core data types from api gateway

Author: KSDaemon

rust/cubeorchestrator/Cargo.lock

@@ -4,7 +4,10 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+chrono = "0.4.38"
 cubeshared = { path = "../cubeshared" }
+serde = { version = "1.0.215", features = ["derive"] }
+serde_json = "1.0.133"
 
 [dependencies.neon]
 version = "=1"

rust/cubeorchestrator/Cargo.toml

@@ -0,0 +1,15 @@
+use chrono::SecondsFormat;
+use crate::types::{DBResponsePrimitive, DBResponseValue};
+
+pub fn transform_value(value: DBResponseValue, type_: &str) -> DBResponsePrimitive {
+    match value {
+        DBResponseValue::DateTime(dt) if type_ == "time" || type_.is_empty() => {
+            let formatted = dt.to_rfc3339_opts(SecondsFormat::Millis, true);
+            DBResponsePrimitive::String(formatted)
+        }
+        DBResponseValue::Primitive(p) => p,
+        DBResponseValue::Object { value } => value,
+        _ => DBResponsePrimitive::Null,
+    }
+}
+

rust/cubeorchestrator/src/cubestore_result_transform.rs

@@ -1 +1,3 @@
 pub mod cubestore_message_parser;
+pub mod cubestore_result_transform;
+pub mod types;