Emergent

Describe the workflow you want to build.

\n \n

Tip: Be descriptive for the best results! Aim for at least 5 words.

\n \n \n \n `;\n}\n\n// --- BACKEND: The Hono API Server ---\nconst app = new Hono();\n\nasync function callOpenAI(c, messages, response_format = { type: \"text\" }) {\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: messages,\n response_format: response_format,\n });\n return completion.choices[0].message.content;\n}\n\napp.post(\"/api/plan-workflow\", async (c) => {\n const { goal } = await c.req.json();\n try {\n const messages = [{ role: \"system\", content: META_PROMPTS.WORKFLOW_PLANNER.replace(\"{{goal}}\", goal) }];\n const planJson = await callOpenAI(c, messages, { type: \"json_object\" });\n return c.json(JSON.parse(planJson));\n } catch (e) {\n console.warn(\"Initial workflow planning failed. Retrying...\", e);\n try {\n const retryMessages = [{\n role: \"system\",\n content: META_PROMPTS.WORKFLOW_PLANNER_RETRY.replace(\"{{goal}}\", goal),\n }];\n const retryPlanJson = await callOpenAI(c, retryMessages, { type: \"json_object\" });\n return c.json(JSON.parse(retryPlanJson));\n } catch (retryError) {\n console.error(\"Workflow planning retry failed:\", retryError);\n return c.json(\n { details: \"The AI failed to create a valid workflow plan. Please try rephrasing your goal.\" },\n 500,\n );\n }\n }\n});\n\napp.post(\"/api/generate-step-ui\", async (c) => {\n try {\n const { task, context } = await c.req.json();\n const contextString = JSON.stringify(context, null, 2);\n const architectMessages = [{\n role: \"system\",\n content: META_PROMPTS.TASK_ARCHITECT.replace(\"{{task}}\", task).replace(\"{{context}}\", contextString),\n }];\n const specJson = await callOpenAI(c, architectMessages, { type: \"json_object\" });\n const uiBuilderMessages = [{ role: \"system\", content: META_PROMPTS.UI_BUILDER.replace(\"{{spec}}\", specJson) }];\n const uiJson = await callOpenAI(c, uiBuilderMessages, { type: \"json_object\" });\n return c.json({ taskSpecification: JSON.parse(specJson), uiSchema: JSON.parse(uiJson) });\n } catch (e) {\n console.error(\"Step UI generation failed:\", e);\n return c.json({ details: \"The AI failed to build the UI for the current step.\" }, 500);\n }\n});\n\n// UPDATED STREAMING ENDPOINT\napp.post(\"/api/execute-step\", (c) => {\n return c.stream(async (stream) => {\n try {\n const { task, context, inputs } = await c.req.json();\n const contextString = JSON.stringify(context, null, 2);\n\n const specJson = await callOpenAI(c, [{\n role: \"system\",\n content: META_PROMPTS.TASK_ARCHITECT.replace(\"{{task}}\", task).replace(\"{{context}}\", contextString),\n }], { type: \"json_object\" });\n let executionPrompt = await callOpenAI(c, [{\n role: \"system\",\n content: META_PROMPTS.LOGIC_WEAVER.replace(\"{{spec}}\", specJson).replace(\"{{context}}\", contextString),\n }]);\n\n for (const [key, value] of Object.entries(inputs)) {\n executionPrompt = executionPrompt.replace(new RegExp(`\\\\{\\\\{\\\\s*${key}\\\\s*\\\\}\\\\}`, \"g\"), value);\n }\n\n const openai = new OpenAI({ apiKey: c.env.OPENAI_API_KEY });\n const aiStream = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [{ role: \"user\", content: executionPrompt }],\n stream: true,\n });\n\n for await (const chunk of aiStream) {\n const content = chunk.choices[0]?.delta?.content || \"\";\n if (content) {\n await stream.write(content);\n }\n }\n } catch (e) {\n console.error(\"Step execution stream failed:\", e);\n const errorPayload = JSON.stringify({ error: true, details: \"The AI failed to execute this step.\" });\n await stream.write(errorPayload);\n }\n });\n});\n\napp.get(\"/\", (c) => c.html(generateHtml(c.req.url)));\n\nexport default app.fetch;","deleted","label","children",[],[99],"files",[150],"counts",{"_173":32,"_174":175,"_176":175,"_177":178},"pulls","branches",1,"forks","envVars",{"_179":32,"_180":32},"count","emptyCount","contents",[],"file",{"_104":151,"_155":138,"_152":153,"_95":99,"_162":163,"_160":161,"_100":159,"_154":-5,"_106":185,"_156":101,"_165":96,"_98":186},["D",1753249293495],[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":195,"_148":200,"_169":204,"_183":205,"_181":208,"_209":-5,"_210":22,"_211":-5,"_212":-5,"_213":-5,"_214":215},{"_104":105,"_95":96,"_106":196,"_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":197,"_132":198,"_135":199,"_147":22},["D",1753244933938],{"_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},[201],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":101,"_157":22,"_106":158,"_100":159,"_160":161,"_162":163,"_164":22,"_165":96,"_166":202,"_98":203},[],[99],[201],{"_104":151,"_155":138,"_152":153,"_95":99,"_162":163,"_160":161,"_100":159,"_154":-5,"_106":206,"_156":101,"_165":96,"_98":207},["D",1753249293495],[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]

join

emergent