Create core/builders/api_builder.py

core/builders/api_builder.py

@@ -0,0 +1,22 @@
+from fastapi import APIRouter
+from core.registry.loader import get_tasks
+from core.execution.executor import execute_task
+
+router = APIRouter()
+
+
+def build_api_router():
+
+    for task in get_tasks():
+
+        async def endpoint(payload: dict, task=task):
+            return await execute_task(task.name, payload)
+
+        router.add_api_route(
+            f"/execute/{task.name}",
+            endpoint,
+            methods=["POST"],
+            name=f"execute_{task.name}"
+        )
+
+    return router