revert changes

server/webhook-ingest/app/logger.py

@@ -26,7 +26,5 @@ def __init__(
     def filter(self, record: logging.LogRecord) -> bool:
         return record.getMessage().find(self._path) == -1
 
-access_logger = logging.getLogger("uvicorn.access")
-access_logger.addFilter(EndpointFilter(path="/health"))
-
-error_logger = logging.getLogger('uvicorn.error')
+uvicorn_logger = logging.getLogger("uvicorn.access")
+uvicorn_logger.addFilter(EndpointFilter(path="/health"))

server/webhook-ingest/app/main.py

@@ -6,7 +6,6 @@
 from nats.js.api import StreamConfig
 from app.config import settings
 from app.nats_client import nats_client
-from app.logger import error_logger
 
 
 @asynccontextmanager
@@ -50,19 +49,19 @@ async def github_webhook(
     if event_type == "ping":
         return { "status": "pong" }
 
-    payload = await request.json()
-
     # Extract subject from the payload
-    try:    
+    payload = await request.json()
+    subject = ""
+    if "repository" in payload:
         owner = payload["repository"]["owner"]["login"]
         repo = payload["repository"]["name"]
         subject = f"github.{owner}.{repo}.{event_type}"
-    except:
+    else:
         subject = f"github.error.{event_type}"
 
     # Publish the payload to NATS JetStream
     await nats_client.js.publish(subject, body)
-    
+
     return { "status": "ok" }