Mechanical Engineering R&D AI Assistant

Step 0 of 0

\n`;\n}",[],[152,219],{"_104":227,"_95":228,"_153":229,"_155":154,"_156":138,"_157":230,"_159":160,"_106":231,"_100":203,"_163":183,"_165":232,"_166":22,"_167":-5,"_168":233,"_98":234},"4a5e5658-3a8b-11f0-93ce-9e149126039e","utils.ts","f0694252-3a8a-11f0-99cc-9e149126039e",18,["D",1748303037099],"// src/utils.ts\n\nexport const Utils = {\n fillPromptTemplate: (template: string, data: Record): string => {\n let filledTemplate = template;\n for (const key in data) {\n const placeholder = new RegExp(`\\\\{\\\\\\{\\\\s*${key}\\\\s*\\\\}\\\\}`, \"g\"); // Escaped for template literal inside string\n filledTemplate = filledTemplate.replace(placeholder, String(data[key] ?? \"N/A\"));\n }\n return filledTemplate;\n },\n generateShortId: (length = 6): string => {\n return Math.random().toString(36).substring(2, 2 + length);\n },\n escapeHTML: (unsafeS: any): string => {\n if (unsafeS == null) return \"\";\n const s = String(unsafeS);\n return s.replace(\n /[&<>\"']/g,\n (m) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", \"\\\"\": \""\", \"'\": \"'\" }[m as keyof typeof Object] || m),\n );\n },\n};",[],[152,228],[152],{"_104":237,"_95":99,"_153":238,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":239,"_100":240,"_163":241,"_165":242,"_166":22,"_167":-5,"_168":243,"_98":244},"9cf16496-3a90-11f0-8ff1-9e149126039e","827e91ac-3a8a-11f0-be23-9e149126039e",["D",1748305323116],5,"http","// index.ts\nimport { z } from \"npm:zod\";\nimport { Utils } from \"src/utils.ts\";\nimport type { FinalRes, LogFn, ProcessDefinition, QResp, UserIn } from \"./coreTypes.ts\";\nimport { LogAgent, Orchestrator, QAgent } from \"./src/mainLogic.ts\";\nimport { generateGuidedAIProcessUI } from \"./src/ui.ts\";\n\nconst processModulePaths: string[] = [\n \"./src/processes/materialSelectionAdvisor.ts\",\n \"./src/processes/conceptualDesignBrainstormer.ts\",\n];\n\nlet ALL_PROCESS_DEFINITIONS: ProcessDefinition[] = [];\nlet processDefinitionsPromise: Promise | null = null;\nlet UserInSchemaInstance: z.ZodType;\n\nasync function initializeProcessesAndSchema(log?: LogFn): Promise {\n if (ALL_PROCESS_DEFINITIONS.length > 0 && UserInSchemaInstance) return;\n\n const loadedDefinitions: ProcessDefinition[] = [];\n for (const path of processModulePaths) {\n try {\n const module = await import(path);\n if (module.default && typeof module.default.id === \"string\") {\n loadedDefinitions.push(module.default);\n log?.(\"IN\", \"ProcessLoader\", `Successfully loaded process: ${module.default.id}`);\n } else {\n const errorMsg = `Module at ${path} does not have a valid ProcessDefinition default export.`;\n log?.(\"ER\", \"ProcessLoader\", errorMsg);\n console.error(errorMsg);\n }\n } catch (e) {\n const errorMsg = `Failed to load process module from ${path}: ${(e as Error).message}`;\n log?.(\"ER\", \"ProcessLoader\", errorMsg, e);\n console.error(errorMsg, e);\n }\n }\n ALL_PROCESS_DEFINITIONS = loadedDefinitions;\n\n UserInSchemaInstance = z.object({\n processId: z.string().refine(\n (val) => ALL_PROCESS_DEFINITIONS.some(p => p.id === val),\n { message: \"Invalid process ID provided.\" },\n ),\n data: z.record(z.any(), { invalid_type_error: \"Input data must be an object.\" }),\n }).refine((input) => {\n const pd = getProcessDefinitionById(input.processId);\n if (!pd) return false;\n for (const q of pd.questions) {\n if (!q.optional) {\n const mappedKey = q.mapsTo;\n if (\n input.data[mappedKey] === undefined\n || input.data[mappedKey] === null\n || (typeof input.data[mappedKey] === \"string\" && String(input.data[mappedKey]).trim() === \"\")\n ) {\n return false;\n }\n }\n }\n return true;\n }, { message: \"Server validation: Missing or empty value for one or more required fields.\" });\n\n log?.(\"IN\", \"Initializer\", `Initialized ${ALL_PROCESS_DEFINITIONS.length} processes and UserIn schema.`);\n}\n\nfunction getProcessDefinitionById(id: string): ProcessDefinition | undefined {\n return ALL_PROCESS_DEFINITIONS.find(p => p.id === id);\n}\n\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\n if (!processDefinitionsPromise) {\n processDefinitionsPromise = initializeProcessesAndSchema(log);\n }\n try {\n await processDefinitionsPromise;\n } catch (initError) {\n log(\"ER\", \"Handler\", \"Critical error during process initialization.\", initError);\n return new Response(JSON.stringify({ err: \"Server Initialization Error. Cannot load processes.\", mid: reqId }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\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 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, count: ALL_PROCESS_DEFINITIONS.length }, reqId);\n\n const uiProcessMetadata = 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 => ({\n key: q.key,\n displayName: q.displayName,\n optional: !!q.optional,\n })),\n }));\n const html = generateGuidedAIProcessUI(JSON.stringify(uiProcessMetadata));\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 as Error).message,\n bodyPreview: rawRequestBody.slice(0, 300),\n }, reqId);\n return new Response(JSON.stringify({ err: `Bad Request: ${(e as Error).message}`, state: null }), {\n status: 400,\n headers,\n });\n }\n const qAgent = new QAgent(log, getProcessDefinitionById);\n let qResponse: QResp;\n try {\n log(\"DB\", \"Handler\", `QAgent Action: ${requestBody.action}`, {\n pid: requestBody.processId,\n sId: requestBody.sessionId,\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 required for 'back'.\");\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 action.\",\n state: requestBody.state || null,\n };\n }\n log(\"DB\", \"Handler\", \"QAgent step OK.\", { sid: qResponse.sid, isDone: qResponse.isDone }, reqId);\n return new Response(JSON.stringify(qResponse), { status: 200, headers });\n } catch (e: any) {\n log(\"ER\", \"Handler\", `QAgent system error: ${requestBody.action}.`, { error: (e as Error).message }, reqId);\n return new Response(\n JSON.stringify({\n err: `Internal QAgent Error: ${(e as Error).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\", { payloadPreview: rawPayloadPreview }, reqId);\n if (!UserInSchemaInstance) throw new Error(\"User input schema not initialized.\");\n validatedUserInput = UserInSchemaInstance.parse(payload);\n log(\"IN\", \"Handler\", \"Payload validated for /execute.\", { processId: validatedUserInput.processId }, reqId);\n } catch (e: any) {\n let errorDetail = \"Bad 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 as Error).message; }\n log(\"WN\", \"Handler\", \"Validation failed for /execute.\", {\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, getProcessDefinitionById);\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}",[],[99],"files",[150,170,177,187,197,207,217,226,236],"counts",{"_249":32,"_250":162,"_251":32,"_252":32},"pulls","branches","forks","envVars","contents",[],"file",{"_104":237,"_95":99,"_153":238,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":257,"_100":240,"_163":241,"_165":242,"_166":22,"_167":-5,"_98":258},["D",1748305323116],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":267,"_148":272,"_245":300,"_255":301,"_253":303,"_304":-5,"_305":22,"_306":-5,"_307":-5,"_308":-5,"_309":310},{"_104":105,"_95":96,"_106":268,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":269,"_132":270,"_135":271,"_147":22},["D",1748302701759],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[273,297],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":160,"_106":161,"_100":162,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":274,"_98":296},[275,284,287,290,293],{"_104":171,"_95":172,"_153":173,"_155":154,"_156":138,"_157":174,"_159":160,"_106":175,"_100":162,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":276,"_98":283},[277,280],{"_104":178,"_95":179,"_153":180,"_155":173,"_156":138,"_157":181,"_159":160,"_106":182,"_100":158,"_163":183,"_165":184,"_166":22,"_167":-5,"_168":278,"_98":279},[],[152,172,179],{"_104":188,"_95":189,"_153":190,"_155":173,"_156":138,"_157":191,"_159":160,"_106":192,"_100":158,"_163":183,"_165":193,"_166":22,"_167":-5,"_168":281,"_98":282},[],[152,172,189],[152,172],{"_104":198,"_95":199,"_153":200,"_155":154,"_156":138,"_157":201,"_159":160,"_106":202,"_100":203,"_163":183,"_165":204,"_166":22,"_167":-5,"_168":285,"_98":286},[],[152,199],{"_104":208,"_95":209,"_153":210,"_155":154,"_156":138,"_157":211,"_159":22,"_106":212,"_100":213,"_163":183,"_165":214,"_166":22,"_167":-5,"_168":288,"_98":289},[],[152,209],{"_104":218,"_95":219,"_153":220,"_155":154,"_156":138,"_157":221,"_159":160,"_106":222,"_100":203,"_163":183,"_165":223,"_166":22,"_167":-5,"_168":291,"_98":292},[],[152,219],{"_104":227,"_95":228,"_153":229,"_155":154,"_156":138,"_157":230,"_159":160,"_106":231,"_100":203,"_163":183,"_165":232,"_166":22,"_167":-5,"_168":294,"_98":295},[],[152,228],[152],{"_104":237,"_95":99,"_153":238,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":239,"_100":240,"_163":241,"_165":242,"_166":22,"_167":-5,"_168":298,"_98":299},[],[99],[273,275,277,280,284,287,290,293,297],{"_104":237,"_95":99,"_153":238,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":257,"_100":240,"_163":241,"_165":242,"_166":22,"_167":-5,"_98":302},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]

join

mech2