Anesthesia Clinical Assistant

Disclaimer: AI-generated info, NOT a substitute for professional medical advice, diagnosis, or treatment. Always verify info & rely on clinical judgment/protocols.

Processing

Assistant Response

Execution Logs (Debug)

`;\n};\n\nconst clientJs = () => `\n const msgs = document.getElementById('messages'),inputArea = document.getElementById('input-area'),loader = document.getElementById('loading-indicator'),errDisp = document.getElementById('error-display'),resDisp = document.getElementById('results-display'),resCont = document.getElementById('results-content'),logCont = document.getElementById('logs-content');\n let sid = null,task = null,currentQ = null,srvState = null;\n const SAFETY_DISCLAIMER = \"Output is informational. Verify info & use professional judgment.\";\n const esc = (unsafe) => { if(unsafe==null)return'';let s=unsafe.toString();const map={'&':'&','<':'<','>':'>','\"':'"',\"'\":'''};return s.replace(/[&<>\\\\\"']/g, m => map[m]); };\n const setLoad = (isLoading) => { loader.style.display = isLoading ? 'block' : 'none'; };\n const showErr = (msg) => { errDisp.textContent = msg; errDisp.style.display = 'block'; };\n const clrErr = () => { errDisp.textContent = ''; errDisp.style.display = 'none'; };\n const clrInArea = () => { inputArea.innerHTML = ''; };\n const enableInput = (enabled) => { inputArea.querySelectorAll('input,select,textarea,button').forEach(el => el.disabled = !enabled); };\n const addMsg = (text, sender) => { const el = document.createElement('div'); el.className = \\`message \\${sender} message-appear\\`; el.innerHTML = esc(text).replace(/\\\\[(.*?)\\\\]\\\$(.*?)\\\$/g, '$1'); msgs.appendChild(el); setTimeout(() => msgs.scrollTop = msgs.scrollHeight, 50); };\n const addBot = (text) => addMsg(text, 'bot'); const addUser = (text) => addMsg(text, 'user');\n const showTasks = () => { clrInArea(); if (!sid || resDisp.style.display === 'block') addBot(\"Welcome! How can I assist? Select a task.\"); enableInput(false); const sel = document.createElement('select'); sel.id = 'task-select'; sel.className = 'form-control'; sel.innerHTML = \\`\\`; const btn = document.createElement('button'); btn.id = 'task-submit'; btn.textContent = 'Start'; btn.onclick = taskSelectHandler; inputArea.append(sel, btn); enableInput(true); sel.focus(); };\n const taskSelectHandler = async () => { const sel = document.getElementById('task-select'); const selectedTask = sel.value; if (!selectedTask) { showErr(\"Please select a task.\"); return; } clrErr(); task = selectedTask; addUser(\\`Task: \\${sel.options[sel.selectedIndex].text}\\`); clrInArea(); enableInput(false); setLoad(true); resDisp.style.display = 'none'; resDisp.classList.remove('visible'); await sendToSrv({ task: task, sessionId: sid, lastAnswer: null, state: srvState }); };\n const setupInForQ = (q) => { clrInArea(); currentQ = q; let inp; const commonEnter = (ev) => { if (ev.key === 'Enter' && !ev.shiftKey) { ev.preventDefault(); sendHandler(); } }; switch (q.type) { case 'select': inp = document.createElement('select'); inp.id = 'user-input'; inp.className = 'form-control'; (q.opts || []).forEach(opt => { const o = document.createElement('option'); o.value = opt.value; o.textContent = opt.label; inp.appendChild(o); }); break; case 'textarea': inp = document.createElement('textarea'); inp.id = 'user-input'; inp.rows = 3; inp.placeholder = \"Enter details...\"; inp.className = 'form-control'; inp.addEventListener('keypress', commonEnter); break; case 'number': inp = document.createElement('input'); inp.type = 'number'; inp.id = 'user-input'; inp.placeholder = \"Enter number...\"; if (q.min != null) inp.min = q.min; if (q.max != null) inp.max = q.max; inp.className = 'form-control'; inp.addEventListener('keypress', commonEnter); break; default: inp = document.createElement('input'); inp.type = 'text'; inp.id = 'user-input'; inp.placeholder = \"Your answer...\"; inp.className = 'form-control'; inp.addEventListener('keypress', commonEnter); break; } const btn = document.createElement('button'); btn.id = 'send-button'; btn.textContent = 'Send'; btn.onclick = sendHandler; inputArea.append(inp, btn); enableInput(true); inp.focus(); };\n const sendHandler = async () => { const inp = document.getElementById('user-input'); if (!inp || !currentQ) return; let answer = inp.value; if (currentQ.type === 'number') { const num = parseFloat(answer); answer = !isNaN(num) ? num : (answer.trim() === '' ? '' : answer); } clrErr(); let displayAnswer = typeof answer === 'number' ? answer.toString() : answer; if (currentQ.type === 'select') { const opt = Array.from(inp.options).find(o => o.value === answer); displayAnswer = opt ? opt.text : answer; if (answer === \"\") displayAnswer = \"(Skipped)\"; } else if (typeof answer === 'string' && !answer.trim() && currentQ.type !== 'textarea') { displayAnswer = \"(No input)\"; } if (displayAnswer && ![\"(Skipped)\", \"(No input)\"].includes(displayAnswer)) addUser(displayAnswer); else if (typeof answer === 'string' && !answer.trim() && currentQ.type === 'textarea') addUser(\"(Empty details)\"); const lastAns = { field: currentQ.fld, value: answer }; clrInArea(); enableInput(false); setLoad(true); await sendToSrv({ task: task, sessionId: sid, lastAnswer: lastAns, state: srvState }); };\n const sendToSrv = async (pld) => { try { console.log(\"-> /questionnaire:\", pld); const resp = await fetch('/questionnaire', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(pld) }); setLoad(false); clrErr(); if (!resp.ok) { let msg = \\`Server error: \\${resp.status} \\${resp.statusText}\\`; try { msg += \\` - \\${(await resp.json()).error || 'Details unavailable'}\\` } catch(e){} throw new Error(msg); } const data = await resp.json(); console.log(\"<- /questionnaire:\", data); sid = data.sid; srvState = data.state; if (data.error) { showErr(data.error); if (currentQ) { addBot(\\`Issue: \\${data.error}. Try again.\\`); setupInForQ(currentQ); } else { addBot(\\`Error: \\${data.error}. Select task again.\\`); showTasks(); } return; } if (data.isDone) { addBot(\"Info gathered. Processing...\"); enableInput(false); clrInArea(); setLoad(true); await execWf(data.data); } else if (data.nextQ) { addBot(data.nextQ.txt); setupInForQ(data.nextQ); } else { showErr(\"Unexpected server response.\"); enableInput(false); addBot(\"Something went wrong. Refresh and try again.\"); } } catch (err) { console.error(\"Comm error:\", err); setLoad(false); showErr(\\`Comm error: \\${err.message}\\`); enableInput(false); addBot(\"Connection issue. Refresh to start over.\"); } };\n const execWf = async (finalPld) => { enableInput(false); try { console.log(\"-> /execute:\", finalPld); if (!finalPld?.task || !finalPld.data) throw new Error(\"Invalid execution payload.\"); const resp = await fetch('/execute', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(finalPld) }); setLoad(false); const resData = await resp.json(); console.log(\"<- /execute:\", resData); resDisp.style.display = 'block'; setTimeout(() => resDisp.classList.add('visible'), 10); resCont.innerHTML = ''; logCont.innerHTML = ''; if (!resp.ok || resData.error) { const msg = resData.error || \\`Exec failed: Status \\${resp.status}\\`; resCont.innerHTML = \\`

\\${esc(msg)}

\\`; if(resData.dtls) resCont.innerHTML += \\`

Details: \\${esc(typeof resData.dtls === 'string' ? resData.dtls : JSON.stringify(resData.dtls))}

\\`; addBot(\\`Error processing request: \\${esc(msg)}\\`); } else { resCont.innerHTML = fmtRes(resData.result, finalPld.task); addBot(\"Request complete! See results.\"); } logCont.innerHTML = fmtLogs(resData.logs); clrInArea(); showTasks(); } catch (err) { console.error(\"Exec error:\", err); setLoad(false); resDisp.style.display = 'block'; setTimeout(() => resDisp.classList.add('visible'), 10); resCont.innerHTML = \\`

Execution failed: \\${esc(err.message)}

\\`; logCont.innerHTML = fmtLogs(null); addBot(\"Critical error during execution. Check logs or retry.\"); clrInArea(); showTasks(); } };\n const fmtList = (items, tag='li') => items && items.length > 0 ? \\`

\\${items.map(i => \\`<$\\{tag\\}>\\${esc(i)}\\`).join('')}\\` : '';\n const fmtDictList = (items) => items && items.length > 0 ? \\`

\\${esc(d.dx || d.diagnosis)}\\${(d.rationale) ? \\`: \\${esc(d.rationale)}\\` : ''}

\\` : '';\n const fmtRes = (res, task) => { let h = ''; if (!res) return '

Process complete, no content generated.

'; const discHtml = \\`

Disclaimer: \\${esc(res.disclaimer || SAFETY_DISCLAIMER)}

\\`; try { switch(task){ case 'PREOP': const p=res; h+= \\`

Pre-Op Summary

\\${esc(p.summary).replace(/\\\\n/g,'
')}

\\`; if(p.keyPts?.length) h+= \\`

Key Considerations:

\\${fmtList(p.keyPts)}

\\`; break; case 'DRUG': const d=res; h+= \\`

\\${esc(d.drug)} Info

Dosing/Admin:
\\${esc(d.doseInfo).replace(/\\\\n/g,'
')}

\\`; if(d.pharmNotes) h+= \\`

Pharm Notes:
\\${esc(d.pharmNotes).replace(/\\\\n/g,'
')}

\\`; if(d.fx?.length) h+= \\`

Side Effects: \\${esc(d.fx.join(', '))}

\\`; if(d.warn?.length) h+= \\`

Warnings:\\${fmtList(d.warn)}

\\`; break; case 'DIAG': const di=res; h+= \\`

Differentials for: \\${esc(di.sign)}

\\${fmtDictList(di.diffs)}

\\`; if(di.actions?.length) h+= \\`

Actions to Consider:

\\${fmtList(di.actions)}

(General suggestions only)

\\`; break; case 'CHECKLIST': const c=res; h+= \\`

\\${esc(c.title)}

\\${fmtList(c.items)}

\\`; break; case 'GUIDELINE': const g=res; h+= \\`

Guideline: \\${esc(g.topic)}

\\${fmtList(g.pts)}

\\`; if(g.src) h+= \\`

\\${esc(g.src)}

\\`; break; case 'PLAN': const pl=res; h+= \\`

Planning: \\${esc(pl.focus)}

\\`; h+= \\`

Considerations:

\\${fmtList(pl.consider)}

\\`; if(pl.strats?.length) h+= \\`

Strategies:

\\${fmtList(pl.strats)}

\\`; if(pl.conting?.length) h+= \\`

Contingencies:

\\${fmtList(pl.conting)}

\\`; break; default: h = \\`

Raw:

\\${esc(JSON.stringify(res,null,2))}

\\`; break; } h += discHtml; } catch (fmtErr) { console.error(\"Result format error:\", fmtErr, \"Raw:\", res); h = \\`

Error displaying results.

Raw:

\\${esc(JSON.stringify(res,null,2))}

\\${discHtml}\\`; } return h; };\n const fmtLogs = (logs) => { if (!logs?.length) return '

No logs.

'; return logs.map(lg => { let dtlStr = ''; if(lg.dtls) { try { dtlStr = esc(JSON.stringify(lg.dtls)); } catch(e){ dtlStr='[Err]'; } } const ts = lg.ts || new Date().toISOString(); const lvl = lg.lvl || 'INFO'; const comp = lg.comp || 'Sys'; const msg = lg.msg || ''; return \\`

[\\${ts.substring(11,23)}] [\\${lvl}][\\${comp}]\\${esc(msg)}\\${dtlStr ? \\` | Dtls: \\${dtlStr}\\` : ''}

\\`; }).join(''); };\n showTasks();\n`;\n\n// --- Server-Side Logic ---\nclass Logger {\n _logs: LogEntry[] = []; midCtx?: string;\n constructor(mid?: string) { this.midCtx = mid; }\n log(lvl: LogLevel, comp: string, msg: string, dtls?: any, mid?: string, tid?: string) {\n const effMid = mid || this.midCtx || \"N/A\";\n let safeDtls; try { safeDtls = dtls === undefined ? undefined : JSON.parse(JSON.stringify(dtls)); } catch(e) { safeDtls = `[Log Err: ${e.message}]`; }\n const entry: LogEntry = { ts: new Date().toISOString(), mid: effMid, tid, lvl, comp, msg, dtls: safeDtls };\n this._logs.push(entry);\n const dStr = safeDtls ? `| D: ${JSON.stringify(safeDtls)}` : \"\";\n console.log(`[${entry.ts.substring(11,23)}] [${entry.mid}] [${entry.tid||'---'}] [${entry.lvl}] [${entry.comp}] ${entry.msg} ${dStr}`);\n }\n getLogs = (): LogEntry[] => { try { return JSON.parse(JSON.stringify(this._logs)); } catch (e) { console.error(\"Log copy failed:\",e); return [...this._logs]; } }\n clear = () => { this._logs = []; }\n setCtx = (mid: string) => { this.midCtx = mid; }\n}\n\nconst llm = async (sysPrompt: string, userPrompt: string, mid: string, tid: string, log: LogFn): Promise => {\n log(\"DEBUG\", \"LLM\", `Call OpenAI task ${tid}`, { sysL: sysPrompt.length, usrL: userPrompt.length }, mid, tid);\n const finalSys = sysPrompt + `\\n\\nREMINDER: Info only, not medical advice. Verify & use clinical judgment.`;\n try {\n const oa = new OpenAI(); // Assumes API key is set in environment\n const completion = await oa.chat.completions.create({\n model: \"gpt-4o-mini\", // Use appropriate model\n messages: [{ role: \"system\", content: finalSys }, { role: \"user\", content: userPrompt }],\n temperature: 0.5, max_tokens: 2048,\n });\n const txt = completion.choices[0]?.message?.content;\n const usage = completion.usage;\n if (!txt) { log(\"WARN\", \"LLM\", `OpenAI task ${tid} no content.`, { usage }, mid, tid); return null; }\n log(\"DEBUG\", \"LLM\", `OpenAI task ${tid} success`, { resL: txt.length, usage }, mid, tid);\n return txt.trim();\n } catch (err: any) {\n const errD = { msg: err.message, name: err.name, status: err.status, type: err.type, code: err.code };\n log(\"ERROR\", \"LLM\", `OpenAI API task ${tid} failed`, { error: errD }, mid, tid);\n throw new Error(`OpenAI API error: ${err.message}${err.code ? ` (Code: ${err.code})` : ''}`);\n }\n}\n\n// Questionnaire Logic\nclass QA {\n log: LogFn; constructor(logFn: LogFn) { this.log = logFn; }\n\n private getFlds(task: UserInput[\"task\"]): string[] {\n const baseReq = [\"procName\"];\n const baseOpt = [\"ptAge\", \"ptWtKg\", \"asa\", \"comorb\", \"allergies\", \"meds\", \"carePhase\"];\n const taskReq: Partial> = { \"DRUG\": [\"drug\"], \"DIAG\": [\"sign\"], \"CHECKLIST\": [\"type\"], \"GUIDELINE\": [\"topic\"] };\n const taskOpt: Partial> = { \"PREOP\": [\"focus\", \"concerns\"], \"DRUG\": [\"ctx\"], \"DIAG\": [\"timing\"], \"CHECKLIST\": [\"customTopic\"], \"PLAN\": [\"challenges\", \"focus\"] };\n return [...new Set([...baseReq, ...(taskReq[task] || []), ...baseOpt, ...(taskOpt[task] || [])])];\n }\n\n private selNext(flds: string[], ans: Record): string | null {\n for (const fld of flds) {\n if (ans[fld] == null || (typeof ans[fld] === 'string' && ans[fld].trim() === '')) {\n if (fld === 'customTopic' && ans['type'] !== 'custom') continue;\n if (fld === 'type' && ans['type'] === 'custom' && !(ans['customTopic'] || '').trim()) {\n const customFld = 'customTopic';\n if (flds.includes(customFld) && (!ans[customFld])) return customFld;\n }\n return fld;\n }\n }\n if (ans['type'] === 'custom' && flds.includes('customTopic') && !(ans['customTopic'] || '').trim()) return 'customTopic';\n return null;\n }\n\n private fmtQ(fld: string, state: QState): Question {\n const qid = `${fld}-${Date.now()}`; let txt = `Provide ${fld}?`; let type: Question[\"type\"] = \"text\"; let opts: Question[\"opts\"]; let min, max;\n switch (fld) {\n case \"ptAge\": txt = \"Patient Age (yrs)?\"; type = \"number\"; min=0; max=120; break;\n case \"ptWtKg\": txt = \"Patient Wt (kg)?\"; type = \"number\"; min=0.1; max=500; break;\n case \"asa\": txt = \"ASA Status?\"; type = \"select\"; opts = [ { label: \"Select ASA\", value: \"\" }, { label: \"ASA I\", value: \"ASA I\" }, { label: \"ASA II\", value: \"ASA II\" }, { label: \"ASA III\", value: \"ASA III\" }, { label: \"ASA IV\", value: \"ASA IV\" }, { label: \"ASA V\", value: \"ASA V\" }, { label: \"ASA VI\", value: \"ASA VI\" }, { label: \"ASA E\", value: \"ASA E\" } ]; break;\n case \"procName\": txt = \"Procedure name?\"; break;\n case \"comorb\": txt = \"Comorbidities / PMH? (e.g., HTN, CAD)\"; type = \"textarea\"; break;\n case \"allergies\": txt = \"Allergies? (Drug, food - specify reaction)\"; type = \"textarea\"; break;\n case \"meds\": txt = \"Current meds? (Incl. dose/freq if relevant)\"; type = \"textarea\"; break;\n case \"carePhase\": txt = \"Phase of care?\"; type = \"select\"; opts = [{ label: \"Select Phase\", value: \"\" }, { label: \"Pre-op\", value: \"pre-op\" }, { label: \"Intra-op\", value: \"intra-op\" }, { label: \"Post-op/PACU\", value: \"post-op\" }]; break;\n case \"focus\": txt = \"Specific focus for assessment? (Optional)\"; break; // PREOP optional\n case \"concerns\": txt = \"Specific pre-op concerns? (Optional)\"; type = \"textarea\"; break; // PREOP optional\n case \"drug\": txt = \"Drug name?\"; break; // DRUG required\n case \"ctx\": txt = \"Context for drug use? (Optional, e.g., Induction)\"; break; // DRUG optional\n case \"sign\": txt = \"Presenting sign/symptom? (e.g., Hypotension)\"; break; // DIAG required\n case \"timing\": txt = \"When did this occur? (Optional)\"; break; // DIAG optional\n case \"type\": txt = \"Checklist type?\"; type = \"select\"; opts = [ { label: \"Select Type\", value: \"\" }, { label: \"Pre-Induction\", value: \"pre-induction\" }, { label: \"Time Out\", value: \"time-out\" }, { label: \"Regional Block\", value: \"regional_block\" }, { label: \"Emergence\", value: \"emergence\" }, { label: \"PACU Handover\", value: \"pacu_handover\" }, { label: \"Custom\", value: \"custom\" } ]; break; // CHECKLIST required\n case \"customTopic\": txt = \"Topic for custom checklist?\"; break; // CHECKLIST required if type=custom\n case \"topic\": txt = \"Guideline topic? (e.g., ASA Fasting)\"; break; // GUIDELINE required\n case \"challenges\": txt = \"Anticipated challenges? (Optional)\"; type = \"textarea\"; break; // PLAN optional\n // case \"focus\" (PLAN): Uses same name as PREOP focus, handled by context. Text set below.\n default: txt = `Details for '${fld}'?`; if (fld.match(/description|details|notes|summary/i)) type = \"textarea\"; break;\n }\n if (fld === 'focus' && state.task === 'PLAN') txt = \"Planning focus area? (Optional)\";\n\n const baseReq = [\"procName\"]; const taskReqMap: Partial> = { \"DRUG\": [\"drug\"], \"DIAG\": [\"sign\"], \"CHECKLIST\": [\"type\"], \"GUIDELINE\": [\"topic\"]};\n const isReq = baseReq.includes(fld) || (taskReqMap[state.task] || []).includes(fld);\n const isCustomTopicReq = fld === 'customTopic' && state.answers['type'] === 'custom';\n if (!isReq && !isCustomTopicReq) txt += \" (Optional)\";\n\n return { id: qid, fld, txt, type, opts, min, max };\n }\n\n async nextQ(sid: string | null, task: UserInput[\"task\"], lastAnswer: { field: string; value: any } | null, prevState?: QState | null): Promise {\n let state: QState;\n if (!prevState || !sid) {\n const newSid = `sess-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;\n this.log(\"INFO\", \"QA\", `New session: ${newSid} for task: ${task}`, undefined, newSid);\n state = { sid: newSid, task, flds: this.getFlds(task), answers: {}, hist: [], isDone: false };\n } else {\n state = { ...prevState, answers: { ...prevState.answers }, hist: [...prevState.hist] };\n if (lastAnswer?.field) {\n let val = (typeof lastAnswer.value === 'string') ? lastAnswer.value.trim() : lastAnswer.value;\n this.log(\"DEBUG\", \"QA\", `Ans for '${lastAnswer.field}'`, { v: val }, state.sid);\n state.answers[lastAnswer.field] = val;\n if(lastAnswer.field === 'type' && val !== 'custom' && state.answers['customTopic']){\n this.log(\"DEBUG\", \"QA\", `Clearing custom topic`, { old: state.answers['customTopic'] }, state.sid);\n delete state.answers['customTopic'];\n state.flds = this.getFlds(state.task); // Re-evaluate fields if type changes\n }\n }\n if (state.task !== task) { // Handle task change mid-session\n this.log(\"INFO\", \"QA\", `Task changed: ${state.task} -> ${task}. Resetting fields.`, { sid: state.sid });\n const commonFlds = [\"ptAge\", \"ptWtKg\", \"asa\", \"procName\", \"comorb\", \"allergies\", \"meds\", \"carePhase\"];\n const retainedAns: Record = {};\n commonFlds.forEach(f => { if (state.answers[f] != null && state.answers[f] !== '') retainedAns[f] = state.answers[f]; });\n state = { sid: state.sid, task, flds: this.getFlds(task), answers: retainedAns, hist: [], isDone: false };\n }\n }\n\n const nextFld = this.selNext(state.flds, state.answers);\n if (!nextFld) {\n state.isDone = true;\n this.log(\"INFO\", \"QA\", `Q complete for '${state.task}'. Finalizing.`, { ans: state.answers }, state.sid);\n const finalData = this.prepData(state.answers, state.task, state.sid);\n try {\n UISchema.parse(finalData); // Final validation\n this.log(\"INFO\", \"QA\", \"Final data valid.\", { data: finalData }, state.sid);\n return { sid: state.sid, isDone: true, data: finalData, state, nextQ: undefined, error: undefined };\n } catch (err) {\n const zErr = err as z.ZodError; const msg = zErr.issues.map(i => `'${i.path.join('.')}': ${i.message}`).join('; ');\n this.log(\"ERROR\", \"QA\", \"Final data invalid\", { errs: zErr.issues, data: finalData }, state.sid);\n state.isDone = false;\n return { sid: state.sid, isDone: false, error: `Validation failed: ${msg}. Missing/invalid info.`, state, nextQ: undefined, data: undefined };\n }\n } else {\n const nextQ = this.fmtQ(nextFld, state);\n if (!state.hist.find(q => q.qid === nextQ.id)) state.hist.push({ qid: nextQ.id, fld: nextQ.fld, txt: nextQ.txt });\n this.log(\"INFO\", \"QA\", `Next Q for: ${nextFld}`, { qTxt: nextQ.txt }, state.sid);\n return { sid: state.sid, isDone: false, nextQ, state, data: undefined, error: undefined };\n }\n }\n\n private prepData(ans: Record, task: UserInput[\"task\"], sid?: string): UserInput {\n let finalData: Record = { ...ans };\n [\"ptAge\", \"ptWtKg\"].forEach(fld => {\n if (fld in finalData) {\n if (typeof finalData[fld] === 'string') {\n const num = parseFloat(finalData[fld]);\n if (!isNaN(num)) finalData[fld] = num;\n else if (finalData[fld].trim() === '') delete finalData[fld]; // Remove empty optional strings\n else this.log(\"WARN\", \"prepData\", `Non-numeric value for '${fld}'`, { v: finalData[fld] }, sid);\n } else if (typeof finalData[fld] !== 'number') {\n if (finalData[fld] == null || finalData[fld] === '') delete finalData[fld]; // Remove null/undefined/empty\n else this.log(\"WARN\", \"prepData\", `Unexpected type for '${fld}'`, { v: finalData[fld], t: typeof finalData[fld] }, sid);\n }\n }\n });\n\n // Determine strictly required fields for *this* task\n const baseReq = [\"procName\"];\n const taskReqMap: Partial> = { \"DRUG\": [\"drug\"], \"DIAG\": [\"sign\"], \"CHECKLIST\": [\"type\"], \"GUIDELINE\": [\"topic\"] };\n const strictReq = new Set([...baseReq, ...(taskReqMap[task] || [])]);\n if (task === 'CHECKLIST' && finalData['type'] === 'custom') strictReq.add('customTopic');\n\n // Remove empty optional fields\n for (const key in finalData) {\n if (!strictReq.has(key) && (finalData[key] == null || finalData[key] === \"\")) {\n delete finalData[key];\n this.log(\"DEBUG\", \"prepData\", `Removed empty opt field: ${key}`, undefined, sid);\n }\n }\n // Cleanup conditional field\n if (task === 'CHECKLIST' && finalData['type'] !== 'custom' && finalData['customTopic'] != null) {\n delete finalData['customTopic'];\n this.log(\"DEBUG\", \"prepData\", `Removed customTopic (type != custom).`, undefined, sid);\n }\n return { task, data: finalData };\n }\n}\n\n// --- Agent Functions (Task Runners) ---\nconst runPreop = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; log(\"INFO\", \"PreopAgent\", `Task ${tid}`, { proc: data.procName, focus: data.focus }, mid, tid);\n const sysPrompt = `AI Anesthesia Pre-op Summarizer. Goal: Highlight potential risks/considerations. NO definitive advice/plans. Info ONLY.\n Context: Proc: ${data.procName||'N/A'}, Age: ${data.ptAge??'N/A'}y, Wt: ${data.ptWtKg??'N/A'}kg, ASA: ${data.asa||'N/A'}, Hx: ${data.comorb||'N/A'}, Allergies: ${data.allergies||'N/A'}, Meds: ${data.meds||'N/A'}, Focus: ${data.focus||'General'}, Concerns: ${data.concerns||'N/A'}\n Task: 1. Analyze context. 2. Summarize anesthetic considerations/risks (airway, cardiac, resp, bleed, meds). 3. Emphasize 'Focus' if given. 4. Address 'Concerns'. 5. Structure: Summary text, optional 'Key Points:' list. 6. Output ONLY summary/points. 7. Include disclaimer.`;\n const userPrompt = `Gen pre-op summary based on system prompt. Focus: ${data.focus || 'General'}.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"PreopAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { summary: \"AI no output.\", disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let summary = res, keyPts: string[] = []; const kpMatch = res.match(/Key Points:?\\s*([\\s\\S]*)/i);\n if (kpMatch) { summary = res.substring(0, kpMatch.index).replace(/^Summary:\\s*/i,'').trim(); keyPts = kpMatch[1].split(/[\\n\\r]\\s*[\\*\\-]\\s*/).map(p=>p.trim()).filter(p=>p.length>1); } else { summary = summary.replace(/^Summary:\\s*/i,'').trim(); }\n const out: POut = { summary: summary || \"No summary.\", keyPts: keyPts.length ? keyPts : undefined, disclaimer: DISCLAIMER };\n log(\"INFO\", \"PreopAgent\", `Task ${tid} OK. Summary len: ${out.summary.length}`, { keyPts: out.keyPts?.length }, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"PreopAgent\", `Task ${tid} FAIL`, { err: err.message }, mid, tid); return { mid, correlationId: tid, data: { summary: \"Error.\", disclaimer: DISCLAIMER }, error: `Preop failed: ${err.message}` }; }\n}\n\nconst runDrug = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; log(\"INFO\", \"DrugAgent\", `Task ${tid}`, { drug: data.drug, ctx: data.ctx }, mid, tid);\n const sysPrompt = `AI Anesthesia Drug Info Assistant. Goal: Summarize general drug info (ranges, route, pharm, fx, warns). CRITICAL: NO specific dose recommendations. Provide RANGES ONLY. Actual dose needs clinical judgment & institutional guidelines. DO NOT calculate dose from wt. Info ONLY.\n Drug: ${data.drug}. Ctx: ${data.ctx||'General'}. Ref: Wt ${data.ptWtKg??'N/A'}kg, Age ${data.ptAge??'N/A'}y, Hx ${data.comorb||'N/A'}, Allergies ${data.allergies||'N/A'}.\n Task: 1. ID drug. 2. Give TYPICAL dose RANGES (e.g., mg/kg) & routes for context. State RANGES. 3. Basic PK/PD (onset, duration). 4. List common side effects. 5. List major contraindications/warnings (consider Hx/Allergies). 6. Clear sections: 'Dosing Info:', 'Pharm Notes:', 'Side Effects:', 'Warnings:'. 7. Output ONLY info. 8. Include disclaimer.`;\n const userPrompt = `Provide info for ${data.drug}, context: ${data.ctx||'General'}, per system prompt.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"DrugAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { drug: data.drug, doseInfo: \"AI no output.\", disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let dose=\"NF\", pharm, fx: string[]=[], warn: string[]=[];\n dose = res.match(/Dosing Info:?\\s*([\\s\\S]*?)(?=Pharm|Side Effects|Warnings:|$)/i)?.[1]?.trim() || dose;\n pharm = res.match(/Pharm Notes:?\\s*([\\s\\S]*?)(?=Side Effects|Warnings:|$)/i)?.[1]?.trim();\n fx = res.match(/Side Effects:?\\s*([\\s\\S]*?)(?=Warnings:|$)/i)?.[1]?.split(/[\\n\\r,;]\\s*[\\*\\-]?\\s*/).map(s=>s.trim()).filter(s=>s.length>1) || [];\n warn = res.match(/Warnings:?\\s*([\\s\\S]*)/i)?.[1]?.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(w=>w.trim()).filter(w=>w.length>1) || [];\n const out: DOut = { drug: data.drug, doseInfo: dose, pharmNotes: pharm, fx: fx.length?fx:undefined, warn: warn.length?warn:undefined, disclaimer: DISCLAIMER };\n log(\"INFO\", \"DrugAgent\", `Task ${tid} OK`, { drug: data.drug }, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"DrugAgent\", `Task ${tid} FAIL`, { err: err.message, drug: data.drug }, mid, tid); return { mid, correlationId: tid, data: { drug: data.drug, doseInfo: \"Error.\", disclaimer: DISCLAIMER }, error: `Drug info failed: ${err.message}` }; }\n}\n\nconst runDiag = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; log(\"INFO\", \"DiagAgent\", `Task ${tid}`, { sign: data.sign, timing: data.timing }, mid, tid);\n const sysPrompt = `AI Anesthesia Differential Diagnosis Aid. Goal: List potential causes for clinical sign/symptom. CRITICAL: NO definitive diagnosis/treatment plan. List possibilities ONLY for clinician consideration. May suggest GENERAL action categories (e.g., 'Assess ABCs'), NOT specific interventions. Info ONLY.\n Scenario: Sign/Symptom: ${data.sign}. Timing: ${data.timing||'N/A'}. Phase: ${data.carePhase||'N/A'}. Proc: ${data.procName||'N/A'}. Ref: Age ${data.ptAge??'N/A'}, ASA ${data.asa||'N/A'}, Hx ${data.comorb||'N/A'}.\n Task: 1. Gen diff dx list for sign/timing. 2. Prioritize common/critical PRN. 3. Brief rationale per dx if helpful. 4. Optionally list GENERAL immediate action types (e.g., Check Vitals, Assess Airway). 5. Clear structure. 6. Output ONLY diffs/actions. 7. Include disclaimer.\n Format: 'differentials' (list of {dx, rationale?}), optional 'immediateActionsSuggested' (list of strings).`;\n const userPrompt = `Gen diff dx for '${data.sign}' (${data.timing||'intra-op'}), per system prompt.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"DiagAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { sign: data.sign, diffs: [{ dx: \"AI no output.\" }], disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let diffs: { dx: string; rationale?: string }[] = []; let actions: string[] = [];\n const diffBlock = res.match(/Differential.*?:\\s*([\\s\\S]*?)(?=Immediate Actions|Actions to Consider|$)/i)?.[1] || res;\n diffs = diffBlock.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(l=>l.trim()).filter(l=>l.length>2).map(l=>{ const p=l.split(/:\\s+/); return { dx: p[0].trim(), rationale: p.length>1 ? p.slice(1).join(': ').trim() : undefined }; });\n actions = res.match(/(Immediate Actions|Actions to Consider):?\\s*([\\s\\S]*)/i)?.[2]?.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(a=>a.trim()).filter(a=>a.length>2) || [];\n if (!diffs.length) { diffs.push({dx:\"Parse error.\", rationale:res.substring(0,100)}); log(\"WARN\",\"DiagAgent\",\"Parse failed\", {len:res.length},mid,tid); }\n const out: DiagOut = { sign: data.sign, diffs, actions: actions.length?actions:undefined, disclaimer: DISCLAIMER };\n log(\"INFO\", \"DiagAgent\", `Task ${tid} OK. Found ${out.diffs.length} diffs.`, { sign: data.sign }, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"DiagAgent\", `Task ${tid} FAIL`, { err: err.message, sign: data.sign }, mid, tid); return { mid, correlationId: tid, data: { sign: data.sign, diffs: [{ dx: \"Error.\" }], disclaimer: DISCLAIMER }, error: `Diag failed: ${err.message}` }; }\n}\n\nconst runChk = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; const title = data.type === 'custom' ? data.customTopic || 'Custom' : data.type.replace(/_/g,' ').toUpperCase(); log(\"INFO\", \"ChkAgent\", `Task ${tid}`, { type: data.type, title }, mid, tid);\n const sysPrompt = `AI Anesthesia Checklist Generator. Goal: Create example checklist items for a phase/procedure. CRITICAL: Generated checklists are EXAMPLES. MUST be reviewed/modified/validated against institutional protocols & context before use. Not a substitute for approved lists/judgment. Info ONLY.\n Context: Type: ${data.type}. Custom Topic: ${data.customTopic||'N/A'}. Proc: ${data.procName||'N/A'}. Phase: ${data.carePhase||'Implied'}.\n Task: 1. Gen relevant items for type/topic. 2. Base on standard practices (e.g., WHO, pre-induction checks). 3. Clear, concise action/verification points. 4. Logical order PRN. 5. Reasonable item count (5-15 typical). 6. Output ONLY item list. 7. Include disclaimer. Format: list of strings.`;\n const userPrompt = `Generate a ${title} Checklist based on standard practices, per system prompt.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"ChkAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { title, items: [\"AI no output.\"], disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let items = res.split(/[\\n\\r]+/).map(l=>l.replace(/^[\\*\\-\\s]+/,'').trim()).filter(i=>i.length>2);\n if(!items.length) { items.push(\"Parse error.\", res.substring(0,100)); log(\"WARN\",\"ChkAgent\",`Parse fail ${title}`,{len:res.length},mid,tid); }\n const out: ChkOut = { title, items, disclaimer: DISCLAIMER + \" Verify vs institutional protocols.\" };\n log(\"INFO\", \"ChkAgent\", `Task ${tid} OK. ${out.items.length} items for ${title}.`, undefined, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"ChkAgent\", `Task ${tid} FAIL`, { err: err.message, title }, mid, tid); return { mid, correlationId: tid, data: { title, items: [\"Error.\"], disclaimer: DISCLAIMER }, error: `Checklist failed: ${err.message}` }; }\n}\n\nconst runGuide = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; log(\"INFO\", \"GuideAgent\", `Task ${tid}`, { topic: data.topic }, mid, tid);\n const sysPrompt = `AI Guideline Summarizer. Goal: Extract key points/recommendations from known medical/anesthesia guidelines. CRITICAL: Summary based on AI knowledge cutoff, may NOT be latest. NOT substitute for reading official full guideline document. Verify info with source. Info ONLY. Suggest consulting full guideline.\n Context: Topic: ${data.topic}. Proc: ${data.procName||'N/A'}. Ref: Age ${data.ptAge??'N/A'}, ASA ${data.asa||'N/A'}.\n Task: 1. ID core recommendations/points for topic from recognized sources (e.g., ASA). 2. Summarize concisely (bullet points). 3. Focus on actionable items/definitions. 4. Do NOT invent. State if topic unknown. 5. Output ONLY points. 6. Suggest consulting full guideline. 7. Include disclaimer. Format: 'summaryPoints' list, 'sourceSuggestion' string.`;\n const userPrompt = `Summarize guideline topic: '${data.topic}', per system prompt.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"GuideAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { topic: data.topic, pts: [\"AI no output.\"], src: \"Consult official guideline.\", disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let pts = res.split(/[\\n\\r]+/).map(l=>l.replace(/^[\\*\\-\\s]+/,'').trim()).filter(p=>p.length>5);\n let src = `Consult official guidelines (e.g., ASA, ESAIC) or institutional protocols re: \"${data.topic}\".`;\n if (res.match(/Refer to|Consult the/i)) { const suggLine = res.substring(res.search(/Refer to|Consult the/i)).split(/[\\n\\r]+/)[0]; if(suggLine?.length > 20) src = suggLine.trim(); }\n if (!pts.length) { pts.push(\"Parse error.\", res.substring(0,100)); log(\"WARN\",\"GuideAgent\",`Parse fail ${data.topic}`,{len:res.length},mid,tid); }\n const out: GOut = { topic: data.topic, pts, src, disclaimer: DISCLAIMER };\n log(\"INFO\", \"GuideAgent\", `Task ${tid} OK. ${out.pts.length} points for ${data.topic}.`, undefined, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"GuideAgent\", `Task ${tid} FAIL`, { err: err.message, topic: data.topic }, mid, tid); return { mid, correlationId: tid, data: { topic: data.topic, pts: [\"Error.\"], src:\"Consult guideline.\", disclaimer: DISCLAIMER }, error: `Guideline failed: ${err.message}` }; }\n}\n\nconst runPlan = async (req: TaskIn, log: LogFn): Promise> => {\n const { mid, tid, data } = req; const focus = data.focus || `Planning for ${data.procName}`; log(\"INFO\", \"PlanAgent\", `Task ${tid}`, { proc: data.procName, focus, chal: data.challenges }, mid, tid);\n const sysPrompt = `AI Anesthesia Case Planning Assistant. Goal: Brainstorm options/considerations. CRITICAL: DO NOT create definitive plan. Output is IDEAS ONLY for clinician evaluation based on expertise, full assessment, institutional practice. Cannot account for real-time events. Info ONLY.\n Context: Proc: ${data.procName||'N/A'}. Ref: Age ${data.ptAge??'N/A'}, Wt ${data.ptWtKg??'N/A'}kg, ASA ${data.asa||'N/A'}, Hx ${data.comorb||'N/A'}, Allergies ${data.allergies||'N/A'}, Meds ${data.meds||'N/A'}. Challenges: ${data.challenges||'N/A'}. Focus: ${data.focus||'General consider.'}.\n Task: 1. Review context (proc, pt, challenges). 2. Based on 'Focus', list relevant points (e.g., monitors, airway, fluids, pain). 3. Suggest POTENTIAL strategies/techniques (e.g., GA vs RA, TIVA vs Volatile). List as OPTIONS. 4. Brainstorm CONTINGENCIES for challenges (e.g., backup airway, vasoactives). 5. Clear headings: 'Considerations:', 'Strategies:', 'Contingencies:'. 6. Output ONLY points. 7. Include disclaimer.`;\n const userPrompt = `Provide planning assist focused on '${focus}', Proc '${data.procName}', Challenges '${data.challenges||'None'}', per system prompt.`;\n try {\n const res = await llm(sysPrompt, userPrompt, mid, tid, log);\n if (!res) { log(\"WARN\", \"PlanAgent\", `LLM no content ${tid}`, undefined, mid, tid); return { mid, correlationId: tid, data: { focus, consider: [\"AI no output.\"], disclaimer: DISCLAIMER }, error: \"AI failed: No content.\" }; }\n let consider:string[]=[], strats:string[]=[], conting:string[]=[];\n consider = res.match(/(Key |General )?Considerations:?\\s*([\\s\\S]*?)(?=Potential Strategies|Contingency|$)/i)?.[2]?.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(c=>c.trim()).filter(c=>c.length>2) || [];\n strats = res.match(/Potential Strategies(\\/Techniques)?:?\\s*([\\s\\S]*?)(?=Contingency|$)/i)?.[2]?.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(s=>s.trim()).filter(s=>s.length>2) || [];\n conting = res.match(/Contingency Planning( Ideas)?:?\\s*([\\s\\S]*)/i)?.[2]?.split(/[\\n\\r]\\s*[\\*\\-]?\\s*/).map(c=>c.trim()).filter(c=>c.length>2) || [];\n if (!consider.length && !strats.length && !conting.length) { consider.push(\"Parse error.\", res.substring(0,100)); log(\"WARN\",\"PlanAgent\",`Parse fail ${focus}`,{len:res.length},mid,tid); }\n const out: CPlanOut = { focus, consider, strats: strats.length?strats:undefined, conting: conting.length?conting:undefined, disclaimer: DISCLAIMER + \" Not a plan; evaluate critically.\" };\n log(\"INFO\", \"PlanAgent\", `Task ${tid} OK. Points for ${focus}.`, { cons:consider.length, strat:strats.length, cont:conting.length }, mid, tid);\n return { mid, correlationId: tid, data: out };\n } catch (err: any) { log(\"ERROR\", \"PlanAgent\", `Task ${tid} FAIL`, { err: err.message, focus }, mid, tid); return { mid, correlationId: tid, data: { focus, consider: [\"Error.\"], disclaimer: DISCLAIMER }, error: `Plan assist failed: ${err.message}` }; }\n}\n\n// --- Orchestrator ---\nclass Orchestrator {\n baseLog: LogFn; mid: string; log: LogFn;\n constructor(logger: Logger) {\n this.baseLog = logger.log.bind(logger);\n this.mid = `mandate-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;\n logger.setCtx(this.mid);\n this.log = (lvl, comp, msg, dtls?, _midIgnored?, tid?) => this.baseLog(lvl, comp, msg, dtls, this.mid, tid);\n this.log(\"INFO\", \"Orch\", `Init mandate: ${this.mid}`);\n }\n\n async runWf(inp: UserInput): Promise {\n this.log(\"INFO\", \"Orch\", `Start WF task: ${inp.task}`, { dataKeys: Object.keys(inp.data) });\n const tid = `${inp.task}-exec-${Date.now()}-${Math.random().toString(36).slice(2, 5)}`;\n const taskIn: TaskIn = { mid: this.mid, tid, data: inp.data };\n let taskOut: TaskOut;\n try {\n const agentLog: LogFn = (l, c, m, d?, _mId?, tId?) => this.log(l, c, m, d, this.mid, tId || tid);\n switch (inp.task) {\n case \"PREOP\": taskOut = await runPreop(taskIn as TaskIn, agentLog); break;\n case \"DRUG\": taskOut = await runDrug(taskIn as TaskIn, agentLog); break;\n case \"DIAG\": taskOut = await runDiag(taskIn as TaskIn, agentLog); break;\n case \"CHECKLIST\": taskOut = await runChk(taskIn as TaskIn, agentLog); break;\n case \"GUIDELINE\": taskOut = await runGuide(taskIn as TaskIn, agentLog); break;\n case \"PLAN\": taskOut = await runPlan(taskIn as TaskIn, agentLog); break;\n default: const _: never = inp.task; throw new Error(`Unsupported task: ${inp.task}`);\n }\n if (taskOut.error) {\n this.log(\"WARN\", \"Orch\", `Agent task ${tid} (${inp.task}) ended with error`, { agentErr: taskOut.error, agentData: taskOut.data });\n return { mid: this.mid, error: `Agent failed: ${taskOut.error}`, result: taskOut.data, logs: [], dtls: 'Agent processing error.' };\n }\n this.log(\"INFO\", \"Orch\", `WF task ${tid} (${inp.task}) OK.`);\n return { mid: this.mid, result: taskOut.data, error: undefined, logs: [] }; // Logs are added by handler\n } catch (err: any) {\n this.log(\"ERROR\", \"Orch\", `WF critical fail ${tid} (${inp.task})`, { errMsg: err.message, stack: err.stack?.substring(0,200) });\n return { mid: this.mid, error: `WF exec failed: ${err.message}`, logs: [], dtls: 'Orchestration layer critical error.' };\n }\n }\n}\n\n// --- Main HTTP Handler ---\nexport default async function(req: Request): Promise {\n const reqId = `req-${Date.now()}-${Math.random().toString(36).slice(2, 7)}`;\n const logger = new Logger(reqId); const log = logger.log.bind(logger);\n const url = new URL(req.url);\n const headers = { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\", \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\", \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\" };\n\n if (req.method === \"OPTIONS\") { log(\"INFO\", \"Handler\", \"OPTIONS preflight\"); return new Response(null, { status: 204, headers }); }\n\n try {\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"\")) {\n log(\"INFO\", \"Handler\", \"GET /: Serve UI shell\");\n return new Response(genHtml(), { status: 200, headers: { ...headers, \"Content-Type\": \"text/html\" } });\n }\n else if (req.method === \"POST\" && url.pathname === \"/questionnaire\") {\n log(\"INFO\", \"Handler\", \"POST /questionnaire: Step\"); let body, rawBody;\n try { rawBody = await req.text(); body = JSON.parse(rawBody); if (!body?.task) throw new Error(\"Missing 'task'.\"); log(\"DEBUG\", \"Handler\", \"Recv /q payload\", { p: body }); }\n catch (e: any) { log(\"WARN\", \"Handler\", \"Bad JSON /q\", { err: e.message, b: rawBody?.substring(0,100) }); return new Response(JSON.stringify({ error: `Bad Request: ${e.message}`, state: null }), { status: 400, headers }); }\n const qa = new QA(log); const { sessionId: sid, task, lastAnswer, state } = body;\n const resp = await qa.nextQ(sid, task, lastAnswer, state);\n log(\"INFO\", \"Handler\", `/q resp gen. Done: ${resp.isDone}`, { sid: resp.sid, err: !!resp.error });\n return new Response(JSON.stringify(resp), { status: resp.error ? 400 : 200, headers });\n }\n else if (req.method === \"POST\" && url.pathname === \"/execute\") {\n log(\"INFO\", \"Handler\", \"POST /execute: Start task\"); let validIn: UserInput, rawPld;\n try { rawPld = await req.json(); log(\"DEBUG\", \"Handler\", \"Recv /exec payload\", { p: rawPld }); validIn = UISchema.parse(rawPld); log(\"INFO\", \"Handler\", \"Payload valid /exec\", { task: validIn.task }); }\n catch (error: any) {\n let errDtls = \"Invalid input format.\", issues;\n if (error instanceof z.ZodError) { issues = error.issues; errDtls = issues.map(i => `'${i.path.join('.')}': ${i.message}`).join('; '); log(\"WARN\", \"Handler\", \"Zod fail /exec\", { errs: errDtls, issues, p: rawPld }); }\n else { errDtls = error.message; log(\"WARN\", \"Handler\", \"Parse/valid fail /exec\", { err: errDtls, p: rawPld }); }\n return new Response(JSON.stringify({ error: \"Invalid input.\", dtls: errDtls, logs: logger.getLogs(), mid: `err-${reqId}` }), { status: 400, headers });\n }\n const execLogger = new Logger(); // Separate logger for execution phase\n const orch = new Orchestrator(execLogger);\n const result = await orch.runWf(validIn);\n result.logs = execLogger.getLogs(); // Add execution logs to the final result\n const status = result.error ? 500 : 200;\n log(\"INFO\", \"Handler\", `/exec WF done status ${status}`, { mid: result.mid, task: validIn.task, err: !!result.error });\n return new Response(JSON.stringify(result), { status, headers });\n }\n else {\n log(\"WARN\", \"Handler\", `Unsupported: ${req.method} ${url.pathname}`);\n return new Response(JSON.stringify({ error: \"Not Found/Allowed\" }), { status: 404, headers });\n }\n } catch (err: any) {\n log(\"ERROR\", \"Handler\", \"Unhandled exception\", { errMsg: err.message, stack: err.stack?.substring(0,200) });\n return new Response(JSON.stringify({ error: \"Internal Server Error\", dtls: \"Unexpected error.\", logs: logger.getLogs(), mid: `crash-${reqId}` }), { status: 500, headers });\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/salon/med/code/main.tsx","extension","actionData","errors"]