[{"_1":2,"_214":-5,"_215":-5},"loaderData",{"_3":4,"_91":92,"_193":194},"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","47e5e932e7cfd8f3edad05dc00b18594b3ad8618","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":-7,"_98":72,"_99":-7,"_100":101,"_146":147,"_169":170,"_171":172,"_181":182,"_186":-5,"_187":-5,"_188":-5,"_189":22,"_190":22,"_191":192},"handle","magoosh","name","dynamic-ads-csv","branchName","path","version","project",{"_102":103,"_95":96,"_104":105,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_145":22},"id","10fdbb04-9fdc-11f0-ba6d-0224a6c84d84","createdAt",["D",1759442797506],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019986c0-3fe8-724c-abdd-a8b3540a43e6","pinnedFileId","pinPreview","screenshotVersion","likeCount","019986c0-3fe8-724c-abdd-ae5c4c6aab58","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzMzRkFGclRKY1JBbDZ5SWtScGZhbTJiR2lBdCJ9","org",{"_93":94,"_132":129},"avatar","branch",{"_99":135,"_95":43,"_102":136,"_137":103,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},9,"10fe0c8a-9fdc-11f0-ba6d-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[148],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":158,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_166":167,"_98":168},"8191ef0e-9fe9-11f0-8598-0224a6c84d84","main.ts","fileId","11005f26-9fdc-11f0-ba6d-0224a6c84d84","parentId","branchId","branchVersion","latest",true,["D",1759448569838],8,"fileType","http","content","// main.ts — CSV → Bannerbear → CSV (24h TTL cache; cache disabled in test/limited runs; verbose logs)\n// Setup: Add secret BANNERBEAR_API_KEY. Make Public. Type = HTTP.\n\nimport Papa from \"https://esm.sh/papaparse@5.4.1\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ===== Config =====\nconst SOURCE_CSV_URL =\n \"https://app.periscopedata.com/api/magoosh/chart/csv/199438e6-eecb-d1fd-7fbc-eed33a1edd99/1895678\";\nconst BANNERBEAR_TEMPLATE_ID = \"E9YaWrZMqma7ZnRd74\";\nconst BANNERBEAR_API_KEY = Deno.env.get(\"BANNERBEAR_API_KEY\");\n\n// CSV columns from your SQL feed\nconst COL_ID = \"id\";\nconst COL_TEMPLATE_IMG = \"image_story_template_link\"; // Cloudflare Image URLs now\nconst COL_DISCOUNT = \"custom_label\"; // e.g., \"30% off\"\nconst COL_SALES_END = \"custom_label_2\"; // e.g., \"ends Oct 6th\"\nconst COL_OUT = \"bannerbear_image_url\";\n\n// Cache settings\nconst TTL_MS = 24 * 60 * 60 * 1000; // 24h TTL\nconst CLEANUP_MAX_AGE_MS = 30 * TTL_MS;\n\n// Default test limit. In prod, call with ?limit=all\nconst DEFAULT_LIMIT = 1;\n\n// ===== SQLite schema =====\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS images (\n row_id TEXT PRIMARY KEY,\n image_url TEXT NOT NULL,\n updated_at INTEGER NOT NULL\n )\n`);\n\ntype Row = Record;\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\nfunction mapFirstRow(\n res: { columns: string[]; rows: any[][] },\n): T | null {\n if (!res.rows?.length) return null;\n const obj: any = {};\n res.columns.forEach((c, i) => (obj[c] = res.rows[0][i]));\n return obj as T;\n}\n\nfunction computeRowId(row: Row): string {\n if (row[COL_ID]?.trim()) return row[COL_ID].trim();\n return `${(row[\"product\"] || \"\").trim()}|${(row[\"region\"] || \"\").trim()}`;\n}\n\n// ===== Cache (24h TTL) =====\nasync function getCached(rowId: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT image_url, updated_at FROM images WHERE row_id = ?\",\n args: [rowId],\n });\n const rec = mapFirstRow<{ image_url: string; updated_at: number }>(res);\n if (!rec) return null;\n if (Date.now() - rec.updated_at > TTL_MS) return null; // expired\n console.log(\"Cache hit for\", rowId, \"→\", rec.image_url);\n return rec.image_url;\n}\n\nasync function putCached(rowId: string, url: string) {\n console.log(\"Caching URL for\", rowId, \"→\", url);\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO images (row_id, image_url, updated_at) VALUES (?, ?, ?)\",\n args: [rowId, url, Date.now()],\n });\n}\n\nasync function cleanupOld() {\n console.log(\"Cleaning cache > 30 days old…\");\n await sqlite.execute({\n sql: \"DELETE FROM images WHERE updated_at < ?\",\n args: [Date.now() - CLEANUP_MAX_AGE_MS],\n });\n}\n\n// ===== IO =====\nasync function fetchCsv(): Promise<{ rows: Row[]; fields: string[] }> {\n console.log(\"Fetching source CSV:\", SOURCE_CSV_URL);\n const res = await fetch(SOURCE_CSV_URL, { redirect: \"follow\" });\n if (!res.ok) {\n throw new Error(`Fetch CSV failed: ${res.status} ${res.statusText}`);\n }\n const text = await res.text();\n const parsed = Papa.parse(text, { header: true, skipEmptyLines: true });\n console.log(\"Parsed\", parsed.data.length, \"rows\");\n const rows = parsed.data || [];\n const fields = parsed.meta.fields?.length\n ? parsed.meta.fields\n : Object.keys(rows[0] || {});\n return { rows, fields };\n}\n\n// ===== Bannerbear =====\nasync function createBannerbearImage(row: Row): Promise {\n console.log(\"Creating Bannerbear image for row:\", row);\n const template_image_url = row[COL_TEMPLATE_IMG]?.trim();\n const discount_amount = row[COL_DISCOUNT]?.trim();\n const sales_end_date = row[COL_SALES_END]?.trim();\n\n if (!template_image_url || !discount_amount || !sales_end_date) {\n console.warn(\"⚠️ Missing BB inputs\", {\n template_image_url,\n discount_amount,\n sales_end_date,\n });\n return \"\";\n }\n\n const body = {\n template: BANNERBEAR_TEMPLATE_ID,\n modifications: [\n { name: \"template_image_url\", image_url: template_image_url },\n {\n name: \"discount_amount\",\n text: discount_amount,\n color: null,\n background: null,\n },\n {\n name: \"sales_end_date\",\n text: sales_end_date,\n color: null,\n background: null,\n },\n ],\n synchronous: true,\n };\n\n console.log(\"POST → Bannerbear body:\", JSON.stringify(body));\n const resp = await fetch(\"https://api.bannerbear.com/v2/images\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${BANNERBEAR_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n\n if (!resp.ok) {\n const t = await resp.text().catch(() => \"\");\n console.error(\"❌ Bannerbear error:\", resp.status, resp.statusText, t);\n return \"\";\n }\n\n const data = await resp.json();\n console.log(\"✅ Bannerbear response keys:\", Object.keys(data || {}));\n const url: string = data?.image_url ||\n data?.image_url_png ||\n data?.image?.url ||\n data?.thumb_url ||\n \"\";\n return url;\n}\n\n// ===== Transform =====\nfunction toCsv(rows: Row[], fields: string[]): string {\n const all = [...new Set([...fields, COL_OUT])];\n return Papa.unparse(rows, { columns: all });\n}\n\nasync function enrichRows(\n rows: Row[],\n force: boolean,\n throttleMs: number,\n limit: number | \"all\",\n): Promise {\n const effectiveRows = limit === \"all\"\n ? rows\n : rows.slice(0, Math.max(0, Number(limit)));\n\n // NEW: disable cache entirely when not a full run\n const skipCache = limit !== \"all\";\n\n console.log(\n `Processing ${effectiveRows.length}/${rows.length} rows (limit=${\n String(\n limit,\n )\n }, skipCache=${skipCache}, force=${force})`,\n );\n\n const out: Row[] = [];\n for (const row of effectiveRows) {\n const rowId = computeRowId(row);\n console.log(\"RowId:\", rowId);\n\n let url: string | null = null;\n if (!force && !skipCache) {\n url = await getCached(rowId);\n }\n\n if (!url) {\n url = await createBannerbearImage(row);\n if (url && !skipCache) await putCached(rowId, url);\n if (throttleMs > 0) await sleep(throttleMs);\n }\n\n console.log(\"Final URL:\", url);\n out.push({ ...row, [COL_OUT]: url ?? \"\" });\n }\n\n // If limited, pass through remaining rows unchanged (keeps CSV shape)\n if (effectiveRows.length < rows.length) {\n for (let i = effectiveRows.length; i < rows.length; i++) {\n out.push({ ...rows[i], [COL_OUT]: \"\" });\n }\n }\n\n return out;\n}\n\n// ===== HTTP entrypoint =====\nexport default async function (req: Request): Promise {\n try {\n console.log(\"=== Request ===\", req.url);\n if (!BANNERBEAR_API_KEY) {\n console.error(\"Missing BANNERBEAR_API_KEY\");\n return new Response(\"Missing BANNERBEAR_API_KEY secret.\", {\n status: 500,\n });\n }\n\n await cleanupOld();\n\n const u = new URL(req.url);\n const force = u.searchParams.get(\"force\") === \"1\";\n const throttle = Number(u.searchParams.get(\"throttle_ms\") ?? 0);\n\n // Row limit: default to DEFAULT_LIMIT; override with ?limit=all or ?limit=N\n const limitParam = u.searchParams.get(\"limit\");\n const limit: number | \"all\" = !limitParam\n ? DEFAULT_LIMIT\n : (limitParam.toLowerCase?.() === \"all\" ? \"all\" : Number(limitParam));\n\n console.log(\n `Options → force=${force} throttle=${throttle} limit=${String(limit)}`,\n );\n\n const { rows, fields } = await fetchCsv();\n if (!rows.length) {\n console.warn(\"No rows in source CSV\");\n return new Response(\"No rows in source CSV.\", { status: 200 });\n }\n\n const enriched = await enrichRows(rows, force, throttle, limit);\n const csv = toCsv(enriched, fields);\n\n console.log(\"Returning CSV with\", enriched.length, \"rows\");\n return new Response(csv, {\n headers: {\n \"Content-Type\": \"text/csv; charset=utf-8\",\n \"Cache-Control\": \"public, max-age=120\",\n },\n });\n } catch (e: any) {\n console.error(\"❌ Error:\", e);\n return new Response(`Error: ${e?.message ?? e}`, { status: 500 });\n }\n}","deleted","label","children",[],[150],"files",[148],"counts",{"_173":32,"_174":175,"_176":32,"_177":178},"pulls","branches",1,"forks","envVars",{"_179":175,"_180":32},"count","emptyCount","contents",[183],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":184,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_98":185},["D",1759448569838],[150],"file","upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name._index",{"_93":94,"_95":96,"_97":-7,"_99":-7,"_100":195,"_181":200,"_203":-7,"_204":-5,"_205":-5,"_169":206,"_210":211,"_212":-5,"_213":-5},{"_102":103,"_95":96,"_104":196,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":197,"_130":198,"_133":199,"_145":22},["D",1759442797506],{"_93":94,"_128":129},{"_93":94,"_132":129},{"_99":135,"_95":43,"_102":136,"_137":103,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},[201],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":184,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_98":202},[150],"readme","upstream","pull",[207],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":158,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_166":208,"_98":209},[],[150],"previews",[207],"ahead","behind","actionData","errors"]