subprocess debug

fetch.py

@@ -92,11 +92,9 @@ async def log_request(request: Request, call_next: Any):
         "method": request.method,
         "headers": str(request.headers),
     }
-    output = json.dumps(
-        obj=data, default=str, indent=None, separators=(", ", ":"), newline="\n"
-    )
+    output = json.dumps(obj=data, default=str, indent=None, separators=(", ", ":"))
     with open(LOGFILE, "a") as f:
-        f.write(output)
+        f.write(output + "\n")
 
     response = await call_next(request)
     return response
@@ -107,10 +105,14 @@ def get_analytics(n: int = 5):
     if n == 0:
         cmd = f"tac {LOGFILE.as_posix()}"
     else:
-        cmd = f"tail -{n} {LOGFILE.as_posix()} | tac"
-    json_lines = subprocess.run(cmd.split(), capture_output=True).stdout
-    content = json.loads(f"[ {json_lines.replace(b"\n", b",").decode()} ]")
-    return content
+        cmd = f"tail {n} {LOGFILE.as_posix()} | tac"
+    _subprocess = subprocess.run(cmd.split(), capture_output=True)
+    json_lines, stderr = _subprocess.stdout, _subprocess.stderr
+    try:
+        content = json.loads(f"[ {json_lines.replace(b"\n", b",").decode()} ]")
+        return content
+    except Exception as e:
+        return {"error": str(e), "stderr": stderr, "json_lines": json_lines}
 
 
 @app.api_route("/qa", response_class=FileResponse, methods=["GET", "HEAD"])