Continuous Execution Active!

PR #${pr.number} merged → Next task started immediately

New Task: ${nextTask.task_name}

Priority: ${nextTask.priority}

Val.town Pro enabling instant task chaining!

\n `\n });\n\n return {\n status: \"task_started\",\n completed_pr: pr.number,\n new_task: nextTask.task_name,\n continuous_execution: true\n };\n }\n\n return {\n status: \"queue_empty\",\n completed_pr: pr.number,\n message: \"No more tasks to execute\"\n };\n}\n\n/**\n * Select and execute next task IMMEDIATELY\n * PRO: We have time to do this inline!\n */\nasync function selectAndExecuteNextTask() {\n const result = await sqlite.execute(\n `SELECT * FROM task_queue\n WHERE status = 'pending'\n ORDER BY priority DESC, created_at ASC\n LIMIT 1`\n );\n\n if (!result.rows[0]) return null;\n\n const task = result.rows[0];\n const octokit = getOctokit();\n\n // Update task status\n await sqlite.execute(\n \"UPDATE task_queue SET status = 'in_progress', assigned_persona = ? WHERE id = ?\",\n [`Senior ${task.task_name} Expert`, task.id]\n );\n\n // Create branch\n const branchName = `auto/${task.task_name.toLowerCase().replace(/\\s+/g, '-')}-${Date.now()}`;\n const { data: ref } = await octokit.rest.git.getRef({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n ref: \"heads/master\"\n });\n\n await octokit.rest.git.createRef({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n ref: `refs/heads/${branchName}`,\n sha: ref.object.sha\n });\n\n // Generate implementation\n const implementation = await generateQuickImplementation(task);\n\n // Create file\n await octokit.rest.repos.createOrUpdateFileContents({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n path: `implementations/${task.task_name.toLowerCase().replace(/\\s+/g, '-')}.ts`,\n message: `feat: implement ${task.task_name} [AUTO]`,\n content: Buffer.from(implementation).toString('base64'),\n branch: branchName\n });\n\n // Create PR\n const { data: pr } = await octokit.rest.pulls.create({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n title: `feat: ${task.task_name} [AUTO]`,\n body: generatePRBody(task),\n head: branchName,\n base: \"master\"\n });\n\n // Request Claude review\n await octokit.rest.issues.createComment({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n issue_number: pr.number,\n body: `@claude Please review this implementation of **${task.task_name}**. Auto-merge enabled on approval.`\n });\n\n // Update task with PR URL\n await sqlite.execute(\n \"UPDATE task_queue SET github_pr_url = ? WHERE id = ?\",\n [pr.html_url, task.id]\n );\n\n return {\n ...task,\n pr_url: pr.html_url,\n branch: branchName\n };\n}\n\n/**\n * Check if comment is Claude approval\n */\nasync function isClaudeApproval(payload: any): boolean {\n const comment = payload.comment;\n const issue = payload.issue;\n\n if (!issue.pull_request) return false;\n\n const approvalPatterns = [\n /LGTM/i,\n /approved/i,\n /ready to merge/i,\n /looks good/i,\n /ship it/i\n ];\n\n return approvalPatterns.some(pattern => pattern.test(comment.body));\n}\n\n/**\n * Trigger auto-merge IMMEDIATELY\n * PRO: No need to queue, do it now!\n */\nasync function triggerAutoMerge(prNumber: number) {\n const octokit = getOctokit();\n\n try {\n // Check if PR is ready\n const { data: pr } = await octokit.rest.pulls.get({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n pull_number: prNumber\n });\n\n if (pr.mergeable_state === 'clean' || pr.mergeable_state === 'unstable') {\n // Merge it!\n const { data: mergeResult } = await octokit.rest.pulls.merge({\n owner: \"Toowiredd\",\n repo: \"universal-development-platform\",\n pull_number: prNumber,\n merge_method: 'squash',\n commit_title: `${pr.title} (#${prNumber})`,\n commit_message: 'Auto-merged by UDP Pro System'\n });\n\n console.log(`✅ PR #${prNumber} auto-merged!`);\n\n return {\n status: \"merged\",\n pr_number: prNumber,\n merge_sha: mergeResult.sha,\n instant_merge: true\n };\n }\n\n return {\n status: \"not_ready\",\n pr_number: prNumber,\n state: pr.mergeable_state\n };\n\n } catch (error) {\n console.error(`Failed to merge PR #${prNumber}:`, error);\n return {\n status: \"error\",\n pr_number: prNumber,\n error: error.message\n };\n }\n}\n\n/**\n * Handle successful workflow run\n */\nasync function handleWorkflowSuccess(workflow: any) {\n await sqlite.execute(\n \"INSERT INTO system_metrics (metric_type, metric_value, metadata) VALUES (?, ?, ?)\",\n [\"workflow_success\", 1, JSON.stringify({\n name: workflow.name,\n run_id: workflow.id,\n conclusion: workflow.conclusion\n })]\n );\n\n return {\n status: \"workflow_complete\",\n workflow: workflow.name,\n conclusion: workflow.conclusion\n };\n}\n\n/**\n * Trigger deployment on push to main\n */\nasync function triggerDeployment(payload: any) {\n // Could trigger additional deployment steps here\n console.log(`🚀 Deploying commit ${payload.head_commit.id}`);\n\n await sqlite.execute(\n \"INSERT INTO system_metrics (metric_type, metric_value, metadata) VALUES (?, ?, ?)\",\n [\"deployment\", 1, JSON.stringify({\n commit: payload.head_commit.id,\n message: payload.head_commit.message,\n timestamp: new Date().toISOString()\n })]\n );\n\n return {\n status: \"deployment_triggered\",\n commit: payload.head_commit.id\n };\n}\n\n/**\n * Generate quick implementation\n */\nfunction generateQuickImplementation(task: any): string {\n const metadata = JSON.parse(task.metadata || \"{}\");\n\n return `/**\n * ${task.task_name} Implementation\n * Auto-generated by UDP Pro Webhook System\n *\n * Patterns cannibalized from: ${metadata.platforms?.join(\", \") || \"Various platforms\"}\n * Generated at: ${new Date().toISOString()}\n */\n\nimport { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nexport class ${task.task_name.replace(/\\s+/g, '')} {\n async execute(params: any) {\n // Pattern cannibalized from ${metadata.platforms?.[0] || 'platform'}\n console.log(\"Executing ${task.task_name}\");\n\n // Core implementation\n const result = {\n success: true,\n task: \"${task.task_name}\",\n timestamp: new Date().toISOString(),\n pattern_source: \"${metadata.platforms?.[0] || 'UDP'}\"\n };\n\n // Store execution metric\n await sqlite.execute(\n \"INSERT INTO system_metrics (metric_type, metric_value, metadata) VALUES (?, ?, ?)\",\n [\"${task.task_name.toLowerCase()}_execution\", 1, JSON.stringify(result)]\n );\n\n return result;\n }\n}\n\nexport default new ${task.task_name.replace(/\\s+/g, '')}();\n`;\n}\n\n/**\n * Generate PR body\n */\nfunction generatePRBody(task: any): string {\n const metadata = JSON.parse(task.metadata || \"{}\");\n\n return `## 🚀 UDP Pro: Instant Task Implementation\n\n### ${task.task_name}\n\n**Description:** ${metadata.description || 'Automated implementation'}\n\n**Patterns Cannibalized From:**\n${metadata.platforms?.map(p => `- ${p}`).join('\\n') || '- Various platforms'}\n\n### ⚡ Val.town Pro Features Used\n- Instant webhook processing (30-second execution)\n- Continuous task execution\n- Real-time PR creation\n- Immediate auto-merge on approval\n\n### Checklist\n- [x] Implementation generated\n- [x] PR created instantly\n- [ ] @claude review pending\n- [ ] Auto-merge ready\n\n**Priority:** ${task.priority}\n**Estimated Hours:** ${task.estimated_hours}\n\n---\n*Generated instantly by UDP Pro Webhook System*\n`;\n}\n\n/**\n * Verify GitHub signature\n */\nfunction verifyGitHubSignature(payload: string, signature: string): boolean {\n const secret = Deno.env.get(\"GITHUB_WEBHOOK_SECRET\") || \"\";\n if (!secret) return true; // Skip in dev\n\n const hmac = crypto.createHmac(\"sha256\", secret);\n hmac.update(payload);\n const expectedSignature = `sha256=${hmac.digest(\"hex\")}`;\n\n return crypto.timingSafeEqual(\n Buffer.from(signature),\n Buffer.from(expectedSignature)\n );\n}\n\n/**\n * Webhook configuration endpoint\n */\nwebhookApp.get(\"/webhook-config\", (c) => {\n return c.html(`\n \n \n UDP Pro Webhook Configuration\n \n \n \n

🚀 UDP Pro Webhook Setup

\n\n

GitHub Webhook URL

\n \n ${c.req.url.replace('/webhook-config', '/github')}\n \n

\n\n

Events to Enable

Pull requests
Issue comments
Pull request reviews
Pushes
Workflow runs

\n\n

Pro Features Active

✅ 30-second execution time
✅ Instant task chaining
✅ Real-time auto-merge
✅ Continuous execution
✅ Priority processing

\n\n

Val.town Pro Subscription Active!

Your webhooks process instantly with no queuing needed.

\n \n \n `);\n});\n\nexport default webhookApp.fetch;\n\n// Note: Interval monitoring temporarily disabled due to import issues\n// Will be re-enabled once Val.town resolves the module path","deleted","label",[170,153],"api","permalink","https://www.val.town/x/toowired/udpWebhookPro/code/api/webhookPro.tsx","extension","actionData","errors"]