Real Estate Showing AI 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); // Per-request logger\n const log = reqLgr.log.bind(reqLgr); // Bound log function for this request\n const url = new URL(req.url);\n const headers = { // Common headers\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\", // Adjust for production\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 // Route: GET / - Serves the main UI\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"\")) {\n log(\"IN\", \"Handler\", \"GET / : UI Request\", { path: url.pathname }, reqId);\n // Prepare process definitions for the UI (only send necessary info)\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 // Only send question keys, display names, and optional status to client for initial render/validation messages\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 // Route: POST /questionnaire - Handles questionnaire logic\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 { // Validate incoming questionnaire action payload\n rawRequestBody = await req.text(); // Read body once as text\n requestBody = JSON.parse(rawRequestBody);\n // Basic validation for the structure of questionnaire actions\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 /* value can be null/empty for optionals, so don't check requestBody.lastAnswer.value strictly here */\n || requestBody.lastAnswer.value === undefined)) // but it must exist\n || ((requestBody.action === \"back\" || requestBody.action === \"answer\") && requestBody.state === undefined) // state is needed for these\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\n const qAgent = new QAgent(log); // Use the per-request logger\n let qResponse: QResp;\n\n try {\n log(\"DB\", \"Handler\", `QAgent Action: ${requestBody.action}`, {\n pid: requestBody.processId,\n sId: requestBody.sessionId, // Can be null for 'start'\n laFK: requestBody.lastAnswer?.fieldKey, // Can be null\n }, reqId);\n switch (requestBody.action) {\n case \"start\":\n qResponse = await qAgent.nextStep(\n requestBody.sessionId, // will be null, QAgent generates new\n requestBody.processId,\n requestBody.lastAnswer, // will be null\n null, // no current state\n );\n break;\n case \"answer\":\n qResponse = await qAgent.nextStep(\n requestBody.sessionId,\n requestBody.processId,\n requestBody.lastAnswer,\n requestBody.state, // Current state from client\n );\n break;\n case \"back\":\n if (!requestBody.state) throw new Error(\"State is required for 'back' action.\"); // Should be caught by initial check\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: // Should not be reachable due to initial validation\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, // return current state if possible for debugging\n debugLog: reqLgr.getLogs(), // Include logs for this request for debugging\n mid: reqId,\n }),\n { status: 500, headers },\n );\n }\n }\n\n // Route: POST /execute - Runs the AI agent\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); // For logging on error\n log(\"DB\", \"Handler\", \"Received /execute payload for validation.\", { payloadPreview: rawPayloadPreview }, reqId);\n validatedUserInput = UserInSchema.parse(payload); // Zod validation\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(\"; \");\n else 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, // Bad Request\n headers,\n });\n }\n\n // Use a new LogAgent for this specific execution trace if more isolation is needed,\n // or pass the existing reqLgr if logs should be combined.\n // For simplicity, we'll use a new one for the orchestrator run's specific logs.\n const executionLogAgent = new LogAgent(); // Orchestrator will use this\n const orchestrator = new Orchestrator(executionLogAgent);\n const finalResult: FinalRes = await orchestrator.runWorkflow(validatedUserInput);\n\n // Combine logs: orchestrator's logs are now in finalResult.dbgLog\n // If you want to include the handler's initial logs as well:\n // finalResult.dbgLog = [...reqLgr.getLogs(), ...executionLogAgent.getLogs()];\n finalResult.dbgLog = executionLogAgent.getLogs(); // Orchestrator's logs\n\n // Determine status based on result\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, // Orchestrator's main ID\n hasError: !!finalResult.err,\n }, reqId);\n return new Response(JSON.stringify(finalResult), { status: responseStatus, headers });\n }\n\n // Fallback for unhandled routes\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 // Catch-all for any truly unexpected errors in the handler itself\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}`, // Critical error main ID\n debugLog: reqLgr.getLogs(), // Include any logs captured so far for this request\n }),\n { status: 500, headers },\n );\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/join/realestate/code/main.tsx","extension","actionData","errors"]