chore: release version 4.2.8

Author: Philip Z

Cargo.lock

@@ -18,7 +18,7 @@ members = [
 resolver = "2"
 
 [workspace.package]
-version = "4.2.7"
+version = "4.2.8"
 edition = "2024"
 license = "Apache-2.0"
 authors = ["Philip"]
@@ -42,12 +42,12 @@ proc-macro2 = "1"
 quote = "1"
 syn = { version = "2", features = ["full", "extra-traits"] }
 
-teaql-core = { path = "teaql-core", version = "4.2.7" }
-teaql-macros = { path = "teaql-macros", version = "4.2.7" }
-teaql-runtime = { path = "teaql-runtime", version = "4.2.7" }
-teaql-sql = { path = "teaql-sql", version = "4.2.7" }
-teaql-provider-sqlite = { path = "teaql-provider-sqlite", version = "4.2.7" }
-teaql-provider-postgres = { path = "teaql-provider-postgres", version = "4.2.7" }
-teaql-provider-mysql = { path = "teaql-provider-mysql", version = "4.2.7" }
-teaql-data-service = { path = "teaql-data-service", version = "4.2.7" }
-teaql-provider-linux = { path = "teaql-provider-linux", version = "4.2.7" }
+teaql-core = { path = "teaql-core", version = "4.2.8" }
+teaql-macros = { path = "teaql-macros", version = "4.2.8" }
+teaql-runtime = { path = "teaql-runtime", version = "4.2.8" }
+teaql-sql = { path = "teaql-sql", version = "4.2.8" }
+teaql-provider-sqlite = { path = "teaql-provider-sqlite", version = "4.2.8" }
+teaql-provider-postgres = { path = "teaql-provider-postgres", version = "4.2.8" }
+teaql-provider-mysql = { path = "teaql-provider-mysql", version = "4.2.8" }
+teaql-data-service = { path = "teaql-data-service", version = "4.2.8" }
+teaql-provider-linux = { path = "teaql-provider-linux", version = "4.2.8" }

Cargo.toml

@@ -3,7 +3,7 @@ use std::str::FromStr;
 
 use chrono::{DateTime, NaiveDate, Utc};
 pub use rust_decimal::Decimal;
-use rust_decimal::prelude::{FromPrimitive, ToPrimitive};
+use rust_decimal::prelude::ToPrimitive;
 
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 pub enum DataType {

teaql-core/src/value.rs

@@ -764,11 +764,16 @@ mod tests {
 
     #[test]
     fn decimal_bind_is_numeric_and_comparable() {
-        let value = bind_sqlite_value(&Value::Decimal(Decimal::from_str("123.450").unwrap())).unwrap();
+        let value =
+            bind_sqlite_value(&Value::Decimal(Decimal::from_str("123.450").unwrap())).unwrap();
         assert_eq!(value, SqliteValue::Text("123.450".to_owned()));
         let connection = Connection::open_in_memory().unwrap();
         let matches: i64 = connection
-            .query_row("SELECT 1 WHERE CAST(? AS NUMERIC) BETWEEN 120 AND 130", [value], |row| row.get(0))
+            .query_row(
+                "SELECT 1 WHERE CAST(? AS NUMERIC) BETWEEN 120 AND 130",
+                [value],
+                |row| row.get(0),
+            )
             .unwrap();
         assert_eq!(matches, 1);
     }

teaql-provider-sqlite/src/lib.rs

@@ -412,7 +412,11 @@ where
                 ensure_initial_version(&mut node.values, descriptor);
                 crate::data_service::helpers::ensure_timestamps(&mut node.values, descriptor, true);
             } else {
-                crate::data_service::helpers::ensure_timestamps(&mut node.values, descriptor, false);
+                crate::data_service::helpers::ensure_timestamps(
+                    &mut node.values,
+                    descriptor,
+                    false,
+                );
             }
             let update_fields = is_update
                 .then(|| {
@@ -1216,7 +1220,8 @@ where
     pub(crate) async fn execute_ledger_plan_internal(
         &self,
         root: crate::EntityRoot,
-    ) -> Result<std::collections::BTreeMap<crate::EntityKey, Value>, DataServiceError<E::Error>> {
+    ) -> Result<std::collections::BTreeMap<crate::EntityKey, Value>, DataServiceError<E::Error>>
+    {
         let mut generated_ids = std::collections::BTreeMap::new();
         let comment = root.get_comment();
         let trace_chain = comment
@@ -1307,7 +1312,6 @@ where
         let mut insert_order: Vec<String> = insert_batches.keys().cloned().collect();
         insert_order.sort();
 
-
         for entity in insert_order {
             let keys = insert_batches.get(&entity).unwrap();
             let descriptor = self
@@ -1323,7 +1327,10 @@ where
                 let mut db_record = Record::new();
                 let mut real_id = key.id.clone();
                 if crate::data_service::helpers::is_unassigned_id_value(&real_id) {
-                    let gen_id = self.data_service.metadata.context
+                    let gen_id = self
+                        .data_service
+                        .metadata
+                        .context
                         .next_id(&entity)
                         .map_err(DataServiceError::Runtime)?;
                     real_id = Value::U64(gen_id);
@@ -1346,7 +1353,6 @@ where
         let mut update_order: Vec<(String, String)> = update_batches.keys().cloned().collect();
         update_order.sort();
 
-
         for signature in update_order {
             let keys = update_batches.get(&signature).unwrap();
             let descriptor = self
@@ -1357,7 +1363,12 @@ where
                 .map_err(DataServiceError::Runtime)?;
             let mut update_fields: Vec<String> =
                 signature.1.split(',').map(|s| s.to_string()).collect();
-            if descriptor.properties.iter().any(|p| p.name == "update_time") && !update_fields.contains(&"update_time".to_owned()) {
+            if descriptor
+                .properties
+                .iter()
+                .any(|p| p.name == "update_time")
+                && !update_fields.contains(&"update_time".to_owned())
+            {
                 update_fields.push("update_time".to_owned());
             }
             let mut cmd = teaql_core::BatchUpdateCommand::new(&descriptor.name, update_fields);

teaql-runtime/src/data_service/graph.rs

@@ -142,10 +142,9 @@ pub(super) fn ensure_initial_version(record: &mut Record, descriptor: &EntityDes
 
 pub(super) fn ensure_timestamps(record: &mut Record, descriptor: &EntityDescriptor, is_new: bool) {
     let now = Value::Timestamp(teaql_core::time::Timestamp::now());
-    let has_property = |name: &str| -> bool {
-        descriptor.properties.iter().any(|p| p.name == name)
-    };
-    
+    let has_property =
+        |name: &str| -> bool { descriptor.properties.iter().any(|p| p.name == name) };
+
     if is_new && has_property("create_time") {
         let needs_time = match record.get("create_time") {
             None | Some(Value::Null) => true,
@@ -156,7 +155,7 @@ pub(super) fn ensure_timestamps(record: &mut Record, descriptor: &EntityDescript
             record.insert("create_time".to_owned(), now.clone());
         }
     }
-    
+
     if has_property("update_time") {
         let needs_time = match record.get("update_time") {
             None | Some(Value::Null) => true,

teaql-runtime/src/data_service/helpers.rs

@@ -85,16 +85,21 @@ where
             let eds = ctx
                 .entity_data_service::<E>(&entity)
                 .map_err(|e| RuntimeError::Graph(e.to_string()))?;
-            let generated_ids = eds.execute_ledger_plan_internal(root)
-                .await
-                .map_err(|e| match e {
-                    DataServiceError::Runtime(r) => r,
-                    other => RuntimeError::Graph(other.to_string()),
-                })?;
-                
+            let generated_ids =
+                eds.execute_ledger_plan_internal(root)
+                    .await
+                    .map_err(|e| match e {
+                        DataServiceError::Runtime(r) => r,
+                        other => RuntimeError::Graph(other.to_string()),
+                    })?;
+
             let descriptor = ctx.require_entity(&entity).unwrap();
             if let Some(id_prop) = descriptor.id_property() {
-                let current_id = node.values.get(&id_prop.name).cloned().unwrap_or(Value::I64(0));
+                let current_id = node
+                    .values
+                    .get(&id_prop.name)
+                    .cloned()
+                    .unwrap_or(Value::I64(0));
                 let root_key = crate::EntityKey::new(entity.clone(), current_id);
                 if let Some(new_id) = generated_ids.get(&root_key) {
                     node.values.insert(id_prop.name.clone(), new_id.clone());

teaql-runtime/src/entity_save.rs

@@ -153,4 +153,3 @@ pub(crate) fn local_id_generator() -> &'static AtomicCounterIdGenerator {
     static LOCAL_ID_GENERATOR: OnceLock<AtomicCounterIdGenerator> = OnceLock::new();
     LOCAL_ID_GENERATOR.get_or_init(AtomicCounterIdGenerator::default)
 }
-

teaql-runtime/src/id.rs

@@ -1230,9 +1230,10 @@ mod tests {
         let events = Arc::new(Mutex::new(Vec::new()));
         let safe_events = Arc::new(Mutex::new(Vec::new()));
         let mut ctx = UserContext::new()
-            .with_metadata(InMemoryMetadataStore::new().with_entity(
-                entity().audit_mask_fields(vec!["name".to_owned()]),
-            ))
+            .with_metadata(
+                InMemoryMetadataStore::new()
+                    .with_entity(entity().audit_mask_fields(vec!["name".to_owned()])),
+            )
             .with_entity_registry(InMemoryEntityRegistry::new().with_entity("Order"))
             .with_internal_id_generator(FixedIdGenerator(88))
             .with_event_sink(RecordingEventSink {

teaql-runtime/src/lib.rs

@@ -169,7 +169,11 @@ mod tests {
                     .partition_by("order_id"),
             )
             .unwrap();
-        assert_eq!(query.sql.matches("\"id\"").count(), 2, "one projection and one window order");
+        assert_eq!(
+            query.sql.matches("\"id\"").count(),
+            2,
+            "one projection and one window order"
+        );
         assert!(!query.sql.contains("\"id\", \"order_id\", \"id\""));
     }