\n \n \n \n",[],[137,216],"e15c9536-0347-11f0-b1af-569c3dd06744","WebhookForm.tsx","5833b63a-00fa-11f0-8cfe-569c3dd06744","26ce3111-6f1a-4d85-af76-d04a6b462ddb",40,["D",1742226770687],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\n\nexport function WebhookForm({ onSubmit }: { onSubmit: () => void }) {\n const [projectId, setProjectId] = React.useState(\"\");\n const [webhookUrl, setWebhookUrl] = React.useState(\"\");\n const [event, setEvent] = React.useState(\"FilesCreated\");\n const [isSubmitting, setIsSubmitting] = React.useState(false);\n const [error, setError] = React.useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n setError(\"\");\n\n // Form validation\n if (!projectId.trim() || !webhookUrl.trim()) {\n setError(\"Please fill in all required fields\");\n return;\n }\n\n // URL validation\n try {\n new URL(webhookUrl);\n } catch {\n setError(\"Please enter a valid URL\");\n return;\n }\n\n setIsSubmitting(true);\n\n try {\n const response = await fetch(\"/submit-webhook\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n projectId,\n webhookUrl,\n event,\n }),\n });\n\n if (response.ok) {\n onSubmit();\n setProjectId(\"\");\n setWebhookUrl(\"\");\n setEvent(\"FilesCreated\");\n } else {\n const data = await response.json();\n setError(data.message || \"Failed to register webhook\");\n }\n } catch (error) {\n console.error(\"Webhook registration failed\", error);\n setError(\"Connection error. Please try again later\");\n } finally {\n setIsSubmitting(false);\n }\n };\n\n const eventOptions = [\n { value: \"FilesCreated\", label: \"Files Created\" },\n { value: \"FilesDeleted\", label: \"Files Deleted\" },\n ];\n\n return (\n

Register New Webhook

\n\n {error && (\n

\n {error}\n

\n )}\n\n

\n \n Project ID *\n \n setProjectId(e.target.value)}\n placeholder=\"Enter your project ID\"\n required\n disabled={isSubmitting}\n />\n

\n\n

\n \n Webhook URL *\n \n setWebhookUrl(e.target.value)}\n placeholder=\"https://example.com/webhook\"\n required\n disabled={isSubmitting}\n />\n

\n\n

\n \n Event Type *\n \n setEvent(e.target.value)}\n disabled={isSubmitting}\n >\n {eventOptions.map(option => (\n \n ))}\n \n

\n\n \n

\n );\n}",[],[137,232,224],"components","0c3a14d6-0348-11f0-83f5-569c3dd06744","App.tsx","415fb276-00e9-11f0-9cf6-569c3dd06744",43,["D",1742226842608],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { WebhookForm } from \"./WebhookForm.tsx\";\n\nexport function App({ thisProjectURL }: { thisProjectURL?: string }) {\n const [webhooks, setWebhooks] = React.useState([]);\n const [loading, setLoading] = React.useState(true);\n const [notification, setNotification] = React.useState({ show: false, message: \"\", type: \"\" });\n\n const fetchWebhooks = async () => {\n setLoading(true);\n // Commented out for now as per original code\n // try {\n // const response = await fetch(\"/getWebhooks\");\n // const data = await response.json();\n // setWebhooks(data);\n // } catch (error) {\n // console.error(\"Failed to fetch webhooks\", error);\n // showNotification(\"Failed to load webhooks\", \"error\");\n // }\n\n // Simulating response for demo purposes\n setTimeout(() => {\n setWebhooks([\n { projectId: \"demo-project-1\", webhookUrl: \"https://example.com/hook1\", event: \"FilesCreated\" },\n { projectId: \"demo-project-2\", webhookUrl: \"https://example.com/hook2\", event: \"FilesDeleted\" },\n ]);\n setLoading(false);\n }, 500);\n };\n\n const showNotification = (message, type = \"success\") => {\n setNotification({ show: true, message, type });\n setTimeout(() => {\n setNotification({ show: false, message: \"\", type: \"\" });\n }, 3000);\n };\n\n const handleWebhookSubmit = () => {\n fetchWebhooks();\n showNotification(\"Webhook registered successfully!\");\n };\n\n React.useEffect(() => {\n fetchWebhooks();\n }, []);\n\n return (\n

\n 🔔 Project Updates Webhook Register\n

\n\n {notification.show && (\n

\n {notification.message}\n

\n )}\n\n \n\n {thisProjectURL && (\n \n )}\n

\n );\n}\n\nfunction WebhookItem({ webhook }) {\n // Create a friendly label for the event type\n const getEventLabel = (eventType) => {\n const labels = {\n \"FilesCreated\": \"Files Created\",\n \"FilesDeleted\": \"Files Deleted\",\n \"UserJoined\": \"User Joined\",\n \"ProjectUpdated\": \"Project Updated\",\n };\n return labels[eventType] || eventType;\n };\n\n return (\n

\n Project ID: {webhook.projectId}\n

\n URL: {webhook.webhookUrl}\n

\n Event: {getEventLabel(webhook.event)}\n {webhook.event}\n

\n );\n}",[],[137,232,234],"4135b480-00e9-11f0-9cf6-569c3dd06744",9,["D",1741966226980],[168,169],[137,232],["D",1741966224992],[167,170,171,172],[137],"23dae0ae-0107-11f0-9910-569c3dd06744","webhookService.ts","23dae11c-0107-11f0-9910-569c3dd06744",["D",1741979062632],"export async function sendWebhookNotification(url: string, data: any) {\n try {\n const response = await fetch(url, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(data),\n });\n \n if (!response.ok) {\n throw new Error(`Webhook notification failed: ${response.status} ${response.statusText}`);\n }\n \n return true;\n } catch (error) {\n console.error(`Failed to send webhook notification to ${url}:`, error);\n return false;\n }\n }",[],[143,250],"5833c242-00fa-11f0-8cfe-569c3dd06744","index.ts",15,["D",1741973566997],"http","import { parseProject } from \"https://esm.town/v/std/parseImportMeta@149-main/project\";\nimport { readFile, servePublicFile } from \"https://esm.town/v/stevekrouse/utils@187-main/serve-public/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport { insertWebhook } from \"./database/queries.ts\";\n\nconst app = new Hono();\n\n// Serve index.html at the root /\napp.get(\"/\", async c => {\n return servePublicFile(\"/frontend/index.html\", import.meta.url);\n});\n\n// Serve all /frontend files under /public\napp.get(\"/public/**/*\", c => servePublicFile(c.req.path.replace(\"/public\", \"/frontend\"), import.meta.url));\n\n// Serve all /shared files under /shared\napp.get(\"/shared/**/*\", c => servePublicFile(c.req.path, import.meta.url));\n\n// Provide an endpoint for the frontend to insert a new message\napp.post(\"/submit-webhook\", async (c) => {\n const { projectId, webhookUrl, event } = await c.req.json();\n\n if (!projectId || projectId.trim() === \"\") {\n return c.json({ error: \"Project ID cannot be empty\" }, 400);\n }\n\n if (!webhookUrl || webhookUrl.trim() === \"\") {\n return c.json({ error: \"Webhook URL cannot be empty\" }, 400);\n }\n\n if (!event) {\n return c.json({ error: \"Event type is required\" }, 400);\n }\n\n await insertWebhook(projectId, webhookUrl, event);\n\n return c.json({ success: true }, 201);\n});\n\n// Unwrap and rethrow Hono errors as the original error\n// If you delete this, all errors will be \"Internal Server Error\"\napp.onError((err, c) => {\n throw err;\n});\n\n// HTTP vals expect an exported \"fetch handler\"\n// This is how you \"run the server\" in Val Town with Hono\nexport default app.fetch;",[],[143,257],"ef7412e0-0110-11f0-9f26-569c3dd06744","eventsManager.ts","5833afe6-00fa-11f0-8cfe-569c3dd06744",29,["D",1741983269686],6,"interval","import ValTown from \"npm:@valtown/sdk\";\nimport { getProjectState, getWebhooks, updateProjectState } from \"./database/queries.ts\";\nimport { sendWebhookNotification } from \"./webhookService.ts\";\nconst vt = new ValTown();\n\nexport default async function(interval: Interval) {\n try {\n // Get all webhook subscriptions\n const webhooks = await getWebhooks();\n\n // Group webhooks by projectId\n const projectWebhooks = new Map();\n\n for (const webhook of webhooks) {\n if (!projectWebhooks.has(webhook.projectId)) {\n projectWebhooks.set(webhook.projectId, {\n projectId: webhook.projectId,\n subscriptions: [],\n });\n }\n\n projectWebhooks.get(webhook.projectId)?.subscriptions.push({\n event: webhook.event,\n webhookUrl: webhook.webhookUrl,\n });\n }\n\n // Process each project once\n for (const [projectId, project] of projectWebhooks) {\n try {\n // Get current project state from ValTown API\n const currentFiles = await getProjectFiles(projectId);\n\n // Get previous project state from our database\n const previousState = await getProjectState(projectId);\n\n if (!previousState) {\n // First time tracking this project, store initial state\n await updateProjectState(projectId, currentFiles);\n continue;\n }\n\n // Compare current files with previous state to detect changes\n const { createdFiles, deletedFiles } = compareProjectFiles(\n previousState.files,\n currentFiles,\n );\n\n console.log(`Project ${projectId} - createdFiles:`, createdFiles);\n console.log(`Project ${projectId} - deletedFiles:`, deletedFiles);\n\n // Get subscriptions by event type\n const createdSubscriptions = project.subscriptions.filter(sub => sub.event === \"FilesCreated\");\n const deletedSubscriptions = project.subscriptions.filter(sub => sub.event === \"FilesDeleted\");\n\n // Send notifications for FilesCreated event\n if (createdFiles.length > 0 && createdSubscriptions.length > 0) {\n const payload = {\n event: \"FilesCreated\",\n projectId,\n files: createdFiles,\n };\n\n // Send to all subscribed webhooks for this event\n for (const subscription of createdSubscriptions) {\n await sendWebhookNotification(subscription.webhookUrl, payload);\n }\n }\n\n // Send notifications for FilesDeleted event\n if (deletedFiles.length > 0 && deletedSubscriptions.length > 0) {\n const payload = {\n event: \"FilesDeleted\",\n projectId,\n files: deletedFiles,\n };\n\n // Send to all subscribed webhooks for this event\n for (const subscription of deletedSubscriptions) {\n await sendWebhookNotification(subscription.webhookUrl, payload);\n }\n }\n\n // Update project state in database\n await updateProjectState(projectId, currentFiles);\n } catch (error) {\n console.error(`Error processing project ${projectId}:`, error);\n }\n }\n } catch (error) {\n console.error(\"Error in eventsManager:\", error);\n }\n}\n\n// Helper function to get all files in a project using ValTown SDK\nasync function getProjectFiles(projectId: string) {\n try {\n const response = await vt.projects.files.list(projectId, { recursive: true });\n return response.data.map(file => ({\n id: file.id,\n name: file.name,\n path: file.path,\n type: file.type,\n updatedAt: file.updatedAt,\n }));\n } catch (error) {\n console.error(`Failed to fetch files for project ${projectId}:`, error);\n return [];\n }\n}\n\n// Helper function to compare previous and current project files\nfunction compareProjectFiles(previousFiles: any[], currentFiles: any[]) {\n const previousFileIds = new Set(previousFiles.map(file => file.id));\n const currentFileIds = new Set(currentFiles.map(file => file.id));\n\n const createdFiles = currentFiles.filter(file => !previousFileIds.has(file.id));\n const deletedFiles = previousFiles.filter(file => !currentFileIds.has(file.id));\n\n return { createdFiles, deletedFiles };\n}",[],[143,265],"23dae658-0107-11f0-9910-569c3dd06744","queries.ts","41205748-00e9-11f0-9cf6-569c3dd06744","ba51ef61-14d6-4805-b94b-9d6c8b42e4e9",["D",1741979062632],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { type Webhook, WEBHOOK_LIMIT } from \"../../shared/utils.ts\";\nimport { createTables, projectStatesTableName, subscriptionsTableName } from \"./migrations.ts\";\n\n// This will create the database table if it doesn't exist.\n// This will run every time the app starts up. You can\n// comment out this line for a modest (30ms) perforamnce improvement\n// on cold starts. It's left in to ensure the database tables are\n// automatically set up correctly for users who fork this app.\nawait createTables();\n\nexport async function getWebhooks(limit = WEBHOOK_LIMIT): Promise {\n const webhooks = await sqlite.execute(\n `SELECT * FROM ${subscriptionsTableName} \n ORDER BY createdAt DESC \n LIMIT ?`,\n [limit],\n );\n return webhooks.rows as unknown as Webhook[];\n}\n\nexport async function insertWebhook(projectId: string, webhookUrl: string, event: string) {\n await sqlite.execute(\n `INSERT INTO ${subscriptionsTableName} (projectId, webhookUrl, event) \n VALUES (?, ?, ?)`,\n [projectId, webhookUrl, event],\n );\n}\n\nexport async function getProjectState(projectId: string) {\n const result = await sqlite.execute(\n `SELECT * FROM ${projectStatesTableName} \n WHERE projectId = ?`,\n [projectId],\n );\n\n if (result.rows.length === 0) {\n return null;\n }\n\n const state = result.rows[0] as any;\n return {\n projectId: state.projectId,\n files: JSON.parse(state.files),\n lastUpdated: state.lastUpdated,\n };\n}\n\nexport async function updateProjectState(projectId: string, files: any[]) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${projectStatesTableName} (projectId, files, lastUpdated) \n VALUES (?, ?, CURRENT_TIMESTAMP)`,\n [projectId, JSON.stringify(files)],\n );\n}",[],[143,282,275],"database","3e55d8aa-010a-11f0-b0a3-569c3dd06744","migrations.ts","412a62a6-00e9-11f0-bbde-569c3dd06744",27,["D",1741980395553],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport const subscriptionsTableName = \"project_creation_subscriptions\";\nexport const projectStatesTableName = \"project_creation_project_states\";\n\nexport async function createTables() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS ${subscriptionsTableName} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n projectId TEXT NOT NULL,\n webhookUrl TEXT NOT NULL,\n event TEXT NOT NULL,\n createdAt DATETIME DEFAULT CURRENT_TIMESTAMP\n )`,\n\n `CREATE TABLE IF NOT EXISTS ${projectStatesTableName} (\n projectId TEXT PRIMARY KEY,\n files TEXT NOT NULL,\n lastUpdated DATETIME DEFAULT CURRENT_TIMESTAMP\n )`,\n ]);\n}",[],[143,282,284],"41205c7a-00e9-11f0-9cf6-569c3dd06744",["D",1741966226843],[161,162],[143,282],["D",1741966225241],[160,163,164,165],[143],["D",1741966224804],{"_11":12,"_85":81},{"_11":12,"_79":-5,"_80":81,"_25":38,"_82":83,"_84":24},{"_68":69,"_13":16,"_26":70,"_71":27,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"ctx",{"_61":-5,"_106":335,"_336":337,"_338":339,"_340":24,"_341":24,"_342":24,"_343":42,"_344":-5,"_345":-7,"_346":-7,"_347":20,"_348":24,"_349":24,"_350":-5,"_351":24,"_352":24,"_353":24,"_354":-5},"ENV",{"_306":307,"_308":309,"_310":16,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

History