Agent Workflow Platform

\n Select Workflow:\n \n \n\n \n\n

Workflow Result

— Waiting for execution —

Execution Log

— Waiting for execution —

\n \n\n \n \n\n`;\n}\n\n// Main HTTP request handler\nexport default async function(req: Request): Promise {\n globalLogger.clear(); // Clear logs for each new request\n const requestStartTime = Date.now();\n // Using import.meta.url to get the current val's URL for the view source link\n const currentValUrl = import.meta.url;\n const requestLog = globalLogger.createLogFunction(`REQ-${requestStartTime}`, \"RequestHandler\");\n\n requestLog(\"INFO\", \"RequestReceived\", `${req.method} ${req.url}`);\n\n try {\n if (req.method === \"GET\") {\n requestLog(\"DEBUG\", \"ServeHTML\", \"Serving HTML UI with workflow selector\");\n return new Response(generateHtmlWithWorkflowSelector(availableWorkflows, currentValUrl), { // Pass workflows map\n status: 200,\n headers: { \"Content-Type\": \"text/html\" },\n });\n } else if (req.method === \"POST\") {\n let requestBody: { workflowId?: string; payload?: any };\n try {\n requestBody = await req.json();\n requestLog(\"DEBUG\", \"ParsePayload\", \"Parsed JSON payload\", { body: requestBody });\n } catch (e: any) {\n requestLog(\"ERROR\", \"ParsePayload\", \"Failed to parse request JSON\", e);\n return new Response(\n JSON.stringify({\n success: false,\n error: \"Invalid JSON payload\",\n details: e.message,\n debugLog: globalLogger.getLogs(),\n }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n const { workflowId, payload: initialPayload } = requestBody;\n\n if (!workflowId || !availableWorkflows[workflowId]) {\n requestLog(\"ERROR\", \"WorkflowSelection\", `Invalid or missing workflowId: ${workflowId}`);\n return new Response(\n JSON.stringify({\n success: false,\n error: \"Invalid or missing workflowId\",\n availableIds: Object.keys(availableWorkflows),\n debugLog: globalLogger.getLogs(),\n }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n const workflowToExecute = availableWorkflows[workflowId];\n requestLog(\"INFO\", \"WorkflowExecute\", `Executing workflow: ${workflowToExecute.id}`);\n\n const result = await workflowEngine.execute(workflowToExecute, initialPayload || {}); // Pass empty object if payload is undefined\n\n requestLog(\"INFO\", \"WorkflowComplete\", `Workflow ${workflowToExecute.id} finished`, {\n success: result.success,\n durationMs: Date.now() - requestStartTime,\n });\n\n // Ensure the final response includes the debugLog\n const responsePayload = { ...result, debugLog: globalLogger.getLogs() };\n\n return new Response(JSON.stringify(responsePayload), {\n status: result.success ? 200 : (result.error === \"Workflow input error.\" ? 400 : 500),\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n } else {\n requestLog(\"WARN\", \"MethodNotAllowed\", `Method: ${req.method}`);\n return new Response(\n JSON.stringify({ success: false, error: \"Method Not Allowed\", debugLog: globalLogger.getLogs() }),\n { status: 405, headers: { \"Content-Type\": \"application/json\", \"Allow\": \"GET, POST\" } },\n );\n }\n } catch (e: any) {\n requestLog(\"ERROR\", \"UnhandledException\", \"Unhandled error in request handler\", e);\n return new Response(\n JSON.stringify({\n success: false,\n error: \"Internal Server Error\",\n details: e.message,\n debugLog: globalLogger.getLogs(),\n }),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}","deleted","label",[99],"permalink","https://www.val.town/x/salon/mandate/code/main.ts","extension","actionData","errors"]