From 70cdba88473acdf8c1bedaad8ba9a3745b300df3 Mon Sep 17 00:00:00 2001
From: grillkol <maxwesterlund2@gmail.com>
Date: Mon, 27 Apr 2026 22:52:12 +0200
Subject: [PATCH] removed enrichment

---
 api/app/enrichment.py | 5 -----
 api/app/influx.py     | 9 ++++-----
 api/app/main.py       | 8 ++------
 3 files changed, 6 insertions(+), 16 deletions(-)
 delete mode 100644 api/app/enrichment.py

diff --git a/api/app/enrichment.py b/api/app/enrichment.py
deleted file mode 100644
index f3445f2..0000000
--- a/api/app/enrichment.py
+++ /dev/null
@@ -1,5 +0,0 @@
-def enrich_event(event, game: str):
-    """Add the game tag to the event. All other data passes through unchanged."""
-    event.data = event.data or {}
-    event.data["game"] = game
-    return event
\ No newline at end of file
diff --git a/api/app/influx.py b/api/app/influx.py
index 4797df9..10667f3 100644
--- a/api/app/influx.py
+++ b/api/app/influx.py
@@ -24,16 +24,15 @@ if INFLUX_URL and INFLUX_TOKEN:
 else:
     logger.warning("InfluxDB environment variables missing – writing disabled")
 
-def write_event(event) -> bool:
+def write_event(event, game: str) -> bool:
     if write_api is None:
-        logger.debug("InfluxDB not available, skipping write")
         return False
     try:
         p = Point(event.type).time(event.time * 1_000_000_000)
-        p.tag("game", event.data.get("game", "unknown"))
+        p.tag("game", game)
         p.tag("serverId", event.serverId)
-        # Write all data fields as InfluxDB fields (no game-specific tags)
-        for k, v in event.data.items():
+        # Ensure data is a dict, even if not provided
+        for k, v in (event.data or {}).items():
             if isinstance(v, (int, float, str, bool)):
                 p.field(k, v)
         write_api.write(bucket=INFLUX_BUCKET, record=p)
diff --git a/api/app/main.py b/api/app/main.py
index 15d57be..d6b737c 100644
--- a/api/app/main.py
+++ b/api/app/main.py
@@ -45,13 +45,9 @@ async def ingest_event(payload: Event | BatchEvents, game: str = Depends(verify_
     
     if isinstance(payload, BatchEvents):
         for event in payload.events:
-            check_event(event)
-            enriched = enrich_event(event, game)
-            write_event(enriched)
+            write_event(event, game)
     else:
-        check_event(payload)
-        enriched = enrich_event(payload, game)
-        write_event(enriched)
+        write_event(payload, game)
     return {"success": True}
 
 # ---------- Serve the admin HTML ----------