Your Triggers

\n \n New trigger\n \n

\n\n {!Array.isArray(triggers) || triggers.length === 0\n ? (\n

\n No triggers yet.\n

\n )\n : (\n

\n {triggers.map((trigger) => (\n \n

\n {trigger.configurable_props.find(x => x.type === \"app\")?.name || \"Unknown App\"}\n

\n \n View events\n \n

\n Created at: {trigger.created_at\n ? new Date(trigger.created_at * 1000).toLocaleDateString()\n : \"Unknown\"}\n

\n {\n if (\n !confirm(\n `Are you sure you want to delete the triggers ${trigger.app?.name || \"this app\"}?`,\n )\n ) {\n e.preventDefault();\n }\n }}\n >\n \n Delete\n \n \n

\n ))}\n \n )}\n \n );\n}",[],[19,37,126],"352f50d8-4b85-11f0-8357-76b3cceeab13","TriggerEventsPage.tsx","01cd0916-4ac1-11f0-8f0d-76b3cceeab13",669,["D",1750169594342],36,"/** @jsxImportSource https://esm.sh/react@18.2.0? */\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function({ trigger, events, user }) {\n return (\n \n

Trigger

\n {trigger.configurable_props.find(x => x.type === \"app\")?.name || \"Unknown App\"}\n

\n Created at: {trigger.created_at\n ? new Date(trigger.created_at * 1000).toLocaleString(\"en-US\", {\n timeZoneName: \"short\",\n })\n : \"Unknown\"}\n

\n Trigger JSON\n

\n          {JSON.stringify(trigger, null, 2)}\n

Events

\n {!Array.isArray(events) || events.length === 0\n ? (\n

\n No events yet.\n

\n )\n : (\n

\n {events.map((event) => (\n

\n Event at {new Date(event.ts).toLocaleString(\"en-US\", {\n timeZoneName: \"short\",\n })}\n

\n                    {JSON.stringify(event, null, 2)}\n

\n ))}\n

\n )}\n \n );\n}",[],[19,37,135],"062559ac-8cf5-11f0-8bc4-0224a6c84d84","NewTriggerPage.tsx","d5b87a66-4abd-11f0-ab2f-76b3cceeab13",802,["D",1757364444632],56,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport {\n ComponentForm,\n FrontendClientProvider,\n SelectApp,\n SelectComponent,\n} from \"https://esm.sh/@pipedream/connect-react?deps=react@18.2.0,react-dom@18.2.0\";\nimport { createFrontendClient } from \"https://esm.sh/@pipedream/sdk@1.6.8/browser?deps=react@18.2.0,react-dom@18.2.0\";\nimport { toast } from \"https://esm.sh/react-toastify?deps=react@18.2.0,react-dom@18.2.0\";\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { AccountsList } from \"../components/AccountsList.tsx\";\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function (\n { user, effectiveUserId }: { user: any; effectiveUserId: string },\n) {\n const [selectedApp, setSelectedApp] = useState();\n const [selectedComponent, setSelectedComponent] = useState();\n const [configuredProps, setConfiguredProps] = useState({});\n const [sdkErrors, setSdkErrors] = useState();\n const [dynamicProps, setDynamicProps] = useState();\n const [webhookUrl, setWebhookUrl] = useState(\"\");\n\n const frontendClient = createFrontendClient({\n environment: \"production\",\n externalUserId: effectiveUserId,\n tokenCallback: async () => {\n const resp = await fetch(\"/api/pipedream/token\", {\n method: \"POST\",\n });\n const data = await resp.json();\n return data;\n },\n });\n\n const handleComponentSubmit = async (ctx) => {\n try {\n const result = await frontendClient.deployTrigger({\n externalUserId: effectiveUserId,\n triggerId: selectedComponent!.key,\n configuredProps: ctx.configuredProps,\n webhookUrl,\n dynamicPropsId: dynamicProps?.id,\n });\n toast(\"Trigger created! Redirecting to the list of triggers...\");\n window.location.href = \"/triggers\";\n } catch (error) {\n setSdkErrors(error);\n }\n };\n\n return (\n \n \n

\n New Trigger\n

\n\n

\n \n 1. Select an App:\n \n {\n setSelectedApp(app);\n setSelectedComponent(null); // Reset component when app changes\n }}\n />\n

\n\n {selectedApp && (\n

\n \n 2. Select an Trigger\n \n {\n setSelectedComponent(comp);\n }}\n />\n

\n )}\n\n {selectedComponent && (\n

\n \n 3. Webhook URL to trigger:\n \n setWebhookUrl(e.target.value)}\n autoFocus\n />\n

\n )}\n\n {webhookUrl && selectedComponent && (\n

\n \n 4. Configure Trigger:\n \n

\n \n

\n )}\n

\n \n \n );\n}",[],[19,37,144],"0a14f0c2-8cf5-11f0-b864-0224a6c84d84","NewConnectionPage.tsx","3d7365ec-5295-11f0-8782-f69ea79377d9",803,["D",1757364451236],28,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport {\n FrontendClientProvider,\n SelectApp,\n} from \"https://esm.sh/@pipedream/connect-react?deps=react@18.2.0,react-dom@18.2.0\";\nimport { createFrontendClient } from \"https://esm.sh/@pipedream/sdk@1.6.8/browser\";\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { AccountsList } from \"../components/AccountsList.tsx\";\nimport { CodeSnippet } from \"../components/CodeSnippet.tsx\";\nimport { Layout } from \"../components/Layout.tsx\";\n\nasync function tokenCallback() {\n const resp = await fetch(\"/api/pipedream/token\", {\n method: \"POST\",\n });\n const data = await resp.json();\n return data;\n}\n\nexport default function (\n { user, effectiveUserId }: { user: any; effectiveUserId: string },\n) {\n const [selectedApp, setSelectedApp] = useState();\n const [sdkErrors, setSdkErrors] = useState();\n const [success, setSuccess] = useState(false);\n\n const frontendClient = createFrontendClient({\n environment: \"production\",\n externalUserId: effectiveUserId,\n tokenCallback,\n });\n\n async function connectAccount() {\n const pd = createFrontendClient();\n await pd.connectAccount({\n app: selectedApp.name_slug,\n token: (await tokenCallback()).token,\n onSuccess: (account) => {\n console.log(\"Connection successful:\", account);\n setSuccess(true);\n },\n onError: (err) => {\n console.error(\"Connection error:\", err);\n setSdkErrors(err);\n },\n });\n }\n\n return (\n \n \n

\n New Connection\n

\n\n

\n \n 1. Select an App:\n \n {\n setSelectedApp(app);\n }}\n />\n

\n\n {selectedApp && (\n

\n \n Connect to {selectedApp.name}\n \n

\n )}\n\n {sdkErrors && (\n

\n {sdkErrors.message}\n

\n )}\n\n {success && (\n

\n Connection successful!\n

\n\n

\n You can now create actions and triggers using this connection:\n

\n\n

\n \n Create Action\n \n\n \n Create Trigger\n \n

\n )}\n

\n \n \n );\n}",[],[19,37,153],"ff64c864-8cf4-11f0-a6bc-0224a6c84d84","NewActionPage.tsx","3651b41a-4969-11f0-9fbb-76b3cceeab13",800,["D",1757364433304],43,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport {\n ComponentForm,\n FrontendClientProvider,\n SelectApp,\n SelectComponent,\n} from \"https://esm.sh/@pipedream/connect-react?deps=react@18.2.0,react-dom@18.2.0\";\nimport { createFrontendClient } from \"https://esm.sh/@pipedream/sdk@1.6.8/browser\";\nimport ReactJson from \"https://esm.sh/react-json-view?deps=react@18.2.0,react-dom@18.2.0\";\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { AccountsList } from \"../components/AccountsList.tsx\";\nimport { CodeSnippet } from \"../components/CodeSnippet.tsx\";\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function (\n { user, effectiveUserId }: { user: any; effectiveUserId: string },\n) {\n const [selectedApp, setSelectedApp] = useState();\n const [selectedComponent, setSelectedComponent] = useState();\n const [configuredProps, setConfiguredProps] = useState({});\n const [dynamicProps, setDynamicProps] = useState();\n const [sdkErrors, setSdkErrors] = useState();\n const [result, setResult] = useState();\n\n const frontendClient = createFrontendClient({\n environment: \"production\",\n externalUserId: effectiveUserId,\n tokenCallback: async () => {\n const resp = await fetch(\"/api/pipedream/token\", {\n method: \"POST\",\n });\n const data = await resp.json();\n return data;\n },\n });\n const handleComponentSubmit = async (ctx) => {\n try {\n const result = await frontendClient.actionRun({\n externalUserId: effectiveUserId,\n actionId: selectedComponent!.key,\n configuredProps: ctx.configuredProps,\n dynamicPropsId: dynamicProps?.id,\n });\n setResult(result);\n } catch (error) {\n setSdkErrors(error);\n }\n };\n\n const code =\n `import { actionRun } from \"https://esm.town/v/valdottown/pipedream-connect/sdk/sdk.ts\";\n\n// Configured at https://pipedream.val.run\nconst result = await actionRun(${\n JSON.stringify(\n {\n actionId: selectedComponent?.key,\n configuredProps,\n dynamicPropsId: dynamicProps?.id,\n },\n null,\n 2,\n )\n });\n\nconsole.log(result);`;\n\n return (\n \n \n

\n New Action\n

\n\n

\n \n 1. Select an App:\n \n {\n setSelectedApp(app);\n setSelectedComponent(null); // Reset component when app changes\n }}\n />\n

\n\n {selectedApp && (\n

\n \n 2. Select an Action\n \n {\n setSelectedComponent(comp);\n }}\n />\n

\n )}\n\n {selectedComponent && (\n

\n \n 3. Configure Action:\n \n

\n \n

\n )}\n\n {result && (\n

\n \n Action Result:\n \n

\n \n

\n )}\n\n {selectedComponent && (\n

\n \n 4. Copy code to use in Val Town:\n \n

\n \n

\n )}\n

\n \n \n );\n}",[],[19,37,162],"ddbb1c4a-5293-11f0-bee2-f69ea79377d9","LoginPage.tsx","fa619216-3817-11f0-972c-9e149126039e",733,["D",1750945548209],45,"/** @jsxImportSource https://esm.sh/react@18.2.0? */\nimport { useState } from \"https://esm.sh/react@18.2.0?\";\nimport { ExperimentalWarning } from \"../components/ExperimentalWarning.tsx\";\n\nexport default function({ onLogin }) {\n const [apiKey, setApiKey] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, onError] = useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n setIsLoading(true);\n onError(\"\");\n try {\n const response = await fetch(\"/auth/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ apiKey }),\n });\n if (response.ok) window.location.href = \"/\";\n } catch (err) {\n console.error(err);\n onError(err.message);\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Val Town + Pipedream Connect

\n \n View source\n \n

\n Pipedream Connect{\" \"}\n provides managed authentication for thousands of services, such as Slack, Discord, Google, etc. This app gives\n Val Town users access to Pipedream's OAuth library.\n

\n\n {error && (\n

\n {error}\n

\n )}\n\n

To login:

\n 1. Create an API key:{\" \"}\n \n https://www.val.town/settings/api\n \n

2. Give it the \"Users: read-only\" scope.

\n\n

\n );\n}",[],[19,37,171],"5c1d0e56-5210-11f0-bff3-f69ea79377d9","HomePage.tsx","fa617f4c-3817-11f0-972c-9e149126039e",["D",1750889066669],114,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { ExperimentalWarning } from \"../components/ExperimentalWarning.tsx\";\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function({ user }) {\n return (\n \n

\n \n\n {/* Introduction */}\n

\n Connect Val Town to Thousands of Services\n

\n \n Pipedream Connect\n {\" \"}\n provides managed authentication for thousands of services. This application gives Val Town users secure\n access to APIs without managing OAuth flows or API keys yourself.\n

\n\n {/* Actions vs Triggers */}\n

\n {/* Actions */}\n

\n \n

Actions

\n\n

\n Actions let you send data to{\" \"}\n external services from your Val Town code. Perfect for posting to social media, sending emails, creating\n records, or triggering workflows.\n

\n\n

\n Secure by default: Authentication is handled automatically - no API keys to manage\n

\n Copy & paste: Get ready-to-use code snippets for your vals\n

\n Thousands of services: Gmail, Slack, Twitter, Notion, Airtable, and more\n

\n\n

\n \n Create Action\n \n \n

\n\n {/* Triggers */}\n

\n \n

Triggers

\n\n

\n Triggers send data to your vals{\" \"}\n when events happen in external services. Get notified of new emails, form submissions, file uploads, or\n any other event.\n

\n\n

\n Real-time webhooks: Data is sent to your val instantly when events occur\n

\n Any HTTP val: Send data to any Val Town HTTP endpoint you specify\n

\n Event debugging: View all events sent to your triggers for easy debugging\n

\n\n

\n \n Create Trigger\n \n \n

\n\n {/* How it Works */}\n

How It Works

\n\n

\n \n 1\n \n Using Actions\n

• Connect to a service (Gmail, Slack, etc.)
• Configure the action (what data to send)
• Copy the generated code into your val
• Call the action from your val - authentication handled automatically!

\n\n

\n \n 2\n \n Using Triggers\n

• Connect to a service that sends events
• Configure what events to listen for
• Provide your val's HTTP endpoint URL
• Your val receives data automatically when events happen!

\n\n {/* Management */}\n

Manage Your Integrations

\n\n

\n \n

My Connections

Manage connected accounts

\n \n\n \n

\n \n

My Triggers

View & debug your triggers, and the events they've sent

\n \n

\n \n );\n}",[],[19,37,180],"0c3c12e4-5295-11f0-9fa6-f69ea79377d9","ConnectionsPage.tsx","fa61761e-3817-11f0-972c-9e149126039e",751,["D",1750946055720],16,"/** @jsxImportSource https://esm.sh/react@18.2.0? */\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function({ accounts, user }) {\n console.log(accounts);\n return (\n \n

Your Connections

\n \n New connection\n \n

\n {!Array.isArray(accounts) || accounts.length === 0\n ? (\n

\n No connected accounts yet.\n

\n )\n : (\n

\n {accounts.map((account) => (\n \n

\n {account.app?.name || \"Unknown App\"}\n

\n {account.name || \"Connected Account\"}\n

\n Connected: {account.created_at\n ? new Date(account.created_at).toLocaleDateString()\n : \"Unknown\"}\n

\n \n {account.app?.auth_type || \"Unknown\"}\n \n {\n if (\n !confirm(\n `Are you sure you want to delete the connection to ${account.app?.name || \"this app\"}?`,\n )\n ) {\n e.preventDefault();\n }\n }}\n >\n \n Delete\n \n \n

\n ))}\n \n )}\n \n );\n}",[],[19,37,188],["D",1747682411203],[199,200,201,202],[19,59],{"_35":229,"_13":230,"_38":231,"_40":60,"_42":43,"_44":232,"_46":47,"_48":233,"_17":234,"_51":105,"_53":235,"_54":55,"_56":-5,"_80":236,"_18":237},{"_35":220,"_13":221,"_38":222,"_40":60,"_42":43,"_44":223,"_46":47,"_48":224,"_17":225,"_51":105,"_53":226,"_54":55,"_56":-5,"_80":227,"_18":228},{"_35":212,"_13":213,"_38":214,"_40":60,"_42":43,"_44":86,"_46":47,"_48":215,"_17":216,"_51":105,"_53":217,"_54":55,"_56":-5,"_80":218,"_18":219},{"_35":203,"_13":204,"_38":205,"_40":60,"_42":43,"_44":206,"_46":47,"_48":207,"_17":208,"_51":105,"_53":209,"_54":55,"_56":-5,"_80":210,"_18":211},"8fcbbe5c-5295-11f0-bee2-f69ea79377d9","Layout.tsx","52fcadde-496b-11f0-b5e0-76b3cceeab13",756,["D",1750946276439],32,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { ToastContainer } from \"https://esm.sh/react-toastify?deps=react@18.2.0,react-dom@18.2.0\";\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nexport function Layout(\n { user, children }: { user: { username: string }; children: React.ReactNode },\n) {\n const [isMenuOpen, setIsMenuOpen] = useState(false);\n const [isCreateMenuOpen, setIsCreateMenuOpen] = useState(false);\n const handleLogout = async () => {\n await fetch(\"/auth/logout\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n window.location.href = \"/\";\n };\n\n const toggleMenu = () => {\n setIsMenuOpen(!isMenuOpen);\n };\n\n const toggleCreateMenu = () => {\n setIsCreateMenuOpen(!isCreateMenuOpen);\n };\n\n // Close menu when clicking outside\n useEffect(() => {\n const handleClickOutside = (event: MouseEvent) => {\n if (isMenuOpen && !(event.target as Element).closest(\".profile-menu\")) {\n setIsMenuOpen(false);\n }\n if (isCreateMenuOpen && !(event.target as Element).closest(\".create-menu\")) {\n setIsCreateMenuOpen(false);\n }\n };\n\n const handleEscKey = (event: KeyboardEvent) => {\n if (event.key === \"Escape\") {\n setIsMenuOpen(false);\n setIsCreateMenuOpen(false);\n }\n };\n\n document.addEventListener(\"mousedown\", handleClickOutside);\n document.addEventListener(\"keydown\", handleEscKey);\n\n return () => {\n document.removeEventListener(\"mousedown\", handleClickOutside);\n document.removeEventListener(\"keydown\", handleEscKey);\n };\n }, [isMenuOpen, isCreateMenuOpen]);\n\n return (\n

\n \n

\n \n Val Town x Pipedream Connect\n \n

\n \n View source\n \n

\n\n

\n \n \n \n \n \n\n {isCreateMenuOpen && (\n

\n \n New Action\n \n \n New Trigger\n \n \n New Connection\n \n

\n )}\n

\n\n

\n \n {user?.username}\n \n \n \n \n\n {isMenuOpen && (\n

\n \n My Triggers\n \n \n My Connections\n \n \n Logout\n \n

\n )}\n

\n\n {children}\n

\n );\n}",[],[19,59,204],"5c1d0ce4-5210-11f0-bff3-f69ea79377d9","ExperimentalWarning.tsx","3604c37e-4dda-11f0-8f96-76b3cceeab13",["D",1750889066669],31,"/** @jsxImportSource https://esm.sh/react@18.2.0? */\n\nexport function ExperimentalWarning({ user }: { user: { email: string } }) {\n return (\n

\n ⚠️ Experimental Integration – We'll email you at {user.email} about breaking changes.\n

\n );\n}",[],[19,59,213],"5994f14c-49de-11f0-9032-76b3cceeab13","ErrorMessage.tsx","fa618f50-3817-11f0-972c-9e149126039e",421,["D",1749987978287],5,"/** @jsxImportSource https://esm.sh/react@18.2.0? */\n\nexport function ErrorMessage({ error, onDismiss }) {\n if (!error) return null;\n\n return (\n

\n {error}\n {onDismiss && (\n \n ×\n \n )}\n

\n );\n}",[],[19,59,221],"f61b2c84-4b82-11f0-af65-76b3cceeab13","CodeSnippet.tsx","8144a792-4889-11f0-bd53-76b3cceeab13",635,["D",1750168629517],21,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { toast } from \"https://esm.sh/react-toastify?deps=react@18.2.0,react-dom@18.2.0\";\n\nexport function CodeSnippet({ code }: { code: string }) {\n return (\n

\n {\n navigator.clipboard.writeText(code);\n toast(\"Copied!\");\n }}\n className=\"absolute right-3 top-3 px-3 py-1 text-xs font-medium text-gray-600 bg-gray-100 hover:bg-gray-200 border border-gray-300 rounded transition-colors z-10\"\n >\n Copy\n \n

\n        \n          {code}\n        \n

\n );\n}",[],[19,59,230],"4181f08a-34e6-11f0-b465-9e149126039e","backend","3bc97898-34e6-11f0-9e62-9e149126039e",6,["D",1747682399458],[245,246,247,248],[239],{"_35":276,"_13":277,"_38":278,"_40":240,"_42":43,"_44":279,"_46":47,"_48":280,"_17":281,"_51":105,"_53":282,"_54":55,"_56":-5,"_80":283,"_18":284},{"_35":265,"_13":266,"_38":267,"_40":240,"_42":43,"_44":268,"_46":47,"_48":269,"_17":270,"_51":271,"_53":272,"_54":55,"_56":273,"_80":274,"_18":275},{"_35":257,"_13":258,"_38":259,"_40":240,"_42":43,"_44":260,"_46":47,"_48":261,"_17":166,"_51":105,"_53":262,"_54":55,"_56":-5,"_80":263,"_18":264},{"_35":249,"_13":250,"_38":251,"_40":240,"_42":43,"_44":223,"_46":47,"_48":252,"_17":253,"_51":105,"_53":254,"_54":55,"_56":-5,"_80":255,"_18":256},"5994c8c0-49de-11f0-9032-76b3cceeab13","render-react-page.tsx","226b0b94-4965-11f0-825a-76b3cceeab13",["D",1749987978287],35,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { renderToReadableStream } from \"npm:react-dom@18.2.0/server\";\nimport serialize from \"npm:serialize-javascript\";\n\nexport async function renderPage({\n pageModuleURL,\n props = {},\n status = 200,\n title = \"\",\n extraHeaders = {},\n}: {\n pageModuleURL: string;\n props?: Record;\n status?: number;\n title?: string;\n extraHeaders?: HeadersInit;\n}): Promise {\n const safeJson = serialize(props, { isJSON: true });\n const renderScript = `import React from 'https://esm.sh/react@18.2.0';\nimport { createRoot } from 'https://esm.sh/react-dom@18.2.0/client';\nimport Page from '${pageModuleURL}';\nconst data = JSON.parse(document.getElementById('__DATA__').textContent);\ncreateRoot(document.getElementById('root')).render(\n React.createElement(Page, data)\n);`;\n const stream = await renderToReadableStream(\n \n \n \n \n {title}\n \n \n \n

\n \n \n \n \n ,\n );\n\n return new Response(stream, {\n status,\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n ...extraHeaders,\n },\n });\n}",[],[239,250],"a4ac428c-7f8c-11f0-9e7a-0224a6c84d84","pipedream.tsx","fc0842e2-487d-11f0-abe5-76b3cceeab13",798,["D",1755890248319],"import { createBackendClient } from \"npm:@pipedream/sdk@1.6.8/server\"; \nimport { Hono } from \"npm:hono\";\nimport { getCurrentUser, getLatestUserID } from \"./auth.tsx\";\n\nconst app = new Hono();\nexport { app as pipedream };\n\nexport const pd = createBackendClient({\n environment: Deno.env.get(\"PIPEDREAM_PROJECT_ENVIRONMENT\"),\n credentials: {\n clientId: Deno.env.get(\"PIPEDREAM_CLIENT_ID\"),\n clientSecret: Deno.env.get(\"PIPEDREAM_CLIENT_SECRET\"),\n },\n projectId: Deno.env.get(\"PIPEDREAM_PROJECT_ID\"),\n});\n\napp.post(\"/token\", async (c) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const data = await pd\n .createConnectToken({\n external_user_id: getLatestUserID(user),\n allowed_origins: [new URL(c.req.url).origin],\n });\n console.log(data);\n return c.json(data);\n});\n\n// Pipedream Action Proxy\n// Authenicate with Val Town Bearer Token\n// Actually runs the pipedream action\napp.post(\"/action\", async (c) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n console.log(\"Running action for:\", user);\n\n try {\n const args = await c.req.json();\n if (args.externalUserId) {\n // To be doubly sure of authentication\n return c.json({ error: \"Do not include externalUserId\" }, 400);\n }\n\n const result = await pd.actionRun({\n ...args,\n externalUserId: getLatestUserID(user),\n });\n\n return c.json(result);\n } catch (error) {\n console.error(\"Failed to execute action:\", error);\n return c.json({ error: \"Failed to execute action\" }, 500);\n }\n});\n\n// Pipedream Proxy Proxy\n// https://pipedream.com/docs/connect/api-proxy/\napp.post(\"/proxy\", async (c) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n console.log(\"Running proxy for:\", user);\n\n try {\n const args = await c.req.json();\n const result = await pd.makeProxyRequest({\n searchParams: {\n account_id: args.account_id,\n external_user_id: getLatestUserID(user),\n },\n }, args.fetch);\n\n return c.json(result);\n } catch (error) {\n console.error(\"Failed to execute action:\", error);\n return c.json({ error: \"Failed to execute action\" }, 500);\n }\n});\n\napp.post(\"/connections/:id/delete\", async (c) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const id = c.req.param(\"id\");\n const account = await pd.getAccountById(id);\n if (account.external_id !== getLatestUserID(user)) {\n return c.json({ error: \"Not authorized\" }, 401);\n }\n await pd.deleteAccount(id);\n return c.redirect(\"/connections\");\n});\n\napp.post(\"/triggers/:id/delete\", async (c) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const id = c.req.param(\"id\");\n // TODO: confirm with Pipedream that this enforces the correct externalUserId\n await pd.deleteTrigger({\n externalUserId: getLatestUserID(user),\n id,\n });\n return c.redirect(\"/triggers\");\n});",[],[239,258],"af5ce9bc-7f8b-11f0-b9e9-0224a6c84d84","main.tsx","6d6d5536-34e6-11f0-a1d9-9e149126039e",797,["D",1755889836442],115,"http","import { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport { auth, getCurrentUser, getLatestUserID } from \"./auth.tsx\";\nimport { pd, pipedream } from \"./pipedream.tsx\";\nimport { renderPage } from \"./render-react-page.tsx\";\n\nconst app = new Hono();\n\n// Serve all /frontend files\napp.get(\"/frontend/**/*\", (c) => serveFile(c.req.path, import.meta.url));\n\napp.get(\"/speed-test\", c => c.text(\"OK\"))\n\napp.route(\"/auth\", auth);\napp.route(\"/api/pipedream\", pipedream);\n\nconst title = \"Pipedream x Val Town Connect\";\n\napp.use(\"*\", async (c, next) => {\n const user = await getCurrentUser(c);\n if (!user) {\n return renderPage({\n pageModuleURL: \"/frontend/pages/LoginPage.tsx\",\n title,\n });\n } else {\n c.set(\"user\", user);\n await next();\n }\n});\n\napp.get(\"/\", async (c) => {\n const user = c.get(\"user\");\n return renderPage({\n pageModuleURL: \"/frontend/pages/HomePage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n },\n });\n});\n\napp.get(\"/actions/new\", async (c) => {\n const user = c.get(\"user\");\n return renderPage({\n pageModuleURL: \"/frontend/pages/NewActionPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n },\n });\n});\n\napp.get(\"/triggers-new\", async (c) => {\n const user = c.get(\"user\");\n return renderPage({\n pageModuleURL: \"/frontend/pages/NewTriggerPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n },\n });\n});\n\napp.get(\"/connections-new\", async (c) => {\n const user = c.get(\"user\");\n return renderPage({\n pageModuleURL: \"/frontend/pages/NewConnectionPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n },\n });\n});\n\napp.get(\"/triggers\", async (c) => {\n const user = c.get(\"user\");\n const triggers = await pd.getTriggers({\n externalUserId: getLatestUserID(user),\n });\n return renderPage({\n pageModuleURL: \"/frontend/pages/TriggersPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n triggers: triggers.data,\n },\n });\n});\n\napp.get(\"/triggers/:id/events\", async (c) => {\n const user = c.get(\"user\");\n const [trigger, events] = await Promise.all([\n pd.getTrigger({\n externalUserId: getLatestUserID(user),\n id: c.req.param(\"id\"),\n }),\n pd.getTriggerEvents({\n externalUserId: getLatestUserID(user),\n id: c.req.param(\"id\"),\n }),\n ]);\n return renderPage({\n pageModuleURL: \"/frontend/pages/TriggerEventsPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n trigger: trigger.data,\n events: events.data,\n },\n });\n});\n\napp.get(\"/connections\", async (c) => {\n const user = c.get(\"user\");\n const accounts = await pd.getAccounts({\n external_user_id: getLatestUserID(user),\n include_credentials: false, // only works for oauth clients we own\n });\n return renderPage({\n pageModuleURL: \"/frontend/pages/ConnectionsPage.tsx\",\n title,\n props: {\n user,\n effectiveUserId: getLatestUserID(user),\n accounts: accounts.data,\n },\n });\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) => Promise.reject(err));\nexport default app.fetch;","pipedream",[],[239,266],"af30d5a2-7f8b-11f0-ac3a-0224a6c84d84","auth.tsx","0e09f6fa-487b-11f0-9981-76b3cceeab13",794,["D",1755889836437],17,"import { ValTown } from \"npm:@valtown/sdk\";\nimport { Hono } from \"npm:hono\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\n\n// in-memory cache\nconst users = {};\nasync function getValTownUser(apiKey: string) {\n if (users[apiKey]) return users[apiKey];\n try {\n const vt = new ValTown({ bearerToken: apiKey });\n const user = await vt.me.profile.retrieve();\n users[apiKey] = user;\n return user;\n } catch (error) {\n console.error(error);\n return null;\n }\n}\n\n// Helper function to get latest user ID, mapping upgraded Teams to their original IDs\nexport function getLatestUserID(user): string {\n // Hardcoded mapping for upgraded Teams\n if (user.id === \"605468d1-6330-11f0-a5c1-e512bb716b07\") {\n return \"dc5211a0-627f-11f0-b33c-4da69e05ed9d\"; // stainless org → laura_stainless personal\n }\n return user.id;\n}\n\n// Helper function to get current user from cookie\nexport function getCurrentUser(c: any) {\n const apiKey = getCookie(c, \"vt_api_key\");\n if (!apiKey) return null;\n return getValTownUser(apiKey);\n}\n\nconst app = new Hono();\nexport { app as auth };\n\n// Login endpoint\napp.post(\"/login\", async (c) => {\n const { apiKey } = await c.req.json();\n\n if (!apiKey) {\n return c.json({ error: \"API key is required\" }, 400);\n }\n\n const user = await getValTownUser(apiKey);\n\n if (!user) {\n return c.json({ error: \"Invalid Val Town API key\" }, 401);\n }\n\n // Set secure cookie with API key\n setCookie(c, \"vt_api_key\", apiKey, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\", // Changed from Strict to Lax for better compatibility\n maxAge: 60 * 60 * 24 * 30, // 30 days\n path: \"/\", // Ensure cookie is available for all paths\n });\n\n return c.json({\n success: true,\n user: user,\n });\n});\n\n// Logout endpoint\napp.post(\"/logout\", (c) => {\n deleteCookie(c, \"vt_api_key\");\n return c.json({ success: true });\n});",[],[239,277],"df364c6e-34e5-11f0-ba03-9e149126039e",["D",1747682234550],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","OAuth to everything","imageUrl","userId","bb89e6f6-754a-445c-8647-65845a173c3e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","ba7bb5fb-1abb-4ffb-8f3d-7c244782e5f7","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_339":335},"org",{"_11":12,"_332":333,"_334":335,"_295":-5,"_336":337,"_338":47},"branch",{"_17":155,"_13":16,"_35":43,"_324":285,"_325":-5,"_326":-5,"_327":-5,"_328":-5,"_329":-5,"_330":14,"_331":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Val Town ","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJyWnQ5cFE0c3pleVRCSEVTWmxzaXJsTUlGciJ9","tier","business","canRestrictVals","profileImageUrl","adoptOrgId",{"_35":285,"_13":14,"_48":446,"_287":-5,"_288":55,"_289":290,"_291":290,"_292":293,"_294":-5,"_295":296,"_297":267,"_298":47,"_299":47,"_300":-5,"_301":78,"_302":303,"_304":-5,"_305":-5,"_306":-5,"_307":-5,"_308":309,"_310":309,"_311":312,"_313":312,"_314":312,"_315":309,"_316":309,"_317":447,"_319":448,"_321":449,"_323":55},[374,379,394,396,397],"files",[374,375,376,377,378,379,380,381,382,383,384,385,386,387,388,389,390,391,392,393,394,395,396,397],"counts",{"_364":78,"_365":366,"_367":63,"_32":368,"_369":370},[360,361],{"_35":65,"_13":19,"_38":41,"_40":-5,"_42":43,"_44":50,"_46":47,"_48":66,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_18":359},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],{"_35":58,"_13":59,"_38":60,"_40":41,"_42":43,"_44":61,"_46":47,"_48":62,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_18":363},{"_35":36,"_13":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":-5,"_54":55,"_56":-5,"_18":362},[19,37],[19,59],"pulls","branches",4,"forks",{"_371":366,"_373":78},"connections",{"_371":78,"_372":78},"count","unfilledCount","emptyCount",{"_35":238,"_13":239,"_38":240,"_40":-5,"_42":43,"_44":241,"_46":47,"_48":242,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_80":444,"_18":445},{"_35":276,"_13":277,"_38":278,"_40":240,"_42":43,"_44":279,"_46":47,"_48":280,"_17":281,"_51":105,"_53":282,"_54":55,"_56":-5,"_80":442,"_18":443},{"_35":265,"_13":266,"_38":267,"_40":240,"_42":43,"_44":268,"_46":47,"_48":269,"_17":270,"_51":271,"_53":272,"_54":55,"_56":273,"_80":440,"_18":441},{"_35":257,"_13":258,"_38":259,"_40":240,"_42":43,"_44":260,"_46":47,"_48":261,"_17":166,"_51":105,"_53":262,"_54":55,"_56":-5,"_80":438,"_18":439},{"_35":249,"_13":250,"_38":251,"_40":240,"_42":43,"_44":223,"_46":47,"_48":252,"_17":253,"_51":105,"_53":254,"_54":55,"_56":-5,"_80":436,"_18":437},{"_35":65,"_13":19,"_38":41,"_40":-5,"_42":43,"_44":50,"_46":47,"_48":109,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_80":434,"_18":435},{"_35":58,"_13":59,"_38":60,"_40":41,"_42":43,"_44":61,"_46":47,"_48":196,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_80":432,"_18":433},{"_35":229,"_13":230,"_38":231,"_40":60,"_42":43,"_44":232,"_46":47,"_48":233,"_17":234,"_51":105,"_53":235,"_54":55,"_56":-5,"_80":430,"_18":431},{"_35":220,"_13":221,"_38":222,"_40":60,"_42":43,"_44":223,"_46":47,"_48":224,"_17":225,"_51":105,"_53":226,"_54":55,"_56":-5,"_80":428,"_18":429},{"_35":212,"_13":213,"_38":214,"_40":60,"_42":43,"_44":86,"_46":47,"_48":215,"_17":216,"_51":105,"_53":217,"_54":55,"_56":-5,"_80":426,"_18":427},{"_35":203,"_13":204,"_38":205,"_40":60,"_42":43,"_44":206,"_46":47,"_48":207,"_17":208,"_51":105,"_53":209,"_54":55,"_56":-5,"_80":424,"_18":425},{"_35":36,"_13":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":114,"_17":50,"_51":52,"_53":-5,"_54":55,"_56":-5,"_80":422,"_18":423},{"_35":187,"_13":188,"_38":189,"_40":39,"_42":43,"_44":190,"_46":47,"_48":191,"_17":192,"_51":105,"_53":193,"_54":55,"_56":-5,"_80":420,"_18":421},{"_35":179,"_13":180,"_38":181,"_40":39,"_42":43,"_44":86,"_46":47,"_48":182,"_17":183,"_51":105,"_53":184,"_54":55,"_56":-5,"_80":418,"_18":419},{"_35":170,"_13":171,"_38":172,"_40":39,"_42":43,"_44":173,"_46":47,"_48":174,"_17":175,"_51":105,"_53":176,"_54":55,"_56":-5,"_80":416,"_18":417},{"_35":161,"_13":162,"_38":163,"_40":39,"_42":43,"_44":164,"_46":47,"_48":165,"_17":166,"_51":105,"_53":167,"_54":55,"_56":-5,"_80":414,"_18":415},{"_35":152,"_13":153,"_38":154,"_40":39,"_42":43,"_44":155,"_46":47,"_48":156,"_17":157,"_51":105,"_53":158,"_54":55,"_56":-5,"_80":412,"_18":413},{"_35":143,"_13":144,"_38":145,"_40":39,"_42":43,"_44":146,"_46":47,"_48":147,"_17":148,"_51":105,"_53":149,"_54":55,"_56":-5,"_80":410,"_18":411},{"_35":134,"_13":135,"_38":136,"_40":39,"_42":43,"_44":137,"_46":47,"_48":138,"_17":139,"_51":105,"_53":140,"_54":55,"_56":-5,"_80":408,"_18":409},{"_35":125,"_13":126,"_38":127,"_40":39,"_42":43,"_44":128,"_46":47,"_48":129,"_17":130,"_51":105,"_53":131,"_54":55,"_56":-5,"_80":406,"_18":407},{"_35":92,"_13":93,"_38":94,"_40":-5,"_42":43,"_44":95,"_46":47,"_48":96,"_17":63,"_51":52,"_53":-5,"_54":55,"_56":-5,"_80":404,"_18":405},{"_35":100,"_13":101,"_38":102,"_40":94,"_42":43,"_44":103,"_46":47,"_48":104,"_17":61,"_51":105,"_53":106,"_54":55,"_56":-5,"_80":402,"_18":403},{"_35":83,"_13":84,"_38":85,"_40":-5,"_42":43,"_44":86,"_46":47,"_48":87,"_17":88,"_51":24,"_53":89,"_54":55,"_56":-5,"_80":400,"_18":401},{"_35":73,"_13":74,"_38":75,"_40":-5,"_42":43,"_44":76,"_46":47,"_48":77,"_17":78,"_51":24,"_53":79,"_54":55,"_56":-5,"_80":398,"_18":399},[],[74],[],[84],[],[93,101],[395],[93],[],[19,37,126],[],[19,37,135],[],[19,37,144],[],[19,37,153],[],[19,37,162],[],[19,37,171],[],[19,37,180],[],[19,37,188],[386,387,388,389,390,391,392,393],[19,37],[],[19,59,204],[],[19,59,213],[],[19,59,221],[],[19,59,230],[381,382,383,384],[19,59],[380,385],[19],[],[239,250],[],[239,258],[],[239,266],[],[239,277],[375,376,377,378],[239],["D",1747682234550],{"_11":12,"_339":335},{"_11":12,"_332":333,"_334":335,"_295":-5,"_336":337,"_338":47},{"_17":155,"_13":16,"_35":43,"_324":285,"_325":-5,"_326":-5,"_327":-5,"_328":-5,"_329":-5,"_330":14,"_331":12},"ctx",{"_317":-5,"_356":483,"_484":485,"_486":487,"_488":55,"_489":55,"_490":55,"_491":47,"_492":-5,"_493":-7,"_494":-7,"_495":78,"_496":55,"_497":55,"_498":-5,"_499":55,"_500":55,"_501":55,"_502":-5},"ENV",{"_454":455,"_456":457,"_458":16,"_459":460,"_461":462,"_463":464,"_465":466,"_467":468,"_469":470,"_471":472,"_473":474,"_475":476,"_477":478,"_479":480,"_481":482},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]