Added new backend router for logging-related endpoints

Author: tieneupin

src/murfey/server/api/logging.py

@@ -0,0 +1,35 @@
+import json
+import logging
+from datetime import datetime
+from typing import Any
+
+from fastapi import APIRouter, Request
+
+logger = logging.getLogger("murfey.server.api.hub")
+
+router = APIRouter(
+    prefix="/logging",
+    tags=["Logging"],
+)
+
+
+@router.post("/logs")
+async def forward_logs(request: Request):
+    """
+    Receives a list of stringified JSON log records from the instrument server,
+    unpacks them, and forwards them through the handlers set up on the backend.
+    """
+
+    data: list[str] = await request.json()
+    for line in data:
+        log_data: dict[str, Any] = json.loads(line)
+        logger_name = log_data["name"]
+        log_data.pop("msecs", None)
+        log_data.pop("relativeCreated", None)
+        client_timestamp = log_data.pop("created", 0)
+        if client_timestamp:
+            log_data["client_time"] = datetime.fromtimestamp(
+                client_timestamp
+            ).isoformat()
+        log_data["client_host"] = request.client.host if request.client else None
+        logging.getLogger(logger_name).handle(logging.makeLogRecord(log_data))

src/murfey/server/main.py

@@ -18,6 +18,7 @@
 import murfey.server.api.file_io_instrument
 import murfey.server.api.hub
 import murfey.server.api.instrument
+import murfey.server.api.logging
 import murfey.server.api.mag_table
 import murfey.server.api.processing_parameters
 import murfey.server.api.prometheus
@@ -77,6 +78,8 @@ class Settings(BaseSettings):
 
 app.include_router(murfey.server.api.instrument.router)
 
+app.include_router(murfey.server.api.logging.router)
+
 app.include_router(murfey.server.api.mag_table.router)
 
 app.include_router(murfey.server.api.session_control.router)

src/murfey/util/route_manifest.yaml

@@ -692,6 +692,12 @@ murfey.server.api.instrument.router:
         type: int
     methods:
       - GET
+murfey.server.api.logging.router:
+  - path: /logging/logs
+    function: forward_logs
+    path_params: []
+    methods:
+      - POST
 murfey.server.api.mag_table.router:
   - path: /mag_table/mag_table/
     function: get_mag_table