\n {children}\n

\n \n\n\n`, {headers:{\"Content-Type\":\"text/html\"}});\n}",[],[248],{"_106":256,"_97":257,"_160":258,"_162":-5,"_163":145,"_164":259,"_166":167,"_108":260,"_102":261,"_170":171,"_172":74,"_174":22,"_175":-5,"_176":262,"_100":263},"885a1f6c-ff3b-11f0-bb19-42dde27851f2","demo2.1.ts","81c5ac2a-ff3b-11f0-8b36-42dde27851f2",199,["D",1769929160414],1,[],[257],{"_106":265,"_97":266,"_160":267,"_162":-5,"_163":145,"_164":268,"_166":167,"_108":269,"_102":270,"_170":233,"_172":271,"_174":22,"_175":-5,"_176":272,"_100":273},"69b107e8-fe13-11f0-b71a-42dde27851f2","demo2.ts","47fa2c24-fe0e-11f0-b3e4-42dde27851f2",63,["D",1769801977942],6,"// Learn more: https://docs.val.town/vals/http/\nimport { CodeValidator, CodeUtilities,CodeSense } from \"./CodeUtilities2.ts\";\nimport { List } from \"./System.Collections.Generic.ts\";\n\n// --- UI Components ---\n// We define a simple function to generate HTML strings, avoiding large template literals.\n\n/** Generates the main page structure. */\nfunction createPageHtml(content: string, output: string = '') {\n // We use a simple concatenation or template literal here for cleaner structure.\n // The inner content (output) is generated dynamically based on server-side analysis.\n return `\n\n\n \n \n CodeSense Analyzer Demo\n \n\n\n\n

Code Validator & Inspector Demo

\n\n

\n Input Text (Markdown or Code)\n \n \n

\n Analysis Output\n

${output}

\n\n\n`;\n}\n\n/** Analyzes the code and generates the output string. */\nfunction runAnalysis(inputText: string): string {\n let outputText = \"\";\n\n // 1. Markdown Segment Analysis (for structure and errors)\n const validationResult = CodeValidator.Analyze(inputText);\n if (!validationResult.IsSafe) {\n outputText += `Validation Error Found:\\n`;\n outputText += `Type: ${validationResult.Error.Type}\\n`;\n outputText += `Line: ${validationResult.Error.Line}\\n\\n`;\n }\n\n // 2. Code Definition Inspection\n const jsCodeBlocks = validationResult.Segments\n .Where(s => s.Type === 'code' && (s.Lang === 'js' || s.Lang === 'javascript' || s.Lang === 'ts' || s.Lang === 'typescript'))\n .Select(s => s.Value)\n .ToArray()\n .join('\\n');\n\n if (jsCodeBlocks.length > 0) {\n outputText += `Inspecting Definitions (${jsCodeBlocks.length} chars of code):\\n`;\n // Use your CodeSense/SourceInspector logic here\n // Note: CodeSense.Inspect is part of CodeUtilities2, which you imported\n const definitions = CodeSense.Inspect(jsCodeBlocks, \"demo.js\");\n outputText += JSON.stringify(definitions.ToArray(), null, 2);\n } else {\n outputText += \"No relevant JavaScript/TypeScript code blocks found for definition analysis.\";\n }\n\n return outputText;\n}\n\n// --- Val Town HTTP Handler ---\nexport default async function (req: Request): Promise {\n let inputText = `# Example Markdown Document\n\nThis document contains a few code blocks for analysis.\n\n## JavaScript Example\n\\`\\`\\`javascript\n// A simple function definition\nfunction calculateArea(width, height) {\n let area = width * height;\n return area;\n}\n\\`\\`\\`\n`;\n let analysisOutput = '';\n\n // If a POST request (form submission), run analysis on the data.\n if (req.method === 'POST') {\n try {\n const formData = await req.formData();\n inputText = formData.get('code')?.toString() || '';\n analysisOutput = runAnalysis(inputText);\n } catch (error) {\n analysisOutput = `Error processing form data: ${error.message}`;\n }\n }\n\n // Generate HTML response with form and analysis results (if any).\n const htmlBody = createPageHtml(inputText, analysisOutput);\n return new Response(htmlBody, { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[266],{"_106":275,"_97":276,"_160":277,"_162":-5,"_163":145,"_164":278,"_166":167,"_108":279,"_102":280,"_170":233,"_172":281,"_174":22,"_175":-5,"_176":282,"_100":283},"f356569a-fe15-11f0-8a38-42dde27851f2","demo3.ts","4c552cdc-fe14-11f0-ac47-42dde27851f2",72,["D",1769803067863],5,"// Learn more: https://docs.val.town/vals/http/\n\n// --- Server-Side Imports ---\n// These imports work because Val Town resolves them before running the main function.\nimport { CodeValidator, SourceInspector, CodeUtilities,CodeSense } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\nimport { List } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic.ts\";\n\n// --- Helper Functions ---\n\n/** Generates a basic HTML structure, allowing dynamic content insertion. */\nfunction createPageHtml(content: string, output: string = '') {\n // Note: No client-side JavaScript analysis code here. All analysis runs on the server.\n return `\n\n\n \n \n CodeSense Analyzer Demo\n \n\n\n\n

Code Validator & Inspector Demo

\n\n

\n Input Text (Markdown or Code)\n \n \n

\n Analysis Output\n

${output}

\n\n\n`;\n}\n\n/** Analyzes the code and generates the output string (server-side logic). */\nfunction runAnalysis(inputText: string): string {\n let outputText = \"\";\n\n // 1. Markdown Segment Analysis (for structure and errors)\n const validationResult = CodeValidator.Analyze(inputText);\n if (!validationResult.IsSafe) {\n outputText += `Validation Error Found:\\n`;\n outputText += `Type: ${validationResult.Error.Type}\\n`;\n outputText += `Line: ${validationResult.Error.Line}\\n\\n`;\n }\n\n // 2. Code Definition Inspection\n const jsCodeBlocks = validationResult.Segments\n .Where(s => s.Type === 'code' && (s.Lang === 'js' || s.Lang === 'javascript' || s.Lang === 'ts' || s.Lang === 'typescript'))\n .Select(s => s.Value)\n .ToArray()\n .join('\\n');\n\n if (jsCodeBlocks.length > 0) {\n outputText += `Inspecting Definitions (${jsCodeBlocks.length} chars of code):\\n`;\n // Use your CodeSense/SourceInspector logic here\n const definitions = SourceInspector.ListDefinitions(jsCodeBlocks, \"demo.js\");\n outputText += JSON.stringify(definitions.ToArray(), null, 2);\n } else {\n outputText += \"No relevant JavaScript/TypeScript code blocks found for definition analysis.\";\n }\n\n return outputText;\n}\n\n// --- Val Town HTTP Handler ---\nexport default async function (req: Request): Promise {\n // Default sample text for initial page load\n let inputText = `# Example Markdown Document\n\nThis document contains a few code blocks for analysis.\n\n## JavaScript Example\n\\`\\`\\`javascript\n// A simple function definition\nfunction calculateArea(width, height) {\n let area = width * height;\n return area;\n}\n\\`\\`\\`\n`;\n let analysisOutput = '';\n\n // If a POST request (form submission), run analysis on the data.\n if (req.method === 'POST') {\n try {\n const formData = await req.formData();\n inputText = formData.get('code')?.toString() || '';\n analysisOutput = runAnalysis(inputText);\n } catch (error) {\n analysisOutput = `Error processing form data: ${error.message}`;\n }\n }\n\n // Generate HTML response with form and analysis results (if any).\n const htmlBody = createPageHtml(inputText, analysisOutput);\n return new Response(htmlBody, { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[276],{"_106":285,"_97":286,"_160":287,"_162":-5,"_163":145,"_164":288,"_166":167,"_108":289,"_102":290,"_170":233,"_172":291,"_174":22,"_175":-5,"_176":292,"_100":293},"53a9ce96-fe16-11f0-915a-42dde27851f2","demo4.ts","3f95d88c-fe16-11f0-9c15-42dde27851f2",77,["D",1769803229471],4,"// Learn more: https://docs.val.town/vals/http/\n\n// --- Server-Side Imports ---\n// These imports will work on Val Town.\n// The code in these modules runs on the server when the val executes.\nimport { CodeValidator, SourceInspector, CodeUtilities } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\nimport { List, Enumerable } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic.ts\";\n\n// --- Sample Code Input ---\n// This sample code will test the parser's ability to handle classes, functions, variables, and errors.\nconst sampleCodeInput = `# Example Project Documentation\n\nThis document contains several code blocks to demonstrate different analysis capabilities.\n\n## Code Block 1: Valid TypeScript/JavaScript Class\n\n\\`\\`\\`typescript\n/** Represents a user profile */\nclass UserProfile {\n // A private field (variable)\n private name: string;\n public age: number = 25;\n\n constructor(name: string) {\n this.name = name;\n }\n\n // A getter method for a property\n get details() {\n return \\`\\${this.name} (\\${this.age})\\`;\n }\n\n // An async method\n public async loadData() {\n // ... implementation ...\n }\n}\n\n// Global variable definitions\nconst PI = 3.14159;\nlet message = \"Hello, world\";\n\n// Standard function declaration\nfunction calculateAverage(a, b) {\n return (a + b) / 2;\n}\n\\`\\`\\`\n\n## Code Block 2: Python Example (Non-JS Code)\n\n\\`\\`\\`python\ndef main():\n print(\"This is Python code.\")\n\\`\\`\\`\n\n## Code Block 3: Unclosed Block Example\n\n\\`\\`\\`javascript\n// This block is missing its closing backticks, triggering a validation error.\nfunction unclosedFunction() {\n console.log(\"Error here\");\n`;\n\n// --- Analysis Logic (Server-Side) ---\n\n/** Runs the analysis and organizes all results into a single object for rendering. */\nfunction runAnalysis(inputText: string): any {\n const report = {\n validationStatus: CodeValidator.Analyze(inputText),\n codeSegments: null,\n definitions: null\n };\n\n // 1. Get code segments (prose and code blocks) from markdown parsing.\n report.codeSegments = report.validationStatus.Segments.ToList();\n\n // 2. Extract JS code blocks for inspection.\n const jsCodeBlocks = report.codeSegments\n .Where(s => s.Type === 'code' && (s.Lang === 'js' || s.Lang === 'javascript' || s.Lang === 'ts' || s.Lang === 'typescript'))\n .Select(s => s.Value)\n .ToArray()\n .join('\\n');\n\n // 3. Perform deep inspection if JS code exists.\n if (jsCodeBlocks.length > 0) {\n report.definitions = SourceInspector.ListDefinitions(jsCodeBlocks, \"demo.js\").ToArray();\n }\n\n return report;\n}\n\n// --- HTML Rendering Logic (Server-Side) ---\n\n/** Generates a detailed report based on the analysis results. */\nfunction generateReportHtml(analysisReport: any) {\n const { validationStatus, codeSegments, definitions } = analysisReport;\n\n let html = '';\n\n // 1. Validation Status Section\n html += '

';\n if (validationStatus.IsSafe) {\n html += '

Validation Status: PASS

';\n html += '

The document structure and code block syntax are valid.

';\n } else {\n html += '

Validation Status: FAIL

';\n html += `

Error Found: ${validationStatus.Error.Type} on line ${validationStatus.Error.Line}.`;\n }\n html += '

';\n\n // 2. Definitions Summary Table\n if (definitions && definitions.length > 0) {\n html += '

';\n html += '

Detected Definitions Summary

';\n html += '';\n html += '';\n html += '';\n for (const def of definitions) {\n html += ``;\n html += ``;\n html += ``;\n html += ``;\n html += ``;\n html += ``;\n html += ``;\n }\n html += '';\n html += '

Kind	Name	Modifiers	Start Line	End Line
${def.Kind}	${def.Name}	${def.Modifiers.ToArray().join(', ') \|\| 'None'}	${def.Start.Line}	${def.End.Line}

';\n html += '

';\n } else {\n html += '

No definitions found for inspection.

';\n }\n\n // 3. Code Segment Breakdown\n html += '

';\n html += '

Document Segment Breakdown

';\n for (const segment of codeSegments) {\n const langInfo = segment.Lang ? `(${segment.Lang})` : '(Prose)';\n html += `

Type: ${segment.Type} ${langInfo}`;\n html += `

${escapeHtml(segment.Value)}

`;\n }\n html += '

';\n\n return html;\n}\n\n/** Escapes HTML special characters in the text. */\nfunction escapeHtml(text: string): string {\n return text.replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\n/** Generates the complete HTML page structure with input and results. */\nfunction createPageHtml(content: string, output: string) {\n return `\n\n\n \n \n CodeSense Analyzer Demo (Complex SSR)\n \n\n\n\n

Code Validator & Inspector Demo

\n\n

\n Input Text (Markdown or Code)\n \n

\n Analysis Output\n

${output}

\n\n\n`;\n}\n\n// --- Val Town HTTP Handler ---\n\n/** Main entry point for the HTTP handler. */\nexport default async function (req: Request): Promise {\n let inputText = sampleCodeInput;\n let analysisOutputHtml = '';\n\n // If a POST request (form submission), run analysis on the data.\n if (req.method === 'POST') {\n try {\n const formData = await req.formData();\n inputText = formData.get('code')?.toString() || '';\n const analysisReportData = runAnalysis(inputText);\n analysisOutputHtml = generateReportHtml(analysisReportData);\n } catch (error) {\n analysisOutputHtml = `

Error processing request: ${error.message}

`;\n }\n } else {\n // Run initial analysis for GET request to pre-populate results\n const analysisReportData = runAnalysis(inputText);\n analysisOutputHtml = generateReportHtml(analysisReportData);\n }\n\n // Generate HTML response with form and analysis results (if any).\n const htmlBody = createPageHtml(inputText, analysisOutputHtml);\n return new Response(htmlBody, { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[286],{"_106":295,"_97":296,"_160":297,"_162":-5,"_163":145,"_164":298,"_166":167,"_108":299,"_102":169,"_170":233,"_172":300,"_174":22,"_175":-5,"_176":301,"_100":302},"4b21ecd0-fe30-11f0-bba5-42dde27851f2","demo5.ts","064cc67c-fe1a-11f0-9ac9-42dde27851f2",97,["D",1769814382073],"// Learn more: https://docs.val.town/vals/http\n// --- Server-Side Imports ---\nimport { CodeValidator, SourceInspector, CodeUtilities,EnhancedDefinition,Definition } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\nimport { List, Enumerable } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic.ts\";\n\n// --- Sample Code Input ---\nconst sampleCodeInput = `# Example Project Documentation\n\nThis document contains several code blocks to demonstrate different analysis capabilities.\n\n## Code Block 1: Valid TypeScript/JavaScript Class\n\n\\`\\`\\`typescript\n/** Represents a user profile */\nclass UserProfile {\n // A private field (variable) with an initializer\n private name: string = \"defaultName\";\n\n // A getter method for a property\n get details() {\n if (this.name) {\n return \\`Name: \\${this.name}\\`;\n } else {\n return \"No name set\";\n }\n }\n\n // A constructor with parameters\n public constructor(name: string, age: number = 25) {\n this.name = name;\n this.age = age;\n if (age < 18) {\n console.warn(\"User is minor.\");\n }\n }\n\n // An async method with logic complexity\n public async loadData(userId: number, force: boolean) {\n if (force || userId === 0) {\n await this.fetchFromAPI(userId);\n } else if (userId > 100) {\n return;\n }\n }\n\n private fetchFromAPI(id: number) {\n // ... implementation ...\n }\n}\n\n// Global variable definitions\nconst PI = 3.14159;\n\n// Standard function declaration\nfunction calculateAverage(a, b) {\n let sum = a + b;\n return sum / 2;\n}\n\n// Unclosed Block Example (triggers validation error)\n// The parser will attempt to analyze this but note the error.\n\\`\\`\\`javascript\nfunction unclosedFunction() {\n console.log(\"Error here\");\n`;\n\n\n\n/** Runs the analysis and organizes all results into a single object for rendering. */\nfunction runAnalysis(inputText: string): any {\n const report = {\n validationStatus: CodeValidator.Analyze(inputText),\n codeSegments: null,\n definitions: null\n };\n\n // 1. Get code segments (prose and code blocks) from markdown parsing.\n report.codeSegments = report.validationStatus.Segments.ToList();\n\n // 2. Extract JS code blocks for inspection.\n const jsCodeBlocks = report.codeSegments\n .Where(s => s.Type === 'code' && (s.Lang === 'js' || s.Lang === 'javascript' || s.Lang === 'ts' || s.Lang === 'typescript'))\n .Select(s => s.Value)\n .ToArray()\n .join('\\n');\n\n // 3. Perform deep inspection if JS code exists.\n if (jsCodeBlocks.length > 0) {\n // The SourceInspector logic has been significantly improved for this.\n report.definitions = SourceInspector.AnalyzeCode(jsCodeBlocks, \"demo.js\").ToArray();\n }\n\n return report;\n}\n\n// --- HTML Rendering Logic (Server-Side) ---\n\n/** Generates a detailed report based on the analysis results. */\nfunction generateReportHtml(analysisReport: any) {\n const { validationStatus, codeSegments, definitions } = analysisReport;\n\n let html = '';\n\n // 1. Validation Status Section\n html += '

';\n html += '

Validation Status:

';\n if (validationStatus.IsSafe) {\n html += '

PASS

';\n html += '

The document structure and code block syntax are valid.

';\n } else {\n html += '

FAIL

';\n html += `

Error Found: ${validationStatus.Error.Type} on line ${validationStatus.Error.Line}.`;\n }\n html += '

';\n\n // 2. Definitions Summary Table\n if (definitions && definitions.length > 0) {\n html += '

';\n html += '

Detected Definitions Summary

';\n html += renderDefinitionHierarchy(new List(definitions));\n html += '

';\n } else {\n html += '

No definitions found for inspection.

';\n }\n\n // 3. Code Segment Breakdown (for ()context)\n html += '

';\n html += '

Document Segment Breakdown

';\n for (const segment of codeSegments) {\n const langInfo = segment.Lang ? `(${segment.Lang})` : '(Prose)';\n html += `

Type: ${segment.Type} ${langInfo}`;\n html += `

${escapeHtml(segment.Value)}

`;\n }\n html += '

';\n\n return html;\n}\n\n/** Recursively renders the definition hierarchy into nested lists for better visualization. */\nfunction renderDefinitionHierarchy(definitions: List, level: number = 0): string {\n let html = `

`;\n html += `${modifiers} ${def.Name} (${def.Kind}`;\n if (def.Kind !== 'variable') {\n html += `(${parameters}))`;\n } else {\n html += `)`;\n }\n html += `
Metrics: Complexity=${complexity}, Lines=${lineCount}
`;\n\n if (def.children.Count > 0) {\n html += renderDefinitionHierarchy(def.children, level + 1);\n }\n html += `

`;\n return html;\n}\n\n/** Escapes HTML special characters in the text. */\nfunction escapeHtml(text: string): string {\n return text.replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\n/** Generates the complete HTML page structure with input and results. */\nfunction createPageHtml(content: string, output: string) {\n return `\n\n\n \n \n CodeSense Analyzer Demo (Complex SSR)\n \n\n\n\n

Code Validator & Inspector Demo

\n\n

\n Input Text (Markdown or Code)\n \n

\n Analysis Output\n

${output}

Error processing request: ${error.message}

`;\n }\n }\n\n // Run analysis and generate report for the current input text.\n const analysisReportData = runAnalysis(inputText);\n analysisOutputHtml = generateReportHtml(analysisReportData);\n\n // Generate HTML response with form and analysis results.\n const htmlBody = createPageHtml(inputText, analysisOutputHtml);\n return new Response(htmlBody, { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[296],{"_106":304,"_97":305,"_160":306,"_162":-5,"_163":145,"_164":307,"_166":167,"_108":308,"_102":309,"_170":233,"_172":310,"_174":22,"_175":-5,"_176":311,"_100":312},"ee9316ca-fee2-11f0-bd2e-42dde27851f2","demo6.ts","004f12bc-fe37-11f0-a8ef-42dde27851f2",136,["D",1769891106708],7,"//SourceUtilities\n\n\n\n\n//demo5\n// Learn more: https://docs.val.town/vals/http\n// --- Server-Side Imports ---\nimport { CodeValidator, SourceInspector, CodeUtilities,EnhancedDefinition,Definition } from \"./CodeUtilities9.ts\";\nimport { List, Enumerable } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic9.ts\";\n\n// --- Sample Code Input ---\nconst sampleCodeInput = `# Example Project Documentation\n\nThis document contains several code blocks to demonstrate different analysis capabilities.\n\n## Code Block 1: Valid TypeScript/JavaScript Class\n\n\\`\\`\\`typescript\n/** Represents a user profile */\nclass UserProfile {\n // A private field (variable) with an initializer\n private name: string = \"defaultName\";\n\n // A getter method for a property\n get details() {\n if (this.name) {\n return \\`Name: \\${this.name}\\`;\n } else {\n return \"No name set\";\n }\n }\n\n // A constructor with parameters\n public constructor(name: string, age: number = 25) {\n this.name = name;\n this.age = age;\n if (age < 18) {\n console.warn(\"User is minor.\");\n }\n }\n\n // An async method with logic complexity\n public async loadData(userId: number, force: boolean) {\n if (force || userId === 0) {\n await this.fetchFromAPI(userId);\n } else if (userId > 100) {\n return;\n }\n }\n\n private fetchFromAPI(id: number) {\n // ... implementation ...\n }\n}\n\n// Global variable definitions\nconst PI = 3.14159;\n\n// Standard function declaration\nfunction calculateAverage(a, b) {\n let sum = a + b;\n return sum / 2;\n}\n\n// Unclosed Block Example (triggers validation error)\n// The parser will attempt to analyze this but note the error.\n\\`\\`\\`javascript\nfunction unclosedFunction() {\n console.log(\"Error here\");\n`;\n\n\n\n/** Runs the analysis and organizes all results into a single object for rendering. */\nfunction runAnalysis(inputText: string): any {\n const report = {\n validationStatus: CodeValidator.Analyze(inputText),\n codeSegments: null,\n definitions: null\n };\n\n // 1. Get code segments (prose and code blocks) from markdown parsing.\n report.codeSegments = report.validationStatus.Segments.ToList();\n\n // 2. Extract JS code blocks for inspection.\n const jsCodeBlocks = report.codeSegments\n .Where(s => s.Type === 'code' && (s.Lang === 'js' || s.Lang === 'javascript' || s.Lang === 'ts' || s.Lang === 'typescript'))\n .Select(s => s.Value)\n .ToArray()\n .join('\\n');\n\n // 3. Perform deep inspection if JS code exists.\n if (jsCodeBlocks.length > 0) {\n // The SourceInspector logic has been significantly improved for this.\n report.definitions = SourceInspector.AnalyzeCode(jsCodeBlocks, \"demo.js\").ToArray();\n }\n\n return report;\n}\n\n// --- HTML Rendering Logic (Server-Side) ---\n\n/** Generates a detailed report based on the analysis results. */\nfunction generateReportHtml(analysisReport: any) {\n const { validationStatus, codeSegments, definitions } = analysisReport;\n\n let html = '';\n\n // 1. Validation Status Section\n html += '

';\n html += '

Validation Status:

';\n if (validationStatus.IsSafe) {\n html += '

PASS

';\n html += '

The document structure and code block syntax are valid.

';\n } else {\n html += '

FAIL

';\n html += `

Error Found: ${validationStatus.Error.Type} on line ${validationStatus.Error.Line}.`;\n }\n html += '

';\n\n // 2. Definitions Summary Table\n if (definitions && definitions.length > 0) {\n html += '

';\n html += '

Detected Definitions Summary

';\n html += renderDefinitionHierarchy(new List(definitions));\n html += '

';\n } else {\n html += '

No definitions found for inspection.

';\n }\n\n // 3. Code Segment Breakdown (for ()context)\n html += '

';\n html += '

Document Segment Breakdown

';\n for (const segment of codeSegments) {\n const langInfo = segment.Lang ? `(${segment.Lang})` : '(Prose)';\n html += `

Type: ${segment.Type} ${langInfo}`;\n html += `

${escapeHtml(segment.Value)}

`;\n }\n html += '

`;\n html += `${modifiers} ${def.Name} (${def.Kind}`;\n if (def.Kind !== 'variable') {\n html += `(${parameters}))`;\n } else {\n html += `)`;\n }\n html += `
Metrics: Complexity=${complexity}, Lines=${lineCount}
`;\n\n if (def.children.Count > 0) {\n html += renderDefinitionHierarchy(def.children, level + 1);\n }\n html += `

Code Validator & Inspector Demo

\n\n

\n Input Text (Markdown or Code)\n \n

\n Analysis Output\n

${output}

Error processing request: ${error.message}

`;\n }\n }\n\n // Run analysis and generate report for the current input text.\n const analysisReportData = runAnalysis(inputText);\n analysisOutputHtml = generateReportHtml(analysisReportData);\n\n // Generate HTML response with form and analysis results.\n const htmlBody = createPageHtml(inputText, analysisOutputHtml);\n return new Response(htmlBody, { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[305],{"_106":314,"_97":315,"_160":316,"_162":-5,"_163":145,"_164":317,"_166":167,"_108":318,"_102":290,"_170":233,"_172":319,"_174":22,"_175":-5,"_176":320,"_100":321},"47d46078-ff2d-11f0-9ea3-42dde27851f2","deployer.ts","2724e06e-ff2d-11f0-8608-42dde27851f2",183,["D",1769923039206],"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono@3\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\nconst app = new Hono();\nconst openai = new OpenAI();\n\n// ---------------------------------------------------------\n// 1. SERVER SIDE LOGIC (The Brain)\n// ---------------------------------------------------------\n\n// Helper: Sort name##ID##\nconst sortVals = (vals: any[]) => {\n return vals.sort((a, b) => {\n const regex = /^(.*)##(\\d+)##/;\n const matchA = a.name.match(regex);\n const matchB = b.name.match(regex);\n if (!matchA && !matchB) return a.name.localeCompare(b.name);\n if (!matchA) return 1;\n if (!matchB) return -1;\n if (matchA[1] !== matchB[1]) return matchA[1].localeCompare(matchB[1]);\n return parseInt(matchA[2]) - parseInt(matchB[2]);\n });\n};\n\nasync function fetchVals(token: string, prefix: string) {\n const meRes = await fetch(\"https://api.val.town/v1/me\", { headers: { Authorization: `Bearer ${token}` } });\n const me = await meRes.json();\n \n // Fetch vals (simplified for brevity, usually needs pagination)\n const res = await fetch(`https://api.val.town/v1/users/${me.id}/vals?limit=100`, {\n headers: { Authorization: `Bearer ${token}` },\n });\n const data = await res.json();\n \n const regex = new RegExp(`^${prefix || '.*'}##(\\\\d+)##`);\n return sortVals(data.data.filter(v => v.name.match(regex)));\n}\n\n// ---------------------------------------------------------\n// 2. THE ADVANCED UI (SimCity Style Dashboard)\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Swarm Command\n \n \n \n \n \n {children}\n \n \n);\n\n// ---------------------------------------------------------\n// 3. API ROUTES\n// ---------------------------------------------------------\n\napp.get(\"/api/vals\", async (c) => {\n const token = Deno.env.get(\"VAL_TOWN_API_KEY\");\n const prefix = c.req.query(\"prefix\") || \"\";\n try {\n const vals = await fetchVals(token, prefix);\n return c.json(vals.map(v => ({ \n id: v.id, \n name: v.name, \n version: v.version,\n status: 'idle', // idle, running, evolving\n logs: 'Ready.'\n })));\n } catch (e) { return c.json({ error: e.message }, 500); }\n});\n\napp.post(\"/api/spawn\", async (c) => {\n const token = Deno.env.get(\"VAL_TOWN_API_KEY\");\n const { prefix } = await c.req.json();\n \n // Find max ID\n const currentVals = await fetchVals(token, prefix);\n let maxId = 0;\n const regex = new RegExp(`^${prefix}##(\\\\d+)##`);\n currentVals.forEach(v => {\n const match = v.name.match(regex);\n if(match) maxId = Math.max(maxId, parseInt(match[1]));\n });\n\n const newName = `${prefix}##${maxId + 1}##`;\n const defaultCode = `export default async function(req) { console.log(\"I am alive\"); return Response.json({ status: \"alive\" }); }`;\n\n await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: newName, code: defaultCode, privacy: \"public\" })\n });\n\n return c.json({ success: true, name: newName });\n});\n\napp.post(\"/api/evolve\", async (c) => {\n const token = Deno.env.get(\"VAL_TOWN_API_KEY\");\n const { id, directive } = await c.req.json();\n\n // 1. Get Code\n const valRes = await fetch(`https://api.val.town/v1/vals/${id}`, { headers: { Authorization: `Bearer ${token}` }});\n const valData = await valRes.json();\n \n // 2. AI Mutation\n const completion = await openai.chat.completions.create({\n messages: [\n { role: \"system\", content: \"You are an AI coding swarm controller. You output ONLY raw TypeScript code for a Val Town HTTP val. No markdown, no explanations.\" },\n { role: \"user\", content: `Current Code:\\n${valData.code}\\n\\nDirective: ${directive}\\n\\nOutput the new full code:` }\n ],\n model: \"gpt-3.5-turbo\",\n });\n \n const newCode = completion.choices[0].message.content.replace(/```typescript|```/g, \"\").trim();\n\n // 3. Save\n await fetch(`https://api.val.town/v1/vals/${id}/versions`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ code: newCode })\n });\n\n return c.json({ success: true, codeSnippet: newCode.substring(0, 50) + \"...\" });\n});\n\napp.get(\"/\", (c) => {\n return c.html(\n \n {/* ALPINE APP ROOT */}\n

this.tick(), 2000);\n },\n\n log(source, msg) {\n this.logs.unshift({ time: new Date().toLocaleTimeString(), source, msg });\n if(this.logs.length > 50) this.logs.pop();\n }\n }`}\n {...{ \"x-init\": \"load()\" }}\n >\n \n {/* TOP BAR */}\n

VAL::SWARM

\n \n

\n CLUSTER:\n \n \n

\n\n

\n AI DIRECTIVE:\n \n

\n\n

\n \n \n

\n\n {/* MAIN AREA */}\n

\n \n {/* GRID VIEW (SimCity Style) */}\n

\n \n \n\n

\n \n {/* --- ADVANCED TEMPLATE FOR AGENT CARD --- */}\n \n {/* -------------------------------------- */}\n\n

\n\n {/* RIGHT SIDEBAR: LOGS */}\n

SYSTEM LOGS

\n \n

\n\n

\n \n );\n});\n\nexport default app.fetch;",[],[315],{"_106":323,"_97":324,"_160":325,"_162":-5,"_163":145,"_164":326,"_166":167,"_108":327,"_102":328,"_170":233,"_172":329,"_174":22,"_175":-5,"_176":330,"_100":331},"a33b5d40-ff2d-11f0-947d-42dde27851f2","deployer2.ts","874dd9c8-ff2d-11f0-994f-42dde27851f2",187,["D",1769923192548],3,"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono@3\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst app = new Hono();\n\n// ---------------------------------------------------------\n// 1. CONFIGURATION & DATABASE INIT\n// ---------------------------------------------------------\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_nodes (\n id TEXT PRIMARY KEY,\n name TEXT,\n last_seen DATETIME,\n status TEXT,\n logs TEXT\n )\n`);\n\n// ---------------------------------------------------------\n// 2. THE DRONE CODE\n// ---------------------------------------------------------\n// Implements the specific backoff logic requested\n\nconst GET_NODE_CODE = (hubUrl: string) => `\nimport { fetch } from \"https://esm.town/v/std/fetch\";\n\nconst HUB_URL = \"${hubUrl}\";\nconst API_TOKEN = Deno.env.get(\"APITOKEN\"); \nconst MY_ID = crypto.randomUUID().split('-')[0];\n\nfunction getWaitTime(failureCount) {\n // 1. Error -> 30s\n if (failureCount === 1) return 30000;\n // 2. Still limited -> 20s\n if (failureCount === 2) return 20000;\n // 3. Waiting -> 10 more seconds\n if (failureCount === 3) return 10000;\n // 4. Then 5 seconds\n if (failureCount === 4) return 5000;\n // 5. Then 2.5 seconds 10 times (failureCount 5 to 14)\n if (failureCount >= 5 && failureCount < 15) return 2500;\n // 6. Then 5 seconds (failureCount 15)\n if (failureCount === 15) return 5000;\n // 7. Then 10 seconds indefinitely\n return 10000;\n}\n\nconst sleep = (ms) => new Promise(r => setTimeout(r, ms));\n\nexport default async function(interval) {\n console.log(\"Drone \" + MY_ID + \" active.\");\n \n let failureStreak = 0;\n const startTime = Date.now();\n \n // Run for ~50 seconds to respect Val Town timeouts but maintain persistence\n while (true) {\n if (Date.now() - startTime > 50000) break; \n\n try {\n const res = await fetch(HUB_URL + \"/api/heartbeat\", {\n method: \"POST\",\n headers: { \n \"Authorization\": \"Bearer \" + API_TOKEN,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({\n id: MY_ID,\n name: \"Drone-\" + MY_ID,\n status: \"ACTIVE\"\n })\n });\n\n if (res.status === 429 || res.statusText === \"Too Many Requests\") {\n throw new Error(\"RATE_LIMIT\");\n }\n \n if (!res.ok) throw new Error(\"HTTP_\" + res.status);\n\n // Success - Reset\n failureStreak = 0;\n await sleep(10000); // Standard 10s broadcast interval\n\n } catch (err) {\n const isRateLimit = err.message === \"RATE_LIMIT\" || err.message.includes(\"429\");\n \n if (isRateLimit) {\n failureStreak++;\n const waitMs = getWaitTime(failureStreak);\n console.log(\\`Rate Limit (Streak \\${failureStreak}). Waiting \\${waitMs}ms\\`);\n await sleep(waitMs);\n } else {\n console.error(\"Connection Error:\", err.message);\n await sleep(5000);\n }\n }\n }\n}\n`;\n\n// ---------------------------------------------------------\n// 3. API ROUTES\n// ---------------------------------------------------------\n\napp.post(\"/api/heartbeat\", async (c) => {\n const token = c.req.header(\"Authorization\")?.replace(\"Bearer \", \"\");\n if (token !== Deno.env.get(\"APITOKEN\")) return c.json({ error: \"Unauthorized\" }, 401);\n\n const { id, name, status } = await c.req.json();\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT INTO swarm_nodes (id, name, last_seen, status, logs) \n VALUES (?, ?, ?, ?, ?) \n ON CONFLICT(id) DO UPDATE SET last_seen = ?, status = ?`,\n args: [id, name, now, status, \"Heartbeat OK\", now, status]\n });\n\n return c.json({ received: true });\n});\n\napp.get(\"/api/swarm\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM swarm_nodes ORDER BY last_seen DESC\");\n return c.json(result.rows.map(r => ({\n id: r.id, name: r.name, lastSeen: r.last_seen, status: r.status, logs: r.logs\n })));\n});\n\napp.post(\"/api/spawn\", async (c) => {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) return c.json({ error: \"APITOKEN env var missing\" }, 500);\n\n const hubUrl = c.req.url.replace(\"/api/spawn\", \"\");\n const newName = `drone_${Date.now()}`;\n\n try {\n const code = GET_NODE_CODE(hubUrl);\n \n // Create new Val via API\n const res = await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { \n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({ \n name: newName, \n code: code, \n privacy: \"public\",\n type: \"interval\", \n interval: \"1m\"\n })\n });\n\n if (!res.ok) throw new Error(await res.text());\n \n return c.json({ success: true, message: `Spawned ${newName}` });\n } catch (e) {\n return c.json({ error: e.message }, 500);\n }\n});\n\napp.post(\"/api/flush\", async (c) => {\n await sqlite.execute(\"DELETE FROM swarm_nodes\");\n return c.json({ ok: true });\n});\n\n// ---------------------------------------------------------\n// 4. UI\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Swarm Nexus\n \n \n \n \n \n {children}\n \n \n);\n\napp.get(\"/\", (c) => {\n return c.html(\n \n

this.refresh(), 5000);\n },\n\n async refresh() {\n const res = await fetch('/api/swarm');\n this.nodes = await res.json();\n this.nodes.forEach(n => {\n const diff = new Date() - new Date(n.lastSeen);\n n.active = diff < 20000; \n });\n },\n\n async spawn() {\n this.status = 'INITIALIZING DEPLOYMENT...';\n this.loading = true;\n try {\n const res = await fetch('/api/spawn', {\n method: 'POST',\n headers: {'Content-Type': 'application/json'},\n body: JSON.stringify({ count: 1 })\n });\n const data = await res.json();\n if(data.error) throw new Error(data.error);\n this.status = 'DEPLOYMENT SUCCESSFUL: ' + data.message;\n } catch(e) {\n this.status = 'DEPLOYMENT FAILED: ' + e.message;\n }\n this.loading = false;\n this.refresh();\n },\n \n async flush() {\n if(confirm('Clear all node data?')) {\n await fetch('/api/flush', { method: 'POST' });\n this.refresh();\n }\n }\n }`}\n >\n {/* HEADER */}\n

SWARM::NEXUS

\n TOKEN: \n

n.active).length\">

ACTIVE DRONES

\n\n {/* CONTROLS */}\n

\n \n\n \n\n

\n\n {/* NODE GRID */}\n

\n \n \n\n

\n \n );\n});\n\nexport default app.fetch;",[],[324],{"_106":333,"_97":334,"_160":335,"_162":-5,"_163":145,"_164":336,"_166":167,"_108":337,"_102":290,"_170":233,"_172":338,"_174":22,"_175":-5,"_176":339,"_100":340},"9ddf75bc-ff36-11f0-853b-42dde27851f2","hub3.tsx","6516ec56-ff36-11f0-94d6-42dde27851f2",193,["D",1769927049036],"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono@3\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\nconst app = new Hono();\nconst openai = new OpenAI();\n\n// ---------------------------------------------------------\n// 1. HIVE MEMORY & DATA STRUCTURES\n// ---------------------------------------------------------\n\n// --- Project State ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY,\n ambition TEXT,\n codebase TEXT, -- The main codebase file (will grow over time)\n status TEXT DEFAULT 'bootstrapping'\n )\n`);\n\n// --- Task Queue ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS task_queue (\n id INTEGER PRIMARY KEY,\n description TEXT,\n role TEXT, -- e.g., 'planner', 'coder', 'critic'\n status TEXT DEFAULT 'pending', -- pending, assigned, completed\n assigned_to TEXT,\n result TEXT\n )\n`);\n\n// --- Swarm Workers ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_workers (\n id TEXT PRIMARY KEY,\n name TEXT,\n last_seen DATETIME,\n status TEXT DEFAULT 'idle'\n )\n`);\n\n// ---------------------------------------------------------\n// 2. BOOTSTRAPPING DRONE CODE (THE SELF-BUILDING WORKER)\n// ---------------------------------------------------------\n\nconst GET_DRONE_CODE = (hubUrl: string) => `\nimport { fetch } from \"https://esm.town/v/std/fetch\";\n\nconst HUB_URL = \"${hubUrl}\";\nconst API_TOKEN = Deno.env.get(\"APITOKEN\"); \nconst MY_ID = crypto.randomUUID().split('-')[0];\n\nconst sleep = (ms) => new Promise(r => setTimeout(r, ms));\n\n// --- The Core Drone Logic ---\nexport default async function(interval) {\n const startTime = Date.now();\n \n while (true) {\n if (Date.now() - startTime > 50000) break;\n\n try {\n // 1. Request task from Hub\n const res = await fetch(HUB_URL + \"/api/task/poll\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, name: \"Drone-\" + MY_ID })\n });\n const data = await res.json();\n\n // 2. Execute Task (Hub proxy for AI work)\n if (data.status === \"ASSIGNED\" && data.task) {\n console.log(\"Task assigned: \" + data.task.description);\n // We simulate work by having the drone trigger a \"complete\" call\n // The Hub (AI) will perform the actual code generation.\n \n const completeRes = await fetch(HUB_URL + \"/api/task/complete\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, taskId: data.task.id })\n });\n console.log(\"Task submitted for review: \" + completeRes.status);\n } else {\n console.log(\"Idle. Waiting for tasks...\");\n await sleep(5000);\n }\n } catch (e) {\n console.error(\"Hub communication error:\", e.message);\n await sleep(10000);\n }\n }\n}\n`;\n\n// ---------------------------------------------------------\n// 3. API ROUTES (THE FACTORY FLOOR)\n// ---------------------------------------------------------\n\n// --- SWARM MANAGEMENT ---\n\napp.post(\"/api/swarm/spawn\", async (c) => {\n const token = Deno.env.get(\"APITOKEN\");\n const hubUrl = c.req.url.replace(\"/api/swarm/spawn\", \"\");\n const newName = `worker_${Date.now()}`;\n \n await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: newName, code: GET_DRONE_CODE(hubUrl), privacy: \"public\", type: \"interval\", interval: \"1m\" })\n });\n return c.json({ ok: true, message: `Worker ${newName} created.` });\n});\n\napp.post(\"/api/task/poll\", async (c) => {\n const { id, name } = await c.req.json();\n const now = new Date().toISOString();\n\n // 1. Register Worker or Update Status\n await sqlite.execute({\n sql: `INSERT INTO swarm_workers (id, name, last_seen, status) VALUES (?, ?, ?, 'idle') \n ON CONFLICT(id) DO UPDATE SET last_seen = ?, name = ?`,\n args: [id, name, now, now, name]\n });\n\n // 2. Find Pending Task\n const taskRes = await sqlite.execute(`SELECT * FROM task_queue WHERE status = 'pending' LIMIT 1`);\n if (taskRes.rows.length === 0) {\n return c.json({ status: \"IDLE\" });\n }\n\n const task = taskRes.rows[0];\n\n // 3. Assign Task\n await sqlite.execute({\n sql: `UPDATE task_queue SET status = 'assigned', assigned_to = ? WHERE id = ?`,\n args: [id, task.id]\n });\n await sqlite.execute({\n sql: `UPDATE swarm_workers SET status = 'working' WHERE id = ?`,\n args: [id]\n });\n\n return c.json({ status: \"ASSIGNED\", task: task });\n});\n\n// --- CODE FACTORY LOGIC ---\n\napp.post(\"/api/task/complete\", async (c) => {\n const { id, taskId } = await c.req.json();\n \n // 1. Get Task details\n const taskRes = await sqlite.execute({ sql: \"SELECT * FROM task_queue WHERE id = ?\", args: [taskId] });\n const task = taskRes.rows[0];\n const currentProjectRes = await sqlite.execute(\"SELECT * FROM projects LIMIT 1\");\n const project = currentProjectRes.rows[0];\n\n // 2. AI Code Generation (The Core Factory logic)\n // We use function calling to ensure structured output.\n const completion = await openai.chat.completions.create({\n model: \"gpt-3.5-turbo\",\n messages: [\n { role: \"system\", content: `You are an expert ${task.role}. The current project codebase is:\\n${project.codebase}\\n\\nYour task is: ${task.description}. Provide the updated full file content.` },\n { role: \"user\", content: `Complete the task: ${task.description}` }\n ],\n // Function calling to ensure structured output (e.g., provide code in 'file_update' function)\n functions: [\n {\n name: \"file_update\",\n description: \"Update the main codebase with the new code from the task.\",\n parameters: {\n type: \"object\",\n properties: { code: { type: \"string\" } },\n required: [\"code\"],\n }\n }\n ]\n });\n \n // 3. Process result and update codebase\n const code = completion.choices[0].message.function_call?.arguments;\n let newCode = code ? JSON.parse(code).code : `// Error: AI failed to parse task: ${task.description}`;\n\n // 4. Update project state\n await sqlite.execute({\n sql: `UPDATE projects SET codebase = ? WHERE id = ?`,\n args: [newCode, project.id]\n });\n\n // 5. Update task status and worker status\n await sqlite.execute({ sql: `UPDATE task_queue SET status = 'completed' WHERE id = ?`, args: [taskId] });\n await sqlite.execute({ sql: `UPDATE swarm_workers SET status = 'idle' WHERE id = ?`, args: [id] });\n\n return c.json({ ok: true });\n});\n\n// --- BOOTSTRAPPING LOGIC (Self-Building) ---\n\napp.post(\"/api/project/create\", async (c) => {\n const { ambition } = await c.req.json();\n \n // 1. Reset everything for a new project\n await sqlite.execute(\"DELETE FROM projects\");\n await sqlite.execute(\"DELETE FROM task_queue\");\n\n // 2. Create initial project state with empty codebase\n await sqlite.execute({\n sql: `INSERT INTO projects (ambition, codebase, status) VALUES (?, '', 'planning')`,\n args: [ambition]\n });\n\n // 3. Bootstrapping tasks (The factory builds itself first)\n // The first task is to create the \"planner\" logic. The second task is to then execute the planner logic.\n await sqlite.execute({ sql: `INSERT INTO task_queue (description, role) VALUES (?, ?)`, args: [\"Design the API for a basic project, including endpoints for data input and retrieval.\", \"planner\"] });\n await sqlite.execute({ sql: `INSERT INTO task_queue (description, role) VALUES (?, ?)`, args: [\"Create the database schema (SQLite) based on the project design.\", \"coder\"] });\n await sqlite.execute({ sql: `INSERT INTO task_queue (description, role) VALUES (?, ?)`, args: [\"Implement the server-side logic for data input using the designed API.\", \"coder\"] });\n\n return c.json({ success: true, message: \"Project created. Swarm is now self-bootstrapping tasks.\" });\n});\n\n// ---------------------------------------------------------\n// 4. UI (THE MINIMALIST COMMAND CENTER)\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Code Factory\n \n \n \n \n \n {children}\n \n \n);\n\napp.get(\"/\", (c) => {\n return c.html(\n \n

this.refresh(), 2000);\n },\n async refresh() {\n const stateRes = await fetch('/api/state');\n const data = await stateRes.json();\n this.workers = data.workers;\n this.tasks = data.tasks;\n this.project = data.project;\n },\n async createProject() {\n this.loading = true;\n await fetch('/api/project/create', { method: 'POST', body: JSON.stringify({ ambition: this.ambition }) });\n this.loading = false;\n this.ambition = '';\n },\n async spawn() {\n await fetch('/api/swarm/spawn', { method: 'POST' });\n }\n }`}\n >\n {/* HEADER */}\n

`\nimport { fetch } from \"https://esm.town/v/std/fetch\";\n\nconst HUB_URL = \"${hubUrl}\";\nconst API_TOKEN = Deno.env.get(\"APITOKEN\"); \nconst MY_ID = crypto.randomUUID().split('-')[0];\n\nconst sleep = (ms) => new Promise(r => setTimeout(r, ms));\n\n// --- The Core Drone Logic (Now more intelligent) ---\nexport default async function(interval) {\n const startTime = Date.now();\n \n while (true) {\n // Check if close to 1-minute timeout (e.g., 50 seconds remaining)\n // --- TIMEOUT HANDOFF LOGIC ---\n if (Date.now() - startTime > 50000) {\n console.log(\"Approaching timeout. Detaching from current thread...\");\n // Post to server to trigger handoff/new thread.\n // We do not await this fetch, allowing the current process to terminate cleanly.\n fetch(HUB_URL + \"/api/hand_off\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ workerId: MY_ID, currentTask: \"task name here\" }) // Pass state data\n });\n break; \n }\n // --- END TIMEOUT HANDOFF LOGIC ---\n\n try {\n // 1. Request task from Hub (Drone self-assigns a role based on task queue)\n const res = await fetch(HUB_URL + \"/api/task/poll\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, name: \"Drone-\" + MY_ID })\n });\n const data = await res.json();\n\n // 2. Execute Task (Hub proxy for AI work)\n if (data.status === \"ASSIGNED\" && data.task) {\n console.log(\"Task assigned: \" + data.task.description);\n \n // --- Dynamic Role Execution (Simulated) ---\n // The Hub assigns the role. We simulate work by having the drone trigger a \"complete\" call.\n // The Hub (AI) will perform the actual code generation using a sophisticated prompt.\n \n const completeRes = await fetch(HUB_URL + \"/api/task/complete\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, taskId: data.task.id })\n });\n console.log(\"Task submitted for review: \" + completeRes.status);\n } else {\n console.log(\"Idle. Waiting for tasks...\");\n await sleep(5000);\n }\n } catch (e) {\n console.error(\"Hub communication error:\", e.message);\n await sleep(10000);\n }\n }\n}\n`;\n\n// ---------------------------------------------------------\n// 3. API ROUTES (THE FACTORY FLOOR)\n// ---------------------------------------------------------\n\n// --- SWARM MANAGEMENT ---\n\napp.post(\"/api/swarm/spawn\", async (c) => {\n const token = Deno.env.get(\"APITOKEN\");\n const hubUrl = c.req.url.replace(\"/api/swarm/spawn\", \"\");\n const newName = `worker_${Date.now()}`;\n \n await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: newName, code: GET_DRONE_CODE(hubUrl), privacy: \"public\", type: \"interval\", interval: \"1m\" })\n });\n return c.json({ ok: true, message: `Worker ${newName} created.` });\n});\n\napp.post(\"/api/task/poll\", async (c) => {\n const { id, name } = await c.req.json();\n const now = new Date().toISOString();\n\n // 1. Register Worker or Update Status\n await sqlite.execute({\n sql: `INSERT INTO swarm_workers (id, name, last_seen, status) VALUES (?, ?, ?, 'idle') \n ON CONFLICT(id) DO UPDATE SET last_seen = ?, name = ?`,\n args: [id, name, now, now, name]\n });\n\n // 2. Find Pending Task for an available worker\n const taskRes = await sqlite.execute(`SELECT * FROM tasks WHERE status = 'pending' LIMIT 1`);\n if (taskRes.rows.length === 0) {\n return c.json({ status: \"IDLE\" });\n }\n\n const task = taskRes.rows[0];\n\n // 3. Assign Task (Worker self-assigns)\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'assigned', assigned_to = ? WHERE id = ?`,\n args: [id, task.id]\n });\n await sqlite.execute({\n sql: `UPDATE swarm_workers SET status = 'working' WHERE id = ?`,\n args: [id]\n });\n\n return c.json({ status: \"ASSIGNED\", task: task });\n});\n\n// --- CODE FACTORY LOGIC ---\n\napp.post(\"/api/task/complete\", async (c) => {\n const { id, taskId } = await c.req.json();\n \n // 1. Get Task details\n const taskRes = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id = ?\", args: [taskId] });\n const task = taskRes.rows[0];\n const currentProjectRes = await sqlite.execute(\"SELECT * FROM projects LIMIT 1\");\n const project = currentProjectRes.rows[0];\n\n // 2. AI Code Generation (The Core Factory logic)\n // We use function calling to ensure structured output.\n const completion = await openai.chat.completions.create({\n model: \"gpt-3.5-turbo\",\n messages: [\n { role: \"system\", content: `You are an expert ${task.role}. The current project codebase is:\\n${project.codebase}\\n\\nYour task is: ${task.description}. Provide the updated full file content.` },\n { role: \"user\", content: `Complete the task: ${task.description}` }\n ],\n // Function calling to ensure structured output (e.g., provide code in 'file_update' function)\n functions: [\n {\n name: \"file_update\",\n description: \"Update the main codebase with the new code from the task.\",\n parameters: {\n type: \"object\",\n properties: { code: { type: \"string\" } },\n required: [\"code\"],\n }\n }\n ]\n });\n \n // 3. Process result and update codebase\n const code = completion.choices[0].message.function_call?.arguments;\n let newCode = code ? JSON.parse(code).code : `// Error: AI failed to parse task: ${task.description}`;\n\n // 4. Update project state\n await sqlite.execute({\n sql: `UPDATE projects SET codebase = ? WHERE id = ?`,\n args: [newCode, project.id]\n });\n\n // 5. Update task status and worker status\n await sqlite.execute({ sql: `UPDATE tasks SET status = 'completed' WHERE id = ?`, args: [taskId] });\n await sqlite.execute({ sql: `UPDATE swarm_workers SET status = 'idle' WHERE id = ?`, args: [id] });\n\n return c.json({ ok: true });\n});\n\n// --- BOOTSTRAPPING LOGIC (Self-Building) ---\n\napp.post(\"/api/project/create\", async (c) => {\n const { ambition } = await c.req.json();\n \n // 1. Reset everything for a new project\n await sqlite.execute(\"DELETE FROM projects\");\n await sqlite.execute(\"DELETE FROM tasks\");\n\n // 2. Create initial project state with empty codebase\n await sqlite.execute({\n sql: `INSERT INTO projects (ambition, codebase, status) VALUES (?, '', 'planning')`,\n args: [ambition]\n });\n\n // 3. Bootstrapping tasks (The factory builds itself first)\n // The first task is to create the \"planner\" logic. The second task is to then execute the planner logic.\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Design the API for a basic project, including endpoints for data input and retrieval.\", \"planner\"] });\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Create the database schema (SQLite) based on the project design.\", \"coder\"] });\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Implement the server-side logic for data input using the designed API.\", \"coder\"] });\n\n return c.json({ success: true, message: \"Project created. Swarm is now self-bootstrapping tasks.\" });\n});\n\n// ---------------------------------------------------------\n// 4. UI (THE MINIMALIST COMMAND CENTER)\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Code Factory\n \n \n \n \n \n {children}\n \n \n);\n\napp.get(\"/\", (c) => {\n return c.html(\n \n

Code Factory

Self-Building Swarm Deployment

WORKERS ACTIVE: w.status === 'working').length\">

TOTAL WORKERS:

\n\n

\n \n {/* LEFT: PROJECT INPUT AND TASKS */}\n

\n {/* INPUT */}\n

PROJECT AMBITION

\n \n \n

\n\n {/* TASK LIST */}\n

TASK QUEUE

\n \n \n

\n\n {/* RIGHT: CODEBASE & WORKERS */}\n

Codebase Output

\n \n

\n\n

\n WORKER STATUS (Last Seen)\n

\n \n

\n\n

\n \n );\n});\n\n// --- STATE API ---\napp.get(\"/api/state\", async (c) => {\n const workers = await sqlite.execute(\"SELECT * FROM swarm_workers\");\n const tasks = await sqlite.execute(\"SELECT * FROM tasks\");\n const project = await sqlite.execute(\"SELECT * FROM projects LIMIT 1\");\n return c.json({ \n workers: workers.rows, \n tasks: tasks.rows,\n project: project.rows[0]\n });\n});\n\nexport default app.fetch;",[],[343],{"_106":351,"_97":352,"_160":353,"_162":-5,"_163":145,"_164":354,"_166":167,"_108":355,"_102":33,"_170":171,"_172":74,"_174":22,"_175":-5,"_176":356,"_100":357},"ebdf5b00-ff1e-11f0-aae9-42dde27851f2","new-file-4084.ts","ebdf5bf0-ff1e-11f0-aae9-42dde27851f2",164,["D",1769916871976],[],[352],{"_106":359,"_97":360,"_160":361,"_162":-5,"_163":145,"_164":362,"_166":167,"_108":363,"_102":328,"_170":233,"_172":364,"_174":22,"_175":-5,"_176":365,"_100":366},"3639f322-ff29-11f0-a495-42dde27851f2","new-file-6383.ts","2234859a-ff29-11f0-a495-42dde27851f2",178,["D",1769921291686],"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono@3\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst app = new Hono();\n\n// ---------------------------------------------------------\n// 1. CONFIGURATION & DATABASE INIT\n// ---------------------------------------------------------\n\n// Initialize Database Table for the Swarm\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_nodes (\n id TEXT PRIMARY KEY,\n name TEXT,\n last_seen DATETIME,\n status TEXT,\n logs TEXT\n )\n`);\n\n// ---------------------------------------------------------\n// 2. THE DRONE CODE (This is injected into new Vals)\n// ---------------------------------------------------------\n// This code implements the complex backoff strategy you requested.\n\nconst GET_NODE_CODE = (hubUrl: string) => `\nimport { fetch } from \"https://esm.town/v/std/fetch\";\n\n// --- CONFIGURATION ---\nconst HUB_URL = \"${hubUrl}\";\n// We use Deno.env.get as standard, ensuring compatibility if user meant .val\nconst API_TOKEN = Deno.env.get(\"APITOKEN\"); \nconst MY_ID = crypto.randomUUID().split('-')[0]; // Short ID\n\n// --- BACKOFF STRATEGY ENGINE ---\nfunction getWaitTime(failureCount) {\n // \"If the service returns an error... wait 30 seconds\"\n if (failureCount === 1) return 30000;\n \n // \"if still limited then wait 20 seconds\"\n if (failureCount === 2) return 20000;\n \n // \"If waiting, wait 10 more seconds\"\n if (failureCount === 3) return 10000;\n \n // \"then 5 seconds\"\n if (failureCount === 4) return 5000;\n \n // \"then 2.5 seconds 10 times\"\n if (failureCount >= 5 && failureCount < 15) return 2500;\n \n // \"then 5 seconds\"\n if (failureCount === 15) return 5000;\n \n // \"then 10 seconds indefinitely\"\n return 10000;\n}\n\nconst sleep = (ms) => new Promise(r => setTimeout(r, ms));\n\nexport default async function(interval) {\n console.log(\"Drone \" + MY_ID + \" starting cycle...\");\n \n let failureStreak = 0;\n\n // We run a loop to simulate the persistent process\n // Note: Val Town limits execution time, so this handles \"bursts\" of activity\n // Ideally, this Val is set as an INTERVAL (Cron) Val to restart automatically.\n \n const startTime = Date.now();\n \n while (true) {\n // Safety break to prevent Val timeout hard crashes (stop after 50s)\n if (Date.now() - startTime > 50000) {\n console.log(\"Cycle complete, sleeping until next cron trigger.\");\n break; \n }\n\n try {\n console.log(\"Broadcasting to Hub...\");\n \n const res = await fetch(HUB_URL + \"/api/heartbeat\", {\n method: \"POST\",\n headers: { \n \"Authorization\": \"Bearer \" + API_TOKEN,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({\n id: MY_ID,\n name: \"Drone-\" + MY_ID,\n status: \"ACTIVE\"\n })\n });\n\n if (res.status === 429 || res.statusText === \"Too Many Requests\") {\n throw new Error(\"RATE_LIMIT\");\n }\n \n if (!res.ok) throw new Error(\"HTTP_\" + res.status);\n\n // Success! Reset streak and wait standard 10s\n console.log(\"Heartbeat acknowledged.\");\n failureStreak = 0;\n await sleep(10000); // Standard broadcast interval\n\n } catch (err) {\n const isRateLimit = err.message === \"RATE_LIMIT\" || err.message.includes(\"429\");\n \n if (isRateLimit) {\n failureStreak++;\n const waitMs = getWaitTime(failureStreak);\n console.log(\\`Rate Limited (Streak \\${failureStreak}). Waiting \\${waitMs}ms\\`);\n await sleep(waitMs);\n } else {\n console.error(\"Connection Error:\", err.message);\n await sleep(5000); // Standard error backoff\n }\n }\n }\n}\n`;\n\n// ---------------------------------------------------------\n// 3. API ROUTES (The Hub)\n// ---------------------------------------------------------\n\n// A. Receive Heartbeats\napp.post(\"/api/heartbeat\", async (c) => {\n const token = c.req.header(\"Authorization\")?.replace(\"Bearer \", \"\");\n if (token !== Deno.env.get(\"APITOKEN\")) return c.json({ error: \"Unauthorized\" }, 401);\n\n const { id, name, status } = await c.req.json();\n const now = new Date().toISOString();\n\n // Upsert into SQLite\n await sqlite.execute({\n sql: `INSERT INTO swarm_nodes (id, name, last_seen, status, logs) \n VALUES (?, ?, ?, ?, ?) \n ON CONFLICT(id) DO UPDATE SET last_seen = ?, status = ?`,\n args: [id, name, now, status, \"Heartbeat OK\", now, status]\n });\n\n return c.json({ received: true });\n});\n\n// B. Get Swarm Status\napp.get(\"/api/swarm\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM swarm_nodes ORDER BY last_seen DESC\");\n return c.json(result.rows.map(r => ({\n id: r.id, name: r.name, lastSeen: r.last_seen, status: r.status, logs: r.logs\n })));\n});\n\n// C. Spawn New Drone\napp.post(\"/api/spawn\", async (c) => {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) return c.json({ error: \"APITOKEN env var missing\" }, 500);\n\n const hubUrl = c.req.url.replace(\"/api/spawn\", \"\"); // Self-discovery\n const { count } = await c.req.json();\n const spawnCount = count || 1;\n\n // Generate unique name\n const timestamp = Date.now();\n const newName = `drone_${timestamp}`;\n\n try {\n // Call Val Town API to create a new val\n const code = GET_NODE_CODE(hubUrl);\n \n const res = await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { \n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({ \n name: newName, \n code: code, \n privacy: \"public\",\n // IMPORTANT: We set it as an Interval to keep it running\n type: \"interval\", \n interval: \"1m\" // Runs every minute, loops internally for 50s\n })\n });\n\n if (!res.ok) throw new Error(await res.text());\n \n return c.json({ success: true, message: `Spawned ${newName}` });\n } catch (e) {\n return c.json({ error: e.message }, 500);\n }\n});\n\n// D. Clean Database (Optional)\napp.post(\"/api/flush\", async (c) => {\n await sqlite.execute(\"DELETE FROM swarm_nodes\");\n return c.json({ ok: true });\n});\n\n// ---------------------------------------------------------\n// 4. UI (Command Center)\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Swarm Nexus\n \n \n \n \n \n {children}\n \n \n);\n\napp.get(\"/\", (c) => {\n return c.html(\n \n

this.refresh(), 5000); // Auto refresh UI\n },\n\n async refresh() {\n const res = await fetch('/api/swarm');\n this.nodes = await res.json();\n // Calculate active nodes (seen in last 15s)\n this.nodes.forEach(n => {\n const diff = new Date() - new Date(n.lastSeen);\n n.active = diff < 20000; \n });\n },\n\n async spawn() {\n this.status = 'INITIALIZING DEPLOYMENT...';\n this.loading = true;\n try {\n const res = await fetch('/api/spawn', {\n method: 'POST',\n headers: {'Content-Type': 'application/json'},\n body: JSON.stringify({ count: 1 })\n });\n const data = await res.json();\n if(data.error) throw new Error(data.error);\n this.status = 'DEPLOYMENT SUCCESSFUL: ' + data.message;\n } catch(e) {\n this.status = 'DEPLOYMENT FAILED: ' + e.message;\n }\n this.loading = false;\n this.refresh();\n },\n \n async flush() {\n if(confirm('Clear all node data?')) {\n await fetch('/api/flush', { method: 'POST' });\n this.refresh();\n }\n }\n }`}\n >\n {/* HEADER */}\n

SWARM::NEXUS

\n TOKEN: \n | HUB STATUS: ONLINE\n

n.active).length\">

ACTIVE DRONES

\n\n {/* CONTROLS */}\n

\n \n\n \n\n

\n\n {/* NODE GRID */}\n

\n \n \n\n

\n \n );\n});\n\nexport default app.fetch;",[],[360],{"_106":368,"_97":369,"_160":370,"_162":-5,"_163":145,"_164":371,"_166":167,"_108":372,"_102":270,"_170":233,"_172":373,"_174":22,"_175":-5,"_176":374,"_100":375},"9b1c80ae-0021-11f1-93fc-42dde27851f2","test3.ts","1e5d8564-0020-11f1-911d-42dde27851f2",207,["D",1770027976129],"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono@3\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\nconst app = new Hono();\n\n// ---------------------------------------------------------\n// 1. DATABASE SETUP\n// ---------------------------------------------------------\n\n// --- Project State ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY,\n ambition TEXT,\n codebase TEXT, -- The main codebase file (will grow over time)\n status TEXT DEFAULT 'bootstrapping'\n )\n`);\n\n// --- Dynamic Task Queue with Consensus ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY,\n description TEXT,\n role TEXT, -- e.g., 'planner', 'coder', 'critic'\n status TEXT DEFAULT 'pending', -- pending, assigned, completed\n assigned_to TEXT,\n proposed_by TEXT,\n result TEXT\n )\n`);\n\n// --- Proposal Voting Mechanism ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS votes (\n task_id INTEGER,\n worker_id TEXT,\n vote TEXT, -- 'approve' or 'reject'\n PRIMARY KEY (task_id, worker_id)\n )\n`);\n\n// --- Swarm Workers (Drones with Roles) ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_workers (\n id TEXT PRIMARY KEY,\n name TEXT,\n last_seen DATETIME,\n status TEXT DEFAULT 'idle',\n role TEXT -- assigned role (e.g., coder, critic)\n )\n`);\n\n// --- Distributed Knowledge Base (Self-Optimization) ---\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS knowledge_base (\n id INTEGER PRIMARY KEY,\n type TEXT, -- e.g., 'code_snippet', 'design_pattern'\n content TEXT,\n tags TEXT\n )\n`);\n\n// ---------------------------------------------------------\n// 2. BOOTSTRAPPING DRONE CODE (THE SELF-BUILDING WORKER)\n// ---------------------------------------------------------\n\nconst GET_DRONE_CODE = (hubUrl: string) => `\nimport { fetch } from \"https://esm.town/v/std/fetch\";\n\nconst HUB_URL = \"${hubUrl}\";\nconst API_TOKEN = Deno.env.get(\"APITOKEN\"); \nconst MY_ID = crypto.randomUUID().split('-')[0];\n\nconst sleep = (ms) => new Promise(r => setTimeout(r, ms));\n\n// --- The Core Drone Logic (Now more intelligent) ---\nexport default async function(interval) {\n const startTime = Date.now();\n \n while (true) {\n // Check if close to 1-minute timeout (e.g., 50 seconds remaining)\n // --- TIMEOUT HANDOFF LOGIC ---\n if (Date.now() - startTime > 50000) {\n console.log(\"Approaching timeout. Detaching from current thread...\");\n // Post to server to trigger handoff/new thread.\n // We do not await this fetch, allowing the current process to terminate cleanly.\n fetch(HUB_URL + \"/api/hand_off\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ workerId: MY_ID, currentTask: \"task name here\" }) // Pass state data\n });\n break; \n }\n // --- END TIMEOUT HANDOFF LOGIC ---\n\n try {\n // 1. Request task from Hub (Drone self-assigns a role based on task queue)\n const res = await fetch(HUB_URL + \"/api/task/poll\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, name: \"Drone-\" + MY_ID })\n });\n const data = await res.json();\n\n // 2. Execute Task (Hub proxy for AI work)\n if (data.status === \"ASSIGNED\" && data.task) {\n console.log(\"Task assigned: \" + data.task.description);\n \n // --- Dynamic Role Execution (Simulated) ---\n // The Hub assigns the role. We simulate work by having the drone trigger a \"complete\" call.\n // The Hub (AI) will perform the actual code generation using a sophisticated prompt.\n \n const completeRes = await fetch(HUB_URL + \"/api/task/complete\", {\n method: \"POST\",\n headers: { \"Authorization\": \"Bearer \" + API_TOKEN, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: MY_ID, taskId: data.task.id })\n });\n console.log(\"Task submitted for review: \" + completeRes.status);\n } else {\n console.log(\"Idle. Waiting for tasks...\");\n await sleep(5000);\n }\n } catch (e) {\n console.error(\"Hub communication error:\", e.message);\n await sleep(10000);\n }\n }\n}\n`;\n\n// ---------------------------------------------------------\n// 3. API ROUTES (THE FACTORY FLOOR)\n// ---------------------------------------------------------\n\n// --- SWARM MANAGEMENT ---\n\napp.post(\"/api/swarm/spawn\", async (c) => {\n const token = Deno.env.get(\"APITOKEN\");\n const hubUrl = c.req.url.replace(\"/api/swarm/spawn\", \"\");\n const newName = `worker_${Date.now()}`;\n \n await fetch(\"https://api.val.town/v1/vals\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: newName, code: GET_DRONE_CODE(hubUrl), privacy: \"public\", type: \"interval\", interval: \"1m\" })\n });\n return c.json({ ok: true, message: `Worker ${newName} created.` });\n});\n\napp.post(\"/api/task/poll\", async (c) => {\n const { id, name } = await c.req.json();\n const now = new Date().toISOString();\n\n // 1. Register Worker or Update Status\n await sqlite.execute({\n sql: `INSERT INTO swarm_workers (id, name, last_seen, status) VALUES (?, ?, ?, 'idle') \n ON CONFLICT(id) DO UPDATE SET last_seen = ?, name = ?`,\n args: [id, name, now, now, name]\n });\n\n // 2. Find Pending Task for an available worker\n const taskRes = await sqlite.execute(`SELECT * FROM tasks WHERE status = 'pending' LIMIT 1`);\n if (taskRes.rows.length === 0) {\n return c.json({ status: \"IDLE\" });\n }\n\n const task = taskRes.rows[0];\n\n // 3. Assign Task (Worker self-assigns)\n await sqlite.execute({\n sql: `UPDATE tasks SET status = 'assigned', assigned_to = ? WHERE id = ?`,\n args: [id, task.id]\n });\n await sqlite.execute({\n sql: `UPDATE swarm_workers SET status = 'working' WHERE id = ?`,\n args: [id]\n });\n\n return c.json({ status: \"ASSIGNED\", task: task });\n});\n\n// --- CODE FACTORY LOGIC ---\n\napp.post(\"/api/task/complete\", async (c) => {\n const { id, taskId } = await c.req.json();\n \n // 1. Get Task details\n const taskRes = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id = ?\", args: [taskId] });\n const task = taskRes.rows[0];\n const currentProjectRes = await sqlite.execute(\"SELECT * FROM projects LIMIT 1\");\n const project = currentProjectRes.rows[0];\n\n // 2. AI Code Generation (The Core Factory logic)\n // We use function calling to ensure structured output.\n const completion = await fetch('https://text.pollinations.ai/openai',{method:\"POST\"},\n {\n // model: \"gpt-3.5-turbo\",\n messages: [\n { role: \"system\", content: `You are an expert ${task.role}. The current project codebase is:\\n${project.codebase}\\n\\nYour task is: ${task.description}. Provide the updated full file content.` },\n { role: \"user\", content: `Complete the task: ${task.description}` }\n ],\n // Function calling to ensure structured output (e.g., provide code in 'file_update' function)\n functions: [\n {\n name: \"file_update\",\n description: \"Update the main codebase with the new code from the task.\",\n parameters: {\n type: \"object\",\n properties: { code: { type: \"string\" } },\n required: [\"code\"],\n }\n }\n ]\n });\n \n // 3. Process result and update codebase\n const code = completion.choices[0].message.function_call?.arguments;\n let newCode = code ? JSON.parse(code).code : `// Error: AI failed to parse task: ${task.description}`;\n\n // 4. Update project state\n await sqlite.execute({\n sql: `UPDATE projects SET codebase = ? WHERE id = ?`,\n args: [newCode, project.id]\n });\n\n // 5. Update task status and worker status\n await sqlite.execute({ sql: `UPDATE tasks SET status = 'completed' WHERE id = ?`, args: [taskId] });\n await sqlite.execute({ sql: `UPDATE swarm_workers SET status = 'idle' WHERE id = ?`, args: [id] });\n\n return c.json({ ok: true });\n});\n\n// --- BOOTSTRAPPING LOGIC (Self-Building) ---\n\napp.post(\"/api/project/create\", async (c) => {\n const { ambition } = await c.req.json();\n \n // 1. Reset everything for a new project\n await sqlite.execute(\"DELETE FROM projects\");\n await sqlite.execute(\"DELETE FROM tasks\");\n\n // 2. Create initial project state with empty codebase\n await sqlite.execute({\n sql: `INSERT INTO projects (ambition, codebase, status) VALUES (?, '', 'planning')`,\n args: [ambition]\n });\n\n // 3. Bootstrapping tasks (The factory builds itself first)\n // The first task is to create the \"planner\" logic. The second task is to then execute the planner logic.\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Design the API for a basic project, including endpoints for data input and retrieval.\", \"planner\"] });\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Create the database schema (SQLite) based on the project design.\", \"coder\"] });\n await sqlite.execute({ sql: `INSERT INTO tasks (description, role) VALUES (?, ?)`, args: [\"Implement the server-side logic for data input using the designed API.\", \"coder\"] });\n\n return c.json({ success: true, message: \"Project created. Swarm is now self-bootstrapping tasks.\" });\n});\n\n// ---------------------------------------------------------\n// 4. UI (THE MINIMALIST COMMAND CENTER)\n// ---------------------------------------------------------\n\nconst Layout = ({ children }) => (\n \n \n Code Factory\n {/* Added for responsiveness */}\n \n \n \n \n \n {children}\n \n \n);\n\napp.get(\"/\", (c) => {\n return c.html(\n \n

Code Factory

Self-Building Swarm Deployment

WORKERS ACTIVE: w.status === 'working').length\">

TOTAL WORKERS:

\n\n {/* --- MAIN LAYOUT --- */}\n

{/* Added responsiveness */}\n \n {/* LEFT: PROJECT INPUT AND TASKS */}\n

{/* Added responsiveness */}\n {/* INPUT */}\n

PROJECT AMBITION

\n \n \n

\n\n {/* TASK LIST */}\n

TASK QUEUE

\n \n \n

\n\n {/* RIGHT: CODEBASE & WORKERS */}\n

{/* Added responsiveness */}\n

Codebase Output

\n \n

\n\n

\n WORKER STATUS (Last Seen)\n

{/* Responsive worker grid */}\n \n

\n\n

\n \n );\n});\n\n// --- STATE API ---\napp.get(\"/api/state\", async (c) => {\n const workers = await sqlite.execute(\"SELECT * FROM swarm_workers\");\n const tasks = await sqlite.execute(\"SELECT * FROM tasks\");\n const project = await sqlite.execute(\"SELECT * FROM projects LIMIT 1\");\n return c.json({ \n workers: workers.rows, \n tasks: tasks.rows,\n project: project.rows[0]\n });\n});\n\nexport default app.fetch;",[],[369],"files",[157,179,189,198,208,217,226,237,246,255,264,274,284,294,303,313,322,332,341,350,358,367],"counts",{"_380":33,"_381":261,"_382":33,"_383":384,"_387":388},"pulls","branches","forks","envVars",{"_385":261,"_386":33},"count","emptyCount","connections",{"_385":33,"_389":33},"unfilledCount","contents",[],{"_106":190,"_97":101,"_160":191,"_162":-5,"_163":145,"_164":192,"_166":167,"_108":393,"_102":194,"_170":171,"_172":195,"_174":22,"_175":-5,"_100":394},["D",1769802902356],[101],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_95":96,"_97":98,"_99":45,"_102":103,"_100":101,"_104":403,"_155":408,"_376":475,"_204":476,"_390":478,"_479":-5,"_480":-5,"_481":-5,"_482":-5,"_483":484,"_383":-5},{"_106":107,"_97":98,"_108":404,"_110":-5,"_111":22,"_112":113,"_114":-5,"_115":-5,"_14":116,"_117":-5,"_118":22,"_119":-5,"_120":-5,"_121":33,"_16":122,"_123":-5,"_124":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":405,"_137":406,"_142":407,"_154":22},["D",1769234447182],{"_95":96,"_135":136},{"_95":96,"_139":136,"_14":116,"_140":141},{"_102":144,"_97":45,"_106":145,"_146":107,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},[409,412,415,418,421,424,427,430,433,436,439,442,445,448,451,454,457,460,463,466,469,472],{"_106":158,"_97":159,"_160":161,"_162":-5,"_163":145,"_164":165,"_166":167,"_108":168,"_102":169,"_170":171,"_172":173,"_174":22,"_175":-5,"_176":410,"_100":411},[],[159],{"_106":180,"_97":181,"_160":182,"_162":-5,"_163":145,"_164":183,"_166":167,"_108":184,"_102":185,"_170":171,"_172":186,"_174":22,"_175":-5,"_176":413,"_100":414},[],[181],{"_106":190,"_97":101,"_160":191,"_162":-5,"_163":145,"_164":192,"_166":167,"_108":193,"_102":194,"_170":171,"_172":195,"_174":22,"_175":-5,"_176":416,"_100":417},[],[101],{"_106":199,"_97":200,"_160":201,"_162":-5,"_163":145,"_164":202,"_166":167,"_108":203,"_102":33,"_170":204,"_172":205,"_174":22,"_175":-5,"_176":419,"_100":420},[],[200],{"_106":209,"_97":210,"_160":211,"_162":-5,"_163":145,"_164":212,"_166":167,"_108":213,"_102":194,"_170":171,"_172":214,"_174":22,"_175":-5,"_176":422,"_100":423},[],[210],{"_106":218,"_97":219,"_160":220,"_162":-5,"_163":145,"_164":221,"_166":167,"_108":222,"_102":185,"_170":171,"_172":223,"_174":22,"_175":-5,"_176":425,"_100":426},[],[219],{"_106":227,"_97":228,"_160":229,"_162":-5,"_163":145,"_164":230,"_166":167,"_108":231,"_102":232,"_170":233,"_172":234,"_174":22,"_175":-5,"_176":428,"_100":429},[],[228],{"_106":238,"_97":239,"_160":240,"_162":-5,"_163":145,"_164":103,"_166":22,"_108":241,"_102":242,"_170":233,"_172":243,"_174":22,"_175":-5,"_176":431,"_100":432},[],[239],{"_106":247,"_97":248,"_160":249,"_162":-5,"_163":145,"_164":250,"_166":167,"_108":251,"_102":169,"_170":233,"_172":252,"_174":22,"_175":-5,"_176":434,"_100":435},[],[248],{"_106":256,"_97":257,"_160":258,"_162":-5,"_163":145,"_164":259,"_166":167,"_108":260,"_102":261,"_170":171,"_172":74,"_174":22,"_175":-5,"_176":437,"_100":438},[],[257],{"_106":265,"_97":266,"_160":267,"_162":-5,"_163":145,"_164":268,"_166":167,"_108":269,"_102":270,"_170":233,"_172":271,"_174":22,"_175":-5,"_176":440,"_100":441},[],[266],{"_106":275,"_97":276,"_160":277,"_162":-5,"_163":145,"_164":278,"_166":167,"_108":279,"_102":280,"_170":233,"_172":281,"_174":22,"_175":-5,"_176":443,"_100":444},[],[276],{"_106":285,"_97":286,"_160":287,"_162":-5,"_163":145,"_164":288,"_166":167,"_108":289,"_102":290,"_170":233,"_172":291,"_174":22,"_175":-5,"_176":446,"_100":447},[],[286],{"_106":295,"_97":296,"_160":297,"_162":-5,"_163":145,"_164":298,"_166":167,"_108":299,"_102":169,"_170":233,"_172":300,"_174":22,"_175":-5,"_176":449,"_100":450},[],[296],{"_106":304,"_97":305,"_160":306,"_162":-5,"_163":145,"_164":307,"_166":167,"_108":308,"_102":309,"_170":233,"_172":310,"_174":22,"_175":-5,"_176":452,"_100":453},[],[305],{"_106":314,"_97":315,"_160":316,"_162":-5,"_163":145,"_164":317,"_166":167,"_108":318,"_102":290,"_170":233,"_172":319,"_174":22,"_175":-5,"_176":455,"_100":456},[],[315],{"_106":323,"_97":324,"_160":325,"_162":-5,"_163":145,"_164":326,"_166":167,"_108":327,"_102":328,"_170":233,"_172":329,"_174":22,"_175":-5,"_176":458,"_100":459},[],[324],{"_106":333,"_97":334,"_160":335,"_162":-5,"_163":145,"_164":336,"_166":167,"_108":337,"_102":290,"_170":233,"_172":338,"_174":22,"_175":-5,"_176":461,"_100":462},[],[334],{"_106":342,"_97":343,"_160":344,"_162":-5,"_163":145,"_164":345,"_166":167,"_108":346,"_102":328,"_170":233,"_172":347,"_174":22,"_175":-5,"_176":464,"_100":465},[],[343],{"_106":351,"_97":352,"_160":353,"_162":-5,"_163":145,"_164":354,"_166":167,"_108":355,"_102":33,"_170":171,"_172":74,"_174":22,"_175":-5,"_176":467,"_100":468},[],[352],{"_106":359,"_97":360,"_160":361,"_162":-5,"_163":145,"_164":362,"_166":167,"_108":363,"_102":328,"_170":233,"_172":364,"_174":22,"_175":-5,"_176":470,"_100":471},[],[360],{"_106":368,"_97":369,"_160":370,"_162":-5,"_163":145,"_164":371,"_166":167,"_108":372,"_102":270,"_170":233,"_172":373,"_174":22,"_175":-5,"_176":473,"_100":474},[],[369],[409,412,415,418,421,424,427,430,433,436,439,442,445,448,451,454,457,460,463,466,469,472],{"_106":190,"_97":101,"_160":191,"_162":-5,"_163":145,"_164":192,"_166":167,"_108":393,"_102":194,"_170":171,"_172":195,"_174":22,"_175":-5,"_100":477},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]