AI Engineering & Strategy Assistant

Step 0 of 0

\n`;\n}\n\n// --- SECTION: Main Request Handler (Val Town Function Entry Point) ---\nexport default async function(req: Request): Promise {\n const reqId = `r-${Utils.generateShortId(8)}`;\n const reqLgr = new LogAgent(reqId);\n const log = reqLgr.log.bind(reqLgr);\n const url = new URL(req.url);\n const headers = {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n };\n\n if (req.method === \"OPTIONS\") {\n log(\"IN\", \"Handler\", \"OPTIONS request received and allowed.\", {}, reqId);\n return new Response(null, { status: 204, headers });\n }\n\n try {\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"\")) {\n log(\"IN\", \"Handler\", \"GET / : UI Request\", { path: url.pathname }, reqId);\n const uiProcessDefinitions = ALL_PROCESS_DEFINITIONS.map(p => ({\n id: p.id,\n name: p.name,\n description: p.description,\n color: p.color,\n questionCount: p.questions.length,\n questions: p.questions.map(q => ({ key: q.key, displayName: q.displayName, optional: !!q.optional })),\n }));\n const html = generateGuidedAIProcessUI(JSON.stringify(uiProcessDefinitions));\n return new Response(html, { status: 200, headers: { ...headers, \"Content-Type\": \"text/html;charset=utf-8\" } });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/questionnaire\") {\n log(\"IN\", \"Handler\", \"POST /questionnaire request\", { path: url.pathname }, reqId);\n let requestBody: any;\n let rawRequestBody = \"[NoBodyReadYet]\";\n try {\n rawRequestBody = await req.text();\n requestBody = JSON.parse(rawRequestBody);\n if (\n !requestBody?.processId || typeof requestBody.processId !== \"string\" || !requestBody.action\n || ![\"start\", \"answer\", \"back\", \"restart\"].includes(requestBody.action)\n || (requestBody.action === \"answer\"\n && (!requestBody.lastAnswer || typeof requestBody.lastAnswer.fieldKey !== \"string\"\n || requestBody.lastAnswer.value === undefined))\n || ((requestBody.action === \"back\" || requestBody.action === \"answer\") && requestBody.state === undefined)\n ) {\n throw new Error(\"Invalid or incomplete questionnaire request structure.\");\n }\n } catch (e: any) {\n log(\"WN\", \"Handler\", \"Bad /questionnaire request body.\", {\n error: e.message,\n bodyPreview: rawRequestBody.slice(0, 300),\n }, reqId);\n return new Response(JSON.stringify({ err: `Bad Request: ${e.message}`, state: null }), {\n status: 400,\n headers,\n });\n }\n const qAgent = new QAgent(log);\n let qResponse: QResp;\n try {\n log(\"DB\", \"Handler\", `QAgent Action: ${requestBody.action}`, {\n pid: requestBody.processId,\n sId: requestBody.sessionId,\n laFK: requestBody.lastAnswer?.fieldKey,\n }, reqId);\n switch (requestBody.action) {\n case \"start\":\n qResponse = await qAgent.nextStep(\n requestBody.sessionId,\n requestBody.processId,\n requestBody.lastAnswer,\n null,\n );\n break;\n case \"answer\":\n qResponse = await qAgent.nextStep(\n requestBody.sessionId,\n requestBody.processId,\n requestBody.lastAnswer,\n requestBody.state,\n );\n break;\n case \"back\":\n if (!requestBody.state) throw new Error(\"State is required for 'back' action.\");\n qResponse = await qAgent.goBack(requestBody.sessionId, requestBody.processId, requestBody.state);\n break;\n case \"restart\":\n qResponse = await qAgent.restart(requestBody.sessionId, requestBody.processId);\n break;\n default:\n qResponse = {\n sid: requestBody.sessionId || `err-${Utils.generateShortId()}`,\n isDone: false,\n err: \"Invalid questionnaire action.\",\n state: requestBody.state || null,\n };\n }\n log(\"DB\", \"Handler\", \"QAgent step processed successfully.\", {\n sid: qResponse.sid,\n isDone: qResponse.isDone,\n hasError: !!qResponse.err,\n nextQKey: qResponse.nextQ?.fieldKey,\n }, reqId);\n return new Response(JSON.stringify(qResponse), { status: 200, headers });\n } catch (e: any) {\n log(\"ER\", \"Handler\", `QAgent system error during action: ${requestBody.action}.`, {\n error: e.message,\n stackPreview: e.stack?.slice(0, 200),\n }, reqId);\n return new Response(\n JSON.stringify({\n err: `Internal QAgent System Error: ${e.message}`,\n state: requestBody.state || null,\n debugLog: reqLgr.getLogs(),\n mid: reqId,\n }),\n { status: 500, headers },\n );\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/execute\") {\n log(\"IN\", \"Handler\", \"POST /execute request\", { path: url.pathname }, reqId);\n let validatedUserInput: UserIn;\n let rawPayloadPreview = \"[NoPayloadReadYet]\";\n try {\n const payload = await req.json();\n rawPayloadPreview = JSON.stringify(payload).slice(0, 500);\n log(\"DB\", \"Handler\", \"Received /execute payload for validation.\", { payloadPreview: rawPayloadPreview }, reqId);\n validatedUserInput = UserInSchema.parse(payload);\n log(\"IN\", \"Handler\", \"Payload validated successfully for /execute.\", {\n processId: validatedUserInput.processId,\n dataKeys: Object.keys(validatedUserInput.data),\n }, reqId);\n } catch (e: any) {\n let errorDetail = \"Invalid input structure or missing/empty required fields.\";\n if (e instanceof z.ZodError)\n errorDetail = e.issues.map(issue => `${issue.path.join(\".\") || \"input\"}: ${issue.message}`).join(\"; \"); else\n errorDetail = e.message;\n log(\"WN\", \"Handler\", \"Validation failed for /execute payload.\", {\n errorDetails: errorDetail,\n payloadPreview: rawPayloadPreview,\n }, reqId);\n return new Response(JSON.stringify({ err: \"Invalid Input.\", details: errorDetail, mid: `m-val-${reqId}` }), {\n status: 400,\n headers,\n });\n }\n const executionLogAgent = new LogAgent();\n const orchestrator = new Orchestrator(executionLogAgent);\n const finalResult: FinalRes = await orchestrator.runWorkflow(validatedUserInput);\n finalResult.dbgLog = executionLogAgent.getLogs();\n const responseStatus = finalResult.err ? (finalResult.err.includes(\"AI output unparseable\") ? 422 : 500) : 200;\n log(\"IN\", \"Handler\", `/execute workflow finished with status ${responseStatus}`, {\n mainId: finalResult.mid,\n hasError: !!finalResult.err,\n }, reqId);\n return new Response(JSON.stringify(finalResult), { status: responseStatus, headers });\n }\n\n log(\"WN\", \"Handler\", `Unsupported route: ${req.method} ${url.pathname}.`, {}, reqId);\n return new Response(JSON.stringify({ err: \"Not Found.\", mid: reqId }), { status: 404, headers });\n } catch (criticalError: any) {\n log(\"ER\", \"Handler\", \"Critical unhandled error in main request handler.\", {\n error: criticalError.message,\n stack: criticalError.stack?.slice(0, 300),\n }, reqId);\n return new Response(\n JSON.stringify({\n err: \"Internal Server Error.\",\n details: \"An unexpected error occurred. Check server logs.\",\n mid: `m-crit-${reqId}`,\n debugLog: reqLgr.getLogs(),\n }),\n { status: 500, headers },\n );\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/join/pool/code/main.tsx","extension","actionData","errors"]