[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_443":444,"_445":446},"routes/_app.x.$handle.$name",{"_101":100,"_32":46,"_109":87,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":122,"_123":124,"_125":25,"_126":127,"_128":59,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",34,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","backend/auth.tsx","latestPath","fileId","0199bbc9-3b47-704a-8f96-bfc655edd59d","name","auth.tsx","fileType","script","content","import { ValTown } from \"npm:@valtown/sdk@latest\";\nimport { Hono } from \"npm:hono@latest\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono@latest/cookie\";\n\n// in-memory cache\nconst users = {};\nasync function getValTownUser(apiKey: string): Promise {\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 }\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});","import { ValTown } from \"npm:@valtown/sdk@latest\";\nimport { Hono } from \"npm:hono@latest\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono@latest/cookie\";\n\nexport type User = ValTown.Me.Profile.ProfileRetrieveResponse;\n\n// in-memory cache\nconst users = {};\nasync function getValTownUser(apiKey: string): Promise {\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 }\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});","createdAt",["D",1759807190286],"branchVersion","branchId","781ba3c0-a309-11f0-99c8-0224a6c84d84","id","7816d73c-a309-11f0-99c8-0224a6c84d84","pipedream-connect",["D",1759792151298],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","0199bbc9-3b47-704a-8f96-c2fc8522c07b","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_108":104},"org",{"_101":100,"_102":-5,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":86,"_32":87,"_44":43,"_88":45,"_89":90,"_91":92,"_93":51,"_94":95,"_96":97,"_98":46,"_99":100},"isOwned",83,"main","projectId","forkedBranchId","df36932c-34e5-11f0-ba03-9e149126039e","forkedBranchVersion",803,"forkedProjectPrivacy","forkedProjectId","df364c6e-34e5-11f0-ba03-9e149126039e","forkedProjectOrgId","ba7bb5fb-1abb-4ffb-8f3d-7c244782e5f7","projectName","userHandle","nbbaier","handle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":439,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":440,"_81":441,"_83":442,"_85":25},"tree",[238,243,258,260,261,262,263,264,265,266,267],"files",[238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255,256,257,258,259,260,261,262,263,264,265,266,267],"counts",{"_228":63,"_229":160,"_230":63,"_231":232,"_233":234},"contents",[142,143,144,145,146,147,148,149,150,151,152],"upstreamProject",{"_44":95,"_32":46,"_53":139,"_54":-5,"_50":51,"_79":140},"upstreamBranch",{"_44":90,"_39":133,"_134":135,"_32":87,"_88":95,"_13":92,"_89":-5,"_91":-5,"_136":137,"_48":-5,"_85":25,"_50":51,"_99":138,"_64":97,"_98":46},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1747682234550],"updatedAt",["D",1757364451236],"lockfileKey","1767103213128-esm.town_v_valdottown_pipedream-connect@803-main","valdottown","OAuth to everything",{"_101":138,"_108":141},"https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJyWnQ5cFE0c3pleVRCSEVTWmxzaXJsTUlGciJ9",{"_44":223,"_32":224,"_30":225,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":226,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_27":227},{"_44":218,"_32":219,"_30":220,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":221,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_27":222},{"_44":212,"_32":213,"_30":214,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":215,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_27":217},{"_44":205,"_32":206,"_30":207,"_156":-5,"_42":43,"_41":208,"_158":59,"_39":209,"_13":63,"_34":20,"_36":210,"_24":25,"_162":-5,"_27":211},{"_44":198,"_32":199,"_30":200,"_156":-5,"_42":43,"_41":201,"_158":59,"_39":202,"_13":63,"_34":20,"_36":203,"_24":25,"_162":-5,"_27":204},{"_44":191,"_32":192,"_30":193,"_156":-5,"_42":43,"_41":194,"_158":59,"_39":195,"_13":63,"_34":20,"_36":196,"_24":25,"_162":-5,"_27":197},{"_44":184,"_32":185,"_30":186,"_156":-5,"_42":43,"_41":187,"_158":25,"_39":188,"_13":63,"_34":20,"_36":189,"_24":25,"_162":-5,"_27":190},{"_44":177,"_32":178,"_30":179,"_156":-5,"_42":43,"_41":180,"_158":25,"_39":181,"_13":63,"_34":20,"_36":182,"_24":25,"_162":-5,"_27":183},{"_44":171,"_32":172,"_30":173,"_156":-5,"_42":43,"_41":160,"_158":25,"_39":174,"_13":63,"_34":20,"_36":175,"_24":25,"_162":-5,"_27":176},{"_44":164,"_32":165,"_30":166,"_156":-5,"_42":43,"_41":167,"_158":25,"_39":168,"_13":63,"_34":20,"_36":169,"_24":25,"_162":-5,"_27":170},{"_44":153,"_32":154,"_30":155,"_156":-5,"_42":43,"_41":157,"_158":25,"_39":159,"_13":160,"_34":20,"_36":161,"_24":25,"_162":-5,"_27":163},"903b393a-a30d-11f0-b0b1-0224a6c84d84","deno.json","0199bbc9-3b47-704a-8f97-193c5d3f5c5e","parentId",16,"latest",["D",1759793909808],1,"{\n\t\"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n\t\"lock\": false,\n\t\"compilerOptions\": {\n\t\t\"noImplicitAny\": false,\n\t\t\"strict\": false,\n\t\t\"types\": [\"https://www.val.town/types/valtown.d.ts\"],\n\t\t\"lib\": [\n\t\t\t\"dom\",\n\t\t\t\"dom.iterable\",\n\t\t\t\"dom.asynciterable\",\n\t\t\t\"deno.ns\",\n\t\t\t\"deno.unstable\"\n\t\t],\n\t\t\"jsx\": \"react-jsx\",\n\t\t\"jsxImportSource\": \"https://esm.sh/react@18.2.0\",\n\t\t\"jsxImportSourceTypes\": \"https://esm.sh/react@18.2.0\"\n\t},\n\t\"lint\": {\n\t\t\"files\": {\n\t\t\t\"include\": [\"deno:/https/esm.town/**/*\"]\n\t\t},\n\t\t\"rules\": {\n\t\t\t\"exclude\": [\n\t\t\t\t\"no-explicit-any\",\n\t\t\t\t\"no-import-prefix\",\n\t\t\t\t\"no-unversioned-import\"\n\t\t\t]\n\t\t}\n\t},\n\t\"node_modules_dir\": false,\n\t\"experimental\": {\n\t\t\"unstable-node-globals\": true,\n\t\t\"unstable-temporal\": true,\n\t\t\"unstable-worker-options\": true,\n\t\t\"unstable-sloppy-imports\": true\n\t},\n\t\"imports\": {\n\t\t\"@pipedream/sdk\": \"npm:@pipedream/sdk@2.0.12\"\n\t}\n}\n","label",[154],"0d17a1ee-a30b-11f0-b8fb-0224a6c84d84","biome.json","0d17a28e-a30b-11f0-b8fb-0224a6c84d84",2,["D",1759792830801],"{\n\t\"$schema\": \"https://biomejs.dev/schemas/2.2.5/schema.json\",\n\t\"vcs\": {\n\t\t\"enabled\": false,\n\t\t\"clientKind\": \"git\",\n\t\t\"useIgnoreFile\": true\n\t},\n\t\"files\": {\n\t\t\"ignoreUnknown\": false\n\t},\n\t\"formatter\": {\n\t\t\"enabled\": true,\n\t\t\"indentStyle\": \"tab\"\n\t},\n\t\"linter\": {\n\t\t\"enabled\": true,\n\t\t\"rules\": {\n\t\t\t\"recommended\": true\n\t\t}\n\t},\n\t\"javascript\": {\n\t\t\"formatter\": {\n\t\t\t\"quoteStyle\": \"double\"\n\t\t}\n\t},\n\t\"assist\": {\n\t\t\"enabled\": true,\n\t\t\"actions\": {\n\t\t\t\"source\": {\n\t\t\t\t\"organizeImports\": \"on\"\n\t\t\t}\n\t\t}\n\t}\n}\n",[165],"781fb028-a309-11f0-99c8-0224a6c84d84","README.md","0199bbc9-3b47-704a-8f97-143e38f23c95",["D",1759792151298],"# Val Town + Pipedream Connect Integration\n\nThis application allows Val Town users to authenticate and connect to external services via Pipedream Connect.\n\n## Features\n\n### Actions\n- **Send data to external services** from your Val Town code\n- **Secure authentication** handled automatically - no API keys to manage\n- **Copy & paste code snippets** ready for your vals\n- **Thousands of services** supported: Gmail, Slack, Twitter, Notion, Airtable, and more\n\n### Triggers \n- **Receive data from external services** when events happen\n- **Real-time webhooks** send data to your vals instantly\n- **Any HTTP val** can receive trigger data\n- **Event debugging** to view all events sent to your triggers\n\n### Home Page\nThe home page now provides comprehensive explanations of:\n- What actions vs triggers are and how they differ\n- How authentication is handled securely under the hood\n- Step-by-step guides for using both actions and triggers\n- Quick access to create new integrations and manage existing ones\n\n## Misc todos\n\n- [ ] Automatically include `\"includeSentViaPipedream\": false` for Discord and Slack\n- [ ] Replace Discord & Slack apps with our own https://pipedream.com/docs/connect/managed-auth/oauth-clients/#using-a-custom-oauth-client\n - [ ] I made one for discord, but am struggling to figure out where to supply the `oauthAppId`. I asked Pipedream.\n- [ ] Would be neat if you could scroll more in the list of connections or see a grid of the top 100 connections\n- [ ] How do we teach Townie how to use this?\n - [ ] search for potential actions (maybe their mcp can help?)\n- [ ] (Maybe) Help users connect trigger to val more directly than copying endpoint (via val town sdk)\n\n## Authentication\n\nThis app uses Val Town API tokens for authentication. (Eventually, we'll swap\nthis for Val Town OAuth.)\n\nTo login, create and supply a Val Town API token with the `user:read` scope only. We store it in cookies.\n\nTo run actions on connected apps, you'll also need to supply a Val Town API\ntoken. If you're doing this from within Val Town, you can use\n`process.env.valtown`, which this app's client libraries will use by default.",[172],"902b2b8a-a30d-11f0-899c-0224a6c84d84","MIGRATION_PLAN.md","902b2c52-a30d-11f0-899c-0224a6c84d84",14,["D",1759793909674],"# Pipedream SDK v1.x to v2.x Migration Plan\n\n## Current State Analysis\n\nThe codebase is currently using:\n\n- **SDK Version**: v1.6.8 (server) and v1.6.8 (browser)\n- **Client Creation**: `createBackendClient()` and `createFrontendClient()`\n- **Method Calls**: Old v1.x method names like `actionRun()`, `deployTrigger()`, etc.\n- **Deno.json**: Already has v2.0.12 mapped but code still uses v1.6.8\n\n## Required Changes\n\n### 1. Update SDK Imports and Client Initialization\n\n#### Backend (`backend/pipedream.tsx`)\n\n**Current (v1.x):**\n\n```typescript\nimport { createBackendClient } from \"npm:@pipedream/sdk@1.6.8/server\";\nexport const pd = createBackendClient({\n environment: Deno.env.get(\"PIPEDREAM_PROJECT_ENVIRONMENT\") as\n | \"development\"\n | \"production\",\n credentials: {\n clientId: Deno.env.get(\"PIPEDREAM_CLIENT_ID\") as string,\n clientSecret: Deno.env.get(\"PIPEDREAM_CLIENT_SECRET\") as string,\n },\n projectId: Deno.env.get(\"PIPEDREAM_PROJECT_ID\"),\n});\n```\n\n**Needs to become (v2.x):**\n\n```typescript\nimport { PipedreamClient } from \"@pipedream/sdk\";\nexport const pd = new PipedreamClient({\n clientId: Deno.env.get(\"PIPEDREAM_CLIENT_ID\"),\n clientSecret: Deno.env.get(\"PIPEDREAM_CLIENT_SECRET\"),\n projectId: Deno.env.get(\"PIPEDREAM_PROJECT_ID\"),\n projectEnvironment: Deno.env.get(\"PIPEDREAM_PROJECT_ENVIRONMENT\"),\n});\n```\n\n#### Frontend (multiple files)\n\n**Current (v1.x):**\n\n```typescript\nimport { createFrontendClient } from \"https://esm.sh/@pipedream/sdk@1.6.8/browser\";\nconst 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\n**Needs to become (v2.x):**\n\n```typescript\nimport { PipedreamClient } from \"https://esm.sh/@pipedream/sdk@2.0.12/browser\";\nconst frontendClient = new PipedreamClient({\n tokenCallback: async ({ externalUserId }) => {\n const resp = await fetch(\"/api/pipedream/token\", {\n method: \"POST\",\n });\n const data = await resp.json();\n return data;\n },\n projectId: \"your-project-id\", // Add your project ID\n projectEnvironment: \"production\",\n});\n```\n\n### 2. Update Method Calls to Namespaced Format\n\n#### Backend (`backend/pipedream.tsx`)\n\n| Current (v1.x) | New (v2.x) |\n| ------------------------- | ---------------------------------------------- |\n| `pd.createConnectToken()` | `pd.tokens.create()` |\n| `pd.actionRun()` | `pd.actions.run()` |\n| `pd.makeProxyRequest()` | `pd.proxy.post()` (or appropriate HTTP method) |\n| `pd.getAccountById()` | `pd.accounts.retrieve()` |\n| `pd.deleteAccount()` | `pd.accounts.delete()` |\n| `pd.deleteTrigger()` | `pd.deployedTriggers.delete()` |\n\n#### Backend (`backend/main.tsx`)\n\n| Current (v1.x) | New (v2.x) |\n| ----------------------- | ---------------------------------- |\n| `pd.getTriggers()` | `pd.deployedTriggers.list()` |\n| `pd.getTrigger()` | `pd.deployedTriggers.retrieve()` |\n| `pd.getTriggerEvents()` | `pd.deployedTriggers.listEvents()` |\n| `pd.getAccounts()` | `pd.accounts.list()` |\n\n#### Frontend\n\n| Current (v1.x) | New (v2.x) |\n| -------------------------------- | ---------------------------------- |\n| `frontendClient.actionRun()` | `frontendClient.actions.run()` |\n| `frontendClient.deployTrigger()` | `frontendClient.triggers.deploy()` |\n\n### 3. Update Parameter Names\n\nChange from snake_case to camelCase in TypeScript code:\n\n| Current | New |\n| --------------------- | -------------------- |\n| `external_user_id` | `externalUserId` |\n| `include_credentials` | `includeCredentials` |\n| `action_id` | `id` (for actions) |\n| `trigger_id` | `id` (for triggers) |\n\n### 4. Update Proxy Request Structure\n\n#### Current (`backend/pipedream.tsx` lines 75-83):\n\n```typescript\nconst result = await pd.makeProxyRequest(\n {\n searchParams: {\n account_id: args.account_id,\n external_user_id: getLatestUserID(user),\n },\n },\n args.fetch\n);\n```\n\n#### Needs to become:\n\n```typescript\nconst result = await pd.proxy.post({\n accountId: args.account_id,\n externalUserId: getLatestUserID(user),\n url: args.fetch.url,\n body: args.fetch.body,\n headers: args.fetch.headers,\n});\n```\n\n### 5. Update SDK Version References\n\nRemove the explicit version pinning from imports:\n\n- `npm:@pipedream/sdk@1.6.8/server` → `@pipedream/sdk` (uses deno.json mapping)\n- `https://esm.sh/@pipedream/sdk@1.6.8/browser` → `https://esm.sh/@pipedream/sdk@2.0.12/browser`\n\n### 6. Files That Need Changes\n\n#### High Priority\n\n1. **`backend/pipedream.tsx`** - Complete rewrite of client initialization and all method calls\n2. **`backend/main.tsx`** - Update all Pipedream method calls\n\n#### Medium Priority\n\n3. **`frontend/pages/NewActionPage.tsx`** - Update client creation and `actionRun()` call\n4. **`frontend/pages/NewTriggerPage.tsx`** - Update client creation and `deployTrigger()` call\n5. **`frontend/pages/NewConnectionPage.tsx`** - Update client creation\n\n#### Low Priority\n\n6. **`sdk/sdk.ts`** - This appears to be a wrapper function that calls your backend, so it might not need changes\n\n### 7. Environment Variables\n\nThe v2.x SDK supports automatic environment variable loading, so you could potentially simplify the client initialization to just:\n\n```typescript\nexport const pd = new PipedreamClient();\n```\n\n### 8. Error Handling\n\nConsider updating error handling to use the new `PipedreamError` type from v2.x for better error management:\n\n```typescript\nimport { PipedreamError } from \"@pipedream/sdk\";\n\ntry {\n // ... SDK calls\n} catch (error) {\n if (error instanceof PipedreamError) {\n console.error(\"API Error:\", error.status, error.message);\n }\n}\n```\n\n## Migration Checklist\n\n- [ ] Update import statements from `createBackendClient`/`createFrontendClient` to `PipedreamClient`\n- [ ] Update client initialization to use `new PipedreamClient()` for both server-side and browser-side\n- [ ] Convert all method calls to use namespaced format (e.g., `client.actions.run()`)\n- [ ] Keep parameter names in camelCase in your TypeScript/JavaScript code (the SDK handles conversion to snake_case automatically)\n- [ ] Pass `externalUserId` to methods instead of setting it on the client\n- [ ] Update error handling to use `PipedreamError` type\n- [ ] Review and implement new features like pagination and request options where beneficial\n- [ ] Replace any usage of removed methods with their alternatives\n- [ ] Update any code using `rawAccessToken()` - for server-side code, you can access `client.rawAccessToken` as a getter property that returns a Promise\n- [ ] For raw response access, use `.withRawResponse()` method chaining instead of passing `includeRawResponse` option\n- [ ] Test all migrated code thoroughly\n- [ ] Remove the old SDK dependency once migration is complete\n\n## Migration Priority\n\n1. **High Priority**: Backend client initialization and core method calls\n2. **Medium Priority**: Frontend client updates\n3. **Low Priority**: Error handling improvements and environment variable simplification\n\n## Notes\n\n- The migration is straightforward but requires updating method calls across multiple files\n- The good news is that your `deno.json` already has the v2.0.12 mapping, so you just need to update the code to use the new API\n- The v2.x SDK includes several new features not available in v1.x:\n - Full TypeScript support\n - Pagination support\n - Enhanced error handling\n - Request options\n - Abort signals\n - Raw response access\n",[178],"9059c3b4-a30d-11f0-bab4-0224a6c84d84","MIGRATE.md","9059c44a-a30d-11f0-bab4-0224a6c84d84",21,["D",1759793909696],"\n\n# Migrating from v1.x\n\nThis guide will help you migrate your existing Pipedream SDK v1.x integration to\nthe latest version.\n\n## Table of contents\n\n- [Migrating from v1.x](#migrating-from-v1x)\n - [Table of contents](#table-of-contents)\n - [Deprecation](#deprecation)\n - [Breaking changes](#breaking-changes)\n - [Client initialization](#client-initialization)\n - [Server-side](#server-side)\n - [v1.x (old)](#v1x-old)\n - [v2.x (new)](#v2x-new)\n - [Browser-side](#browser-side)\n - [v1.x (old)](#v1x-old-1)\n - [v2.x (new)](#v2x-new-1)\n - [Environment variables](#environment-variables)\n - [Method migration](#method-migration)\n - [Method and parameter naming](#method-and-parameter-naming)\n - [Migration examples](#migration-examples)\n - [Running actions](#running-actions)\n - [v1.x (old)](#v1x-old-2)\n - [v2.x (new)](#v2x-new-2)\n - [Deploying triggers](#deploying-triggers)\n - [v1.x (old)](#v1x-old-3)\n - [v2.x (new)](#v2x-new-3)\n - [Managing accounts](#managing-accounts)\n - [v1.x (old)](#v1x-old-4)\n - [v2.x (new)](#v2x-new-4)\n - [Creating connect tokens](#creating-connect-tokens)\n - [v1.x (old)](#v1x-old-5)\n - [v2.x (new)](#v2x-new-5)\n - [Validating connect tokens](#validating-connect-tokens)\n - [v1.x (old)](#v1x-old-6)\n - [v2.x (new)](#v2x-new-6)\n - [Configuring component props](#configuring-component-props)\n - [v1.x (old)](#v1x-old-7)\n - [v2.x (new)](#v2x-new-7)\n - [Deleting accounts](#deleting-accounts)\n - [v1.x (old)](#v1x-old-8)\n - [v2.x (new)](#v2x-new-8)\n - [Getting project info](#getting-project-info)\n - [v1.x (old)](#v1x-old-9)\n - [v2.x (new)](#v2x-new-9)\n - [Making proxy requests](#making-proxy-requests)\n - [v1.x (old)](#v1x-old-10)\n - [v2.x (new)](#v2x-new-10)\n - [Invoking workflows](#invoking-workflows)\n - [v1.x (old)](#v1x-old-11)\n - [v2.x (new)](#v2x-new-11)\n - [Namespace mapping](#namespace-mapping)\n - [New features in v2.x](#new-features-in-v2x)\n - [Full TypeScript support](#full-typescript-support)\n - [Pagination support](#pagination-support)\n - [Enhanced error handling](#enhanced-error-handling)\n - [Request options](#request-options)\n - [Abort signals](#abort-signals)\n - [Raw response access](#raw-response-access)\n - [Browser/Server Environment Separation](#browserserver-environment-separation)\n - [Package.json Export Structure](#packagejson-export-structure)\n - [Import Recommendations](#import-recommendations)\n - [Additional namespaces](#additional-namespaces)\n - [Partial migration](#partial-migration)\n - [Important removed functionality](#important-removed-functionality)\n - [Migration checklist](#migration-checklist)\n\n## Deprecation\n\nThe v1.x version of the Pipedream SDK is now deprecated. This means that no\nchanges will be made to this version unless there are critical security issues.\nWe recommend that you migrate to the latest version of the SDK to take advantage\nof new features, improvements, and bug fixes if possible.\n\n## Breaking changes\n\nThe new SDK version introduces several breaking changes that you need to be\naware of when migrating from v1.x. Below is a summary of the most significant\nchanges:\n\n- **Namespaced Methods**: Methods are now namespaced by the resource they act\n upon. For example, instead of using `client.runAction()`, you now use\n `client.actions.run()`.\n- **Automatic Snake Case Conversion**: While the TypeScript interfaces use\n `camelCase` for better developer experience, the SDK automatically converts\n these to `snake_case` when making API calls to align with our [OpenAPI\n spec](https://api.pipedream.com/api-docs/swagger.json).\n- **Client Initialization**: The `createBackendClient()` and\n `createFrontendClient()` methods have been replaced with a new\n `PipedreamClient` class. Note: The v1.x `BrowserClient` class has been\n replaced with `PipedreamClient` in the browser context.\n- **TypeScript Types**: All TypeScript types are now exported for better type\n safety.\n- **Authentication Changes**: The `rawAccessToken()` method is now available as\n a `rawAccessToken` getter property on the server-side SDK.\n- **Environment Variables**: The SDK now supports automatic configuration via\n environment variables (see below).\n\n## Client initialization\n\n### Server-side\n\nFor server-side applications, we recommend using the `PipedreamClient` wrapper\nclass, which simplifies OAuth token management.\n\n#### v1.x (old)\n\n```javascript\nimport { createBackendClient } from \"@pipedream/sdk\";\n\nconst client = createBackendClient({\n credentials: {\n clientId: \"your-client-id\",\n clientSecret: \"your-client-secret\",\n },\n projectId: \"your-project-id\",\n environment: \"development\", // or 'production'\n});\n```\n\n#### v2.x (new)\n\n```javascript\nimport { PipedreamClient } from \"@pipedream/sdk\";\n\nconst client = new PipedreamClient({\n clientId: \"your-client-id\",\n clientSecret: \"your-client-secret\",\n projectId: \"your-project-id\",\n projectEnvironment: \"development\", // or 'production'\n});\n```\n\n### Browser-side\n\nFor browser-side applications, you should use the `PipedreamClient` class and\nauthenticate using a `connect_token` obtained from your backend.\n\n#### v1.x (old)\n\n```javascript\nimport { createFrontendClient } from \"@pipedream/sdk\";\n\nconst frontendClient = createFrontendClient({\n environment: \"development\",\n credentials: {\n token: \"connect-token-from-backend\",\n },\n});\n```\n\n#### v2.x (new)\n\nThe v2.x SDK provides two options for browser-side usage:\n\n**Option 1: Using `PipedreamClient` with token callback (for dynamic token\nmanagement)**\n\n```javascript\nimport { PipedreamClient } from \"@pipedream/sdk\";\n\nconst tokenCallback = async ({ externalUserId }) => {\n // Call your backend to get a connect token\n const response = await fetch(\"/api/pipedream/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ externalUserId }),\n });\n return response.json();\n};\nconst clientWithToken = new PipedreamClient({\n tokenCallback,\n projectId: \"your-project-id\",\n projectEnvironment: \"development\", // or 'production'\n});\n```\n\n**Option 2: Using `createFrontendClient` with connect token (for simple token-based\nauth)**\n\n```javascript\n// Explicit browser import (recommended for browser apps)\nimport {\n createFrontendClient,\n type PipedreamClient,\n} from \"@pipedream/sdk/browser\";\n\n// Or automatic browser resolution\nimport { createFrontendClient, type PipedreamClient } from \"@pipedream/sdk\";\n\n// `tokenCallback` is also supported here\nconst client: PipedreamClient = createFrontendClient({\n token: \"connect-token\",\n externalUserId: \"user-123\",\n});\n\n// Connect an account using Pipedream Connect\nclient.connectAccount({\n app: \"github\",\n onSuccess: (result) => {\n console.log(\"Account connected:\", result.id);\n },\n onError: (error) => {\n console.error(\"Connection failed:\", error);\n },\n});\n\n// Get user's accounts\nconst accounts = await client.getAccounts();\n```\n\n### Environment variables\n\nThe v2.x SDK supports automatic configuration via environment variables:\n\n```javascript\n// These environment variables are automatically used if set:\n// PIPEDREAM_CLIENT_ID\n// PIPEDREAM_CLIENT_SECRET\n// PIPEDREAM_PROJECT_ID\n// PIPEDREAM_PROJECT_ENVIRONMENT (defaults to 'production')\n\n// You can initialize the client with minimal configuration\nconst client = new PipedreamClient({\n projectId: \"your-project-id\", // Can also come from PIPEDREAM_PROJECT_ID\n});\n\n// If environment variables are set, you can even do:\nconst client = new PipedreamClient();\n// This will use PIPEDREAM_CLIENT_ID, PIPEDREAM_CLIENT_SECRET, and PIPEDREAM_PROJECT_ID\n```\n\n## Method migration\n\n### Method and parameter naming\n\nIn v2.x, all methods are namespaced. While you write TypeScript code using\n`camelCase` (e.g., `externalUserId`), the SDK automatically converts these to\n`snake_case` (e.g., `external_user_id`) when making API calls. For example,\n`client.runAction({ externalUserId: '...' })` becomes\n`client.actions.run({ externalUserId: '...' })` in your code, but the SDK sends\n`external_user_id` to the API. This automatic conversion aligns with the\n[OpenAPI spec](https://api.pipedream.com/api-docs/swagger.json), but does\n**not apply** to the following arguments:\n\n1. Client constructor parameters like `clientId`, `clientSecret`, `projectId`,\n `projectEnvironment`, and `workflowDomain`.\n2. The props listed under `configuredProps` (the naming follows whatever the\n corresponding component defines).\n3. Request options like `timeoutInSeconds`, `maxRetries`, and `headers` (these\n remain in camelCase as they are not part of the API request body).\n\n### Migration examples\n\n#### Running actions\n\n##### v1.x (old)\n\n```javascript\nconst result = await client.runAction({\n externalUserId: \"jverce\",\n actionId: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n});\n```\n\n##### v2.x (new)\n\n```javascript\nconst result = await client.actions.run({\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n});\n```\n\n#### Deploying triggers\n\n##### v1.x (old)\n\n```javascript\nconst trigger = await client.deployTrigger({\n externalUserId: \"jverce\",\n triggerId: \"gitlab-new-issue\",\n configuredProps: {\n gitlab: {\n authProvisionId: \"apn_kVh9AoD\",\n },\n projectId: 45672541,\n },\n webhookUrl: \"https://events.example.com/gitlab-new-issue\",\n});\n```\n\n##### v2.x (new)\n\n```javascript\nconst trigger = await client.triggers.deploy({\n externalUserId: \"jverce\",\n id: \"gitlab-new-issue\",\n configuredProps: {\n gitlab: {\n authProvisionId: \"apn_kVh9AoD\",\n },\n projectId: 45672541,\n },\n webhookUrl: \"https://events.example.com/gitlab-new-issue\",\n});\n```\n\n#### Managing accounts\n\n##### v1.x (old)\n\n```javascript\n// List accounts\nconst accounts = await client.getAccounts({\n external_user_id: \"jverce\",\n include_credentials: true,\n});\n\n// Get specific account\nconst account = await client.getAccountById(\"apn_kVh9AoD\", {\n include_credentials: true,\n});\n```\n\n##### v2.x (new)\n\n```javascript\n// List accounts\nconst accounts = await client.accounts.list({\n externalUserId: \"jverce\",\n includeCredentials: true,\n});\n\n// Get specific account\nconst account = await client.accounts.retrieve(\"apn_kVh9AoD\", {\n includeCredentials: true,\n});\n```\n\n#### Creating connect tokens\n\n##### v1.x (old)\n\n```javascript\nconst token = await client.createConnectToken({\n external_user_id: \"jverce\",\n});\n```\n\n##### v2.x (new)\n\n```javascript\nconst token = await client.tokens.create({\n externalUserId: \"jverce\",\n});\n```\n\n#### Validating connect tokens\n\n##### v1.x (old)\n\n```javascript\n// validateConnectToken was available in v1.x\nconst isValid = await client.validateConnectToken({\n token: \"connect-token-to-validate\",\n});\n```\n\n##### v2.x (new)\n\n```javascript\nconst validation = await client.tokens.validate({\n token: \"connect-token-to-validate\",\n});\n```\n\n#### Configuring component props\n\n##### v1.x (old)\n\n```javascript\nconst response = await client.configureComponent({\n externalUserId: \"jverce\",\n componentId: \"gitlab-new-issue\",\n propName: \"projectId\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n },\n});\n```\n\n##### v2.x (new)\n\n```javascript\nconst response = await client.components.configureProp({\n externalUserId: \"jverce\",\n id: \"gitlab-new-issue\",\n propName: \"projectId\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n },\n});\n```\n\n#### Deleting accounts\n\n##### v1.x (old)\n\n```javascript\n// Delete specific account\nawait client.deleteAccount(\"account-id\");\n\n// Delete all accounts for an app\nawait client.deleteAccountsByApp(\"app-id\");\n\n// Delete external user\nawait client.deleteExternalUser(\"jverce\");\n```\n\n##### v2.x (new)\n\n```javascript\n// Delete specific account\nawait client.accounts.delete(\"account-id\");\n\n// Delete all accounts for an app - functionality removed\n// Consider using accounts.list() and deleting individually\n\n// Delete external user - use users namespace\nawait client.users.delete({\n externalUserId: \"jverce\",\n});\n```\n\n#### Getting project info\n\n##### v1.x (old)\n\n```javascript\nconst projectInfo = await client.getProjectInfo();\nconsole.log(projectInfo.apps);\n```\n\n##### v2.x (new)\n\n```javascript\nconst project = await client.projects.retrieve();\nconsole.log(project);\n```\n\n#### Making proxy requests\n\n##### v1.x (old)\n\n```javascript\n// v1.x uses a single method with two parameters\nconst response = await client.makeProxyRequest(\n {\n searchParams: {\n external_user_id: \"jverce\",\n account_id: \"apn_kVh9AoD\",\n },\n },\n {\n url: \"https://api.example.com/data\",\n options: {\n method: \"GET\",\n headers: {\n Accept: \"application/json\",\n },\n },\n }\n);\n\n// POST request with body\nconst postResponse = await client.makeProxyRequest(\n {\n searchParams: {\n external_user_id: \"jverce\",\n account_id: \"apn_kVh9AoD\",\n },\n },\n {\n url: \"https://api.example.com/users\",\n options: {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ name: \"John Doe\" }),\n },\n }\n);\n```\n\n##### v2.x (new)\n\n```javascript\n// v2.x uses separate methods for each HTTP verb\nconst response = await client.proxy.get({\n externalUserId: \"jverce\",\n accountId: \"apn_kVh9AoD\",\n url: \"https://api.example.com/data\",\n headers: {\n Accept: \"application/json\",\n },\n params: {}, // Additional query parameters if needed\n});\n\n// POST request with body\nconst postResponse = await client.proxy.post({\n externalUserId: \"jverce\",\n accountId: \"apn_kVh9AoD\",\n url: \"https://api.example.com/users\",\n body: { name: \"John Doe\" }, // Body is passed as an object, not a string\n headers: {\n \"Content-Type\": \"application/json\",\n },\n});\n\n// Other HTTP methods are available\nawait client.proxy.put({\n /* ... */\n});\nawait client.proxy.delete({\n /* ... */\n});\nawait client.proxy.patch({\n /* ... */\n});\n```\n\n#### Invoking workflows\n\n##### v1.x (old)\n\n```javascript\n// Invoke a workflow\nconst response = await client.invokeWorkflow(\n \"https://your-endpoint.m.pipedream.net\",\n {\n foo: 123,\n bar: \"abc\",\n },\n HTTPAuthType.OAuth // Optional auth type\n);\n\n// Invoke a workflow for an external user\nconst response = await client.invokeWorkflowForExternalUser(\n \"https://your-workflow-url.m.pipedream.net\",\n \"jverce\", // external user ID as second parameter\n {\n foo: 123,\n bar: \"abc\",\n }\n);\n```\n\n##### v2.x (new)\n\n```javascript\n// Invoke a workflow\nconst response = await client.workflows.invoke(\n {\n urlOrEndpoint: \"https://your-endpoint.m.pipedream.net\",\n body: {\n foo: 123,\n bar: \"abc\",\n },\n headers: {\n Accept: \"application/json\",\n },\n },\n Pipedream.HTTPAuthType.OAuth\n);\n\n// Invoke a workflow for an external user\nconst response = await client.workflows.invokeForExternalUser({\n urlOrEndpoint: \"https://your-workflow-url.m.pipedream.net\",\n externalUserId: \"jverce\", // now part of the options object\n body: {\n foo: 123,\n bar: \"abc\",\n },\n});\n```\n\n## Namespace mapping\n\nHere's a complete list of how v1.x methods map to v2.x namespaced methods:\n\n| v1.x Method | v2.x Method |\n| --------------------------------- | ------------------------------------------------ |\n| `runAction()` | `actions.run()` |\n| `getAccounts()` | `accounts.list()` |\n| `getAccountById()` | `accounts.retrieve()` |\n| `deleteAccount()` | `accounts.delete()` |\n| `deleteAccountsByApp()` | Not available (use list + delete) |\n| `deleteExternalUser()` | `users.delete()` |\n| `createConnectToken()` | `tokens.create()` |\n| `validateConnectToken()` | `tokens.validate()` |\n| `deployTrigger()` | `triggers.deploy()` |\n| `getDeployedTriggers()` | `deployedTriggers.list()` |\n| `getDeployedTrigger()` | `deployedTriggers.retrieve()` |\n| `updateDeployedTrigger()` | `deployedTriggers.update()` |\n| `deleteDeployedTrigger()` | `deployedTriggers.delete()` |\n| `getTriggerEvents()` | `deployedTriggers.listEvents()` |\n| `getTriggerWebhooks()` | `deployedTriggers.listWebhooks()` |\n| `updateTriggerWebhooks()` | `deployedTriggers.updateWebhooks()` |\n| `getTriggerWorkflows()` | `deployedTriggers.listWorkflows()` |\n| `updateTriggerWorkflows()` | `deployedTriggers.updateWorkflows()` |\n| `getUsers()` | `users.list()` |\n| `getUser()` | `users.retrieve()` |\n| `getApps()` | `apps.list()` |\n| `getApp()` | `apps.retrieve()` |\n| `getComponents()` | `components.list()` |\n| `getComponent()` | `components.retrieve()` |\n| `configureComponent()` | `components.configureProp()` |\n| `reloadComponentProps()` | `components.reloadProps()` |\n| `getProjectInfo()` | `projects.retrieve()` |\n| `makeProxyRequest()` | `proxy.get()`, `proxy.post()`, etc. |\n| `invokeWorkflow()` | `workflows.invoke()` |\n| `invokeWorkflowForExternalUser()` | `workflows.invokeForExternalUser()` |\n| `rawAccessToken()` | `rawAccessToken` (getter property in server SDK) |\n\n## New features in v2.x\n\nThe v2.x SDK includes several new features not available in v1.x:\n\n### Full TypeScript support\n\n```typescript\nimport { type RunActionResponse } from \"@pipedream/sdk\";\n\nconst result: RunActionResponse = await client.actions.run({\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n});\n```\n\n### Pagination support\n\n```javascript\n// Automatic pagination\nfor await (const account of client.accounts.list({\n externalUserId: \"jverce\",\n})) {\n console.log(account);\n}\n\n// Manual pagination\nconst firstPage = await client.accounts.list({\n externalUserId: \"jverce\",\n limit: 20,\n});\n\nif (firstPage.hasNextPage()) {\n const nextPage = await firstPage.getNextPage();\n console.log(nextPage.data);\n}\n```\n\n### Enhanced error handling\n\n```javascript\nimport { PipedreamError } from \"@pipedream/sdk\";\n\ntry {\n await client.actions.run({\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n });\n} catch (error) {\n if (error instanceof PipedreamError) {\n console.error(\"API Error:\", error.status, error.message);\n }\n}\n```\n\n### Request options\n\n```javascript\n// Custom timeout\nconst result = await client.actions.run(\n {\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n },\n {\n timeoutInSeconds: 30,\n }\n);\n\n// Retry configuration\nconst result = await client.actions.run(\n {\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n },\n {\n maxRetries: 3,\n }\n);\n\n// Custom headers\nconst result = await client.actions.run(\n {\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n },\n {\n headers: {\n \"X-Custom-Header\": \"value\",\n },\n }\n);\n```\n\n### Abort signals\n\n```javascript\nconst controller = new AbortController();\n\n// Abort after 5 seconds\nsetTimeout(() => controller.abort(), 5000);\n\ntry {\n const result = await client.actions.run(\n {\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n },\n {\n abortSignal: controller.signal,\n }\n );\n} catch (error) {\n if (error.name === \"AbortError\") {\n console.log(\"Request was aborted\");\n }\n}\n```\n\n### Raw response access\n\n```javascript\nconst response = await client.actions\n .run({\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n })\n .withRawResponse();\n\nconsole.log(response.data); // Parsed response data\nconsole.log(response.rawResponse); // Original Response object\n```\n\n## Browser/Server Environment Separation\n\nThe v2.x SDK provides proper environment separation to ensure browser-safe\nimports without Node.js dependencies.\n\n### Package.json Export Structure\n\nThe SDK uses conditional exports to automatically serve the right code:\n\n```json\n{\n \"exports\": {\n \".\": {\n \"browser\": \"./dist/esm/browser/index.mjs\", // Browser gets browser-only code\n \"import\": \"./dist/esm/index.mjs\", // Node.js gets full functionality\n \"require\": \"./dist/cjs/index.js\"\n },\n \"./browser\": {\n \"import\": \"./dist/esm/browser/index.mjs\" // Explicit browser import\n },\n \"./server\": {\n \"import\": \"./dist/esm/index.mjs\", // Explicit server import\n \"require\": \"./dist/cjs/index.js\"\n }\n }\n}\n```\n\n### Import Recommendations\n\n```typescript\n// For browser applications - avoids Node.js dependencies\nimport { PipedreamClient, createFrontendClient } from \"@pipedream/sdk/browser\";\n\n// For server applications - includes full functionality\nimport { PipedreamClient } from \"@pipedream/sdk/server\";\n\n// Automatic resolution (recommended for most cases)\nimport { PipedreamClient } from \"@pipedream/sdk\";\n```\n\nThis ensures:\n\n- **Browser bundlers** automatically get the browser-safe version\n- **Node.js environments** get the full SDK with all server functionality\n- **Smaller bundle sizes** for browser applications\n- **No Node.js dependency errors** in browser builds\n\n## Additional namespaces\n\nThe v2.x SDK includes several new namespaces not available in v1.x:\n\n- `apps` - Browse available apps and integrations\n- `appCategories` - List app categories\n- `components` - Work with components\n- `deployedTriggers.listEvents()` - List events for a deployed trigger\n- `deployedTriggers.listWebhooks()` - List webhooks for a deployed trigger\n- `deployedTriggers.listWorkflows()` - List workflows for a deployed trigger\n- `projects` - Get project information\n- `proxy` - Work with HTTP proxy endpoints\n- `triggers` - Additional trigger operations beyond deployment\n- `users` - User information\n- `oauthTokens` - OAuth token management\n- `workflows` - Invoke workflows\n\n## Partial migration\n\nIf you are unable to migrate all your code at once, you can use the new SDK\nalongside the old one by leveraging package aliases. This allows you to migrate\nincrementally without breaking your existing codebase. To do this, you can\ninstall the new SDK with an alias:\n\n```bash\nnpm install @pipedream/sdk-v2@npm:@pipedream/sdk@^2.0.0 --save\n```\n\nThen, in your code, you can import the new SDK with the alias:\n\n```javascript\nimport { createBackendClient } from \"@pipedream/sdk\";\nimport { PipedreamClient } from \"@pipedream/sdk-v2\";\n\nconst clientOpts = {\n credentials: {\n clientId,\n clientSecret,\n },\n projectId,\n environment,\n};\n\nconst client = createBackendClient(clientOpts);\nconst newClient = new PipedreamClient({\n ...clientOpts.credentials,\n projectEnvironment: clientOpts.environment,\n projectId: clientOpts.projectId,\n});\n\n// Use old client for existing code\nconst oldResult = await client.runAction({\n externalUserId: \"jverce\",\n actionId: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n});\n\n// Use new client for migrated code\nconst newResult = await newClient.actions.run({\n externalUserId: \"jverce\",\n id: \"gitlab-list-commits\",\n configuredProps: {\n gitlab: { authProvisionId: \"apn_kVh9AoD\" },\n projectId: 45672541,\n refName: \"main\",\n },\n});\n```\n\n## Important removed functionality\n\nSome methods from v1.x have been removed or changed significantly in v2.x:\n\n1. **`deleteAccountsByApp()`** - This bulk deletion method is no longer\n available. You'll need to list accounts for an app and delete them\n individually.\n\n2. **`rawAccessToken()`** - The method has been changed to a getter property.\n For the server-side SDK (`Pipedream` class from `@pipedream/sdk/server` or\n the wrapper), you can access the raw access token via the `rawAccessToken`\n getter property which returns a Promise:\n\n ```javascript\n // v1.x (old)\n const token = await client.rawAccessToken();\n\n // v2.x (new)\n const token = await client.rawAccessToken;\n ```\n\n For the base `PipedreamClient` class, token management is handled internally.\n\n3. **Alternative method names** - The v1.x SDK provided alternative method names\n (e.g., `actionRun()` as an alias for `runAction()`). These are no longer\n available in v2.x.\n\n4. **`userId` parameter** - The deprecated `userId` parameter has been removed.\n Always use `externalUserId` instead.\n\n## Migration checklist\n\n- [ ] Update import statements from `createBackendClient`/`createFrontendClient`\n to `PipedreamClient`.\n- [ ] Update client initialization to use `new PipedreamClient()` for both\n server-side and browser-side.\n- [ ] Convert all method calls to use namespaced format (e.g.,\n `client.actions.run()`).\n- [ ] Keep parameter names in camelCase in your TypeScript/JavaScript code (the\n SDK handles conversion to snake_case automatically).\n- [ ] Pass `externalUserId` to methods instead of setting it on the client.\n- [ ] Update error handling to use `PipedreamError` type.\n- [ ] Review and implement new features like pagination and request options\n where beneficial.\n- [ ] Replace any usage of removed methods with their alternatives.\n- [ ] Update any code using `rawAccessToken()` - for server-side code, you can\n access `client.rawAccessToken` as a getter property that returns a Promise.\n- [ ] For raw response access, use `.withRawResponse()` method chaining instead\n of passing `includeRawResponse` option.\n- [ ] Test all migrated code thoroughly.\n- [ ] Remove the old SDK dependency once migration is complete.\n",[185],"0d220792-a30b-11f0-be0b-0224a6c84d84","AGENTS.md","0d220864-a30b-11f0-be0b-0224a6c84d84",4,["D",1759792830827],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider\n refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure\n about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious\n operations)\n- Follow modern ES6+ conventions and functional programming practices if\n possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = \"todo_app_users_2\";\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(\n `SELECT * FROM ${TABLE_NAME} WHERE id = ?`,\n [1]\n);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add\n\\_2 or \\_3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [{ role: \"user\", content: \"Say hello in a creative way\" }],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({\n subject: \"Hi\",\n text: \"Hi\",\n html: \"

Hi

\",\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport {\n parseProject,\n readFile,\n serveFile,\n} from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\"\nurls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's _extremely importing_ to note that `parseProject` and other\nStandard Library utilities ONLY RUN ON THE SERVER. If you need access to this\ndata on the client, run it in the server and pass it to the client by splicing\nit into the HTML page or by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use\n `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})`\n instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode\n symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use:\n `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys)\n unless otherwise specified\n- **View Source:** Add a view source link by importing & using\n `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the\n client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add\n `` to HTML to capture\n client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local\n resolution; Avoid catches that merely log or return 500s. Let errors bubble up\n with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but\n generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure\n compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer\n simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with\n `?deps=react@18.2.0,react-dom@18.2.0` and start the file with\n `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same\n version\n- **Styling:** Default to using TailwindCSS via\n `` unless otherwise\n specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project\n files:\n\n ```ts\n import {\n readFile,\n serveFile,\n } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n\n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to\n see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:**\n\n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of\n React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with\n `export default app.fetch // This is the entry point for HTTP vals`\n",[192],"0d1cecda-a30b-11f0-9a0c-0224a6c84d84",".vtignore","0d1ced8e-a30b-11f0-9a0c-0224a6c84d84",3,["D",1759792830828],".git\n.vscode\n.cursor\n.DS_Store\nnode_modules\nvendor",[199],"9026501a-a30d-11f0-86be-0224a6c84d84",".gitignore","902650c4-a30d-11f0-86be-0224a6c84d84",13,["D",1759793909674],"# Created by https://www.toptal.com/developers/gitignore/api/deno\n# Edit at https://www.toptal.com/developers/gitignore?templates=deno\n\n### Deno ###\n/.idea/\n/.vscode/\n\n/node_modules\n\n.env\n*.orig\n*.pyc\n*.swp\n\n# End of https://www.toptal.com/developers/gitignore/api/deno",[206],"781faefc-a309-11f0-99c8-0224a6c84d84","sdk","0199bbc9-3b47-704a-8f97-12328bf0126c",["D",1759792151298],"directory",[213],"781fab8c-a309-11f0-99c8-0224a6c84d84","frontend","0199bbc9-3b47-704a-8f97-088f0ffb5fc0",["D",1759792151298],[219],"781f7374-a309-11f0-99c8-0224a6c84d84","backend","0199bbc9-3b47-704a-8f96-ccf6e499cd7f",["D",1759792151298],[224],"pulls","branches","forks","envVars",{"_235":194,"_237":63},"connections",{"_235":63,"_236":63},"count","unfilledCount","emptyCount",{"_44":223,"_32":224,"_30":225,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":436,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_269":437,"_27":438},{"_44":431,"_32":33,"_30":31,"_156":225,"_42":43,"_41":14,"_158":25,"_39":432,"_13":433,"_34":35,"_36":38,"_24":25,"_162":-5,"_269":434,"_27":435},{"_44":423,"_32":424,"_30":57,"_156":225,"_42":43,"_41":425,"_158":25,"_39":426,"_13":323,"_34":427,"_36":428,"_24":25,"_162":-5,"_269":429,"_27":430},{"_44":415,"_32":416,"_30":417,"_156":225,"_42":43,"_41":418,"_158":25,"_39":419,"_13":160,"_34":35,"_36":420,"_24":25,"_162":-5,"_269":421,"_27":422},{"_44":408,"_32":409,"_30":410,"_156":225,"_42":43,"_41":160,"_158":25,"_39":411,"_13":63,"_34":35,"_36":412,"_24":25,"_162":-5,"_269":413,"_27":414},{"_44":218,"_32":219,"_30":220,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":405,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_269":406,"_27":407},{"_44":401,"_32":379,"_30":374,"_156":220,"_42":43,"_41":160,"_158":59,"_39":402,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_269":403,"_27":404},{"_44":394,"_32":395,"_30":396,"_156":374,"_42":43,"_41":160,"_158":25,"_39":397,"_13":63,"_34":35,"_36":398,"_24":25,"_162":-5,"_269":399,"_27":400},{"_44":387,"_32":388,"_30":389,"_156":374,"_42":43,"_41":160,"_158":25,"_39":390,"_13":63,"_34":35,"_36":391,"_24":25,"_162":-5,"_269":392,"_27":393},{"_44":380,"_32":381,"_30":382,"_156":374,"_42":43,"_41":160,"_158":25,"_39":383,"_13":63,"_34":35,"_36":384,"_24":25,"_162":-5,"_269":385,"_27":386},{"_44":371,"_32":372,"_30":373,"_156":374,"_42":43,"_41":160,"_158":25,"_39":375,"_13":63,"_34":35,"_36":376,"_24":25,"_162":-5,"_269":377,"_27":378},{"_44":367,"_32":312,"_30":307,"_156":220,"_42":43,"_41":160,"_158":59,"_39":368,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_269":369,"_27":370},{"_44":359,"_32":360,"_30":361,"_156":307,"_42":43,"_41":362,"_158":25,"_39":363,"_13":167,"_34":35,"_36":364,"_24":25,"_162":-5,"_269":365,"_27":366},{"_44":352,"_32":353,"_30":354,"_156":307,"_42":43,"_41":160,"_158":25,"_39":355,"_13":63,"_34":35,"_36":356,"_24":25,"_162":-5,"_269":357,"_27":358},{"_44":344,"_32":345,"_30":346,"_156":307,"_42":43,"_41":347,"_158":25,"_39":348,"_13":167,"_34":35,"_36":349,"_24":25,"_162":-5,"_269":350,"_27":351},{"_44":336,"_32":337,"_30":338,"_156":307,"_42":43,"_41":339,"_158":25,"_39":340,"_13":160,"_34":35,"_36":341,"_24":25,"_162":-5,"_269":342,"_27":343},{"_44":328,"_32":329,"_30":330,"_156":307,"_42":43,"_41":331,"_158":25,"_39":332,"_13":160,"_34":35,"_36":333,"_24":25,"_162":-5,"_269":334,"_27":335},{"_44":320,"_32":321,"_30":322,"_156":307,"_42":43,"_41":323,"_158":25,"_39":324,"_13":160,"_34":35,"_36":325,"_24":25,"_162":-5,"_269":326,"_27":327},{"_44":313,"_32":314,"_30":315,"_156":307,"_42":43,"_41":160,"_158":25,"_39":316,"_13":63,"_34":35,"_36":317,"_24":25,"_162":-5,"_269":318,"_27":319},{"_44":304,"_32":305,"_30":306,"_156":307,"_42":43,"_41":160,"_158":25,"_39":308,"_13":63,"_34":35,"_36":309,"_24":25,"_162":-5,"_269":310,"_27":311},{"_44":212,"_32":213,"_30":214,"_156":-5,"_42":43,"_41":160,"_158":59,"_39":301,"_13":63,"_34":216,"_36":-5,"_24":25,"_162":-5,"_269":302,"_27":303},{"_44":293,"_32":294,"_30":295,"_156":214,"_42":43,"_41":296,"_158":25,"_39":297,"_13":194,"_34":35,"_36":298,"_24":25,"_162":-5,"_269":299,"_27":300},{"_44":205,"_32":206,"_30":207,"_156":-5,"_42":43,"_41":208,"_158":59,"_39":290,"_13":63,"_34":20,"_36":210,"_24":25,"_162":-5,"_269":291,"_27":292},{"_44":198,"_32":199,"_30":200,"_156":-5,"_42":43,"_41":201,"_158":59,"_39":287,"_13":63,"_34":20,"_36":203,"_24":25,"_162":-5,"_269":288,"_27":289},{"_44":191,"_32":192,"_30":193,"_156":-5,"_42":43,"_41":194,"_158":59,"_39":284,"_13":63,"_34":20,"_36":196,"_24":25,"_162":-5,"_269":285,"_27":286},{"_44":184,"_32":185,"_30":186,"_156":-5,"_42":43,"_41":187,"_158":25,"_39":281,"_13":63,"_34":20,"_36":189,"_24":25,"_162":-5,"_269":282,"_27":283},{"_44":177,"_32":178,"_30":179,"_156":-5,"_42":43,"_41":180,"_158":25,"_39":278,"_13":63,"_34":20,"_36":182,"_24":25,"_162":-5,"_269":279,"_27":280},{"_44":171,"_32":172,"_30":173,"_156":-5,"_42":43,"_41":160,"_158":25,"_39":275,"_13":63,"_34":20,"_36":175,"_24":25,"_162":-5,"_269":276,"_27":277},{"_44":164,"_32":165,"_30":166,"_156":-5,"_42":43,"_41":167,"_158":25,"_39":272,"_13":63,"_34":20,"_36":169,"_24":25,"_162":-5,"_269":273,"_27":274},{"_44":153,"_32":154,"_30":155,"_156":-5,"_42":43,"_41":157,"_158":25,"_39":268,"_13":160,"_34":20,"_36":161,"_24":25,"_162":-5,"_269":270,"_27":271},["D",1759793909808],"children",[],[154],["D",1759792830801],[],[165],["D",1759792151298],[],[172],["D",1759793909674],[],[178],["D",1759793909696],[],[185],["D",1759792830827],[],[192],["D",1759792830828],[],[199],["D",1759793909674],[],[206],"904e72fc-a30d-11f0-91b1-0224a6c84d84","sdk.ts","0199bbc9-3b47-704a-8f97-0dfefe6dd117",19,["D",1759793909923],"export async function actionRun(args: any) {\n\tconst response = await fetch(\n\t\t\"https://pipedream.val.run/api/pipedream/action\",\n\t\t{\n\t\t\tmethod: \"POST\",\n\t\t\tbody: JSON.stringify(args),\n\t\t\theaders: {\n\t\t\t\tCookie: `vt_api_key=${Deno.env.get(\"valtown\")}`,\n\t\t\t},\n\t\t},\n\t);\n\treturn response.json();\n}\n\nexport async function proxyRun(args: any) {\n\tconst response = await fetch(\n\t\t\"https://pipedream.val.run/api/pipedream/proxy\",\n\t\t{\n\t\t\tmethod: \"POST\",\n\t\t\tbody: JSON.stringify(args),\n\t\t\theaders: {\n\t\t\t\tCookie: `vt_api_key=${Deno.env.get(\"valtown\")}`,\n\t\t\t},\n\t\t},\n\t);\n\treturn response.json();\n}\n",[],[213,294],["D",1759792151298],[259],[213],"781fa722-a309-11f0-99c8-0224a6c84d84","TriggersPage.tsx","0199bbc9-3b47-704a-8f97-011d49ea7179","0199bbc9-3b47-704a-8f97-06513672dd57",["D",1759792151298],"/** @jsxImportSource https://esm.sh/react@18.2.0? */\nimport { Layout } from \"../components/Layout.tsx\";\n\nexport default function({ triggers, user }) {\n return (\n \n

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}",[],[219,312,305],"pages","781fa420-a309-11f0-99c8-0224a6c84d84","TriggerEventsPage.tsx","0199bbc9-3b47-704a-8f96-ff33da0c91c8",["D",1759792151298],"/** @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}",[],[219,312,314],"0d2dcdc0-a30b-11f0-bcf4-0224a6c84d84","NewTriggerPage.tsx","0199bbc9-3b47-704a-8f96-fb2f4dba680c",6,["D",1759792830944],"/** @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 { useState } from \"https://esm.sh/react@18.2.0\";\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 />\n

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

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

\n \n

\n )}\n

\n \n \n );\n}",[],[219,312,321],"0d32d28e-a30b-11f0-9a0c-0224a6c84d84","NewConnectionPage.tsx","0199bbc9-3b47-704a-8f96-f44d1aac143b",7,["D",1759792830945],"/** @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 { useState } from \"https://esm.sh/react@18.2.0\";\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}",[],[219,312,329],"0d2900a6-a30b-11f0-a711-0224a6c84d84","NewActionPage.tsx","0199bbc9-3b47-704a-8f96-f140bd778a5d",5,["D",1759792830874],"/** @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 { useState } from \"https://esm.sh/react@18.2.0\";\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}",[],[219,312,337],"90341704-a30d-11f0-85d8-0224a6c84d84","LoginPage.tsx","0199bbc9-3b47-704a-8f96-ef32f603f279",15,["D",1759793909680],"/** @jsxImportSource https://esm.sh/react@18.2.0? */\nimport { useState } from \"https://esm.sh/react@18.2.0?\";\n\nexport default function ({ onLogin }) {\n\tconst [apiKey, setApiKey] = useState(\"\");\n\tconst [isLoading, setIsLoading] = useState(false);\n\tconst [error, onError] = useState(\"\");\n\n\tconst handleSubmit = async (e: React.FormEvent) => {\n\t\te.preventDefault();\n\t\tsetIsLoading(true);\n\t\tonError(\"\");\n\t\ttry {\n\t\t\tconst response = await fetch(\"/auth/login\", {\n\t\t\t\tmethod: \"POST\",\n\t\t\t\theaders: { \"Content-Type\": \"application/json\" },\n\t\t\t\tbody: JSON.stringify({ apiKey }),\n\t\t\t});\n\t\t\tif (response.ok) window.location.href = \"/\";\n\t\t} catch (err) {\n\t\t\tconsole.error(err);\n\t\t\tonError(err.message);\n\t\t} finally {\n\t\t\tsetIsLoading(false);\n\t\t}\n\t};\n\n\treturn (\n\t\t

\n\t\t\t

\n\t\t\t\t

\n\t\t\t\t\tVal Town + Pipedream Connect\n\t\t\t\t

\n\t\t\t\t

\n\t\t\t\t\t\n\t\t\t\t\t\tView source\n\t\t\t\t\t\n\t\t\t\t

\n\t\t\t\t

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

\n\t\t\t

\n\n\t\t\t{error && (\n\t\t\t\t

\n\t\t\t\t\t{error}\n\t\t\t\t

\n\t\t\t)}\n\n\t\t\t

\n\t\t\t\t

To login:

\n\t\t\t\t

\n\t\t\t\t\t1. Create an API key:{\" \"}\n\t\t\t\t\t\n\t\t\t\t\t\thttps://www.val.town/settings/api\n\t\t\t\t\t\n\t\t\t\t

\n\t\t\t\t

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

\n\t\t\t

\n\n\t\t\t

\n\t);\n}\n",[],[219,312,345],"781f883c-a309-11f0-99c8-0224a6c84d84","HomePage.tsx","0199bbc9-3b47-704a-8f96-ea71466e4f51",["D",1759792151298],"/** @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}",[],[219,312,353],"4bc0fbbc-a319-11f0-8f1a-0224a6c84d84","ConnectionsPage.tsx","0199bbc9-3b47-704a-8f96-e51ba162ac10",23,["D",1759798948877],"/** @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

\n Your Connections\n

\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 {account.id || \"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 ${\n account.app?.name || \"this app\"\n }?`,\n )\n ) {\n e.preventDefault();\n }\n }}\n >\n \n Delete\n \n \n

\n ))}\n \n )}\n \n );\n}",[],[219,312,360],"781faa74-a309-11f0-99c8-0224a6c84d84",["D",1759792151298],[250,251,252,253,254,255,256,257],[219,312],"781f795a-a309-11f0-99c8-0224a6c84d84","Layout.tsx","0199bbc9-3b47-704a-8f96-dcc9e5154085","0199bbc9-3b47-704a-8f96-e315d5e479ca",["D",1759792151298],"/** @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}",[],[219,379,372],"components","781f77b6-a309-11f0-99c8-0224a6c84d84","ExperimentalWarning.tsx","0199bbc9-3b47-704a-8f96-d91d34030a91",["D",1759792151298],"/** @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}",[],[219,379,381],"781f769e-a309-11f0-99c8-0224a6c84d84","ErrorMessage.tsx","0199bbc9-3b47-704a-8f96-d5294b709bae",["D",1759792151298],"/** @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}",[],[219,379,388],"781f74d2-a309-11f0-99c8-0224a6c84d84","CodeSnippet.tsx","0199bbc9-3b47-704a-8f96-d2733449f36d",["D",1759792151298],"/** @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}",[],[219,379,395],"781f83e6-a309-11f0-99c8-0224a6c84d84",["D",1759792151298],[245,246,247,248],[219,379],["D",1759792151298],[244,249],[219],"781f6b54-a309-11f0-99c8-0224a6c84d84","render-react-page.tsx","0199bbc9-3b47-704a-8f96-c9d827a654bc",["D",1759792151298],"/** @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}",[],[224,409],"9056012a-a30d-11f0-9bbb-0224a6c84d84","pipedream.tsx","0199bbc9-3b47-704a-8f96-c647ed191f9a",20,["D",1759793909983],"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\tenvironment: Deno.env.get(\"PIPEDREAM_PROJECT_ENVIRONMENT\") as\n\t\t| \"development\"\n\t\t| \"production\",\n\tcredentials: {\n\t\tclientId: Deno.env.get(\"PIPEDREAM_CLIENT_ID\") as string,\n\t\tclientSecret: Deno.env.get(\"PIPEDREAM_CLIENT_SECRET\") as string,\n\t},\n\tprojectId: Deno.env.get(\"PIPEDREAM_PROJECT_ID\"),\n});\n\napp.post(\"/token\", async (c) => {\n\tconst user = await getCurrentUser(c);\n\tif (!user) {\n\t\treturn c.json({ error: \"Not authenticated\" }, 401);\n\t}\n\n\tconst data = await pd.createConnectToken({\n\t\texternal_user_id: getLatestUserID(user),\n\t\tallowed_origins: [new URL(c.req.url).origin],\n\t});\n\tconsole.log(data);\n\treturn 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\tconst user = await getCurrentUser(c);\n\tif (!user) {\n\t\treturn c.json({ error: \"Not authenticated\" }, 401);\n\t}\n\n\tconsole.log(\"Running action for:\", user);\n\n\ttry {\n\t\tconst args = await c.req.json();\n\t\tif (args.externalUserId) {\n\t\t\t// To be doubly sure of authentication\n\t\t\treturn c.json({ error: \"Do not include externalUserId\" }, 400);\n\t\t}\n\n\t\tconst result = await pd.actionRun({\n\t\t\t...args,\n\t\t\texternalUserId: getLatestUserID(user),\n\t\t});\n\n\t\treturn c.json(result);\n\t} catch (error) {\n\t\tconsole.error(\"Failed to execute action:\", error);\n\t\treturn c.json({ error: \"Failed to execute action\" }, 500);\n\t}\n});\n\n// Pipedream Proxy Proxy\n// https://pipedream.com/docs/connect/api-proxy/\napp.post(\"/proxy\", async (c) => {\n\tconst user = await getCurrentUser(c);\n\tif (!user) {\n\t\treturn c.json({ error: \"Not authenticated\" }, 401);\n\t}\n\n\tconsole.log(\"Running proxy for:\", user);\n\n\ttry {\n\t\tconst args = await c.req.json();\n\t\tconst result = await pd.makeProxyRequest(\n\t\t\t{\n\t\t\t\tsearchParams: {\n\t\t\t\t\taccount_id: args.account_id,\n\t\t\t\t\texternal_user_id: getLatestUserID(user),\n\t\t\t\t},\n\t\t\t},\n\t\t\targs.fetch,\n\t\t);\n\n\t\treturn c.json(result);\n\t} catch (error) {\n\t\tconsole.error(\"Failed to execute action:\", error);\n\t\treturn c.json({ error: \"Failed to execute action\" }, 500);\n\t}\n});\n\napp.post(\"/connections/:id/delete\", async (c) => {\n\tconst user = await getCurrentUser(c);\n\tif (!user) {\n\t\treturn c.json({ error: \"Not authenticated\" }, 401);\n\t}\n\n\tconst id = c.req.param(\"id\");\n\tconst account = await pd.getAccountById(id);\n\tif (account.external_id !== getLatestUserID(user)) {\n\t\treturn c.json({ error: \"Not authorized\" }, 401);\n\t}\n\tawait pd.deleteAccount(id);\n\treturn c.redirect(\"/connections\");\n});\n\napp.post(\"/triggers/:id/delete\", async (c) => {\n\tconst user = await getCurrentUser(c);\n\tif (!user) {\n\t\treturn c.json({ error: \"Not authenticated\" }, 401);\n\t}\n\n\tconst id = c.req.param(\"id\");\n\t// TODO: confirm with Pipedream that this enforces the correct externalUserId\n\tawait pd.deleteTrigger({\n\t\texternalUserId: getLatestUserID(user),\n\t\tid,\n\t});\n\treturn c.redirect(\"/triggers\");\n});\n",[],[224,416],"773f253a-a32c-11f0-b9bc-0224a6c84d84","main.tsx",33,["D",1759807182290],"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\nexport type User = ValTown.Me.Profile.ProfileRetrieveResponse;\n\ntype Variables = {\n users: string;\n};\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``;\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;",[],[224,424],"7c03ded0-a32c-11f0-80f8-0224a6c84d84",["D",1759807190286],8,[],[224,33],["D",1759792151298],[239,240,241,242],[224],["D",1759792151298],{"_101":100,"_108":104},{"_101":100,"_102":-5,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":86,"_32":87,"_44":43,"_88":45,"_89":90,"_91":92,"_93":51,"_94":95,"_96":97,"_98":46,"_99":100},"ctx",{"_79":-5,"_130":476,"_477":478,"_479":480,"_481":25,"_482":25,"_483":25,"_484":59,"_485":-5,"_486":-7,"_487":-7,"_488":63,"_489":25,"_490":25,"_491":-5,"_492":25,"_493":25,"_494":25,"_495":-5},"ENV",{"_447":448,"_449":450,"_451":87,"_452":453,"_454":455,"_456":457,"_458":459,"_460":461,"_462":463,"_464":465,"_466":467,"_468":469,"_470":471,"_472":473,"_474":475},"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"]

Diff · v34