[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"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":53,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",33,"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","0e7a0da0-815f-11f1-8f7c-1607ee4eb77e","name","fileType","interval","content","// Life Blood - Blog teaser publisher\n// Interval (cron) val. Watches the \"Back of the Can\" RSS feed, stacks every\n// published post oldest-to-newest, and sends ONE Klaviyo teaser campaign per\n// run for the next post that hasn't gone out yet (hook + \"Read the full\n// article\" button) to your subscriber audience.\n//\n// First run seeds the \"already sent\" log with the posts you've already\n// emailed manually (see SEED_ALREADY_SENT_HANDLES below), then immediately\n// sends the oldest still-unsent post in the same run. Every run after that\n// just advances the queue by one.\n//\n// ---- SET THESE AS VAL TOWN SECRETS (Settings > Secrets) ----\n// KLAVIYO_API_KEY your Klaviyo PRIVATE API key (pk_...). scopes: campaigns:write, templates:write\n// KLAVIYO_AUDIENCE_ID the list or segment ID to send to (e.g. a \"Blog subscribers\" segment)\n// FROM_EMAIL a verified Klaviyo sending address, e.g. hello@drinklifeblood.com\n// FROM_LABEL sender name shown in inbox, e.g. Life Blood\n// REPLY_TO_EMAIL reply-to address, e.g. hello@drinklifeblood.com\n// ------------------------------------------------------------\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { XMLParser } from \"https://esm.sh/fast-xml-parser@4.5.0\";\n\n// ---- Config ----\nconst FEED_URL =\n \"https://drinklifeblood.com/blogs/life-blood-back-of-the-can.atom\";\nconst BLOB_KEY = \"lifeblood_blog_sent_ids\"; // now tracks ACTUALLY SENT posts, not just \"seen\"\nconst KLAVIYO_REVISION = \"2026-07-15\";\nconst TEASER_WORDS = 45; // length of the hook pulled from the post\n\n// One-time seed: handles for posts you've already emailed manually before this\n// val existed, so the queue doesn't re-send them. Only used the very first\n// time this val runs (i.e. when the blob key doesn't exist yet).\nconst SEED_ALREADY_SENT_HANDLES = [\n \"hop-infused-kombucha\",\n \"soft-drinks-shift-2026\",\n];\n\n// Schedule the Klaviyo send for 08:06 UK time today (the val itself runs earlier, e.g. Fri 06:00).\nfunction sendStrategy() {\n const now = new Date();\n const dateStr = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/London\",\n }).format(now); // YYYY-MM-DD\n const offPart =\n new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/London\",\n timeZoneName: \"longOffset\",\n })\n .formatToParts(now).find((p) => p.type === \"timeZoneName\")?.value ??\n \"GMT+00:00\";\n let off = offPart.match(/([+-]\\d{2}:?\\d{2})/)?.[1] ?? \"+00:00\";\n if (!off.includes(\":\")) off = off.slice(0, 3) + \":\" + off.slice(3);\n const datetime = `${dateStr}T08:06:00${off}`;\n // If somehow run after 08:06 UK, send now rather than scheduling in the past.\n if (new Date(datetime).getTime() <= now.getTime()) {\n return { method: \"immediate\" };\n }\n return {\n method: \"static\",\n options_static: {\n datetime,\n is_local: false,\n send_past_recipients_immediately: false,\n },\n };\n}\n\n// ---- Klaviyo helpers ----\nfunction kHeaders() {\n const key = Deno.env.get(\"KLAVIYO_API_KEY\");\n if (!key) throw new Error(\"Missing KLAVIYO_API_KEY secret\");\n return {\n Authorization: `Klaviyo-API-Key ${key}`,\n revision: KLAVIYO_REVISION,\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n };\n}\n\nasync function kFetch(path: string, method: string, body?: unknown) {\n const res = await fetch(`https://a.klaviyo.com/api${path}`, {\n method,\n headers: kHeaders(),\n body: body ? JSON.stringify(body) : undefined,\n });\n const text = await res.text();\n if (!res.ok) {\n throw new Error(`Klaviyo ${method} ${path} -> ${res.status}: ${text}`);\n }\n return text ? JSON.parse(text) : {};\n}\n\n// ---- Feed helpers ----\nfunction stripHtml(html: string): string {\n return html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/'|’|‘/g, \"'\")\n .replace(/"|“|”/g, '\"')\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nfunction textOf(node: unknown): string {\n if (node == null) return \"\";\n if (typeof node === \"string\") return node;\n if (\n typeof node === \"object\" && \"#text\" in (node as Record)\n ) {\n return String((node as Record)[\"#text\"] ?? \"\");\n }\n return \"\";\n}\n\nfunction altLink(link: unknown): string {\n if (!link) return \"\";\n const arr = Array.isArray(link) ? link : [link];\n const alt =\n arr.find((l: Record) => l[\"@_rel\"] === \"alternate\") ??\n arr[0];\n return String((alt as Record)?.[\"@_href\"] ?? \"\");\n}\n\n// Pull a stable \"handle\" out of the entry id/link so it matches the seed list\n// regardless of the feed's exact URL host or trailing slash.\nfunction handleOf(id: string): string {\n const parts = id.split(\"/\").filter(Boolean);\n return parts[parts.length - 1] ?? id;\n}\n\nasync function ogImage(url: string): Promise {\n try {\n const html = await (await fetch(url)).text();\n const m =\n html.match(\n /]+property=[\"']og:image[\"'][^>]+content=[\"']([^\"']+)[\"']/i,\n ) ||\n html.match(\n /]+content=[\"']([^\"']+)[\"'][^>]+property=[\"']og:image[\"']/i,\n );\n return m ? m[1].replace(/^http:\\/\\//i, \"https://\") : \"\";\n } catch {\n return \"\";\n }\n}\n\n// ---- Email template ----\nfunction teaserHtml(\n post: { title: string; teaser: string; url: string; image: string },\n): string {\n const img = post.image\n ? ` $\"${post.title}\"$ `\n : \"\";\n return `\n \n \n

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

Back of the Can

${post.title}

Hi {{ first_name|default:'there' }},

${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: sendStrategy(),\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 // Build a normalised, sortable list: id, handle, published date, and the raw entry.\n const normalised = entries\n .map((e) => {\n const id = textOf(e.id) || altLink(e.link);\n const published = textOf(e.published) || textOf(e.updated);\n return { id, handle: handleOf(id), published, entry: e };\n })\n .filter((n) => n.id && n.published);\n\n // Stack oldest first, so the queue always advances in publish order.\n normalised.sort((a, b) =>\n new Date(a.published).getTime() - new Date(b.published).getTime()\n );\n\n let sent: string[] | null = await blob.getJSON(BLOB_KEY);\n\n // First run of this queue logic: seed with posts already emailed manually,\n // don't send anything extra this run beyond the normal \"send the next one\" step.\n if (!sent) {\n sent = [...SEED_ALREADY_SENT_HANDLES];\n await blob.setJSON(BLOB_KEY, sent);\n console.log(\n `Seeded sent-log with ${sent.length} already-sent post(s): ${\n sent.join(\", \")\n }`,\n );\n }\n\n const sentSet = new Set(sent);\n const next = normalised.find((n) => !sentSet.has(n.handle));\n\n if (!next) {\n console.log(\"No unsent posts in the queue. Up to date.\");\n return;\n }\n\n const url = altLink(next.entry.link);\n const title = stripHtml(textOf(next.entry.title));\n const bodyHtml = textOf(next.entry.summary) || textOf(next.entry.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 sentSet.add(next.handle); // only mark sent after a successful send\n await blob.setJSON(BLOB_KEY, [...sentSet]);\n console.log(\n `Queue advanced. Sent: ${next.handle}. Next run will send the following post in the stack.`,\n );\n } catch (err) {\n console.error(`Failed to send for \"${title}\" (${next.handle}):`, err);\n // leave it unsent so it retries next run, queue position holds\n }\n}","// Life Blood - Blog teaser publisher\n// Interval (cron) val. Watches the \"Back of the Can\" RSS feed, stacks every\n// published post oldest-to-newest, and sends ONE Klaviyo teaser campaign per\n// run for the next post that hasn't gone out yet (hook + \"Read the full\n// article\" button) to your subscriber audience.\n//\n// First run seeds the \"already sent\" log with the posts you've already\n// emailed manually (see SEED_ALREADY_SENT_HANDLES below), then immediately\n// sends the oldest still-unsent post in the same run. Every run after that\n// just advances the queue by one.\n//\n// ---- SET THESE AS VAL TOWN SECRETS (Settings > Secrets) ----\n// KLAVIYO_API_KEY your Klaviyo PRIVATE API key (pk_...). scopes: campaigns:write, templates:write\n// KLAVIYO_AUDIENCE_ID the list or segment ID to send to (e.g. a \"Blog subscribers\" segment)\n// FROM_EMAIL a verified Klaviyo sending address, e.g. hello@drinklifeblood.com\n// FROM_LABEL sender name shown in inbox, e.g. Life Blood\n// REPLY_TO_EMAIL reply-to address, e.g. hello@drinklifeblood.com\n// ------------------------------------------------------------\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { XMLParser } from \"https://esm.sh/fast-xml-parser@4.5.0\";\n\n// ---- Config ----\nconst FEED_URL =\n \"https://drinklifeblood.com/blogs/life-blood-back-of-the-can.atom\";\nconst BLOB_KEY = \"lifeblood_blog_sent_ids\"; // now tracks ACTUALLY SENT posts, not just \"seen\"\nconst KLAVIYO_REVISION = \"2026-07-15\";\nconst TEASER_WORDS = 45; // length of the hook pulled from the post\n\n// One-time seed: handles for posts you've already emailed manually before this\n// val existed, so the queue doesn't re-send them. Only used the very first\n// time this val runs (i.e. when the blob key doesn't exist yet).\nconst SEED_ALREADY_SENT_HANDLES = [\n \"hop-infused-kombucha\",\n \"soft-drinks-shift-2026\",\n];\n\n// Schedule the Klaviyo send for 08:06 UK time today (the val itself runs earlier, e.g. Fri 06:00).\nfunction sendStrategy() {\n const now = new Date();\n const dateStr = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Europe/London\",\n }).format(now); // YYYY-MM-DD\n const offPart = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: \"Europe/London\",\n timeZoneName: \"longOffset\",\n })\n .formatToParts(now).find((p) => p.type === \"timeZoneName\")?.value ??\n \"GMT+00:00\";\n let off = offPart.match(/([+-]\\d{2}:?\\d{2})/)?.[1] ?? \"+00:00\";\n if (!off.includes(\":\")) off = off.slice(0, 3) + \":\" + off.slice(3);\n const datetime = `${dateStr}T08:06:00${off}`;\n // If somehow run after 08:06 UK, send now rather than scheduling in the past.\n if (new Date(datetime).getTime() <= now.getTime()) {\n return { method: \"immediate\" };\n }\n return {\n method: \"static\",\n datetime,\n options: { is_local: false },\n };\n}\n\n// ---- Klaviyo helpers ----\nfunction kHeaders() {\n const key = Deno.env.get(\"KLAVIYO_API_KEY\");\n if (!key) throw new Error(\"Missing KLAVIYO_API_KEY secret\");\n return {\n Authorization: `Klaviyo-API-Key ${key}`,\n revision: KLAVIYO_REVISION,\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n };\n}\n\nasync function kFetch(path: string, method: string, body?: unknown) {\n const res = await fetch(`https://a.klaviyo.com/api${path}`, {\n method,\n headers: kHeaders(),\n body: body ? JSON.stringify(body) : undefined,\n });\n const text = await res.text();\n if (!res.ok) {\n throw new Error(`Klaviyo ${method} ${path} -> ${res.status}: ${text}`);\n }\n return text ? JSON.parse(text) : {};\n}\n\n// ---- Feed helpers ----\nfunction stripHtml(html: string): string {\n return html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/'|’|‘/g, \"'\")\n .replace(/"|“|”/g, '\"')\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nfunction textOf(node: unknown): string {\n if (node == null) return \"\";\n if (typeof node === \"string\") return node;\n if (\n typeof node === \"object\" && \"#text\" in (node as Record)\n ) {\n return String((node as Record)[\"#text\"] ?? \"\");\n }\n return \"\";\n}\n\nfunction altLink(link: unknown): string {\n if (!link) return \"\";\n const arr = Array.isArray(link) ? link : [link];\n const alt =\n arr.find((l: Record) => l[\"@_rel\"] === \"alternate\") ??\n arr[0];\n return String((alt as Record)?.[\"@_href\"] ?? \"\");\n}\n\n// Pull a stable \"handle\" out of the entry id/link so it matches the seed list\n// regardless of the feed's exact URL host or trailing slash.\nfunction handleOf(id: string): string {\n const parts = id.split(\"/\").filter(Boolean);\n return parts[parts.length - 1] ?? id;\n}\n\nasync function ogImage(url: string): Promise {\n try {\n const html = await (await fetch(url)).text();\n const m = html.match(\n /]+property=[\"']og:image[\"'][^>]+content=[\"']([^\"']+)[\"']/i,\n ) ||\n html.match(\n /]+content=[\"']([^\"']+)[\"'][^>]+property=[\"']og:image[\"']/i,\n );\n return m ? m[1].replace(/^http:\\/\\//i, \"https://\") : \"\";\n } catch {\n return \"\";\n }\n}\n\n// ---- Email template ----\nfunction teaserHtml(\n post: { title: string; teaser: string; url: string; image: string },\n): string {\n const img = post.image\n ? ` $\"${post.title}\"$ `\n : \"\";\n return `\n \n \n

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

Back of the Can

${post.title}

Hi {{ first_name|default:'there' }},

${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: sendStrategy(),\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 // Build a normalised, sortable list: id, handle, published date, and the raw entry.\n const normalised = entries\n .map((e) => {\n const id = textOf(e.id) || altLink(e.link);\n const published = textOf(e.published) || textOf(e.updated);\n return { id, handle: handleOf(id), published, entry: e };\n })\n .filter((n) => n.id && n.published);\n\n // Stack oldest first, so the queue always advances in publish order.\n normalised.sort((a, b) =>\n new Date(a.published).getTime() - new Date(b.published).getTime()\n );\n\n let sent: string[] | null = await blob.getJSON(BLOB_KEY);\n\n // First run of this queue logic: seed with posts already emailed manually,\n // don't send anything extra this run beyond the normal \"send the next one\" step.\n if (!sent) {\n sent = [...SEED_ALREADY_SENT_HANDLES];\n await blob.setJSON(BLOB_KEY, sent);\n console.log(\n `Seeded sent-log with ${sent.length} already-sent post(s): ${\n sent.join(\", \")\n }`,\n );\n }\n\n const sentSet = new Set(sent);\n const next = normalised.find((n) => !sentSet.has(n.handle));\n\n if (!next) {\n console.log(\"No unsent posts in the queue. Up to date.\");\n return;\n }\n\n const url = altLink(next.entry.link);\n const title = stripHtml(textOf(next.entry.title));\n const bodyHtml = textOf(next.entry.summary) || textOf(next.entry.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 sentSet.add(next.handle); // only mark sent after a successful send\n await blob.setJSON(BLOB_KEY, [...sentSet]);\n console.log(\n `Queue advanced. Sent: ${next.handle}. Next run will send the following post in the stack.`,\n );\n } catch (err) {\n console.error(`Failed to send for \"${title}\" (${next.handle}):`, err);\n // leave it unsent so it retries next run, queue position holds\n }\n}","createdAt",["D",1785700518110],"branchVersion","branchId","975ee0f5-6fae-4bfd-840c-8c837efed0ae","id","8a58d6f2-4dee-47f7-b1f0-874e0c8bfb2e","blog-teaser-publisher",["D",1784236402891],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Back of the can Blog Post publisher","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/84616a00-5483-452a-6fcc-4a4b73e0c100/square512?exp=1789545599&sig=bc0f813a22dc16c47553ca55aa12a85764f1cf4fe65a70b85f56dd3f627ab952","019d5060-1a72-70ea-92a9-e2c91a100d5a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d5060-1a72-70ea-92a9-e7b6c0748108","tursoName","8a58d6f24dee47f7b1f0874e0c8bfb2e","tursoHostname","8a58d6f24dee47f7b1f0874e0c8bfb2e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789489305251],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},"branch",{"_13":14,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Gearymeister","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCb3l3RnlPc1h0RkMwd2w3S3F0aDU2TWtzRSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":167,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":168,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":169,"_83":170,"_85":171,"_87":25},"tree",[158,159],"files",[158,159],"counts",{"_146":62,"_147":148,"_149":62,"_150":151,"_152":153},"contents",[128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":136,"_38":143,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":145},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":136,"_38":137,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_27":141},"afa11cb2-388a-41f7-ba44-9b79c403e2fa","tester.ts","a14ed184-8177-11f1-93fd-1607ee4eb77e","parentId",31,"latest",true,["D",1784287904580],7,"// One-click TEST sender for the blog teaser.\n// Ignores the blob entirely. Every time you click Run, it takes the NEWEST\n// post from the feed, builds the teaser email, and sends it to your audience.\n// Use this to test the look, sender and personalisation without touching the\n// live publisher or the \"seen posts\" store.\n//\n// Uses these Val Town secrets:\n// KLAVIYO_API_KEY, FROM_EMAIL, FROM_LABEL, REPLY_TO_EMAIL (shared with the publisher)\n// KLAVIYO_TEST_AUDIENCE_ID (NEW) = your \"testing\" list ID, so tests never hit the real audience\n//\n// HOW TO USE: New val > paste this > click Run. Check the audience inbox.\n// (Each click sends one email, so don't spam it.)\n\nimport { XMLParser } from \"https://esm.sh/fast-xml-parser@4.5.0\";\n\nconst FEED_URL = \"https://drinklifeblood.com/blogs/life-blood-back-of-the-can.atom\";\nconst KLAVIYO_REVISION = \"2026-07-15\";\nconst TEASER_WORDS = 45;\n\nfunction kHeaders() {\n const key = Deno.env.get(\"KLAVIYO_API_KEY\");\n if (!key) throw new Error(\"Missing KLAVIYO_API_KEY secret\");\n return {\n Authorization: `Klaviyo-API-Key ${key}`,\n revision: KLAVIYO_REVISION,\n \"content-type\": \"application/json\",\n accept: \"application/json\",\n };\n}\n\nasync function kFetch(path: string, method: string, body?: unknown) {\n const res = await fetch(`https://a.klaviyo.com/api${path}`, {\n method,\n headers: kHeaders(),\n body: body ? JSON.stringify(body) : undefined,\n });\n const text = await res.text();\n if (!res.ok) throw new Error(`Klaviyo ${method} ${path} -> ${res.status}: ${text}`);\n return text ? JSON.parse(text) : {};\n}\n\nfunction stripHtml(html: string): string {\n return html\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \").replace(/&/g, \"&\")\n .replace(/'|’|‘/g, \"'\")\n .replace(/"|“|”/g, '\"')\n .replace(/\\s+/g, \" \").trim();\n}\n\nfunction textOf(node: unknown): string {\n if (node == null) return \"\";\n if (typeof node === \"string\") return node;\n if (typeof node === \"object\" && \"#text\" in (node as Record)) {\n return String((node as Record)[\"#text\"] ?? \"\");\n }\n return \"\";\n}\n\nfunction altLink(link: unknown): string {\n if (!link) return \"\";\n const arr = Array.isArray(link) ? link : [link];\n const alt = arr.find((l: Record) => l[\"@_rel\"] === \"alternate\") ?? arr[0];\n return String((alt as Record)?.[\"@_href\"] ?? \"\");\n}\n\nasync function ogImage(url: string): Promise {\n try {\n const html = await (await fetch(url)).text();\n const m =\n html.match(/]+property=[\"']og:image[\"'][^>]+content=[\"']([^\"']+)[\"']/i) ||\n html.match(/]+content=[\"']([^\"']+)[\"'][^>]+property=[\"']og:image[\"']/i);\n return m ? m[1].replace(/^http:\\/\\//i, \"https://\") : \"\";\n } catch {\n return \"\";\n }\n}\n\nfunction teaserHtml(post: { title: string; teaser: string; url: string; image: string }): string {\n const img = post.image\n ? ` $\"${post.title}\"$ `\n : \"\";\n return `\n \n \n

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

Back of the Can

${post.title}

Hi {{ first_name|default:'there' }},

${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\nasync function sendTeaser(post: { title: string; teaser: string; url: string; image: string }) {\n const audience = Deno.env.get(\"KLAVIYO_TEST_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_TEST_AUDIENCE_ID secret (set it to your testing list)\");\n if (!fromEmail) throw new Error(\"Missing FROM_EMAIL secret\");\n\n const tpl = await kFetch(\"/templates/\", \"POST\", {\n data: { type: \"template\", attributes: {\n name: `TEST Blog teaser - ${post.title}`.slice(0, 100),\n editor_type: \"CODE\", html: teaserHtml(post),\n } },\n });\n const templateId = tpl.data.id;\n\n const campaign = await kFetch(\"/campaigns/\", \"POST\", {\n data: { type: \"campaign\", attributes: {\n name: `TEST Blog teaser - ${new Date().toISOString().slice(0, 16)}`.slice(0, 100),\n audiences: { included: [audience], excluded: [] },\n send_strategy: { method: \"immediate\" },\n send_options: { use_smart_sending: false }, // OFF for testing so it always sends\n \"campaign-messages\": { data: [{ type: \"campaign-message\", attributes: { definition: {\n channel: \"email\", label: \"Blog teaser\", content: {\n subject: post.title,\n preview_text: `${post.teaser.slice(0, 120)}...`,\n from_email: fromEmail, from_label: fromLabel, reply_to_email: replyTo,\n },\n } } }] },\n } },\n });\n const campaignId = campaign.data.id;\n\n const messages = await kFetch(`/campaigns/${campaignId}/campaign-messages/`, \"GET\");\n const messageId = messages.data[0].id;\n\n await kFetch(\"/campaign-message-assign-template/\", \"POST\", {\n data: { type: \"campaign-message\", id: messageId,\n relationships: { template: { data: { type: \"template\", id: templateId } } } },\n });\n\n await kFetch(\"/campaign-send-jobs/\", \"POST\", {\n data: { type: \"campaign-send-job\", id: campaignId },\n });\n}\n\n// Runs immediately when you click Run (top-level, no wrapper to forget to call).\nconst xml = await (await fetch(FEED_URL)).text();\nconst parser = new XMLParser({ ignoreAttributes: false, attributeNamePrefix: \"@_\" });\nconst entries = parser.parse(xml).feed.entry;\nconst list = Array.isArray(entries) ? entries : [entries];\nconst newest = list[0]; // newest post\n\nconst url = altLink(newest.link);\nconst title = stripHtml(textOf(newest.title));\nconst bodyHtml = textOf(newest.summary) || textOf(newest.content);\nconst teaser = stripHtml(bodyHtml).split(\" \").slice(0, TEASER_WORDS).join(\" \");\nconst image = await ogImage(url);\n\nawait sendTeaser({ title, teaser, url, image });\nconsole.log(`TEST teaser sent for: ${title}`);","label",[131],"65aa7751-5bad-4af7-8e18-b09401d1eff8",["D",1785700518110],9,[28],"pulls","branches",1,"forks","envVars",{"_154":156,"_157":62},"connections",{"_154":62,"_155":62},"count","unfilledCount",6,"emptyCount",{"_43":142,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":136,"_38":164,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_161":165,"_27":166},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":136,"_38":160,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_161":162,"_27":163},["D",1784287904580],"children",[],[131],["D",1785700518110],[],[28],["D",1784236402891],["D",1789489305251],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},{"_13":14,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_81":-5,"_125":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":136,"_214":-5,"_215":-7,"_216":-7,"_217":62,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":88,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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 · v33