Results & Logs

\n \n \n \n

\n\n

Execution Logs

Logs will appear here...

\n \n

Final Outputs

Final outputs will appear here...

\n\n

Chart Output

\n\n\n\n\n `;\n}\n\n// --- HONO APPLICATION SETUP (from \"second\" file) ---\nconst app = new Hono();\n\n// --- API ROUTES ---\n\n/* ----------------------------------------\n* Frontend Route\n* Serves the client-side orchestrator UI\n----------------------------------------- */\napp.get(\"/\", (c: Context) => c.html(generateHtmlShellForClientOrchestration()));\n\n/* ----------------------------------------\n* Main API Router\n* Replicates the single router function from \"first\" file, but using Hono.\n* Adds streaming logic for 'openai_call'.\n----------------------------------------- */\napp.post(\"/api/:endpointType/:endpointName\", async (c: Context) => {\n const { endpointType, endpointName } = c.req.param();\n\n let reqBody: ApiRequest;\n try {\n reqBody = await c.req.json();\n } catch (e) {\n return c.json({ error: \"Invalid JSON body\" }, 400);\n }\n\n const { workflowInstanceId, stepId, payload } = reqBody;\n if (!workflowInstanceId || !stepId || payload === undefined) {\n return c.json(\n { error: \"Missing workflowInstanceId, stepId, or payload\" },\n 400,\n );\n }\n\n const logger = new EndpointLogger(\n `[${workflowInstanceId}-${stepId}] ${endpointType}:${endpointName}`,\n );\n let responsePayload: any;\n let errorMsg: string | undefined;\n\n try {\n // *** SPECIAL CASE: STREAMING OPENAI CALL ***\n // This logic is from the \"second\" file, integrated here.\n if (\n endpointType === \"tools\" &&\n endpointName === \"openai_call\" &&\n payload.stream === true\n ) {\n logger.log(\"INFO\", \"Handling as STREAMING OpenAI call.\", payload);\n const { messages, model, ...rest } = payload;\n const openai = new OpenAI();\n const completionStream = await openai.chat.completions.create({\n model: model || \"gpt-4o-mini\",\n messages,\n ...rest, // Passes temperature, max_tokens, etc.\n stream: true,\n });\n\n // Note: When streaming, we cannot return the standard 'ApiResponse' JSON.\n // The client-side must be adapted to handle a text/event-stream.\n // The current client orchestrator does NOT support this.\n return streamText(c, async (s) => {\n logger.log(\"SUCCESS\", \"Stream started.\");\n for await (const part of completionStream) {\n await s.write(part.choices[0]?.delta?.content || \"\");\n }\n logger.log(\"SUCCESS\", \"Stream ended.\");\n // Logs for streaming calls are only visible on the server.\n console.log(\"Streaming call logs:\", logger.getLogs());\n });\n }\n\n // --- STANDARD NON-STREAMING TOOL/FUNCTION CALLS ---\n if (endpointType === \"tools\") {\n switch (endpointName) {\n case \"http_fetch\":\n responsePayload = await handleHttpFetch(payload, logger);\n break;\n case \"openai_call\":\n // Calls the non-streaming version\n responsePayload = await handleOpenAICall_nonStreaming(\n payload,\n logger,\n );\n break;\n case \"string_template\":\n responsePayload = await handleStringTemplate(payload, logger);\n break;\n case \"run_script\":\n responsePayload = await handleRunScript(payload, logger);\n break;\n default:\n throw new Error(`Unknown tool endpoint: ${endpointName}`);\n }\n } else if (endpointType === \"custom\") {\n switch (endpointName) {\n case \"validate_data\":\n responsePayload = await handleValidateData(payload, logger);\n break;\n case \"generate_summary_stats\":\n responsePayload = await handleGenerateSummaryStats(payload, logger);\n break;\n case \"generate_chart_config\":\n responsePayload = await handleGenerateChartConfig(payload, logger);\n break;\n default:\n throw new Error(`Unknown custom function endpoint: ${endpointName}`);\n }\n } else {\n throw new Error(`Unknown endpoint type: ${endpointType}`);\n }\n } catch (e: any) {\n errorMsg = e.message || \"An unexpected error occurred on the server.\";\n // The logger will have already logged the detailed error\n }\n\n // --- Standard JSON Response ---\n // This is returned for all non-streaming calls\n const apiResponse: ApiResponse = {\n workflowInstanceId,\n stepId,\n payload: responsePayload, // Undefined if error occurred\n logs: logger.getLogs(),\n error: errorMsg,\n };\n\n return c.json(apiResponse, { status: errorMsg ? 500 : 200 });\n});\n\n// Export the Hono app fetch handler\nexport default app.fetch;","deleted","label",[99],"permalink","https://www.val.town/x/bomb/next/code/main.ts","extension","actionData","errors"]

Workflow Control

Overall Status

Step Status

Results & Logs

Execution Logs

Final Outputs

Chart Output