from fastapi import Request, APIRouter
from agent import run_agent
from logger import logger

router = APIRouter()

@router.post("/webhook")
async def webhook(request: Request):
    payload = await request.json()
    task = payload.get("task", "")
    logger.info(f"Webhook received task: {task}")
    return {"response": run_agent(task)}