AgentForge AI

The Multi-Agent Assembly Line for Complex Tasks

Select a Project to Begin

`;\n}\n\n// --- HONO APPLICATION SETUP ---\nconst app = new Hono();\n\n// --- API ROUTES ---\n\napp.get(\"/\", (c: Context) => c.html(generateHtml(c.req.url)));\n\n// A helper function to make the main logic cleaner\nasync function callOpenAIAndStreamToClient(\n systemPrompt: string,\n userPrompt: string,\n onDelta: (delta: string) => Promise,\n) {\n const openai = new OpenAI();\n const completionStream = await openai.chat.completions.create({\n model: config.models.major,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: userPrompt },\n ],\n stream: true,\n });\n\n let fullText = \"\";\n for await (const part of completionStream) {\n const delta = part.choices[0]?.delta?.content || \"\";\n if (delta) {\n fullText += delta;\n await onDelta(delta); // Use the callback to send data\n }\n }\n return fullText;\n}\n\n// The main project execution endpoint using Server-Sent Events (SSE)\napp.get(\"/api/project/run\", (c: Context) => {\n // Use streamSSE instead of stream\n return streamSSE(c, async (streamApi) => {\n streamApi.onAbort(() => {\n console.log(\"Client disconnected.\");\n });\n\n const task = c.req.query(\"task\") || \"No task provided\";\n\n const company_context: CompanyContext = {\n company_name: \"Innovate Inc.\",\n company_description: \"A leading provider of cutting-edge tech solutions.\",\n use_case: \"Product Development\",\n language: \"English\",\n };\n\n try {\n // --- STAGE 1: Orchestrator plans the assembly line ---\n await streamApi.writeSSE({\n event: \"step_start\",\n data: JSON.stringify({\n index: -1,\n message: \"Orchestrator is planning...\",\n }),\n });\n\n const planPrompt = config.prompts.ORCHESTRATOR_AGENT\n .replace(\"{{occupation_title}}\", \"Senior Project Manager\")\n .replace(\"{{task}}\", task)\n .replace(\"{{company_context}}\", JSON.stringify(company_context));\n\n const planResult = await services.callOpenAI(\n \"You are a helpful assistant that only speaks JSON.\",\n planPrompt,\n { isJson: true, model: config.models.minor },\n );\n const plan = planResult.plan;\n\n await streamApi.writeSSE({\n event: \"plan_complete\",\n data: JSON.stringify(plan),\n });\n\n let accumulatedWork = \"\";\n\n // --- STAGE 2: Execute each step on the assembly line ---\n for (let i = 0; i < plan.length; i++) {\n const step = plan[i];\n\n await streamApi.writeSSE({\n event: \"step_start\",\n data: JSON.stringify({\n index: i,\n message: `Executing: ${step.agent_persona}`,\n }),\n });\n\n const executorPrompt = config.prompts.EXECUTOR_AGENT\n .replace(\"{{company_name}}\", company_context.company_name)\n .replace(\n \"{{company_description}}\",\n company_context.company_description,\n )\n .replace(\"{{use_case}}\", company_context.use_case)\n .replace(\"{{language}}\", company_context.language)\n .replace(\"{{agent_persona}}\", step.agent_persona)\n .replace(\n \"{{previous_work}}\",\n accumulatedWork || \"This is the first step. Start from scratch.\",\n )\n .replace(\"{{task}}\", step.task);\n\n const userPrompt =\n \"Proceed with your task. Generate the deliverable now.\";\n\n // This is the cleaner way to pipe the stream\n const stepResult = await callOpenAIAndStreamToClient(\n executorPrompt,\n userPrompt,\n async (delta) => {\n await streamApi.writeSSE({\n event: \"stream\",\n data: JSON.stringify({ index: i, delta }),\n });\n },\n );\n\n accumulatedWork +=\n `\\n\\n---\\n\\n## Output from ${step.agent_persona}:\\n\\n${stepResult}`;\n await streamApi.writeSSE({\n event: \"step_complete\",\n data: JSON.stringify({ index: i }),\n });\n\n // --- The Critic agent evaluates the step's output ---\n await streamApi.writeSSE({\n event: \"step_start\",\n data: JSON.stringify({\n index: i,\n message: \"Critic is evaluating...\",\n }),\n });\n\n const critiquePrompt = JSON.stringify({\n project_goal: task,\n agent_persona: step.agent_persona,\n task: step.task,\n raw_output: stepResult,\n language: company_context.language,\n });\n\n const critiqueResult = await services.callOpenAI(\n config.prompts.CRITIQUE_AGENT,\n critiquePrompt,\n { isJson: true, model: config.models.minor },\n );\n\n await streamApi.writeSSE({\n event: \"critique_complete\",\n data: JSON.stringify({ index: i, critique: critiqueResult }),\n });\n }\n\n await streamApi.writeSSE({\n event: \"project_complete\",\n data: \"Project finished\",\n });\n } catch (error) {\n console.error(\"Project run failed:\", error);\n await streamApi.writeSSE({\n event: \"error\",\n data: `An error occurred: ${error.message}`,\n });\n }\n });\n});\n\nexport default app.fetch;","deleted","label",[98],"permalink","https://www.val.town/x/volt/assembly/code/main.ts","extension","actionData","errors"]