Create app.py

app.py

@@ -0,0 +1,23 @@
+from fastapi import FastAPI, Request
+from ci_trigger_engine import trigger_engine
+from ci_sync_monitor import sync_monitor
+
+app = FastAPI()
+inputs = []
+
+@app.post("/inputs")
+async def receive_input(req: Request):
+    data = await req.json()
+    inputs.append(data)
+    trigger_engine.add_input(data)
+    sync_monitor.log_event(data)
+    sync_monitor.check_alignment(data)
+    return {"status": "received"}
+
+@app.get("/inputs")
+async def get_all():
+    return inputs
+
+@app.get("/health")
+def health_check():
+    return {"status": "ok"}