Implemented event posting endpoint + logging system

Author: nir1r7

backend/app/api/routes/events.py

@@ -0,0 +1,24 @@
+from fastapi import APIRouter, status
+from app.models.event import EventIn
+from app.core.logging import get_logger
+
+router = APIRouter(prefix="/events", tags=["events"])
+logger = get_logger("eventrelay.events")
+
+@router.post("", status_code=status.HTTP_202_ACCEPTED)
+async def ingest_event(event: EventIn):
+    logger.info(
+        "event_recieved",
+        extra={
+            "extra": {
+                "source": event.source,
+                "type": event.type,
+                "timestamp": event.timestamp.isoformat(),
+            }
+        },
+    )
+
+    return {
+        "status": "accepted",
+        "event_type": event.type,
+    }

backend/app/core/logging.py

@@ -0,0 +1,28 @@
+import logging
+import json
+from datetime import datetime, UTC
+
+class JsonFormatter(logging.Formatter):
+    def format(self, record):
+        log = {
+            "level": record.levelname,
+            "message": record.getMessage(),
+            "time": datetime.now(UTC).isoformat()
+        }
+
+        if hasattr(record, "extra"):
+            log.update(record.extra)
+
+        return json.dumps(log)
+    
+def get_logger(name: str) -> logging.Logger:
+    logger = logging.getLogger(name)
+    logger.setLevel(logging.INFO)
+
+    handler = logging.StreamHandler()
+    handler.setFormatter(JsonFormatter())
+
+    if not logger.handlers:
+        logger.addHandler(handler)
+
+    return logger;

backend/app/main.py

@@ -1,7 +1,10 @@
 from fastapi import FastAPI
+from app.api.routes import events
 
 app = FastAPI(title="EventRelay")
 
+app.include_router(events.router)
+
 @app.get("/health")
 def health():
     return {"status": "ok"}

backend/app/models/event.py

@@ -0,0 +1,12 @@
+from pydantic import BaseModel, Field
+from typing import Optional, Dict
+from datetime import datetime
+
+
+class EventIn(BaseModel):
+    source: str = Field(..., example="auth-service")
+    type: str = Field(..., example="user.login")
+    payload: Dict = Field(..., example={"user_id": 123})
+    timestamp: Optional[datetime] = Field(
+        default_factory=datetime.utcnow
+    )

backend/requirements.txt

@@ -1,5 +1,13 @@
-fastapi
-uvicorn
-psycopg2-binary
-redis
-prometheus-client
+# Web Framework
+fastapi[standard]>=0.115.0
+uvicorn[standard]>=0.32.0
+pydantic>=2.9.0
+
+# Database
+psycopg2-binary>=2.9.9
+
+# Cache/Queue
+redis>=5.2.0
+
+# Monitoring
+prometheus-client>=0.21.0