[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":97,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","efe0d91c-3f52-11f1-b0e3-42b51c65c3df","name","fileType","http","content","export default async function (req: Request): Promise { \n const BASE_URL = \"https://285-WFD-495.mktorest.com/rest\"; \n const CLIENT_ID = \"e0741537-a883-47c9-b5dc-86071363f16d\"; \n const CLIENT_SECRET = \"0tDQXvlmxl5QgcvItd29NvaOLJZONrG9\"; \n const CLAY_WEBHOOK_URL = \"https://api.clay.com/v3/sources/webhook/pull-in-da\n ta-from-a-webhook-927c68e3-8035-4cb4-9579-e842809fcbc3\"; \n \n const NEGATIVE_KEYWORDS = [\"unsubscribe\", \"bounce\", \"not interested\", \"opt \n out\", \"opted out\", \"spam\"];\n const EXCLUDED_DOMAIN = \"rescale.com\"; \n const LEAD_CREATED_SINCE_YEARS = 2; \n \n const authUrl = \"https://285-WFD-495.mktorest.com/identity/oauth/token?grant\n _type=client_credentials&client_id=\" + CLIENT_ID + \"&client_secret=\" + \n CLIENT_SECRET; \n const authResp = await fetch(authUrl);\n const { access_token } = await authResp.json(); \n \n async function getPagingToken(since: string) { \n const url = BASE_URL + \"/v1/activities/pagingtoken.json?access_token=\" + \n access_token + \"&sinceDatetime=\" + since; \n const r = await fetch(url);\n const d = await r.json(); \n return d.nextPageToken; \n } \n \n const typesResp = await fetch(BASE_URL + \n \"/v1/activities/types.json?access_token=\" + access_token);\n const typesData = await typesResp.json(); \n const allTypes: Record = {}; \n for (const t of typesData.result ?? []) { \n allTypes[t.name] = t.id; \n } \n \n const INTERESTING_MOMENT_TYPE_ID = allTypes[\"Interesting Moment\"]; \n const POSITIVE_ACTIVITY_NAMES = [ \n \"Interesting Moment\", \n \"Open Email\", \n \"Click Email\", \n \"Visit Webpage\", \n \"Fill Out Form\", \n \"Click Link\", \n ]; \n const positiveTypeIds = POSITIVE_ACTIVITY_NAMES \n .map((n) => allTypes[n]) \n .filter((id) => id != null); \n \n if (!INTERESTING_MOMENT_TYPE_ID) { \n return Response.json({ error: \"Could not find Interesting Moment activity \n type\", allTypes }); \n } \n \n const createdSince = new Date(Date.now() - LEAD_CREATED_SINCE_YEARS * 365 * \n 24 * 60 * 60 * 1000).toISOString().split(\"T\")[0];\n const leadMap: Record = {}; \n let nextPageToken: string | null = null; \n \n while (true) { \n let url = BASE_URL + \"/v1/leads.json?access_token=\" + access_token \n + \"&filterType=createdAt\" \n + \"&filterValues=\" + createdSince \n + \"&fields=id,email,firstName,lastName,company,leadStatus,createdAt\" \n + \"&batchSize=300\"; \n if (nextPageToken) url += \"&nextPageToken=\" + nextPageToken; \n const r = await fetch(url); \n const d = await r.json(); \n for (const lead of d.result ?? []) { \n if (lead.leadStatus === \"Excluded\") continue; \n if (lead.email && lead.email.endsWith(\"@\" + EXCLUDED_DOMAIN)) continue; \n leadMap[lead.id] = lead; \n } \n nextPageToken = d.nextPageToken ?? null; \n if (!d.moreResult || !nextPageToken) break; \n } \n \n const allLeadIds = Object.keys(leadMap).map(Number); \n \n const since = new Date(Date.now() - LEAD_CREATED_SINCE_YEARS * 365 * 24 * 60\n * 60 * 1000).toISOString();\n let pageToken = await getPagingToken(since); \n const leadsWithMoments = new Set(); \n \n while (true) { \n const url = BASE_URL + \"/v1/activities.json?access_token=\" + access_token \n + \"&activityTypeIds=\" + INTERESTING_MOMENT_TYPE_ID \n + \"&nextPageToken=\" + pageToken; \n const r = await fetch(url); \n const d = await r.json(); \n for (const a of d.result ?? []) { \n if (leadMap[a.leadId]) leadsWithMoments.add(a.leadId); \n } \n pageToken = d.nextPageToken ?? \"\"; \n if (!d.moreResult || !pageToken) break; \n } \n \n const qualifiedLeadIds = [...leadsWithMoments]; \n const qualifiedSet = new Set(qualifiedLeadIds); \n pageToken = await getPagingToken(since); \n const rows: any[] = []; \n \n function isNegative(text: string): boolean { \n const lower = text.toLowerCase(); \n return NEGATIVE_KEYWORDS.some((kw) => lower.includes(kw)); \n } \n \n while (true) { \n const url = BASE_URL + \"/v1/activities.json?access_token=\" + access_token\n + \"&activityTypeIds=\" + positiveTypeIds.join(\",\") \n + \"&nextPageToken=\" + pageToken; \n const r = await fetch(url); \n const d = await r.json(); \n for (const a of d.result ?? []) { \n if (!qualifiedSet.has(a.leadId)) continue; \n const attrs = Object.fromEntries((a.attributes ?? []).map((x: any) => \n [x.name, x.value])); \n const description = attrs[\"Description\"] ?? attrs[\"Web Page\"] ?? \n attrs[\"Form Name\"] ?? attrs[\"Link\"] ?? \"\"; \n const subject = attrs[\"Subject\"] ?? attrs[\"Email Name\"] ?? \"\";\n const combined = [description, subject].filter(Boolean).join(\" \"); \n if (isNegative(combined)) continue; \n const lead = leadMap[a.leadId] ?? {}; \n rows.push({ \n lead_id: a.leadId, \n email: lead.email ?? \"\", \n first_name: lead.firstName ?? \"\", \n last_name: lead.lastName ?? \"\", \n company: lead.company ?? \"\", \n lead_status: lead.leadStatus ?? \"\", \n activity_date: a.activityDate, \n activity_type: POSITIVE_ACTIVITY_NAMES.find((n) => allTypes[n] === \n a.activityTypeId) ?? String(a.activityTypeId), \n description: combined, \n source: attrs[\"Source\"] ?? \"\", \n }); \n }\n pageToken = d.nextPageToken ?? \"\"; \n if (!d.moreResult || !pageToken) break; \n } \n \n const BATCH_SIZE = 100; \n let sent = 0; \n for (let i = 0; i < rows.length; i += BATCH_SIZE) { \n const batch = rows.slice(i, i + BATCH_SIZE); \n const resp = await fetch(CLAY_WEBHOOK_URL, { \n method: \"POST\", \n headers: { \"Content-Type\": \"application/json\" }, \n body: JSON.stringify(batch), \n }); \n if (!resp.ok) { \n return Response.json({ error: \"Clay webhook failed at batch \" + i, \n status: resp.status, sent }); \n } \n sent += batch.length; \n } \n \n return Response.json({ \n success: true,\n eligible_leads: allLeadIds.length, \n leads_with_moments: qualifiedLeadIds.length, \n activity_rows_sent: sent, \n activity_types_discovered: allTypes, \n }); \n }","export default async function (req: Request): Promise { \n const BASE_URL = \"https://285-WFD-495.mktorest.com/rest\"; \n const CLIENT_ID = \"e0741537-a883-47c9-b5dc-86071363f16d\"; \n const CLIENT_SECRET = \"0tDQXvlmxl5QgcvItd29NvaOLJZONrG9\"; \n const CLAY_WEBHOOK_URL = \"https://api.clay.com/v3/sources/webhook/pull-in-da\n ta-from-a-webhook-927c68e3-8035-4cb4-9579-e842809fcbc3\"; \n const NEGATIVE_KEYWORDS = [\"unsubscribe\", \"bounce\", \"not interested\", \"opt \n out\", \"opted out\", \"spam\"]; \n const EXCLUDED_DOMAIN = \"rescale.com\";\n const LEAD_CREATED_SINCE_YEARS = 2; \n const authUrl = \"https://285-WFD-495.mktorest.com/identity/oauth/token?grant\n _type=client_credentials&client_id=\" + CLIENT_ID + \"&client_secret=\" + \n CLIENT_SECRET; \n const authResp = await fetch(authUrl); \n const { access_token } = await authResp.json(); \n async function getPagingToken(since: string) { \n const url = BASE_URL + \"/v1/activities/pagingtoken.json?access_token=\" + \n access_token + \"&sinceDatetime=\" + since; \n const r = await fetch(url); \n const d = await r.json(); \n return d.nextPageToken; \n } \n const typesResp = await fetch(BASE_URL + \n \"/v1/activities/types.json?access_token=\" + access_token); \n const typesData = await typesResp.json();\n const allTypes: Record = {}; \n for (const t of typesData.result ?? []) { \n allTypes[t.name] = t.id; \n } \n const INTERESTING_MOMENT_TYPE_ID = allTypes[\"Interesting Moment\"]; \n const POSITIVE_ACTIVITY_NAMES = [\"Interesting Moment\", \"Open Email\", \"Click \n Email\", \"Visit Webpage\", \"Fill Out Form\", \"Click Link\"]; \n const positiveTypeIds = POSITIVE_ACTIVITY_NAMES.map((n) => \n allTypes[n]).filter((id) => id != null); \n if (!INTERESTING_MOMENT_TYPE_ID) {\n return Response.json({ error: \"Could not find Interesting Moment activity \n type\", allTypes }); \n } \n const createdSince = new Date(Date.now() - LEAD_CREATED_SINCE_YEARS * 365 * \n 24 * 60 * 60 * 1000).toISOString().split(\"T\")[0]; \n const leadMap: Record = {};\n let nextPageToken: string | null = null; \n while (true) { \n let url = BASE_URL + \"/v1/leads.json?access_token=\" + access_token + \n \"&filterType=createdAt&filterValues=\" + createdSince + \"&fields=id,email,first\n Name,lastName,company,leadStatus,createdAt&batchSize=300\"; \n if (nextPageToken) url += \"&nextPageToken=\" + nextPageToken; \n const r = await fetch(url); \n const d = await r.json(); \n for (const lead of d.result ?? []) { \n if (lead.leadStatus === \"Excluded\") continue; \n if (lead.email && lead.email.endsWith(\"@\" + EXCLUDED_DOMAIN)) continue; \n leadMap[lead.id] = lead; \n } \n nextPageToken = d.nextPageToken ?? null; \n if (!d.moreResult || !nextPageToken) break;\n } \n const allLeadIds = Object.keys(leadMap).map(Number);\n const since = new Date(Date.now() - LEAD_CREATED_SINCE_YEARS * 365 * 24 * 60\n * 60 * 1000).toISOString(); \n let pageToken = await getPagingToken(since); \n const leadsWithMoments = new Set(); \n while (true) { \n const url = BASE_URL + \"/v1/activities.json?access_token=\" + access_token \n + \"&activityTypeIds=\" + INTERESTING_MOMENT_TYPE_ID + \"&nextPageToken=\" + \n pageToken; \n const r = await fetch(url); \n const d = await r.json(); \n for (const a of d.result ?? []) { \n if (leadMap[a.leadId]) leadsWithMoments.add(a.leadId); \n } \n pageToken = d.nextPageToken ?? \"\"; \n if (!d.moreResult || !pageToken) break; \n } \n const qualifiedLeadIds = [...leadsWithMoments]; \n const qualifiedSet = new Set(qualifiedLeadIds); \n pageToken = await getPagingToken(since); \n const rows: any[] = []; \n function isNegative(text: string): boolean { \n const lower = text.toLowerCase(); \n return NEGATIVE_KEYWORDS.some((kw) => lower.includes(kw)); \n } \n while (true) { \n const url = BASE_URL + \"/v1/activities.json?access_token=\" + access_token \n + \"&activityTypeIds=\" + positiveTypeIds.join(\",\") + \"&nextPageToken=\" + \n pageToken;\n const r = await fetch(url); \n const d = await r.json(); \n for (const a of d.result ?? []) { \n if (!qualifiedSet.has(a.leadId)) continue; \n const attrs = Object.fromEntries((a.attributes ?? []).map((x: any) => \n [x.name, x.value])); \n const description = attrs[\"Description\"] ?? attrs[\"Web Page\"] ?? \n attrs[\"Form Name\"] ?? attrs[\"Link\"] ?? \"\"; \n const subject = attrs[\"Subject\"] ?? attrs[\"Email Name\"] ?? \"\";\n const combined = [description, subject].filter(Boolean).join(\" \"); \n if (isNegative(combined)) continue; \n const lead = leadMap[a.leadId] ?? {}; \n rows.push({ \n lead_id: a.leadId, \n email: lead.email ?? \"\", \n first_name: lead.firstName ?? \"\", \n last_name: lead.lastName ?? \"\", \n company: lead.company ?? \"\", \n lead_status: lead.leadStatus ?? \"\", \n activity_date: a.activityDate, \n activity_type: POSITIVE_ACTIVITY_NAMES.find((n) => allTypes[n] === \n a.activityTypeId) ?? String(a.activityTypeId), \n description: combined, \n source: attrs[\"Source\"] ?? \"\", \n }); \n } \n pageToken = d.nextPageToken ?? \"\"; \n if (!d.moreResult || !pageToken) break; \n } \n const BATCH_SIZE = 100; \n let sent = 0; \n for (let i = 0; i < rows.length; i += BATCH_SIZE) { \n const batch = rows.slice(i, i + BATCH_SIZE); \n const resp = await fetch(CLAY_WEBHOOK_URL, { \n method: \"POST\", \n headers: { \"Content-Type\": \"application/json\" }, \n body: JSON.stringify(batch), \n }); \n if (!resp.ok) { \n return Response.json({ error: \"Clay webhook failed at batch \" + i, \n status: resp.status, sent }); \n } \n sent += batch.length; \n } \n return Response.json({ success: true, eligible_leads: allLeadIds.length, \n leads_with_moments: qualifiedLeadIds.length, activity_rows_sent: sent, \n activity_types_discovered: allTypes });\n }","createdAt",["D",1777303132806],"branchVersion","branchId","efde5110-3f52-11f1-b0e3-42b51c65c3df","id","efdd5daa-3f52-11f1-b0e3-42b51c65c3df","untitled-2539",["D",1776976086931],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","9e2b0e5b-146b-4f67-aa40-88a346888dc9","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019db696-15aa-743d-83c4-2189823c4ffe","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sluong","handle","displayName","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":148,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":149,"_78":150,"_80":151,"_82":25},"tree",[143],"files",[143],"counts",{"_132":60,"_133":134,"_135":60,"_136":137,"_138":139},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":128,"_13":129,"_33":34,"_35":37,"_24":25,"_130":-5,"_27":131},"666a8cbc-424c-11f1-8bd1-42b51c65c3df","parentId","latest",["D",1777303132806],7,"label",[28],"pulls","branches",1,"forks","envVars",{"_140":60,"_142":60},"connections",{"_140":60,"_141":60},"count","unfilledCount","emptyCount",{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":144,"_13":129,"_33":34,"_35":37,"_24":25,"_130":-5,"_145":146,"_27":147},["D",1777303132806],"children",[],[28],["D",1776976086931],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":185,"_186":187,"_188":189,"_190":25,"_191":25,"_192":25,"_193":119,"_194":-5,"_195":-7,"_196":-7,"_197":60,"_198":25,"_199":25,"_200":-5,"_201":25,"_202":25,"_203":25,"_204":-5},"ENV",{"_156":157,"_158":159,"_160":84,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"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 · v8