From dbf2717092d3f6c2cd07207efcd115d2aedbd953 Mon Sep 17 00:00:00 2001
From: Gabriel Bastos <gabriel.bastos@cloudwalk.io>
Date: Mon, 2 Dec 2024 18:14:59 -0300
Subject: [PATCH] Don't emit invalid json on missing fields

---
 src/layer/mod.rs | 23 ++++++++++++-----------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/src/layer/mod.rs b/src/layer/mod.rs
index 94b91de..733d67d 100644
--- a/src/layer/mod.rs
+++ b/src/layer/mod.rs
@@ -897,10 +897,10 @@ where
         self.keyed_values.insert(
             SchemaKey::from(key.into()),
             JsonValue::DynamicRawFromEvent(Box::new(|event, writer| {
-                event
-                    .metadata()
-                    .file()
-                    .map_or(Ok(()), |file| write_escaped(writer, file))
+                match event.metadata().file() {
+                    Some(file) => write_escaped(writer, file),
+                    None => write!(writer, "null"),
+                }
             })),
         );
         self
@@ -914,10 +914,10 @@ where
         self.keyed_values.insert(
             SchemaKey::from(key.into()),
             JsonValue::DynamicRawFromEvent(Box::new(|event, writer| {
-                event
-                    .metadata()
-                    .line()
-                    .map_or(Ok(()), |line| write!(writer, "{line}"))
+                match event.metadata().line() {
+                    Some(line) => write!(writer, "{line}"),
+                    None => write!(writer, "null"),
+                }
             })),
         );
         self
@@ -942,9 +942,10 @@ where
         self.keyed_values.insert(
             SchemaKey::from(key.into()),
             JsonValue::DynamicRawFromEvent(Box::new(|_event, writer| {
-                std::thread::current()
-                    .name()
-                    .map_or(Ok(()), |name| write_escaped(writer, name))
+                match std::thread::current().name() {
+                    Some(name) => write_escaped(writer, name),
+                    None => write!(writer, "null"),
+                }
             })),
         );
         self