[{"_1":2,"_307":-5,"_308":-5},"loaderData",{"_3":4,"_91":92,"_236":237},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e3ca0a77ab07ff2ce3097208ffd6aa0e378d3c47","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":43,"_98":99,"_100":-7,"_101":102,"_151":152,"_203":204,"_205":206,"_212":213,"_167":214,"_217":218,"_224":225,"_232":22,"_233":22,"_234":235},"handle","stevekrouse","name","setup-clay-proxy-2","branchName","path","main.tsx","version","project",{"_103":104,"_95":96,"_105":106,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_150":22},"id","c8cabd44-7481-11f0-aadb-0224a6c84d84","createdAt",["D",1754676121652],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","pinPreview","screenshotVersion","likeCount","e81e7335-6d4c-4764-a902-d0962bbfa9f7","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_129":130},"profileImageUrl","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","org",{"_93":94,"_133":130},"avatar","branch",{"_100":136,"_95":43,"_103":137,"_138":104,"_139":140,"_141":142,"_143":110,"_144":145,"_146":147,"_148":96,"_149":94},48,"c8ceb4ee-7481-11f0-aadb-0224a6c84d84","projectId","forkedBranchId","8b66794e-747b-11f0-9f8e-0224a6c84d84","forkedBranchVersion",63,"forkedProjectPrivacy","forkedProjectId","8b62acec-747b-11f0-9f8e-0224a6c84d84","forkedProjectOrgId","2019e55b-c541-4c51-bef0-008eef10ef88","projectName","userHandle","isOwned","tree",[153,175,185,194],{"_103":154,"_95":155,"_156":157,"_158":-5,"_159":137,"_160":161,"_162":163,"_105":164,"_100":165,"_166":167,"_168":169,"_170":22,"_171":-5,"_172":173,"_98":174},"971afe64-7484-11f0-b0d5-0224a6c84d84","README.md","fileId","01988ad8-d085-76e8-8e23-c3003381f0fe","parentId","branchId","branchVersion",37,"latest",true,["D",1754677326795],8,"fileType","file","content","# Clay API + SDK\n\nSetup your own API / SDK to enrich data with Clay.\n\n# Setup\n\n1. Remix this val\n\n2. Set up a Clay workbook with both a `Webhook column` and an `HTTP API` column\n (or use\n [this template](https://app.clay.com/shared-workbook/share_0t0oqpwRR8KDw4RRQnZ))\n\n3. Copy your Clay workbook's `Webhook column` URL\n\n ![CleanShot 2025-08-08 at 13.23.47@2x.png](https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/48cd9c4d-2990-480f-9d07-fb09e2282500/public)\n\n4. Set that as `CLAY_WEBHOOK_URL` in\n this val's env variables\n\n5. Copy [main.tsx](./main.tsx)'s HTTP endpoint URL\n\n6. Paste that in the `HTTP API` column in Clay, with `/clay-webhook` on the end\n of it\n\n7. Try it out: click Run in [demo.ts](./demo.ts)","deleted","label","children",[],[155],{"_103":176,"_95":177,"_156":178,"_158":-5,"_159":137,"_160":161,"_162":163,"_105":179,"_100":180,"_166":181,"_168":182,"_170":22,"_171":-5,"_172":183,"_98":184},"971b0cec-7484-11f0-b0d5-0224a6c84d84","demo.ts","304108a2-7482-11f0-b2a5-0224a6c84d84",["D",1754677326795],5,"script","import { clay } from \"./sdk.ts\";\n\nconst result = await clay({\n email: \"charmainekmlee@gmail.com\",\n});\n\nconsole.log(result);",[],[177],{"_103":186,"_95":99,"_156":187,"_158":-5,"_159":137,"_160":188,"_162":163,"_105":189,"_100":165,"_166":190,"_168":191,"_170":22,"_171":-5,"_172":192,"_98":193},"adb8be26-7485-11f0-97a5-0224a6c84d84","01988ad8-d085-76e8-8e23-c589ddb99187",44,["D",1754677794236],"http","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\nimport ValTown from \"npm:@valtown/sdk\";\n\nconst vt = new ValTown();\nconst me = vt.me.profile.retrieve();\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n // authentication\n const token = parseBearerString(c.req.header(\"Authorization\"))\n const vt2 = new ValTown({ bearerToken: token});\n const user = await vt2.me.profile.retrieve();\n if ((await me).id !== user.id) return new Response(\"Unauthorized\", { status: 401})\n \n \n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",[],[99],{"_103":195,"_95":196,"_156":197,"_158":-5,"_159":137,"_160":136,"_162":163,"_105":198,"_100":199,"_166":181,"_168":200,"_170":22,"_171":-5,"_172":201,"_98":202},"e54c5d5c-7485-11f0-8312-0224a6c84d84","sdk.ts","01988ad8-d085-76e8-8e23-c84b88af09e4",["D",1754677887478],31,"import { listFiles } from \"https://esm.town/v/std/utils/index.ts\";\n\nexport async function clay(data: any): Promise {\n console.log(await getClayAPIURL());\n const response = await fetch(`${await getClayAPIURL()}enrich`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${Deno.env.get(\"valtown\")}`,\n },\n body: JSON.stringify(data),\n });\n\n if (!response.ok) {\n throw new Error(`Clay API error: ${response.status}`);\n }\n\n return response.json();\n}\n\nlet CLAY_API_URL: string | undefined;\n\n// This SDK calls the HTTP proxy defined in ./main.tsx.\n// This code gets that file's HTTP endpoint via the Val Town Rest API.\n// You could skip this lookup by hardcoding CLAY_API_URL to the HTTP endpoint.\nasync function getClayAPIURL() {\n<<<<<<< main\n if (CLAY_API_URL) return removeTrailingSlash(CLAY_API_URL);\n=======\n if (CLAY_API_URL) removeTrailingSlash(CLAY_API_URL);\n>>>>>>> main\n const files = await listFiles(import.meta.url);\n // First look for main.tsx\n let endpoint = files.find(\n (file) => file.path === \"main.tsx\" && file.links.endpoint,\n ).links.endpoint;\n // Then just look for any HTTP file\n endpoint ||= files.find(\n (file) => file.links.endpoint,\n ).links.endpoint;\n CLAY_API_URL = endpoint;\n return removeTrailingSlash(CLAY_API_URL);\n}\n\nfunction removeTrailingSlash(url: string) {\n return url.endsWith(\"/\") ? url.slice(0, -1) : url;\n}",[],[196],"files",[153,175,185,194],"counts",{"_207":32,"_208":209,"_210":32,"_211":209},"pulls","branches",1,"forks","envVars","contents",[],{"_103":186,"_159":137,"_156":187,"_95":99,"_168":191,"_166":190,"_100":165,"_158":-5,"_105":215,"_160":188,"_171":-5,"_98":216},["D",1754677794236],[99],"upstreamProject",{"_103":145,"_95":219,"_111":220,"_112":-5,"_109":110,"_23":221},"clay-api-proxy","Set up your own Clay proxy",{"_93":222,"_129":223},"charmaine","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ4cFpFME5pSXNZamJNd296dlZSYVJ0OVF1RSJ9","upstreamBranch",{"_103":140,"_105":226,"_227":228,"_95":43,"_138":145,"_100":229,"_139":-5,"_141":-5,"_230":231,"_107":-5,"_150":22,"_109":110,"_149":222,"_16":147,"_148":219},["D",1754673441650],"updatedAt",["D",1754684852060],73,"lockfileKey","1755612402528-esm.town_v_charmaine_clay-api-proxy@73-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_93":94,"_95":96,"_97":43,"_98":99,"_101":238,"_167":243,"_246":247,"_292":293,"_304":-7,"_305":32,"_306":22},{"_103":104,"_95":96,"_105":239,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":240,"_131":241,"_134":242,"_150":22},["D",1754676121652],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":140,"_141":142,"_143":110,"_144":145,"_146":147,"_148":96,"_149":94},{"_103":186,"_95":99,"_156":187,"_158":-5,"_159":137,"_160":188,"_162":163,"_105":244,"_100":165,"_166":190,"_168":191,"_170":22,"_171":-5,"_98":245},["D",1754677794236],[99],"history",[248,250,256,261,265,271,277,283,288],{"_103":186,"_159":137,"_156":187,"_95":99,"_168":191,"_166":190,"_100":165,"_158":-5,"_105":249,"_160":188,"_171":-5},["D",1754677794236],{"_103":251,"_159":137,"_156":187,"_95":99,"_168":252,"_166":190,"_100":253,"_158":-5,"_105":254,"_160":255,"_171":-5},"9f9d1b08-7484-11f0-97a5-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\nimport ValTown from \"npm:@valtown/sdk\";\n\nconst vt = new ValTown();\nconst me = vt.me.profile.retrieve();\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n // authentication\n const token = parseBearerString(c.req.header(\"Authorization\"))\n const vt2 = new ValTown({ bearerToken: token});\n const user = await vt2.me.profile.retrieve();\n if ((await me).id !== user.id) return new Repsonse(\"Unauthorized\", { status: 401})\n \n \n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",7,["D",1754677341073],38,{"_103":257,"_159":137,"_156":187,"_95":99,"_168":258,"_166":190,"_100":259,"_158":-5,"_105":260,"_160":161,"_171":-5},"971b0634-7484-11f0-b0d5-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\nimport ValTown from \"npm:@valtown/sdk\";\n\nconst vt = new ValTown();\nconst me = vt.me.profile.retrieve();\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n // authentication\n const token = parseBearerString(c.req.header(\"Authorization\"))\n const vt2 = new ValTown({ bearer: token});\n const user = await vt2.me.profile.retrieve();\n if ((await me).id !== user.id) return new Repsonse(\"Unauthorized\", { status: 401})\n \n \n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",6,["D",1754677326795],{"_103":262,"_159":137,"_156":187,"_95":99,"_168":258,"_166":190,"_100":180,"_158":-5,"_105":263,"_160":264,"_171":-5},"81efce0c-7484-11f0-a84b-0224a6c84d84",["D",1754677291280],36,{"_103":266,"_159":137,"_156":187,"_95":99,"_168":267,"_166":190,"_100":268,"_158":-5,"_105":269,"_160":270,"_171":-5},"72e50260-7484-11f0-8ba8-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\nimport ValTown from \"npm:@valtown/sdk\";\n\nconst vt = new ValTown();\nconst me = vt.me.profile.retrieve();\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n // authentication\n const token = parseBearerString(c.req.header(\"Authorization\"))\n const vt2 = = new ValTown({ bearer: token});\n const user = await vt2.me.profile.retrieve();\n if ((await me).id !== user.id) return new Repsonse(\"Unauthorized\", { status: 401})\n \n \n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",4,["D",1754677266047],35,{"_103":272,"_159":137,"_156":187,"_95":99,"_168":273,"_166":190,"_100":274,"_158":-5,"_105":275,"_160":276,"_171":-5},"7012b58c-7484-11f0-8d32-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\nimport ValTown from \"npm:@valtown/sdk\";\n\nconst vt = new ValTown();\nconst me = vt.me.profile.retrieve();\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n // authentication\n const token = parseBearerString(c.req.header(\"Authorization\"))\n const vt2 = = new ValTown({ bearer: token});\n const user = vt2.me.profile.retrieve();\n if ((await me).id !== user.id) return new Repsonse(\"Unauthorized\", { status: 401})\n \n \n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",3,["D",1754677261313],34,{"_103":278,"_159":137,"_156":187,"_95":99,"_168":279,"_166":190,"_100":280,"_158":-5,"_105":281,"_160":282,"_171":-5},"c9741068-7483-11f0-8545-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get(\"CLAY_WEBHOOK_URL\");\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id: string) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id],\n });\n\n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id],\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n ...data,\n id: id,\n }),\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n\n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)],\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n\n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\n \"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\",\n );\n});\n\nexport default app.fetch;",2,["D",1754676981772],32,{"_103":284,"_159":137,"_156":187,"_95":99,"_168":285,"_166":190,"_100":209,"_158":-5,"_105":286,"_160":287,"_171":-5},"5bd2bf14-7483-11f0-9ad3-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get('CLAY_WEBHOOK_URL');\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id]\n });\n \n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id]\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ \n ...data, \n id: id\n })\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n \n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)]\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n \n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\");\n});\n\nexport default app.fetch;",["D",1754676797840],22,{"_103":289,"_159":137,"_156":187,"_95":99,"_168":290,"_166":190,"_100":32,"_158":-5,"_105":291,"_160":209,"_171":-5},"c8d4732a-7481-11f0-aadb-0224a6c84d84","import { Hono } from \"https://deno.land/x/hono@v3.12.11/mod.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { parseBearerString } from \"https://esm.town/v/andreterron/parseBearerString\";\n\nconst app = new Hono();\n\nconst CLAY_WEBHOOK_URL = Deno.env.get('CLAY_WEBHOOK_URL');\n\n// Originally stored in memory but it was working unreliably, so switching to using a SQLite DB\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enrichments (\n id TEXT PRIMARY KEY,\n data TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\nfunction sleep(ms) {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function pollEnrichments(id) {\n while (true) {\n const result = await sqlite.execute({\n sql: `SELECT data FROM enrichments WHERE id = ?`,\n args: [id]\n });\n \n if (result.rows.length > 0) {\n const data = JSON.parse(result.rows[0][0]);\n await sqlite.execute({\n sql: `DELETE FROM enrichments WHERE id = ?`,\n args: [id]\n });\n return data;\n }\n await sleep(1000);\n }\n}\n\napp.post(\"/enrich\", async (c) => {\n const data = await c.req.json();\n const id = Math.random().toString(36);\n console.log(`📨 Starting enrichment for ${data.email || data.github_username} (ID: ${id})`);\n\n await fetch(CLAY_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ \n ...data, \n id: id\n })\n });\n\n console.log(`⏳ Polling for result (ID: ${id})`);\n const result = await pollEnrichments(id);\n console.log(`Returning enriched data (ID: ${id})`);\n return c.json(result);\n});\n\napp.post(\"/clay-webhook\", async (c) => {\n const data = await c.req.json();\n console.log(\"📥 Clay webhook data:\", data);\n const { id, ...enrichedData } = data;\n \n if (id) {\n console.log(`Received enriched data for ID: ${id}`);\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO enrichments (id, data) VALUES (?, ?)`,\n args: [id, JSON.stringify(enrichedData)]\n });\n } else {\n console.log(\"Webhook received data without ID\");\n }\n \n return c.json({ status: \"ok\" });\n});\n\napp.get(\"/\", (c) => {\n return c.text(\"Clay API Proxy - POST /enrich to start, Clay calls /clay-webhook when done\");\n});\n\nexport default app.fetch;",["D",1754676121652],"versions",[294,296,297,298,299,300,301,302,303],{"_167":248,"_295":250},"previous",{"_167":250,"_295":256},{"_167":256,"_295":261},{"_167":261,"_295":265},{"_167":265,"_295":271},{"_167":271,"_295":277},{"_167":277,"_295":283},{"_167":283,"_295":288},{"_167":288,"_295":-5},"versionNumber","page","hasNext","actionData","errors"]

stevekrouse

setup-clay-proxy-2

History for main.tsx