feat: convert timestamp to rfc3339

Author: d-perl

Cargo.lock

@@ -4,6 +4,7 @@ version = "0.1.0"
 edition = "2024"
 
 [dependencies]
+chrono = "0.4.41"
 clap = { version = "4.5.42", features = ["derive"] }
 elasticsearch = "9.0.0-alpha.1"
 redis = "0.32.4"

Cargo.toml

@@ -18,9 +18,14 @@ fn elastic_client(config: &ElasticConfig) -> Result<Elasticsearch, Box<dyn Error
 
 /// Convert a LogRecord to the document we want Elastic to ingest
 fn json_from_logrecord(record: &LogRecord) -> Result<serde_json::Value, serde_json::Error> {
-    // Currently a naive implementation but could be:
-    // serde_json::json!({"field_a": record.a, "field_b": record.b, etc...})
-    dbg!(serde_json::to_value(record))
+    // dbg!(serde_json::to_value(record))
+    dbg!(Ok(serde_json::json!({
+        "@timestamp": record.time.as_rfc3339(),
+        "file": record.file,
+        "function": record.function,
+        "message": record.message,
+        "log_type": record.level.name
+    })))
 }
 
 fn make_json_body(

src/elastic_push.rs

@@ -1,3 +1,4 @@
+use chrono::TimeZone;
 use redis::Commands;
 use rmp_serde;
 use serde::{Deserialize, Serialize};
@@ -33,6 +34,13 @@ pub struct Timestamp {
     pub repr: String,
     pub timestamp: f64,
 }
+
+impl Timestamp {
+    pub fn as_rfc3339(&self) -> String {
+        let ts = chrono::Utc.timestamp_opt(self.timestamp as i64, 0).unwrap();
+        ts.to_rfc3339()
+    }
+}
 #[derive(Debug, PartialEq, Deserialize, Serialize, Clone)]
 pub struct LogRecord {
     pub elapsed: Elapsed,