Fixes/adds new date-time validator

Cargo.toml

@@ -12,6 +12,7 @@ csv = "1.1"
 env_logger = "0.11.7"
 jsonschema = "0.16"
 log = "0.4"
+regex = "1.10"
 reqwest = { version = "0.11", features = ["blocking"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

src/main.rs

@@ -12,6 +12,7 @@ use jsonschema::{Draft, JSONSchema};
 use serde::{Deserialize, Serialize};
 use serde_json::{json, Map, Value};
 use log::{debug, error, warn};
+use regex::Regex;
 
 // Initialize env_logger to target stderr.
 use env_logger;
@@ -49,6 +50,13 @@ struct StateMessage {
     value: Value,
 }
 
+// Custom format validator for date-time that accepts both formats with and without timezone
+fn validate_datetime(value: &str) -> bool {
+    // Regex for ISO 8601 date-time with optional timezone
+    let re = Regex::new(r"^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}(\.\d+)?(Z|[+-]\d{2}:\d{2})?$").unwrap();
+    re.is_match(value)
+}
+
 fn emit_state(state: &Option<Value>) {
     // The state message is printed to stdout.
     let state_value = state.clone().unwrap_or(json!({}));
@@ -245,6 +253,7 @@ fn persist_messages(
                 if validate {
                     let compiled = match JSONSchema::options()
                         .with_draft(Draft::Draft4)
+                        .with_format("date-time", validate_datetime)
                         .compile(&schema_message.schema)
                     {
                         Ok(schema) => schema,