AI Biz Asst

\n \n \n \n \n

\n \n `;\n}\n\n// --- Main Request Handler (Concise) ---\nexport default async function(req: Request): Promise {\n const reqId = `r-${Date.now()}-${Math.random().toString(36).slice(2, 7)}`;\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\", \"H\", \"OPT\");\n return new Response(null, { status: 204, headers });\n }\n\n try {\n if (req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"\")) {\n log(\"IN\", \"H\", \"GET /\");\n const html = generateOrthogonalUI();\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\", \"H\", \"POST /q\");\n let b;\n let rawB = \"[No body]\";\n try {\n rawB = await req.text();\n b = JSON.parse(rawB);\n if (\n !b?.task || typeof b.task !== \"string\" || !b.action\n || ![\"start\", \"answer\", \"back\", \"restart\"].includes(b.action) || (b.action === \"answer\" && !b.lastAnswer)\n ) throw new Error(\"Bad req.\");\n } catch (e: any) {\n log(\"WN\", \"H\", \"Bad /q body\", { e: e.message, b: rawB.slice(0, 300) });\n return new Response(JSON.stringify({ err: `Bad Req: ${e.message}`, st: null, dbgL: reqLgr.getLogs() }), {\n status: 400,\n headers,\n });\n }\n\n const qA = new QAgent(log);\n let qRes: QResp;\n try {\n log(\"DB\", \"H\", `Proc: ${b.action}`, { t: b.task, s: b.sessionId, hasS: !!b.state, hasA: !!b.lastAnswer });\n switch (b.action) {\n case \"start\":\n qRes = await qA.nextStep(b.sessionId, b.task, b.lastAnswer, null);\n break;\n case \"answer\":\n qRes = await qA.nextStep(b.sessionId, b.task, b.lastAnswer, b.state);\n break;\n case \"back\":\n qRes = !b.state\n ? { sid: b.sessionId || `e-${Date.now()}`, isDone: false, err: \"No state to go back.\", state: null }\n : await qA.goBack(b.sessionId, b.task, b.state);\n break;\n case \"restart\":\n qRes = await qA.restart(b.sessionId, b.task);\n break;\n default: // Should not be reached due to initial validation\n qRes = {\n sid: b.sessionId || `e-${Date.now()}`,\n isDone: false,\n err: \"Invalid action.\",\n state: b.state || null,\n };\n }\n const respSt = qRes.state ? { ...qRes.state } : null;\n log(\"DB\", \"H\", \"Q step proc.\", {\n sid: qRes.sid,\n done: qRes.isDone,\n hasE: !!qRes.err,\n nextF: qRes.nextQ?.field,\n });\n return new Response(JSON.stringify({ ...qRes, state: respSt }), { status: qRes.err ? 400 : 200, headers });\n } catch (e: any) {\n log(\"ER\", \"H\", `QAgent proc err: ${b.action}.`, { e: e.message, s: e.stack?.slice(0, 300) });\n return new Response(\n JSON.stringify({ err: `Internal Q err: ${e.message}`, st: null, dbgL: reqLgr.getLogs(), mid: reqId }),\n { status: 500, headers },\n );\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/execute\") {\n log(\"IN\", \"H\", \"POST /exec\");\n let vInput: UserIn;\n let rawP = \"[No payload]\";\n try {\n const p = await req.json();\n rawP = JSON.stringify(p).slice(0, 300);\n log(\"DB\", \"H\", \"Payload /exec\", { p: rawP });\n vInput = UserInSchema.parse(p);\n log(\"IN\", \"H\", \"Payload valid OK /exec.\", { t: vInput.task });\n } catch (e: any) {\n let d = \"Bad input.\";\n if (e instanceof z.ZodError) d = e.issues.map(i => `${i.path.join(\".\")}: ${i.message}`).join(\"; \"); else d =\n e.message;\n log(\"WN\", \"H\", \"Valid fail /exec.\", { e: d, p: rawP });\n return new Response(\n JSON.stringify({ err: \"Bad input data.\", details: d, dbgL: reqLgr.getLogs(), mid: `m-v-${reqId}` }),\n { status: 400, headers },\n );\n }\n const execLgr = new LogAgent();\n const orch = new Orchestrator(execLgr);\n const finalRes: FinalRes = await orch.runWorkflow(vInput);\n finalRes.dbgLog = execLgr.getLogs();\n const respS = finalRes.err ? (finalRes.err.startsWith(\"AI output was unparseable\") ? 422 : 500) : 200; // 422 for unprocessable AI entity\n log(\"IN\", \"H\", `/exec wf end status ${respS}`, { mid: finalRes.mid, hasE: !!finalRes.err });\n return new Response(JSON.stringify(finalRes), { status: respS, headers });\n }\n\n log(\"WN\", \"H\", `Unsup req: ${req.method} ${url.pathname}`);\n const errL = reqLgr.getLogs();\n return new Response(JSON.stringify({ err: \"Not Found\", dbgL: errL, mid: reqId }), { status: 404, headers });\n } catch (err: any) {\n log(\"ER\", \"H\", \"Unhandled exc.\", { e: err.message, s: err.stack?.slice(0, 300) });\n const crashL = reqLgr.getLogs();\n return new Response(\n JSON.stringify({\n err: \"Internal Error\",\n details: \"Unexpected server error.\",\n dbgL: crashL,\n mid: `m-c-${reqId}`,\n st: null, // Ensure 'st' (state) is defined as null for error consistency if frontend expects it\n }),\n { status: 500, headers },\n );\n }\n}","label","children",[72],"contentHash","11302a66ae762ee2a77c2e58ab04f0d112ac272436b8e38b74612aac5de9057c","9208eb98-31cc-11f0-a119-569c3dd06744","1c904b35-3784-44b3-b404-248e74be2c0f",["D",1747341514149],2,"import { fetch } from \"https://esm.town/v/std/fetch\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { z } from \"npm:zod\";\n\n// --- Types (Minimal & Core) ---\ntype TskIn = { mid: string; tid: string; p: T };\ntype TskOut = { mid: string; cid: string; p: T; e?: string };\ntype Lvl = \"DB\" | \"IN\" | \"WN\" | \"ER\"; // Abbreviated log levels\ntype LogFn = (lvl: Lvl, comp: string, msg: string, dt?: any, mid?: string, tid?: string) => void;\ntype LogEntry = { ts: string; mid: string; tid?: string; lvl: Lvl; comp: string; msg: string; dt?: any };\ntype BaseIn = { bType?: string; sDesc?: string; tAud?: string; bTone?: string; goals?: string };\n\n// Task-specific inputs (reusing types from before, minimal change needed)\ntype CntIn = BaseIn & { cType: string; plat: string; specInstr?: string };\ntype StratIn = BaseIn & { plats: string[]; budgetLvl?: string; duration?: string };\ntype LogoIn = BaseIn & { bName: string; stylePrefs?: string; colorPrefs?: string };\ntype BrandIn = BaseIn & { bName: string; coreVals?: string };\ntype SimIn = BaseIn & { simType: string; specParams: Record | string };\ntype MetaIn = { pInput: string };\n\n// Consolidated User Input Schema (reusing schema, essential for validation)\nconst UserInSchema = z.object({\n task: z.enum([\n \"create_content\",\n \"develop_strategy\",\n \"generate_logo_concept\",\n \"build_brand_identity\",\n \"run_simulation\",\n \"meta_prompt\",\n ]),\n data: z.record(z.any()),\n}).refine((input) => {\n const d = input.data;\n const has = (key: string) => d && d[key] != null && d[key] !== \"\";\n const hasArr = (key: string) => Array.isArray(d?.[key]) && d[key].length > 0;\n switch (input.task) {\n case \"create_content\":\n return has(\"businessType\") && has(\"serviceDescription\") && has(\"targetAudience\") && has(\"contentType\")\n && has(\"platform\");\n case \"develop_strategy\":\n return has(\"businessType\") && has(\"serviceDescription\") && has(\"targetAudience\") && hasArr(\"platforms\");\n case \"generate_logo_concept\":\n return has(\"businessType\") && has(\"serviceDescription\") && has(\"targetAudience\") && has(\"businessName\");\n case \"build_brand_identity\":\n return has(\"businessType\") && has(\"serviceDescription\") && has(\"targetAudience\") && has(\"businessName\");\n case \"run_simulation\":\n return has(\"businessType\") && has(\"serviceDescription\") && has(\"targetAudience\") && has(\"simulationType\")\n && has(\"specificParams\") && (typeof d?.specificParams === \"object\" || typeof d?.specificParams === \"string\");\n case \"meta_prompt\":\n return has(\"prompt_input\");\n default:\n return false;\n }\n}, { message: \"Missing required fields for the selected task or invalid data format.\" });\ntype UserIn = z.infer;\n\n// Task-specific outputs (reusing types)\ntype CntOut = { content: string; suggestions?: string };\ntype StratOut = { strategy: string; adIdeas?: string[]; audSugs?: string[] };\ntype LogoOut = { concepts: string[]; prompts?: string[]; svg?: string };\ntype BrandOut = { bVoice: string; kMsgs: string[]; cPalSugs: string; typo: string };\ntype SimOut = { simResult: string; analysis?: string };\ntype MetaOut = { sysPrompt: string };\n\ntype FinalRes = { res?: any; err?: string; details?: string; dbgLog: LogEntry[]; mid: string };\n\n// Questionnaire Types (reusing types)\ntype QState = {\n sid: string;\n task: UserIn[\"task\"];\n reqFlds: string[];\n answers: Partial>;\n qHist: { qid: string; field: string; text: string }[];\n isDone: boolean;\n};\ntype Quest = {\n id: string;\n field: string;\n text: string;\n type: \"text\" | \"textarea\" | \"select\";\n opts?: { lbl: string; val: string }[];\n}; // Removed 'confirm' as not used\ntype QResp = { sid: string; nextQ?: Quest; isDone: boolean; data?: UserIn; err?: string; state: QState | null };\n\n// --- Data Structure for Questionnaire Fields (Simplified) ---\nconst Q_FIELDS: {\n [key: string]: {\n txt: string; // Abbreviated text\n typ?: Quest[\"type\"]; // Abbreviated type\n opts?: Quest[\"opts\"];\n opt?: true; // Abbreviated optional\n tasks?: Array; // Applies to tasks\n ph?: string; // Abbreviated placeholder\n map?: string; // Maps to schema/API key\n };\n} = {\n bType: { txt: \"Type of business?\", tasks: [\"base\"], ph: \"e.g., SaaS, Bakery\", map: \"businessType\" },\n sDesc: {\n txt: \"Describe products/services.\",\n typ: \"textarea\",\n tasks: [\"base\"],\n ph: \"Briefly explain what you offer\",\n map: \"serviceDescription\",\n },\n tAud: {\n txt: \"Ideal customer? (Specific)\",\n typ: \"textarea\",\n tasks: [\"base\"],\n ph: \"e.g., Small business owners in marketing\",\n map: \"targetAudience\",\n },\n bTone: {\n txt: \"Desired tone?\",\n typ: \"select\",\n opt: true,\n tasks: [\"base\"],\n opts: [\n { lbl: \"-- Tone --\", val: \"\" },\n { lbl: \"Professional\", val: \"professional\" },\n { lbl: \"Friendly\", val: \"friendly\" },\n { lbl: \"Casual\", val: \"casual\" },\n { lbl: \"Humorous\", val: \"humorous\" },\n { lbl: \"Informative\", val: \"informative\" },\n ],\n map: \"brandTone\",\n },\n goals: { txt: \"Main goals for this task?\", typ: \"textarea\", opt: true, tasks: [\"base\"], map: \"goals\" },\n bName: { txt: \"Exact business name?\", tasks: [\"generate_logo_concept\", \"build_brand_identity\"], map: \"businessName\" },\n cType: {\n txt: \"Content type needed?\",\n typ: \"select\",\n tasks: [\"create_content\"],\n opts: [\n { lbl: \"-- Type --\", val: \"\" },\n { lbl: \"Promo Post\", val: \"promo_post\" },\n { lbl: \"Blog Ideas\", val: \"blog_idea\" },\n { lbl: \"Blog Draft\", val: \"blog_draft\" },\n { lbl: \"Ad Copy\", val: \"ad_copy\" },\n ],\n map: \"contentType\",\n },\n plat: {\n txt: \"Platform for content?\",\n typ: \"select\",\n tasks: [\"create_content\"],\n opts: [\n { lbl: \"-- Platform --\", val: \"\" },\n { lbl: \"Generic\", val: \"generic\" },\n { lbl: \"Facebook\", val: \"facebook\" },\n { lbl: \"Instagram\", val: \"instagram\" },\n { lbl: \"LinkedIn\", val: \"linkedin\" },\n { lbl: \"Blog\", val: \"blog\" },\n ],\n map: \"platform\",\n },\n specInstr: {\n txt: \"Specific instructions/keywords?\",\n typ: \"textarea\",\n opt: true,\n tasks: [\"create_content\"],\n map: \"specificInstructions\",\n },\n plats: {\n txt: \"Strategy platforms? (comma separated)\",\n tasks: [\"develop_strategy\"],\n ph: \"e.g., LinkedIn, SEO\",\n map: \"platforms\",\n },\n budgetLvl: {\n txt: \"Approx budget level?\",\n typ: \"select\",\n opt: true,\n tasks: [\"develop_strategy\"],\n opts: [{ lbl: \"-- Budget --\", val: \"\" }, { lbl: \"Low (Organic)\", val: \"low\" }, {\n lbl: \"Medium (Mod Ads)\",\n val: \"medium\",\n }, { lbl: \"High (Sig Ads)\", val: \"high\" }],\n map: \"budgetLevel\",\n },\n duration: { txt: \"Strategy duration?\", opt: true, tasks: [\"develop_strategy\"], map: \"duration\" },\n stylePrefs: { txt: \"Logo style preferences?\", opt: true, tasks: [\"generate_logo_concept\"], map: \"stylePreferences\" },\n colorPrefs: { txt: \"Logo color preferences?\", opt: true, tasks: [\"generate_logo_concept\"], map: \"colorPreferences\" },\n coreVals: {\n txt: \"Core values/mission?\",\n typ: \"textarea\",\n opt: true,\n tasks: [\"build_brand_identity\"],\n map: \"coreValues\",\n },\n simType: {\n txt: \"Simulation type?\",\n typ: \"select\",\n tasks: [\"run_simulation\"],\n opts: [{ lbl: \"-- Sim --\", val: \"\" }, { lbl: \"Ad Response Est.\", val: \"ad_response_estimate\" }, {\n lbl: \"Customer Interaction\",\n val: \"customer_interaction\",\n }, { lbl: \"Other\", val: \"other\" }],\n map: \"simulationType\",\n },\n specParams: {\n txt: \"Sim details/params?\",\n typ: \"textarea\",\n tasks: [\"run_simulation\"],\n ph: \"Ad: audience, platform, offer. Cust: scenario, issue. Other: describe.\",\n map: \"specificParams\",\n },\n pInput: { txt: \"AI task desc or prompt to refine?\", typ: \"textarea\", tasks: [\"meta_prompt\"], map: \"prompt_input\" },\n};\n\n// --- LogAgent Class (Minor Abbreviation) ---\nclass LogAgent {\n logs: LogEntry[];\n midCtx?: string;\n constructor(mid?: string) {\n this.logs = [];\n this.midCtx = mid;\n }\n log(lvl: Lvl, comp: string, msg: string, dt?: any, mid?: string, tid?: string): void {\n const effMid = mid || this.midCtx || \"N/A\";\n let safeDt: any;\n if (dt != null) {\n try {\n safeDt = typeof structuredClone === \"function\"\n ? structuredClone(dt)\n : JSON.parse(JSON.stringify(dt, this.getCircReplacer()));\n } catch (e) {\n safeDt = `[Log Err: ${(e as Error).m}]`;\n }\n } else safeDt = dt;\n const entry: LogEntry = { ts: new Date().toISOString(), mid: effMid, tid, lvl, comp, msg, dt: safeDt };\n this.logs.push(entry);\n const dtStr = safeDt != null ? `| D: ${JSON.stringify(safeDt)}` : \"\";\n console.log(\n `[${entry.ts}] [${entry.mid}] [${entry.tid || \"---\"}] [${entry.lvl}] [${entry.comp}] ${entry.msg} ${dtStr}`,\n );\n }\n private getCircReplacer = () => {\n const s = new WeakSet();\n return (_k: string, v: any) => {\n if (typeof v === \"o\" && v !== null) {\n if (s.has(v)) return \"[C]\";\n s.add(v);\n }\n return v;\n };\n }; // Abbreviated\n getLogs(): LogEntry[] {\n try {\n return typeof structuredClone === \"function\"\n ? structuredClone(this.logs)\n : JSON.parse(JSON.stringify(this.logs, this.getCircReplacer()));\n } catch (e) {\n console.error(\"[LogAgent] Fail copy:\", e);\n return [...this.logs];\n }\n }\n clearLogs(): void {\n this.logs = [];\n }\n setMidCtx(mid: string): void {\n this.midCtx = mid;\n }\n}\n\n// --- OpenAI Call Wrapper (Minor Abbreviation) ---\nasync function callOpenAI(\n sysP: string,\n userP: string,\n mid: string,\n tid: string,\n log: LogFn,\n): Promise {\n log(\"DB\", \"oai\", `Call tid=${tid}`, { spL: sysP.length, upL: userP.length }, mid, tid);\n try {\n if (!process.env.OPENAI_API_KEY) {\n log(\"ER\", \"oai\", \"Key missing.\", {}, mid, tid);\n throw new Error(\"OpenAI Key missing.\");\n }\n const oai = new OpenAI();\n const comp = await oai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [{ role: \"system\", content: sysP }, { role: \"user\", content: userP }],\n temperature: 0.7,\n max_tokens: 2048,\n });\n const resT = comp.choices[0]?.message?.content;\n const usage = comp.usage;\n if (!resT) {\n log(\"WN\", \"oai\", `No text tid=${tid}.`, { usage, fin: comp.choices[0]?.finish_reason }, mid, tid);\n return null;\n }\n log(\"IN\", \"oai\", `OK tid=${tid}`, { resL: resT.length, usage, fin: comp.choices[0]?.finish_reason }, mid, tid);\n return resT.trim();\n } catch (err: any) {\n const d = { m: err.m, n: err.n, s: err.s, t: err.t, c: err.c }; // Abbreviated error details\n log(\"ER\", \"oai\", `Fail tid=${tid}`, { e: d }, mid, tid);\n throw new Error(`API fail: ${err.m}` + (err.c ? ` (Code: ${err.c})` : \"\"));\n }\n}\n\n// --- QAgent Class (Refactored & Concise) ---\nclass QAgent {\n lg: LogFn;\n fDefs = Q_FIELDS;\n constructor(lgFn: LogFn) {\n this.lg = lgFn;\n }\n\n private getTaskFields(task: UserIn[\"task\"]) {\n const fields = Object.keys(this.fDefs).filter(k =>\n this.fDefs[k].tasks?.includes(task) || (this.fDefs[k].tasks?.includes(\"base\") && task !== \"meta_prompt\")\n );\n const req = fields.filter(k => !this.fDefs[k].opt);\n const opt = fields.filter(k => this.fDefs[k].opt);\n return { req, opt };\n }\n\n private isOptional(f: string): boolean {\n return this.fDefs[f]?.opt === true;\n }\n\n private selectNextField(req: string[], opt: string[], ans: Record): string | null {\n for (const f of req)\n if (!(f in ans) || (ans[f] === \"\" && !this.isOptional(f))) {\n this.lg(\"DB\", \"QA\", `Sel REQ: ${f}`, { ak: Object.keys(ans) });\n return f;\n }\n for (const f of opt)\n if (!(f in ans)) {\n this.lg(\"DB\", \"QA\", `Sel OPT: ${f}`, { ak: Object.keys(ans) });\n return f;\n }\n this.lg(\"DB\", \"QA\", `All fields done.`, { ak: Object.keys(ans) });\n return null;\n }\n\n private formatQuest(f: string, st: QState): Quest {\n const id = `${f}-${Date.now()}`;\n const fC = this.fDefs[f];\n let txt = fC?.txt || `Provide '${f}'.`;\n const typ = fC?.typ || \"text\";\n const opts = fC?.opts;\n const isOpt = fC?.opt || false;\n const bN = st.ans.bName || \"your business\";\n if (f === \"bType\") txt = `Type of business for ${bN}?`;\n if (f === \"sDesc\") txt = `Describe products/services for ${bN}.`;\n if (f === \"tAud\") txt = `Ideal customer for ${bN}? (Specific)`;\n if (f === \"coreVals\") txt = `Core values/mission of ${bN}?${isOpt ? \" (Optional)\" : \"\"}`;\n txt += isOpt && !txt.includes(\"(Optional)\") ? \" (Optional)\" : \"\";\n return { id, field: f, text: txt, type: typ, opts };\n }\n\n async nextStep(\n sid: string | null,\n task: UserIn[\"task\"],\n lastAns: { field: string; value: any } | null,\n curSt?: QState | null,\n ): Promise {\n let st: QState;\n const sessId = sid || `s-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;\n const { req: reqFlds, opt: optFlds } = this.getTaskFields(task);\n const allFlds = [...reqFlds, ...optFlds];\n\n if (!curSt || !sid || curSt.sid !== sessId || curSt.task !== task) {\n this.lg(\"IN\", \"QA\", `Init/Reset state: ${task}`, { os: curSt?.sid, ot: curSt?.task, ns: sessId }, sessId);\n st = { sid: sessId, task, reqFlds: allFlds, answers: {}, qHist: [], isDone: false };\n if (lastAns?.field && allFlds.includes(lastAns.field)) {\n const v = typeof lastAns.value === \"string\" ? lastAns.value.trim() : lastAns.value;\n if (v !== \"\" || this.isOptional(lastAns.field)) st.answers[lastAns.field] = v;\n else this.lg(\"DB\", \"QA\", `Ign empty req init: ${lastAns.field}`, { v }, sessId);\n }\n } else {\n st = { ...curSt, answers: { ...curSt.answers }, qHist: [...curSt.qHist] };\n if (lastAns?.field && allFlds.includes(lastAns.field)) {\n this.lg(\"DB\", \"QA\", `Proc ans: ${lastAns.field}`, { v: lastAns.value }, st.sid);\n const v = typeof lastAns.value === \"string\" ? lastAns.value.trim() : lastAns.value;\n if (v !== \"\" || !reqFlds.includes(lastAns.field)) st.answers[lastAns.field] = v;\n else {\n this.lg(\"WN\", \"QA\", `Empty req ans: ${lastAns.field}. Re-ask.`, undefined, st.sid);\n delete st.answers[lastAns.field];\n }\n const lastQ = st.qHist[st.qHist.length - 1];\n if (lastQ && lastQ.field !== lastAns.field)\n this.lg(\"WN\", \"QA\", `Ans for ${lastAns.field}, last Q was ${lastQ?.field}. Sync issue?`, undefined, st.sid);\n }\n }\n\n const nextF = this.selectNextField(reqFlds, optFlds, st.answers);\n\n if (!nextF) {\n this.lg(\"IN\", \"QA\", `All fields for ${st.task}. Validate.`, { g: Object.keys(st.answers) }, st.sid);\n const finalD = this.finalizeData(st.answers, st.task, st.sid);\n try {\n UserInSchema.parse(finalD);\n this.lg(\"IN\", \"QA\", \"Valid OK.\", undefined, st.sid);\n st.isDone = true;\n return { sid: st.sid, isDone: true, data: finalD, state: st };\n } catch (validErr) {\n if (validErr instanceof z.ZodError) {\n const errMsgs = validErr.issues.map(i => `${i.path.join(\".\")}: ${i.m}`).join(\"; \"); // Abbreviated msg\n this.lg(\"ER\", \"QA\", \"Valid FAIL.\", { e: validErr.issues }, st.sid);\n st.isDone = false;\n const firstFailPath = validErr.issues[0]?.path;\n let fToReask: string | null = null;\n if (firstFailPath && firstFailPath.length > 1) {\n const schemaF = firstFailPath[1].toString();\n fToReask = Object.keys(this.fDefs).find(k => this.fDefs[k].map === schemaF) || null;\n if (fToReask && !allFlds.includes(fToReask)) fToReask = null;\n }\n if (fToReask) {\n delete st.answers[fToReask];\n const lastQIdx = st.qHist.findIndex(q => q.field === fToReask);\n if (lastQIdx !== -1) st.qHist.splice(lastQIdx, 1);\n const nextQ = this.formatQuest(fToReask, st);\n this.lg(\"WN\", \"QA\", `Valid fail on ${fToReask}. Re-ask.`, { e: errMsgs }, st.sid);\n st.qHist.push({ qid: nextQ.id, field: nextQ.field, text: nextQ.text });\n return {\n sid: st.sid,\n isDone: false,\n nextQ,\n state: st,\n err: `Check input for '${nextQ.text.replace(/\\s+\$Optional\$\\s*$/, \"\")}': ${errMsgs}`,\n };\n } else {\n this.lg(\"ER\", \"QA\", \"Valid fail, no field to re-ask.\", { e: errMsgs }, st.sid);\n return { sid: st.sid, isDone: false, err: `Valid fail: ${errMsgs}. Cannot proceed.`, state: st };\n }\n } else {\n this.lg(\"ER\", \"QA\", \"Unexpected valid error.\", { e: (validErr as Error).m }, st.sid);\n return { sid: st.sid, isDone: false, err: `Unexpected valid error: ${(validErr as Error).m}`, state: st };\n }\n }\n } else {\n const nextQ = this.formatQuest(nextF, st);\n st.qHist.push({ qid: nextQ.id, field: nextQ.field, text: nextQ.text });\n this.lg(\"IN\", \"QA\", `Ask: ${nextF}`, { qT: nextQ.text }, st.sid);\n return { sid: st.sid, isDone: false, nextQ, state: st };\n }\n }\n\n async goBack(sid: string, task: UserIn[\"task\"], curSt: QState): Promise {\n this.lg(\"IN\", \"QA\", `Back action: ${task}`, { sessId: sid });\n const st = { ...curSt, answers: { ...curSt.answers }, qHist: [...curSt.qHist] };\n if (st.qHist.length < 1) {\n this.lg(\"WN\", \"QA\", \"Back fail: no history.\", undefined, st.sid);\n return { sid, isDone: false, err: \"Cannot go back further.\", state: st };\n }\n const lastQ = st.qHist.pop();\n if (lastQ && st.answers) {\n delete st.answers[lastQ.field];\n this.lg(\"DB\", \"QA\", `Back: removed ans for '${lastQ.field}'.`, { qid: lastQ.qid }, st.sid);\n }\n const QToReask = st.qHist[st.qHist.length - 1];\n if (QToReask) {\n const nextQ = this.formatQuest(QToReask.field, st);\n st.qHist[st.qHist.length - 1] = { qid: nextQ.id, field: nextQ.field, text: nextQ.text };\n this.lg(\"IN\", \"QA\", `Back to Q: ${QToReask.field}`, { qT: nextQ.text }, st.sid);\n return { sid, isDone: false, nextQ, state: st };\n } else {\n this.lg(\"WN\", \"QA\", \"Back fail: history empty after pop. Restarting.\", undefined, st.sid);\n return this.nextStep(sid, task, null, null);\n }\n }\n\n async restart(sid: string, task: UserIn[\"task\"]): Promise {\n this.lg(\"IN\", \"QA\", `Restart action: ${task}`, { sessId: sid });\n return this.nextStep(sid, task, null, null);\n }\n\n private finalizeData(g: Record, task: UserIn[\"task\"], sid?: string): UserIn {\n let finalPD: Record = { ...g };\n const { req: reqFlds, opt: optFlds } = this.getTaskFields(task);\n\n optFlds.forEach(f => {\n if (finalPD[f] == null || (typeof finalPD[f] === \"string\" && finalPD[f].trim() === \"\")) delete finalPD[f];\n });\n reqFlds.forEach(f => {\n if (finalPD[f] == null || (typeof finalPD[f] === \"string\" && finalPD[f].trim() === \"\"))\n this.lg(\"WN\", \"finalize\", `Req field missing: ${f}`, { v: finalPD[f] }, sid);\n });\n\n if (task === \"develop_strategy\" && finalPD.plats !== undefined) {\n if (typeof finalPD.plats === \"string\")\n finalPD.plats = finalPD.plats.split(\",\").map((p: string) => p.trim()).filter((p: string) => p.length > 0);\n else if (!Array.isArray(finalPD.plats)) finalPD.plats = [];\n finalPD.plats = (finalPD.plats as any[]).filter((p: any) => typeof p === \"string\");\n }\n if (task === \"run_simulation\" && finalPD.specParams !== undefined) {\n if (typeof finalPD.specParams === \"string\") {\n const pStr = finalPD.specParams.trim();\n if (pStr.startsWith(\"{\") && pStr.endsWith(\"}\")) {\n try {\n const p = JSON.parse(pStr);\n finalPD.specParams = typeof p === \"o\" && p !== null && !Array.isArray(p) ? p : { description: pStr };\n } catch (e) {\n finalPD.specParams = { description: pStr };\n }\n }\n else finalPD.specParams = { description: pStr };\n } else if (\n typeof finalPD.specParams !== \"o\" || finalPD.specParams === null || Array.isArray(finalPD.specParams)\n ) {\n try {\n finalPD.specParams = { description: JSON.stringify(finalPD.specParams) };\n } catch (e) {\n finalPD.specParams = { description: \"[Err stringify]\" };\n }\n }\n }\n\n const finalSD: Record = {};\n for (const k in finalPD) {\n const mapK = Object.keys(this.fDefs).find(f => this.fDefs[f].map === k)\n ? k\n : Object.keys(this.fDefs).find(f => this.fDefs[f].map === k);\n finalSD[this.fDefs[mapK]?.map || k] = finalPD[k];\n } // Simplified mapping\n return { task, data: finalSD };\n }\n}\n\n// --- Generic Agent Execution Function & Configurations (Consolidated) ---\ntype AgentConfig = {\n n: string; // Name\n p: (p: T_In) => { sys: string; user: string }; // Prompts\n ps: (raw: string) => T_Out; // Parse output\n pp?: (out: T_Out, p: T_In) => T_Out; // Post-process\n};\n\nconst AGENT_CFGS: { [key in UserIn[\"task\"]]: AgentConfig } = {\n create_content: {\n n: \"Cnt\",\n p: (p: CntIn) => ({\n sys: `Copywriter. Gen content. CXT: BT:${p.bType || \"N/A\"}, SVC:${p.sDesc || \"N/A\"}, TA:${\n p.tAud || \"Gen\"\n }, Tone:${p.bTone || \"Pro\"}, Goal:${p.goals || \"Engage\"}. TASK: Type:${p.cType}, Plat:${p.plat}, Instr:${\n p.specInstr || \"None\"\n }. INS: 1.Gen '${p.cType}' for '${p.plat}'. 2.Use Tone/TA. 3.Integrate Instr. 4.Align Goal, CTAs. 5.Plat: Social(h/l), Ads(h/d/c), BlogIdea(3-5 titles), BlogDraft(3-500w MD), Gen(adapt). 6.Output ONLY. Ideas: bullets.`,\n user: `Generate the ${p.cType}.`,\n }),\n ps: (raw) => ({ content: raw }),\n pp: (out, p) => {\n const s = { ...out }; // suggestions\n if (p.cType === \"promo_post\" || p.cType === \"ad_copy\") s.suggestions = \"Add image/video. Test CTAs.\";\n else if (p.cType === \"blog_idea\") s.suggestions = \"Research KWs. Outline.\";\n else if (p.cType === \"blog_draft\") s.suggestions = \"Expand. Add links.\";\n return s;\n },\n },\n develop_strategy: {\n n: \"Strat\",\n p: (p: StratIn) => {\n const pS = p.plats?.join(\", \") || \"N/A\";\n return {\n sys: `Mktg Strategist. Outline strat. CXT: BT:${p.bType || \"N/A\"}, SVC:${p.sDesc || \"N/A\"}, TA:${\n p.tAud || \"Gen\"\n }, Goals:${p.goals || \"Leads\"}, Plats:${pS}, Budget:${p.budgetLvl || \"Low\"}, Dur:${\n p.duration || \"Ongoing\"\n }, Tone:${\n p.bTone || \"Pro\"\n }. FW (MD): ## Sum - Core strat. ## TA Ins - Behavior, needs. ## Rec Plats - Eval '${pS}'. Justify. ## Cnt Themes - 2-4 themes. Key msgs. ## Plat Tactics - 2-3 per plat. Prioritize by Budget. ## Sample Ads - 2-3 examples. ## Budget - (if). ## KPIs - 3-5 (Traffic, CVR). ## Next Steps. INS: 1.Practical. 2.Budget Prio. 3.Cohesive. 4.Output ONLY MD.`,\n user: `Develop strategy.`,\n };\n },\n ps: (raw) => {\n const strat = raw;\n const adM = strat.match(/## Sample Ad Copy \\/ Post Ideas\\n+([\\s\\S]*?)(?=\\n##|$)/i);\n const ads = adM?.[1]?.split(/[\\n\\r]+[\\*\\-]\\s*|\\n+\\d+\\.\\s*/).map(s => s.trim()).filter(s => s && s.length > 10)\n || [];\n const audM = strat.match(/## Target Audience Insights\\n+([\\s\\S]*?)(?=\\n##|$)/i);\n const auds = audM?.[1]?.split(/[\\n\\r]+[\\*\\-]\\s*|\\n+\\d+\\.\\s*/).map(s => s.trim()).filter(s => s && s.length > 10)\n || [];\n return { strategy: strat, adIdeas: ads, audSugs: auds };\n },\n },\n generate_logo_concept: {\n n: \"Logo\",\n p: (p: LogoIn) => ({\n sys: `Creative Asst. 2-3 logo concepts (desc + AI prompt). CXT: BN:${p.bName}, BT:${p.bType || \"N/A\"}, Svc:${\n p.sDesc || \"N/A\"\n }, TA:${p.tAud || \"Gen\"}, Styles:${p.stylePrefs || \"Versatile\"}, Colors:${p.colorPrefs || \"Suggest\"}, Tone:${\n p.bTone || \"Pro\"\n }. INS: 1.2-3 diff concepts (icon/word/combo). 2.Format (MD): ### Title \\\\n#### Desc: \\\\n- Visuals, sym, fonts, colors. \\\\n#### AI Prompt: \\\\n- Detailed AI prompt (vector, subj, style, elems, colors, bg). 3.Sep w/ '---'. 4.(Opt) Basic SVG: \\\\\\`\\\\\\`\\\\\\`svg...\\\\\\`\\\\\\`\\\\\\`. 5.Output ONLY.`,\n user: `Generate logo concepts for \"${p.bName}\".`,\n }),\n ps: (raw) => {\n const concepts: string[] = [];\n const prompts: string[] = [];\n let svg: string | undefined;\n const svgM = raw.match(/```svg\\n([\\s\\S]*?)\\n```/);\n if (svgM?.[1]) svg = svgM[1].trim();\n const rawNoSvg = svg ? raw.replace(svgM![0], \"\").trim() : raw.trim();\n const sections = rawNoSvg.split(/\\n---\\n/);\n sections.forEach(sec => {\n const titleM = sec.match(/### (.*?)\\n/);\n const descM = sec.match(/#### Desc:\\n([\\s\\S]*?)(?=\\n#### AI Prompt:|$)/i);\n const promptM = sec.match(/#### AI Prompt:\\n([\\s\\S]*?)$/i);\n if (titleM && descM && promptM) {\n concepts.push(`Title: ${titleM[1].trim()}\\n\\nDesc:\\n${descM[1].trim()}`);\n prompts.push(promptM[1].trim());\n }\n else if (sec.trim().length > 0) concepts.push(`Raw Section (Parse Fail): ${sec.trim().substring(0, 100)}...`);\n });\n return { concepts, prompts, svg };\n },\n },\n build_brand_identity: {\n n: \"Brand\",\n p: (p: BrandIn) => ({\n sys: `Brand Strategist. Define brand ID. CXT: BN:${p.bName}, BT:${p.bType || \"N/A\"}, Svc:${\n p.sDesc || \"N/A\"\n }, TA:${p.tAud || \"Gen\"}, Vals:${p.coreVals || \"N/A\"}, Tone:${\n p.bTone || \"Pro\"\n }. FW (MD): ## Voice - Desc detail. Tone '${\n p.bTone || \"Pro\"\n }', pers. Lang style. ## Key Msgs - 3-5 bullets (*). Value, svc->aud, vals. Concise. ## Color Suggestions - Primary, sec, accent (Hex). Justify. ## Typo Suggestions - Head, body font (Google). Justify. INS: 1.Cohesive. 2.SMB practical. 3.Align CXT. 4.Output ONLY MD.`,\n user: `Develop brand ID guide for \"${p.bName}\".`,\n }),\n ps: (raw) => {\n const voiceM = raw.match(/## Brand Voice & Personality\\n([\\s\\S]*?)(?=\\n##|$)/i);\n const voice = voiceM ? voiceM[1].trim() : \"Parse fail Voice.\";\n const msgsM = raw.match(/## Key Messages\\n([\\s\\S]*?)(?=\\n##|$)/i);\n const msgsR = msgsM ? msgsM[1].trim() : \"\";\n const msgs = msgsR.split(/[\\n\\r]+\\s*[\\*\\-]\\s*/).map(s => s.trim()).filter(s => s.length > 5);\n if (msgs.length === 0 && msgsR.length > 5) msgs.push(`Raw Msgs: ${msgsR}`);\n const colorM = raw.match(/## Color Palette Suggestions\\n([\\s\\S]*?)(?=\\n##|$)/i);\n const color = colorM ? colorM[1].trim() : \"Parse fail Colors.\";\n const typoM = raw.match(/## Typography Suggestions\\n([\\s\\S]*?)$/i);\n const typo = typoM ? typoM[1].trim() : \"Parse fail Typography.\";\n if (\n voice.includes(\"Parse fail\") && msgs.length === 0 && color.includes(\"Parse fail\") && typo.includes(\"Parse fail\")\n && raw.length > 100\n ) throw new Error(\"Sig parse fail Brand.\");\n return { bVoice: voice, kMsgs: msgs, cPalSugs: color, typo };\n },\n },\n run_simulation: {\n n: \"Sim\",\n p: (p: SimIn) => {\n let pD = \"N/A\";\n try {\n pD = typeof p.specParams === \"string\" ? p.specParams : JSON.stringify(p.specParams);\n } catch (e) {\n pD = \"[Ser fail]\";\n }\n return {\n sys: `Sim Model. Predict/role-play. CXT: BT:${p.bType || \"N/A\"}, SVC:${p.sDesc || \"N/A\"}, TA:${\n p.tAud || \"Gen\"\n }, Tone:${\n p.bTone || \"Pro\"\n }. SIM: Type:${p.simType}, Params:${pD}. INS: 1.Analyze. 2.Execute: 'ad_response_estimate'(Qualify ad eff. Est metrics, state assumptions. No guarantees. Focus likelihoods). 'customer_interaction'(Role-play: Cust:, Agent:. Realistic, 3-5 exchanges). 'other'(Execute per desc. Interpret. State assumptions). 3.Output: Result FIRST. OPTIONAL \\\\\\`## Analysis\\\\\\` (MD) 2-4 sent. 4.Output ONLY result+opt analysis.`,\n user: `Run sim '${p.simType}'.`,\n };\n },\n ps: (raw) => {\n let res = raw, analysis;\n const aM = raw.match(/\\n## Analysis\\s*([\\s\\S]*)$/mi);\n if (aM?.[1] !== undefined) {\n const sI = raw.substring(0, aM.index).trimEnd().length;\n res = raw.substring(0, sI).trim();\n analysis = aM[1].trim();\n }\n else res = raw.trim();\n if (!res && !analysis && raw.length > 0) throw new Error(\"Sim output empty.\");\n return { simResult: res, analysis };\n },\n },\n meta_prompt: {\n n: \"Meta\",\n p: (p: MetaIn) => ({\n sys:\n `Prompt Engineer. Create/refine SYSTEM prompt for GPT-4o-mini based on user request. Clear, comprehensive. PRIN: 1.Role. 2.Task/Goal. 3.Context/Input. 4.Process(if complex). 5.Output Format/Constraints(MD, JSON, len, tone, avoid). Output structure examples. 6.Ambiguity. 7.Refinement (analyze user prompt). USER REQ (for sys prompt): \\\\\\`\\\\\\`\\\\\\`\\n${p.pInput}\\n\\\\\\`\\\\\\`\\\\\\` TASK: Gen complete system prompt text based ONLY on user req & PRIN. Output ONLY system prompt. No code blocks unless requested. No intros.`,\n user: `Generate/refine system prompt based on my request.`,\n }),\n ps: (raw) => {\n const sysP = raw.replace(/^```(markdown|text)?\\s*/i, \"\").replace(/\\s*```$/, \"\").trim();\n if (sysP.length < 50 && raw.length > 50) throw new Error(\"Gen prompt too short.\");\n return { sysPrompt: sysP };\n },\n },\n};\n\nasync function runAgent(\n task: TskIn,\n log: LogFn,\n cfg: AgentConfig,\n): Promise> {\n const { mid, tid, p } = task;\n log(\"IN\", cfg.n, `Start tid=${tid}`, {}, mid, tid);\n try {\n const { sys, user } = cfg.p(p);\n const rawC = await callOpenAI(sys, user, mid, tid, log);\n if (!rawC) {\n log(\"WN\", cfg.n, `No LLM content tid=${tid}.`, {}, mid, tid);\n return { mid, cid: tid, p: {} as T_Out, e: `AI failed to gen ${cfg.n}.` };\n }\n let out: T_Out;\n try {\n out = cfg.ps(rawC);\n } catch (e: any) {\n log(\"ER\", cfg.n, `Parse FAIL tid=${tid}.`, { e: e.m, raw: rawC.slice(0, 300) }, mid, tid);\n return { mid, cid: tid, p: {} as T_Out, e: `AI gen unparseable: ${e.m}` };\n }\n if (cfg.pp) {\n try {\n out = cfg.pp(out, p);\n } catch (e: any) {\n log(\"ER\", cfg.n, `PP FAIL tid=${tid}.`, { e: e.m }, mid, tid);\n }\n }\n log(\"IN\", cfg.n, `OK tid=${tid}.`, {}, mid, tid);\n return { mid, cid: tid, p: out };\n } catch (err: any) {\n log(\"ER\", cfg.n, `Task FAIL tid=${tid}.`, { e: err.m }, mid, tid);\n return { mid, cid: tid, p: {} as T_Out, e: `${cfg.n} fail: ${err.m}` };\n }\n}\n\n// --- Orchestrator Class (Minor Abbreviation) ---\nclass Orchestrator {\n baseL: LogFn;\n mId: string;\n lg: LogFn;\n constructor(baseLgr: LogAgent) {\n this.mId = `m-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;\n baseLgr.setMidCtx(this.mId);\n this.baseL = baseLgr.log.bind(baseLgr);\n this.lg = (lvl, comp, msg, dt?, _midIgn?, tid?) => {\n this.baseL(lvl, comp, msg, dt, this.mId, tid);\n };\n this.lg(\"IN\", \"Orch\", `Init mandate: ${this.mId}`);\n }\n async runWorkflow(input: UserIn): Promise {\n this.lg(\"IN\", \"Orch\", `Wf start: ${input.task}`, {}, this.mId);\n const tid = `${input.task.slice(0, 3)}-${Date.now()}-${Math.random().toString(36).slice(2, 7)}`; // Abbreviated tid\n const tInput: TskIn = { mid: this.mId, tid: tid, p: input.data };\n let tOutput: TskOut;\n const aCfg = AGENT_CFGS[input.task];\n if (!aCfg) {\n this.lg(\"ER\", \"Orch\", `Unsup task: ${input.task}`, {}, this.mId, tid);\n return { mId: this.mId, err: `Unsup task: ${input.task}`, dbgLog: [] };\n }\n try {\n tOutput = await runAgent(tInput, this.lg, aCfg);\n if (tOutput.e) {\n this.lg(\"WN\", \"Orch\", `Agent ${tid} err.`, { e: tOutput.e }, this.mId);\n return { mid: this.mId, err: `Agent fail: ${tOutput.e}`, res: tOutput.p, dbgLog: [] };\n }\n this.lg(\"IN\", \"Orch\", `Wf task ${tid} OK.`, {}, this.mId);\n return { mid: this.mId, res: tOutput.p, dbgLog: [] };\n } catch (err: any) {\n this.lg(\"ER\", \"Orch\", `Wf critical fail ${tid}.`, { e: err.m }, this.mId);\n return { mid: this.mId, err: `Wf critical fail: ${err.m}`, dbgLog: [] };\n }\n }\n}\n\n// --- HTML Generation (Minor Abbreviation & CSS/JS reduction) ---\nfunction generateOrthogonalUI(): string {\n return `AI Biz Asst\n

\n \n \n \n \n

Compare

Mergejoin/mainintosalon/main

HMain.tsx+450-315