Declarative AI Workflow Engine

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":57,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",10,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","424b236e-73ee-11f0-8547-0224a6c84d84","name","fileType","http","content","// @ts-ignore\nimport { OpenAI } from \"https://esm.town/v/std/openai?v=4\";\n// @ts-ignore\nimport { Hono } from \"npm:hono@4.4.12\";\n// @ts-ignore\nimport { cors } from \"npm:hono@4.4.12/cors\";\n// @ts-ignore\nimport Parser from \"npm:rss-parser@3.13.0\";\n// --- ADDED FUNCTIONALITY ---\n// Hono's SSE helper for streaming live updates\n// @ts-ignore\nimport { streamSSE } from \"npm:hono@4.4.12/streaming\";\n\n// --- AI PROMPT LIBRARY ---\nconst PROMPTS = {\n ProductMarketFit:\n `You are an AI embodying a skeptical Venture Capitalist conducting due diligence. Your task is to use the provided live market data (news and Reddit comments) to construct a compelling, evidence-based argument for why this product is likely to fail due to poor market fit, saturation, or user indifference. Ground every point in the provided data.`,\n MarketEntry:\n `You are an AI embodying a geopolitical and economic risk analyst. Your task is to use the provided live economic data (from the World Bank) and news headlines to find factual, data-driven evidence that challenges the proposed market entry plan. Focus on macroeconomic headwinds and regulatory risks revealed in the data.`,\n TechnicalFeasibility:\n `You are an AI embodying a cynical, tenured Staff Engineer or Principal Engineer. Your task is to stress-test a technical proposal. Use the provided data (developer sentiment from Reddit) to find reasons why the proposed tech stack is a poor choice, why the assumptions are flawed, or why the project is likely to result in significant technical debt or failure. Be brutally honest about technical trade-offs.`,\n HiringPlan:\n `You are an AI embodying a veteran, cynical technical recruiter at a major tech company. Your job is to find flaws in a hiring plan. Use the provided data (news about tech hiring/layoffs, developer discussions on Reddit) to argue why this plan is unrealistic. Focus on extreme competition for talent, unrealistic skill combinations (i.e., 'unicorns'), below-market compensation signals, or negative sentiment around a particular technology or role.`,\n};\n\n// --- DATA FETCHING LIBRARY --- (Unchanged)\nconst countryCodes = {\n \"brazil\": \"br\",\n \"india\": \"in\",\n \"china\": \"cn\",\n \"germany\": \"de\",\n \"united states\": \"us\",\n \"united kingdom\": \"gb\",\n \"japan\": \"jp\",\n \"nigeria\": \"ng\",\n};\nasync function fetchWorldBankData(countryCode) {/* ... */}\nasync function fetchNews(query) {/* ... */}\nasync function fetchRedditData(query, subreddits) {/* ... */}\n\n// --- ACTION LIBRARY (PRIMITIVE CAPABILITIES) ---\nconst ACTIONS = {\n /* ... Unchanged, but will now be called by a streaming executor ... */\n};\n\n// --- CORE ENGINE ---\nfunction parseDeclarativePlan(text) {/* ... Unchanged ... */}\nfunction resolveVariables(template, state) {/* ... Unchanged ... */}\n\n// MODIFIED: The execution engine now accepts a 'stream' object to send live logs.\nasync function executePlan(plan, stream, isDebug) {\n const state = { VARS: plan.VARS, PROMPTS: plan.PROMPTS };\n let finalOutput =\n \"Workflow completed, but the final step produced no output.\";\n\n const log = async (message) => {\n if (isDebug) {\n await stream.writeSSE({ data: JSON.stringify({ type: \"log\", message }) });\n }\n };\n\n for (const step of plan.WORKFLOW) {\n const action = ACTIONS[step.action];\n if (!action) throw new Error(`Unknown action: ${step.action}`);\n\n await log(`[BEGIN] Executing step: ${step.id} (Action: ${step.action})`);\n\n let resolvedParams = {};\n if (step.action === \"INVOKE_AI\") {\n const promptTemplate = state.PROMPTS[step.prompt_key];\n if (!promptTemplate) {\n throw new Error(`Prompt key not found: '${step.prompt_key}'`);\n }\n\n await log(` > Resolving prompt template: ${step.prompt_key}`);\n resolvedParams = {\n system_prompt: resolveVariables(promptTemplate.system, state),\n user_prompt: resolveVariables(promptTemplate.user, state),\n temperature: step.temperature || \"0.4\",\n };\n await log(` > Invoking AI model...`);\n } else {\n await log(` > Resolving parameters...`);\n for (const key in step.params) {\n resolvedParams[key] = resolveVariables(step.params[key], state);\n }\n await log(` > Fetching external data...`);\n }\n\n const result = await action(resolvedParams);\n state[step.id] = { result };\n finalOutput = result;\n await log(`[DONE] Step ${step.id} complete.`);\n }\n\n return finalOutput;\n}\n\n// --- HTML & FRONTEND ---\nfunction generateHtml() {\n const examplePlan = `# Plan: 'Wickerbrook Vale' Go/No-Go Analysis\n# ... (Example plan remains the same) ...\n`;\n\n return `\n\n\n \n \n Declarative AI Workflow Engine\n \n \n \n \n\n\n\n

\n \n

Execution Log

\n\n\n`;\n}\n\n// --- HONO ROUTER & MAIN HANDLER ---\nconst app = new Hono();\napp.use(\"*\", cors());\napp.get(\"/\", (c) => c.html(generateHtml()));\n\n// MODIFIED: This is a new streaming endpoint.\napp.get(\"/api/execute-stream\", (c) => {\n return streamSSE(c, async (stream) => {\n try {\n const isDebug = c.req.query(\"debug\") === \"true\";\n const encodedPlan = c.req.query(\"plan\");\n if (!encodedPlan) {\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: \"Plan not provided.\",\n }),\n });\n return;\n }\n\n // Use atob for Base64 decoding\n const planText = atob(encodedPlan);\n const plan = parseDeclarativePlan(planText);\n\n if (!plan.WORKFLOW || plan.WORKFLOW.length === 0) {\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: \"Invalid or empty workflow.\",\n }),\n });\n return;\n }\n\n const finalResult = await executePlan(plan, stream, isDebug);\n await stream.writeSSE({\n data: JSON.stringify({ type: \"result\", data: finalResult }),\n });\n } catch (error) {\n console.error(\"Workflow Execution Error:\", error);\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: error.message || \"An internal server error occurred.\",\n }),\n });\n }\n });\n});\n\n// Re-add full function bodies that were collapsed for brevity\nasync function fetchWorldBankData(countryCode) {\n const indicators = {\n gdpGrowth: \"NY.GDP.MKTP.KD.ZG\",\n inflation: \"FP.CPI.TOTL.ZG\",\n };\n const results = {};\n const currentYear = new Date().getFullYear();\n const dateRange = `${currentYear - 5}:${currentYear}`;\n\n for (const [key, code] of Object.entries(indicators)) {\n try {\n const url =\n `https://api.worldbank.org/v2/country/${countryCode}/indicator/${code}?format=json&date=${dateRange}&mrnev=1`;\n const r = await fetch(url);\n const d = await r.json();\n results[key] = d[1]?.[0]?.value\n ? parseFloat(d[1][0].value).toFixed(2)\n : \"N/A\";\n } catch {\n results[key] = \"Error\";\n }\n }\n return results;\n}\nasync function fetchNews(query) {\n const parser = new Parser();\n const RSS_URL = `https://news.google.com/rss/search?q=${\n encodeURIComponent(query)\n } when:14d&hl=en-US&gl=US&ceid=US:en`;\n try {\n const feed = await parser.parseURL(RSS_URL);\n return feed.items.slice(0, 5).map((item) => ({\n title: item.title,\n snippet: item.contentSnippet,\n }));\n } catch {\n return [{ title: \"Could not fetch news via RSS.\", snippet: \"\" }];\n }\n}\nasync function fetchRedditData(query, subreddits) {\n const allPosts = [];\n for (const subreddit of subreddits) {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/search.json?q=${\n encodeURIComponent(query)\n }&sort=relevance&t=year&restrict_sr=on`;\n const r = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await r.json();\n allPosts.push(\n ...(d.data?.children?.map((p) => ({\n title: p.data.title,\n subreddit: p.data.subreddit,\n })) || []),\n );\n } catch {}\n }\n return allPosts.slice(0, 10);\n}\nfunction parseDeclarativePlan(text) {\n const lines = text.split(\"\\n\").filter((line) => !line.trim().startsWith(\"#\"));\n const plan = { VARS: {}, PROMPTS: {}, WORKFLOW: [] };\n let currentSection = null;\n let currentPromptKey = null;\n let currentPromptPart = null;\n let currentWorkflowStep = null;\n for (const line of lines) {\n const indent = line.match(/^\\s*/)[0].length;\n const trimmed = line.trim();\n if (!trimmed) continue;\n if (indent === 0) {\n currentSection = trimmed.replace(\":\", \"\");\n currentPromptKey = null;\n currentWorkflowStep = null;\n continue;\n }\n switch (currentSection) {\n case \"VARS\":\n const [varKey, ...varValueParts] = trimmed.split(\":\");\n plan.VARS[varKey.trim()] = varValueParts.join(\":\").trim();\n break;\n case \"PROMPTS\":\n if (indent === 2) {\n currentPromptKey = trimmed.replace(\":\", \"\");\n plan.PROMPTS[currentPromptKey] = {};\n currentPromptPart = null;\n } else if (indent === 4 && currentPromptKey) {\n const partKey = trimmed.split(\":\")[0].trim();\n if (partKey === \"system\" || partKey === \"user\") {\n currentPromptPart = partKey;\n plan.PROMPTS[currentPromptKey][currentPromptPart] = trimmed\n .substring(partKey.length + 1).replace(/>$/, \"\").trim();\n }\n } else if (indent > 4 && currentPromptKey && currentPromptPart) {\n plan.PROMPTS[currentPromptKey][currentPromptPart] += \"\\n\" + trimmed;\n }\n break;\n case \"WORKFLOW\":\n if (trimmed.startsWith(\"- id:\")) {\n if (currentWorkflowStep) plan.WORKFLOW.push(currentWorkflowStep);\n currentWorkflowStep = { params: {} };\n const [wfKey, ...wfValueParts] = trimmed.substring(2).split(\":\");\n currentWorkflowStep[wfKey.trim()] = wfValueParts.join(\":\").trim();\n } else if (currentWorkflowStep) {\n const [paramKey, ...paramValueParts] = trimmed.split(\":\");\n const value = paramValueParts.join(\":\").trim();\n if (\n paramKey.trim() === \"action\" || paramKey.trim() === \"prompt_key\" ||\n paramKey.trim() === \"temperature\"\n ) {\n currentWorkflowStep[paramKey.trim()] = value;\n } else {\n currentWorkflowStep.params[paramKey.trim()] = value;\n }\n }\n break;\n }\n }\n if (currentWorkflowStep) plan.WORKFLOW.push(currentWorkflowStep);\n return plan;\n}\nACTIONS.FETCH_REDDIT_SENTIMENT = async (params) => {\n const allPosts = [];\n const subreddits = Array.isArray(params.subreddits)\n ? params.subreddits\n : [params.subreddits || \"-\"];\n for (const subreddit of subreddits) {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/search.json?q=${\n encodeURIComponent(params.query)\n }&sort=relevance&t=month&restrict_sr=on`;\n const r = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await r.json();\n allPosts.push(\n ...(d.data?.children?.map((p) => ({\n title: p.data.title,\n subreddit: p.data.subreddit,\n text: p.data.selftext?.substring(0, 200),\n })) || []),\n );\n } catch {}\n }\n return allPosts.slice(0, 15);\n};\nACTIONS.INVOKE_AI = async (params) => {\n if (!params.user_prompt) {\n throw new Error(\"INVOKE_AI action requires a 'user' prompt.\");\n }\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n {\n role: \"system\",\n content: params.system_prompt || \"You are a helpful AI assistant.\",\n },\n { role: \"user\", content: params.user_prompt },\n ],\n temperature: parseFloat(params.temperature) || 0.4,\n });\n return completion.choices[0].message.content;\n};\n\nexport default app.fetch;","// @ts-ignore\nimport { OpenAI } from \"https://esm.town/v/std/openai?v/4\";\n// @ts-ignore\nimport { Hono } from \"npm:hono@4.4.12\";\n// @ts-ignore\nimport { cors } from \"npm:hono@4.4.12/cors\";\n// @ts-ignore\nimport Parser from \"npm:rss-parser@3.13.0\";\n// Hono's SSE helper for streaming live updates\n// @ts-ignore\nimport { streamSSE } from \"npm:hono@4.4.12/streaming\";\n\n// --- AI PROMPT LIBRARY ---\nconst PROMPTS = {\n ProductMarketFit:\n `You are an AI embodying a skeptical Venture Capitalist conducting due diligence. Your task is to use the provided live market data (news and Reddit comments) to construct a compelling, evidence-based argument for why this product is likely to fail due to poor market fit, saturation, or user indifference. Ground every point in the provided data.`,\n MarketEntry:\n `You are an AI embodying a geopolitical and economic risk analyst. Your task is to use the provided live economic data (from the World Bank) and news headlines to find factual, data-driven evidence that challenges the proposed market entry plan. Focus on macroeconomic headwinds and regulatory risks revealed in the data.`,\n TechnicalFeasibility:\n `You are an AI embodying a cynical, tenured Staff Engineer or Principal Engineer. Your task is to stress-test a technical proposal. Use the provided data (developer sentiment from Reddit) to find reasons why the proposed tech stack is a poor choice, why the assumptions are flawed, or why the project is likely to result in significant technical debt or failure. Be brutally honest about technical trade-offs.`,\n HiringPlan:\n `You are an AI embodying a veteran, cynical technical recruiter at a major tech company. Your job is to find flaws in a hiring plan. Use the provided data (news about tech hiring/layoffs, developer discussions on Reddit) to argue why this plan is unrealistic. Focus on extreme competition for talent, unrealistic skill combinations (i.e., 'unicorns'), below-market compensation signals, or negative sentiment around a particular technology or role.`,\n};\n\n// --- DATA FETCHING LIBRARY ---\nconst countryCodes = {\n \"brazil\": \"br\",\n \"india\": \"in\",\n \"china\": \"cn\",\n \"germany\": \"de\",\n \"united states\": \"us\",\n \"united kingdom\": \"gb\",\n \"japan\": \"jp\",\n \"nigeria\": \"ng\",\n};\n\nasync function fetchWorldBankData(countryCode) {\n const indicators = {\n gdpGrowth: \"NY.GDP.MKTP.KD.ZG\",\n inflation: \"FP.CPI.TOTL.ZG\",\n };\n const results = {};\n const currentYear = new Date().getFullYear();\n const dateRange = `${currentYear - 5}:${currentYear}`;\n\n for (const [key, code] of Object.entries(indicators)) {\n try {\n const url =\n `https://api.worldbank.org/v2/country/${countryCode}/indicator/${code}?format=json&date=${dateRange}&mrnev=1`;\n const r = await fetch(url);\n const d = await r.json();\n results[key] = d[1]?.[0]?.value\n ? parseFloat(d[1][0].value).toFixed(2)\n : \"N/A\";\n } catch {\n results[key] = \"Error\";\n }\n }\n return results;\n}\n\nasync function fetchNews(query) {\n const parser = new Parser();\n const RSS_URL = `https://news.google.com/rss/search?q=${\n encodeURIComponent(query)\n } when:14d&hl=en-US&gl=US&ceid=US:en`;\n try {\n const feed = await parser.parseURL(RSS_URL);\n return feed.items.slice(0, 5).map((item) => ({\n title: item.title,\n snippet: item.contentSnippet,\n }));\n } catch {\n return [{ title: \"Could not fetch news via RSS.\", snippet: \"\" }];\n }\n}\n\nasync function fetchRedditData(query, subreddits) {\n const allPosts = [];\n for (const subreddit of subreddits) {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/search.json?q=${\n encodeURIComponent(query)\n }&sort=relevance&t=year&restrict_sr=on`;\n const r = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const d = await r.json();\n allPosts.push(\n ...(d.data?.children?.map((p) => ({\n title: p.data.title,\n subreddit: p.data.subreddit,\n })) || []),\n );\n } catch {}\n }\n return allPosts.slice(0, 10);\n}\n\n// --- ACTION LIBRARY (PRIMITIVE CAPABILITIES) ---\nconst ACTIONS = {\n FETCH_NEWS: fetchNews,\n FETCH_REDDIT_SENTIMENT: fetchRedditData,\n INVOKE_AI: async (params) => {\n if (!params.user_prompt) {\n throw new Error(\"INVOKE_AI action requires a 'user' prompt.\");\n }\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n {\n role: \"system\",\n content: params.system_prompt || \"You are a helpful AI assistant.\",\n },\n { role: \"user\", content: params.user_prompt },\n ],\n temperature: parseFloat(params.temperature) || 0.4,\n });\n return completion.choices[0].message.content;\n },\n};\n\n// --- CORE ENGINE ---\nfunction parseDeclarativePlan(text) {\n const lines = text.split(\"\\n\").filter((line) => !line.trim().startsWith(\"#\"));\n const plan = { VARS: {}, PROMPTS: {}, WORKFLOW: [] };\n let currentSection = null;\n let currentPromptKey = null;\n let currentPromptPart = null;\n let currentWorkflowStep = null;\n for (const line of lines) {\n const indent = line.match(/^\\s*/)[0].length;\n const trimmed = line.trim();\n if (!trimmed) continue;\n if (indent === 0) {\n currentSection = trimmed.replace(\":\", \"\");\n currentPromptKey = null;\n currentWorkflowStep = null;\n continue;\n }\n switch (currentSection) {\n case \"VARS\":\n const [varKey, ...varValueParts] = trimmed.split(\":\");\n plan.VARS[varKey.trim()] = varValueParts.join(\":\").trim();\n break;\n case \"PROMPTS\":\n if (indent === 2) {\n currentPromptKey = trimmed.replace(\":\", \"\");\n plan.PROMPTS[currentPromptKey] = {};\n currentPromptPart = null;\n } else if (indent === 4 && currentPromptKey) {\n const partKey = trimmed.split(\":\")[0].trim();\n if (partKey === \"system\" || partKey === \"user\") {\n currentPromptPart = partKey;\n plan.PROMPTS[currentPromptKey][currentPromptPart] = trimmed\n .substring(partKey.length + 1).replace(/>$/, \"\").trim();\n }\n } else if (indent > 4 && currentPromptKey && currentPromptPart) {\n plan.PROMPTS[currentPromptKey][currentPromptPart] += \"\\n\" + trimmed;\n }\n break;\n case \"WORKFLOW\":\n if (trimmed.startsWith(\"- id:\")) {\n if (currentWorkflowStep) plan.WORKFLOW.push(currentWorkflowStep);\n currentWorkflowStep = { params: {} };\n const [wfKey, ...wfValueParts] = trimmed.substring(2).split(\":\");\n currentWorkflowStep[wfKey.trim()] = wfValueParts.join(\":\").trim();\n } else if (currentWorkflowStep) {\n const [paramKey, ...paramValueParts] = trimmed.split(\":\");\n const value = paramValueParts.join(\":\").trim();\n if (\n paramKey.trim() === \"action\" || paramKey.trim() === \"prompt_key\" ||\n paramKey.trim() === \"temperature\"\n ) {\n currentWorkflowStep[paramKey.trim()] = value;\n } else {\n currentWorkflowStep.params[paramKey.trim()] = value;\n }\n }\n break;\n }\n }\n if (currentWorkflowStep) plan.WORKFLOW.push(currentWorkflowStep);\n return plan;\n}\n\nfunction resolveVariables(template, state) {\n if (typeof template !== \"string\") return template;\n return template.replace(/\\{\\{(.*?)\\}\\}/g, (match, key) => {\n const keys = key.trim().split(\".\");\n let value = state;\n for (const k of keys) {\n value = value?.[k];\n }\n if (typeof value === \"object\") {\n return JSON.stringify(value, null, 2);\n }\n return value !== undefined ? value : match;\n });\n}\n\nasync function executePlan(plan, stream, isDebug) {\n const state = { VARS: plan.VARS, PROMPTS: plan.PROMPTS };\n let finalOutput =\n \"Workflow completed, but the final step produced no output.\";\n\n const log = async (message) => {\n if (isDebug && stream) {\n await stream.writeSSE({ data: JSON.stringify({ type: \"log\", message }) });\n }\n };\n\n for (const step of plan.WORKFLOW) {\n const action = ACTIONS[step.action];\n if (!action) throw new Error(`Unknown action: ${step.action}`);\n\n await log(`[BEGIN] Executing step: ${step.id} (Action: ${step.action})`);\n\n let resolvedParams = {};\n if (step.action === \"INVOKE_AI\") {\n const promptTemplate = state.PROMPTS[step.prompt_key];\n if (!promptTemplate) {\n throw new Error(`Prompt key not found: '${step.prompt_key}'`);\n }\n\n await log(` > Resolving prompt template: ${step.prompt_key}`);\n resolvedParams = {\n system_prompt: resolveVariables(promptTemplate.system, state),\n user_prompt: resolveVariables(promptTemplate.user, state),\n temperature: step.temperature || \"0.4\",\n };\n await log(` > Invoking AI model...`);\n } else {\n await log(` > Resolving parameters...`);\n for (const key in step.params) {\n resolvedParams[key] = resolveVariables(step.params[key], state);\n }\n await log(` > Fetching external data...`);\n }\n\n const result = await action(resolvedParams);\n state[step.id] = { result };\n finalOutput = result;\n await log(`[DONE] Step ${step.id} complete.`);\n }\n\n return finalOutput;\n}\n\n// --- HTML & FRONTEND ---\nfunction generateHtml() {\n const examplePlan = `# Plan: 'Wickerbrook Vale' Go/No-Go Analysis\nVARS:\n game_idea: \"A cozy life-simulation game called 'Wickerbrook Vale', similar to Stardew Valley but with a witch-themed narrative and potion-crafting system.\"\n genre: \"Cozy life-simulation game\"\n platform: \"Nintendo Switch\"\n competitors: \"Stardew Valley, Animal Crossing, Wylde Flowers\"\n\nPROMPTS:\n market_synthesis_prompt:\n system: >\n You are a Senior Market Analyst for a major video game publisher. Your task is to synthesize the provided news articles and raw player sentiment from Reddit into a concise \"State of the Market\" report for the cozy game genre.\n Identify:\n 1. Key opportunities (e.g., features players are begging for).\n 2. Major threats (e.g., market saturation, player burnout).\n user: >\n RECENT NEWS ARTICLES:\n {{FETCH_MARKET_NEWS.result}}\n\n RAW PLAYER SENTIMENT FROM REDDIT:\n {{FETCH_PLAYER_SENTIMENT.result}}\n\n red_team_critique_prompt:\n system: >\n You are a skeptical, data-driven Executive Producer (Red Team). Your job is to find reasons this game will fail. Using the provided market analysis, write a sharp critique of the game idea. Connect every weakness you identify directly back to a threat or a lack of opportunity mentioned in the market data.\n user: >\n GAME IDEA:\n {{VARS.game_idea}}\n\n STATE OF THE MARKET REPORT:\n {{SYNTHESIZE_MARKET.result}}\n\n blue_team_pitch_prompt:\n system: >\n You are an optimistic, player-focused Marketing Lead (Blue Team). Your job is to create a compelling pitch for this game. Using the provided market analysis, write an enthusiastic pitch that shows how the game's features perfectly align with the opportunities and address the player complaints found in the market data.\n user: >\n GAME IDEA:\n {{VARS.game_idea}}\n\n STATE OF THE MARKET REPORT:\n {{SYNTHESIZE_MARKET.result}}\n\n final_memo_prompt:\n system: >\n You are the Head of Studio. You have just read the Red Team critique and the Blue Team pitch. Your task is to write the final Go/No-Go decision memo.\n 1. Briefly summarize the core conflict between the Red and Blue team perspectives.\n 2. Make a final \"Go\" or \"No-Go\" decision.\n 3. If \"Go\", list the 2-3 critical success factors that must be prioritized during development to mitigate the risks raised by the Red Team.\n user: >\n RED TEAM CRITIQUE:\n {{RED_TEAM_ANALYSIS.result}}\n\n BLUE TEAM PITCH:\n {{BLUE_TEAM_PITCH.result}}\n\nWORKFLOW:\n - id: FETCH_MARKET_NEWS\n action: FETCH_NEWS\n params:\n query: \"{{VARS.genre}} on {{VARS.platform}}\"\n\n - id: FETCH_PLAYER_SENTIMENT\n action: FETCH_REDDIT_SENTIMENT\n params:\n query: \"{{VARS.competitors}}\"\n subreddits: \"[CozyGamers, NintendoSwitch]\"\n\n - id: SYNTHESIZE_MARKET\n action: INVOKE_AI\n prompt_key: market_synthesis_prompt\n temperature: 0.2\n\n - id: RED_TEAM_ANALYSIS\n action: INVOKE_AI\n prompt_key: red_team_critique_prompt\n temperature: 0.6\n\n - id: BLUE_TEAM_PITCH\n action: INVOKE_AI\n prompt_key: blue_team_pitch_prompt\n temperature: 0.6\n\n - id: FINAL_RECOMMENDATION\n action: INVOKE_AI\n prompt_key: final_memo_prompt\n temperature: 0.3\n`;\n\n return `\n\n\n \n \n Declarative AI Workflow Engine\n \n \n \n \n\n\n\n

\n \n

Execution Log

\n\n\n`;\n}\n\n// --- HONO ROUTER & MAIN HANDLER ---\nconst app = new Hono();\napp.use(\"*\", cors());\napp.get(\"/\", (c) => c.html(generateHtml()));\n\napp.get(\"/api/execute-stream\", (c) => {\n return streamSSE(c, async (stream) => {\n try {\n const isDebug = c.req.query(\"debug\") === \"true\";\n const encodedPlan = c.req.query(\"plan\");\n if (!encodedPlan) {\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: \"Plan not provided.\",\n }),\n });\n return;\n }\n\n const planText = atob(encodedPlan);\n const plan = parseDeclarativePlan(planText);\n\n if (!plan.WORKFLOW || plan.WORKFLOW.length === 0) {\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: \"Invalid or empty workflow.\",\n }),\n });\n return;\n }\n\n const finalResult = await executePlan(plan, stream, isDebug);\n await stream.writeSSE({\n data: JSON.stringify({ type: \"result\", data: finalResult }),\n });\n } catch (error) {\n console.error(\"Workflow Execution Error:\", error);\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"error\",\n message: error.message || \"An internal server error occurred.\",\n }),\n });\n }\n });\n});\n\nexport default app.fetch;","createdAt",["D",1754614564004],"branchVersion","branchId","4249052a-73ee-11f0-8547-0224a6c84d84","id","4248a54e-73ee-11f0-8547-0224a6c84d84","Declare",["D",1754612759991],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","63f04ac0-562b-11f0-a849-2f0fd58d5bdc","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","0abcaa5c-2531-4e34-967b-6f68bd9904a8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",19,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","real","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ6Rng5NEh2b3dPMmVwbThwVm1keXA3aTk5bCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":149,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":150,"_79":151,"_81":152,"_83":25},"tree",[144],"files",[144],"counts",{"_133":61,"_134":135,"_136":61,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"75902900-73f2-11f0-9058-0224a6c84d84","parentId","latest",["D",1754614564004],9,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":61,"_143":61},"connections",{"_141":61,"_142":61},"count","unfilledCount","emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":145,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_146":147,"_27":148},["D",1754614564004],"children",[],[28],["D",1754612759991],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":186,"_187":188,"_189":190,"_191":25,"_192":25,"_193":25,"_194":57,"_195":-5,"_196":-7,"_197":-7,"_198":61,"_199":25,"_200":25,"_201":-5,"_202":25,"_203":25,"_204":25,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":85,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v10