\n \n \n \n ${img}\n \n \n

Back of the Can

${post.title}

${post.teaser}...

\n Read the full article\n

\n \n \n

Life Blood, Aberdeen. Real kombucha, no artificial sweeteners.
\n Unsubscribe\n

\n`;\n}\n\n// ---- Send one teaser campaign ----\nasync function sendTeaser(\n post: { title: string; teaser: string; url: string; image: string },\n) {\n const audience = Deno.env.get(\"KLAVIYO_AUDIENCE_ID\");\n const fromEmail = Deno.env.get(\"FROM_EMAIL\");\n const fromLabel = Deno.env.get(\"FROM_LABEL\") ?? \"Life Blood\";\n const replyTo = Deno.env.get(\"REPLY_TO_EMAIL\") ?? fromEmail;\n if (!audience) throw new Error(\"Missing KLAVIYO_AUDIENCE_ID secret\");\n if (!fromEmail) throw new Error(\"Missing FROM_EMAIL secret\");\n\n // 1. Create the email template (CODE / HTML)\n const tpl = await kFetch(\"/templates/\", \"POST\", {\n data: {\n type: \"template\",\n attributes: {\n name: `Blog teaser - ${post.title}`.slice(0, 100),\n editor_type: \"CODE\",\n html: teaserHtml(post),\n },\n },\n });\n const templateId = tpl.data.id;\n\n // 2. Create the campaign (draft) to the audience, with an empty email message\n const campaign = await kFetch(\"/campaigns/\", \"POST\", {\n data: {\n type: \"campaign\",\n attributes: {\n name: `Blog teaser - ${post.title} - ${\n new Date().toISOString().slice(0, 10)\n }`.slice(0, 100),\n audiences: { included: [audience], excluded: [] },\n send_strategy: { method: \"immediate\" },\n send_options: { use_smart_sending: true },\n \"campaign-messages\": {\n data: [{\n type: \"campaign-message\",\n attributes: {\n definition: {\n channel: \"email\",\n label: \"Blog teaser\",\n content: {\n subject: post.title,\n preview_text: `${post.teaser.slice(0, 120)}...`,\n from_email: fromEmail,\n from_label: fromLabel,\n reply_to_email: replyTo,\n },\n },\n },\n }],\n },\n },\n },\n });\n const campaignId = campaign.data.id;\n\n // 3. Get the campaign message ID\n const messages = await kFetch(\n `/campaigns/${campaignId}/campaign-messages/`,\n \"GET\",\n );\n const messageId = messages.data[0].id;\n\n // 4. Assign the template to the message\n await kFetch(\"/campaign-message-assign-template/\", \"POST\", {\n data: {\n type: \"campaign-message\",\n id: messageId,\n relationships: {\n template: { data: { type: \"template\", id: templateId } },\n },\n },\n });\n\n // 5. Send the campaign now\n await kFetch(\"/campaign-send-jobs/\", \"POST\", {\n data: { type: \"campaign-send-job\", id: campaignId },\n });\n\n console.log(`Sent teaser campaign for: ${post.title}`);\n}\n\n// ---- Main interval handler ----\nexport default async function () {\n const feedXml = await (await fetch(FEED_URL)).text();\n const parser = new XMLParser({\n ignoreAttributes: false,\n attributeNamePrefix: \"@_\",\n });\n const parsed = parser.parse(feedXml);\n const rawEntries = parsed?.feed?.entry ?? [];\n const entries = Array.isArray(rawEntries) ? rawEntries : [rawEntries];\n\n const ids: string[] = entries.map((e) => textOf(e.id) || altLink(e.link))\n .filter(Boolean);\n\n const seen: string[] | null = await blob.getJSON(BLOB_KEY);\n\n // First run: remember everything currently published, send nothing.\n if (!seen) {\n await blob.setJSON(BLOB_KEY, ids);\n console.log(\n `Seeded ${ids.length} existing posts. No emails sent on first run.`,\n );\n return;\n }\n\n const seenSet = new Set(seen);\n const newEntries = entries.filter((e) => {\n const id = textOf(e.id) || altLink(e.link);\n return id && !seenSet.has(id);\n });\n\n if (newEntries.length === 0) {\n console.log(\"No new posts.\");\n return;\n }\n\n for (const e of newEntries) {\n const id = textOf(e.id) || altLink(e.link);\n const url = altLink(e.link);\n const title = stripHtml(textOf(e.title));\n const bodyHtml = textOf(e.summary) || textOf(e.content);\n const teaser = stripHtml(bodyHtml).split(\" \").slice(0, TEASER_WORDS).join(\n \" \",\n );\n const image = await ogImage(url);\n\n try {\n await sendTeaser({ title, teaser, url, image });\n seenSet.add(id); // only mark seen after a successful send\n } catch (err) {\n console.error(`Failed to send for \"${title}\":`, err);\n // leave it unseen so it retries next run\n }\n }\n\n await blob.setJSON(BLOB_KEY, [...seenSet]);\n}",[29],"pulls","branches",1,"forks","envVars",{"_152":154,"_155":61},"connections",{"_152":61,"_153":61},"count","unfilledCount",6,"emptyCount",{"_42":136,"_32":29,"_30":137,"_131":-5,"_40":41,"_39":138,"_132":24,"_37":162,"_13":140,"_33":141,"_35":142,"_23":24,"_134":-5,"_159":163,"_26":164},{"_42":130,"_32":27,"_30":31,"_131":-5,"_40":41,"_39":14,"_132":24,"_37":158,"_13":61,"_33":34,"_35":36,"_23":24,"_134":-5,"_159":160,"_26":161},["D",1784238068988],"children",[],[27],["D",1784236707994],[],[29],["D",1784236402891],["D",1789489305251],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":24},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_125":203,"_204":205,"_206":207,"_208":24,"_209":24,"_210":24,"_211":123,"_212":-5,"_213":-7,"_214":-7,"_215":61,"_216":24,"_217":24,"_218":-5,"_219":24,"_220":24,"_221":24,"_222":-5},"ENV",{"_174":175,"_176":177,"_178":88,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202},"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 · v13