From dfff8f9ece6a6c3274896d8e9804b99095b10051 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ensar=20Saraj=C4=8Di=C4=87?= <dev@ensarsarajcic.com>
Date: Mon, 16 Dec 2024 18:16:01 +0100
Subject: [PATCH] Remove unnecessary duplicated key from memory table entries

---
 src/enrichment_tables/memory/table.rs | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git a/src/enrichment_tables/memory/table.rs b/src/enrichment_tables/memory/table.rs
index 38f665bf0bd8d..a2a36e9ad63a6 100644
--- a/src/enrichment_tables/memory/table.rs
+++ b/src/enrichment_tables/memory/table.rs
@@ -27,7 +27,6 @@ use vrl::value::{KeyString, ObjectMap, Value};
 /// Single memory entry containing the value and TTL
 #[derive(Clone, Eq, PartialEq, Hash, ShallowCopy)]
 pub struct MemoryEntry {
-    key: String,
     value: Box<Value>,
     update_time: CopyValue<Instant>,
 }
@@ -39,12 +38,12 @@ impl ByteSizeOf for MemoryEntry {
 }
 
 impl MemoryEntry {
-    fn as_object_map(&self, now: Instant, total_ttl: u64) -> ObjectMap {
+    fn as_object_map(&self, now: Instant, total_ttl: u64, key: &str) -> ObjectMap {
         let ttl = total_ttl.saturating_sub(now.duration_since(*self.update_time).as_secs());
         ObjectMap::from([
             (
                 KeyString::from("key"),
-                Value::Bytes(Bytes::copy_from_slice(self.key.as_bytes())),
+                Value::Bytes(Bytes::copy_from_slice(key.as_bytes())),
             ),
             (KeyString::from("value"), (*self.value).clone()),
             (
@@ -111,7 +110,6 @@ impl Memory {
 
         for (k, v) in value.iter() {
             let new_entry = MemoryEntry {
-                key: k.as_str().to_string(),
                 value: Box::new(v.clone()),
                 update_time: now.into(),
             };
@@ -221,7 +219,11 @@ impl Table for Memory {
                         emit!(MemoryEnrichmentTableRead {
                             key: key.to_string()
                         });
-                        Ok(vec![row.as_object_map(Instant::now(), self.config.ttl)])
+                        Ok(vec![row.as_object_map(
+                            Instant::now(),
+                            self.config.ttl,
+                            &key,
+                        )])
                     }
                     None => {
                         emit!(MemoryEnrichmentTableReadFailed {
@@ -336,7 +338,6 @@ mod tests {
             handle.update(
                 "test_key".to_string(),
                 MemoryEntry {
-                    key: "test_key".to_string(),
                     value: Box::new(Value::from(5)),
                     update_time: (Instant::now() - Duration::from_secs(secs_to_subtract)).into(),
                 },
@@ -371,7 +372,6 @@ mod tests {
             handle.update(
                 "test_key".to_string(),
                 MemoryEntry {
-                    key: "test_key".to_string(),
                     value: Box::new(Value::from(5)),
                     update_time: (Instant::now() - Duration::from_secs(ttl + 10)).into(),
                 },
@@ -434,7 +434,6 @@ mod tests {
             handle.update(
                 "test_key".to_string(),
                 MemoryEntry {
-                    key: "test_key".to_string(),
                     value: Box::new(Value::from(5)),
                     update_time: (Instant::now() - Duration::from_secs(ttl / 2)).into(),
                 },