[{"_1":2,"_171":-5,"_172":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8a08d4a46a197c541e82d5fac862bafdcf40c111","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_150":151,"_168":169,"_170":-5},"handle","bomb","name","cyberdyne","path","main.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":116,"_118":-5,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","0ccc04fa-c0f7-11f0-b099-42dde27851f2","createdAt",["D",1763082775256],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019a29dd-b790-744e-b51b-76d556574760","pinnedFileId","0cce4a12-c0f7-11f0-b099-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","019a29dd-b790-744e-b51b-79456055c738","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM0Z2Q2U2p3V2syUGtoYUZ3TUlLY1FzSXRWdyJ9","org",{"_94":95,"_135":132,"_12":112},"avatar","branch",{"_138":139,"_96":44,"_102":140,"_141":103,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":97,"_148":95},"version",86,"0ccc460e-c0f7-11f0-b099-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":152,"_96":99,"_153":114,"_154":-5,"_155":140,"_156":157,"_158":116,"_104":159,"_138":160,"_161":162,"_163":164,"_165":20,"_166":97,"_98":167},"29c84506-c173-11f0-8163-42dde27851f2","fileId","parentId","branchId","branchVersion",63,"latest",["D",1763136081473],16,"fileType","http","content","// @ts-nocheck\n// File: backend.ts\n\nimport { Hono } from \"npm:hono@4.4.12\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport type { Context } from \"npm:hono@4.4.12\";\nimport { streamText } from \"npm:hono@4.4.12/streaming\";\n\n// --- NEW YAHOO FINANCE IMPORT ---\nimport YahooFinance from \"npm:yahoo-finance2@3.10.0\";\n\n// Import the new \"cool\" frontend we will create in the next step\nimport { generateWorkflowFrontend } from \"./workflowFrontend.ts\";\n// Import the new smart config\nimport { config, toolManifest } from \"./workflowConfig.ts\";\n\n// --- TYPE DEFINITIONS ---\ntype LogEntry = {\n timestamp: string;\n level: \"INFO\" | \"WARN\" | \"ERROR\" | \"SUCCESS\";\n component: string;\n message: string;\n details?: any;\n};\n\nconst openai = new OpenAI(); // Initialize once\n// --- NEW YAHOO FINANCE CLIENT ---\nconst yahooFinance = new YahooFinance();\n\n// --- LOGGER FUNCTION ---\nconst createLogger = (logs: LogEntry[], component: string) => {\n return (\n level: \"INFO\" | \"WARN\" | \"ERROR\" | \"SUCCESS\",\n message: string,\n details?: any,\n ) => {\n logs.push({\n timestamp: new Date().toISOString(),\n component,\n level,\n message,\n details: details ? String(details) : undefined,\n });\n };\n};\n\n// --- TOOL IMPLEMENTATIONS ---\n\nasync function handleHttpFetch(\n payload: {\n url: string;\n method?: string;\n headers?: Record;\n body?: any;\n },\n log: ReturnType,\n): Promise {\n const { url, method = \"GET\", headers = {}, body } = payload;\n log(\"INFO\", `Fetching URL: ${method} ${url}`);\n try {\n const resp = await fetch(url, {\n method,\n headers: { \"Content-Type\": \"application/json\", ...headers },\n body: body ? JSON.stringify(body) : undefined,\n });\n const responseText = await resp.text();\n if (!resp.ok) {\n throw new Error(\n `HTTP Error ${resp.status}: ${responseText.substring(0, 200)}`,\n );\n }\n try {\n log(\"SUCCESS\", \"Fetch successful, parsing JSON.\");\n return JSON.parse(responseText);\n } catch (e) {\n log(\"INFO\", \"Response is not JSON, returning as text.\");\n return responseText;\n }\n } catch (e) {\n log(\"ERROR\", `Fetch failed: ${e.message}`, e.stack);\n throw e;\n }\n}\n\nasync function handleOpenAICall(\n payload: {\n messages: any[];\n model?: string;\n stream?: boolean;\n response_format?: { type: \"json_object\" };\n [key: string]: any;\n },\n log: ReturnType,\n): Promise {\n const { messages, model = \"gpt-4o-mini\", stream, ...rest } = payload;\n log(\"INFO\", `Calling OpenAI model: ${model}`, { stream: !!stream, ...rest });\n try {\n return await openai.chat.completions.create({\n model,\n messages,\n stream: !!stream, // Ensure stream is a boolean\n ...rest,\n });\n } catch (e) {\n log(\"ERROR\", `OpenAI call failed: ${e.message}`, e.stack);\n throw e;\n }\n}\n\nasync function handleTextManipulation(\n payload: {\n operation:\n | \"toUpperCase\"\n | \"toLowerCase\"\n | \"reverse\"\n | \"wordCount\"\n | \"length\";\n text: string;\n },\n log: ReturnType,\n): Promise<{ result: any }> {\n log(\"INFO\", `Performing text operation: ${payload.operation}`);\n const { operation, text } = payload;\n let result: any;\n switch (operation) {\n case \"toUpperCase\":\n result = text.toUpperCase();\n break;\n case \"toLowerCase\":\n result = text.toLowerCase();\n break;\n case \"reverse\":\n result = text.split(\"\").reverse().join(\"\");\n break;\n case \"wordCount\":\n result = text.trim().split(/\\s+/).length;\n break;\n case \"length\":\n result = text.length;\n break;\n default:\n log(\"ERROR\", `Unknown text operation: ${operation}`);\n throw new Error(`Unknown text operation: ${operation}`);\n }\n log(\"SUCCESS\", \"Text operation complete.\");\n return { result };\n}\n\n/**\n * NEW TOOL: Based on Metaflow's /api/evaluate\n */\nasync function handleQaEvaluation(\n payload: {\n briefing: string;\n first_draft: string;\n },\n log: ReturnType,\n): Promise {\n const { briefing, first_draft } = payload;\n log(\"INFO\", \"Starting QA Evaluation tool.\");\n try {\n // 1. Generate Success Criteria\n const criteriaPrompt = config.prompts.SUCCESS_CRITERIA_GENERATOR.replace(\n \"{{task_briefing}}\",\n briefing,\n );\n const criteriaCompletion = await handleOpenAICall({\n model: config.models.minor,\n response_format: { type: \"json_object\" },\n messages: [\n { role: \"system\", content: \"You are a JSON-only QA analyst.\" },\n {\n role: \"user\",\n content: criteriaPrompt,\n },\n ],\n }, log);\n\n const criteriaContent = criteriaCompletion.choices[0].message.content;\n const criteria = JSON.parse(criteriaContent).criteria;\n log(\"INFO\", \"Generated success criteria\", criteria);\n\n // 2. Generate Evaluation\n const evalPayload = {\n task_briefing: briefing,\n success_criteria: criteria,\n raw_output: first_draft,\n };\n const evalCompletion = await handleOpenAICall({\n model: config.models.minor,\n response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: config.prompts.EVALUATOR_AGENT }, {\n role: \"user\",\n content: JSON.stringify(evalPayload),\n }],\n }, log);\n\n log(\"SUCCESS\", \"QA Evaluation complete.\");\n return JSON.parse(evalCompletion.choices[0].message.content);\n } catch (e) {\n log(\"ERROR\", `QA Evaluation failed: ${e.message}`, e.stack);\n throw e;\n }\n}\n\n/**\n * NEW TOOL: Based on Metaflow's /api/refine\n */\nasync function handleRefinement(\n payload: {\n briefing: string;\n first_draft: string;\n critique: string;\n language?: string;\n stream?: boolean; // Make refinement streamable\n },\n log: ReturnType,\n): Promise {\n const {\n briefing,\n first_draft,\n critique,\n language = \"English\",\n stream = false,\n } = payload;\n log(\"INFO\", \"Starting Refinement tool.\");\n\n const userContent = `# YOUR TASK\nRewrite your first draft to fully address every point in the critique, elevating the work to a 10/10 standard. Return only the improved final deliverable. Do not write an apology, explanation, or any meta-commentary. Produce the new, superior output in the requested language: ${language}.\n## Original Briefing\n${briefing}\n## Your First Draft\n${first_draft}\n## QA Critique\n${critique}`;\n\n try {\n const result = await handleOpenAICall({\n model: config.models.major, // Use best model for refinement\n messages: [{ role: \"system\", content: config.prompts.REFINER_AGENT }, {\n role: \"user\",\n content: userContent,\n }],\n stream: stream,\n }, log);\n\n log(\"SUCCESS\", \"Refinement complete.\");\n return result;\n } catch (e) {\n log(\"ERROR\", `Refinement failed: ${e.message}`, e.stack);\n throw e;\n }\n}\n\n// --- *** NEW YAHOO FINANCE TOOL IMPLEMENTATION *** ---\nasync function handleYahooFinance(\n payload: {\n module:\n | \"search\"\n | \"quote\"\n | \"quoteSummary\"\n | \"trendingSymbols\"\n | \"recommendationsBySymbol\";\n query: string;\n options?: any;\n },\n log: ReturnType,\n): Promise {\n const { module, query, options = {} } = payload;\n log(\"INFO\", `Running Yahoo Finance module: ${module}`, { query, options });\n\n if (!module || !query) {\n throw new Error(\n \"Missing required 'module' or 'query' for yahoo_finance tool\",\n );\n }\n\n try {\n let result: any;\n switch (module) {\n case \"search\":\n result = await yahooFinance.search(query, options);\n break;\n case \"quote\":\n result = await yahooFinance.quote(query, options);\n break;\n case \"quoteSummary\":\n result = await yahooFinance.quoteSummary(query, options);\n break;\n case \"trendingSymbols\":\n // 'query' here is the region, e.g., 'US', 'GB'\n result = await yahooFinance.trendingSymbols(query, options);\n break;\n case \"recommendationsBySymbol\":\n result = await yahooFinance.recommendationsBySymbol(query, options);\n break;\n default:\n log(\"ERROR\", `Unknown yahoo-finance module: ${module}`);\n throw new Error(`Unknown yahoo-finance module: ${module}`);\n }\n log(\"SUCCESS\", \"Yahoo Finance tool executed successfully.\");\n return result;\n } catch (e) {\n log(\"ERROR\", `Yahoo Finance tool failed: ${e.message}`, e.stack);\n throw e;\n }\n}\n\n// --- TOOL REGISTRY (NOW EXPANDED) ---\nconst toolRegistry = {\n \"http_fetch\": handleHttpFetch,\n \"openai_call\": handleOpenAICall,\n \"text_manipulation\": handleTextManipulation,\n \"qa_evaluation\": handleQaEvaluation, // NEW\n \"refinement\": handleRefinement, // NEW\n \"yahoo_finance\": handleYahooFinance, // --- NEWLY ADDED ---\n};\n\n// --- HONO APPLICATION ---\nconst app = new Hono();\n\n// 1. Frontend Route (Serves the new \"cool\" UI)\napp.get(\"/\", (c: Context) => {\n return c.html(generateWorkflowFrontend(c.req.url));\n});\n\n/**\n * 2. NEW BRAIN: The Orchestrator Agent Endpoint\n * This replaces all of Metaflow's generation/definition endpoints.\n */\napp.post(\"/api/generate-workflow\", async (c: Context) => {\n const { goal, context } = await c.req.json();\n if (!goal) return c.json({ error: \"User goal is required\" }, 400);\n\n const logs: LogEntry[] = [];\n const log = createLogger(logs, \"Orchestrator\");\n\n log(\"INFO\", \"Generating new workflow for goal:\", goal);\n\n const systemPrompt = config.prompts.WORKFLOW_GENERATOR;\n const userContent = `\n# USER GOAL\n${goal}\n\n# AVAILABLE TOOLS\n${JSON.stringify(toolManifest, null, 2)}\n\n# CONTEXT (User's company info)\n${JSON.stringify(context, null, 2)}\n\n# TASK\nGenerate the workflow JSON now.\n`;\n\n try {\n const response = await handleOpenAICall({\n model: config.models.major, // Use your best model\n response_format: { type: \"json_object\" },\n messages: [{ role: \"system\", content: systemPrompt }, {\n role: \"user\",\n content: userContent,\n }],\n }, log);\n\n const workflowJson = JSON.parse(response.choices[0].message.content);\n log(\"SUCCESS\", \"Workflow generated successfully.\");\n\n return c.json({ workflow: workflowJson, logs });\n } catch (e) {\n log(\"ERROR\", `Workflow generation failed: ${e.message}`, e.stack);\n return c.json({ error: e.message, logs }, 500);\n }\n});\n\n// 3. Tool Execution Route (Your existing engine API)\napp.post(\"/api/tools/:toolName\", async (c: Context) => {\n const { toolName } = c.req.param();\n const tool = toolRegistry[toolName];\n if (!tool) return c.json({ error: `Unknown tool: ${toolName}` }, 404);\n\n let reqBody;\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) {\n return c.json(\n { error: \"Missing workflowInstanceId, stepId, or payload\" },\n 400,\n );\n }\n\n const logs: LogEntry[] = [];\n const log = createLogger(logs, `Tool:${toolName}:${stepId}`);\n\n try {\n // Handle streaming for any tool that supports it\n const isStreaming =\n (toolName === \"openai_call\" || toolName === \"refinement\") &&\n payload.stream === true;\n\n if (isStreaming) {\n log(\"INFO\", \"Starting streaming response\");\n const stream = await tool(payload, log);\n return streamText(c, async (s) => {\n try {\n for await (const part of stream) {\n const content = part.choices[0]?.delta?.content || \"\";\n if (content) await s.write(content);\n }\n log(\"SUCCESS\", \"Stream completed successfully\");\n } catch (e) {\n log(\"ERROR\", \"Stream error\", e.message);\n await s.write(`\\n\\n[ERROR: ${e.message}]`);\n }\n });\n }\n\n // Handle regular, non-streaming tools\n const responsePayload = await tool(payload, log);\n return c.json({\n workflowInstanceId,\n stepId,\n payload: responsePayload,\n logs: logs,\n });\n } catch (e) {\n log(\"ERROR\", e.message, e.stack);\n return c.json({\n workflowInstanceId,\n stepId,\n payload: null,\n logs: logs,\n error: e.message,\n }, 500);\n }\n});\n\nexport default app.fetch;","deleted","label",[99],"permalink","https://www.val.town/x/bomb/cyberdyne/code/main.ts","extension","actionData","errors"]