Update usage_logging.py

Changes to json directory to help with concurrent user access telemetry

usage_logging.py

@@ -52,7 +52,7 @@ Author:
     Arjun Singh
 
 Last Updated:
-    2026-01-22
+    2026-01-27
 """
 
 
@@ -65,10 +65,13 @@ from huggingface_hub import HfApi, hf_hub_url
 import ipaddress
 import pycountry
 from io import BytesIO
+import uuid
 
 SPACE_URL = "https://huggingface.co/spaces/19arjun89/AI_Recruiting_Agent"
 USAGE_DATASET_REPO = "19arjun89/ai_recruiting_agent_usage"
-USAGE_JSONL_PATH = "usage/visits.jsonl"
+
+USAGE_EVENTS_DIR = "usage/events"
+
 
 
 def _hf_api():
@@ -158,32 +161,33 @@ def append_visit_to_dataset(
     if not api:
         return
 
-    existing = _download_text_if_exists(USAGE_DATASET_REPO, USAGE_JSONL_PATH)
-
     event = {
         "ts_utc": datetime.utcnow().isoformat() + "Z",
         "space_url": SPACE_URL,
+        "event": event_type,
         "country": country or "Unknown",
         "country_code": (country_code or "").strip().upper(),
         "country_source": country_source or "unknown",
         "city": city or "",
-        "event": event_type,
     }
 
-    # Drop None values so you never write JSON nulls
     if extra_fields:
+        # Prevent JSON nulls
         event.update({k: v for k, v in extra_fields.items() if v is not None})
 
-    new_content = (existing.rstrip("\n") + "\n" if existing.strip() else "") + json.dumps(event) + "\n"
-    print("DEBUG EVENT:", event)
+    # Unique file path per event (prevents collisions)
+    ts = datetime.utcnow().strftime("%Y%m%dT%H%M%S%f")
+    uid = uuid.uuid4().hex[:8]
+    path_in_repo = f"{USAGE_EVENTS_DIR}/{ts}_{uid}.json"
+
     try:
         api.upload_file(
             repo_id=USAGE_DATASET_REPO,
             repo_type="dataset",
-            path_in_repo=USAGE_JSONL_PATH,
-            path_or_fileobj=BytesIO(new_content.encode("utf-8")),
-            commit_message="append visit log",
-            )
+            path_in_repo=path_in_repo,
+            path_or_fileobj=BytesIO(json.dumps(event).encode("utf-8")),
+            commit_message=f"log {event_type}",
+        )
     except Exception:
         pass
 
@@ -197,7 +201,7 @@ def record_visit(request: gr.Request):
         city="",
         event_type="usage_start",
         country_source="header",
-        country_code=country_hint,
+        country_code=country_hint.strip().upper(),
         )
         return