separate routes

main.py

@@ -112,26 +112,44 @@ def process_simship_webhook(data: dict):
 
 app = FastAPI()
 
-@app.post("/webhook")
-async def webhook(request: Request):
-    logger.info(f"Received webhook request from {request.client.host}")
-    if request.headers.get("X-Webhook-Secret") not in {MODEL_CATALOG_WEBHOOK_SECRET, SIMSHIP_WEBHOOK_SECRET}:
-        logger.warning("Invalid webhook secret received")
+@app.post("/webhook/model-catalog")
+async def model_catalog_webhook(request: Request):
+    logger.info(f"Received model catalog webhook request from {request.client.host}")
+    if request.headers.get("X-Webhook-Secret") != MODEL_CATALOG_WEBHOOK_SECRET:
+        logger.warning("Invalid webhook secret received for model catalog")
         return Response("Invalid secret", status_code=401)
     
     data = await request.json()
-    logger.info(f"Webhook payload: {json.dumps(data, indent=2)}")
+    logger.info(f"Model catalog webhook payload: {json.dumps(data, indent=2)}")
 
     webhook_id = data.get("webhook", {}).get("id", None)
     
     if webhook_id == MODEL_CATALOG_WEBHOOK:
         logger.info("Processing model catalog webhook")
         process_model_catalog_webhook(data)
-    elif webhook_id == SIMSHIP_WEBHOOK:
+    else:
+        logger.warning("Invalid webhook ID received for model catalog")
+        return Response("Invalid webhook ID", status_code=401)
+    
+    return Response("Model catalog webhook notification received and processed!", status_code=200)
+
+@app.post("/webhook/simship")
+async def simship_webhook(request: Request):
+    logger.info(f"Received simship webhook request from {request.client.host}")
+    if request.headers.get("X-Webhook-Secret") != SIMSHIP_WEBHOOK_SECRET:
+        logger.warning("Invalid webhook secret received for simship")
+        return Response("Invalid secret", status_code=401)
+    
+    data = await request.json()
+    logger.info(f"Simship webhook payload: {json.dumps(data, indent=2)}")
+
+    webhook_id = data.get("webhook", {}).get("id", None)
+    
+    if webhook_id == SIMSHIP_WEBHOOK:
         logger.info("Processing simship webhook")
         process_simship_webhook(data)
     else:
-        logger.warning("Invalid webhook ID received")
+        logger.warning("Invalid webhook ID received for simship")
         return Response("Invalid webhook ID", status_code=401)
     
-    return Response("Webhook notification received and processed!", status_code=200)
+    return Response("Simship webhook notification received and processed!", status_code=200)