[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_82":65,"_83":76,"_63":-7,"_84":-5,"_13":85,"_86":87,"_11":88,"_89":90,"_91":92,"_93":-5,"_94":-5,"_95":-5,"_96":26,"_97":98,"_99":26,"_100":-5,"_101":-5,"_102":103},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","ibrainbytes","id","ff305588-ab9a-4c83-9c16-9ebf1af9f41d","name","daily-summary","createdAt",["D",1784842286421],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","AI-powered daily Gotify digest for Telegram","imageUrl","userId","42d86647-c81f-4d2f-99cd-03eea2851519","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f514b-b1ca-76ec-99ed-af4c6af87ca8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_81":76},"org",{"_16":17,"_75":76,"_77":76,"_33":34,"_78":79,"_80":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",9,"main","7f8b9bae-5c95-4159-97f7-11bbd10966fc","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":153,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":154,"_58":155,"_60":156,"_62":26},"tree",[144,145],[144,145],"counts",{"_133":40,"_134":135,"_136":40,"_137":138,"_139":140},"contents",[104,105],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":124,"_20":125,"_108":126,"_110":-5,"_111":66,"_112":127,"_113":114,"_22":128,"_63":129,"_117":130,"_119":131,"_121":26,"_122":-5,"_83":132},{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":66,"_112":64,"_113":114,"_22":115,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_83":123},"ff76bbdd-0a2e-42e9-878d-1d00787532b4","listenbrainz.ts","fileId","f4f2b676-873e-11f1-b035-1607ee4eb77e","parentId","branchId","branchVersion","latest",true,["D",1784884008919],2,"fileType","script","content","import { createCanvas, loadImage } from \"https://deno.land/x/canvas@v1.4.1/mod.ts\";\n\ninterface Listen {\n listened_at: number;\n track_metadata: {\n artist_name: string;\n track_name: string;\n release_name?: string;\n mbid_mapping?: {\n caa_release_mbid?: string;\n release_mbid?: string;\n recording_mbid?: string;\n };\n };\n}\n\nexport default async function () {\n const username = Deno.env.get(\"LISTENBRAINZ_USERNAME\");\n const token = Deno.env.get(\"LISTENBRAINZ_TOKEN\"); // Recommended for higher rate limits\n const telegramToken = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n const geminiKey = Deno.env.get(\"GEMINI_API_KEY\");\n\n if (!username || !telegramToken || !chatId) {\n throw new Error(\"Missing required environment variables.\");\n }\n\n // 1. Fetch 24-Hour Scrobbles from ListenBrainz\n const twentyFourHoursAgo = Math.floor(Date.now() / 1000) - 24 * 60 * 60;\n \n const headers: Record = {\n \"User-Agent\": \"ValTown-DailyScrobbleBot/1.0 ( https://val.town )\",\n };\n if (token) {\n headers[\"Authorization\"] = `Token ${token}`;\n }\n\n // Note: ListenBrainz requires omitting max_ts when min_ts is provided\n const lbUrl = `https://api.listenbrainz.org/1/user/${username}/listens?min_ts=${twentyFourHoursAgo}&count=100`;\n const lbRes = await fetch(lbUrl, { headers });\n const lbData = await lbRes.json();\n const listens: Listen[] = lbData.payload?.listens ?? [];\n\n if (listens.length === 0) {\n await sendTelegramMessage(telegramToken, chatId, \"🎧 No scrobbles logged in the last 24 hours!\");\n return \"No scrobbles found.\";\n }\n\n // 2. Aggregate Top Tracks & Top Albums with Play Counts\n const trackMap = new Map();\n const albumMap = new Map();\n\n for (const item of listens) {\n const artist = item.track_metadata.artist_name;\n const track = item.track_metadata.track_name;\n const album = item.track_metadata.release_name || \"Unknown Album\";\n \n // Track stats\n const trackKey = `${artist} - ${track}`;\n if (trackMap.has(trackKey)) {\n trackMap.get(trackKey)!.count++;\n } else {\n trackMap.set(trackKey, { artist, track, count: 1 });\n }\n\n // Album stats\n const albumKey = `${artist} - ${album}`;\n const mbid = item.track_metadata.mbid_mapping?.caa_release_mbid || item.track_metadata.mbid_mapping?.release_mbid;\n\n if (albumMap.has(albumKey)) {\n albumMap.get(albumKey)!.count++;\n } else {\n albumMap.set(albumKey, { artist, album, track, mbid, count: 1 });\n }\n }\n\n // Sort Top Tracks & Top Albums\n const topTracks = Array.from(trackMap.values())\n .sort((a, b) => b.count - a.count)\n .slice(0, 5);\n\n const topAlbums = Array.from(albumMap.values())\n .sort((a, b) => b.count - a.count)\n .slice(0, 9);\n\n // Fallback metadata lookup for album art if MBID is missing\n for (const item of topAlbums) {\n if (!item.mbid && item.artist && item.track) {\n item.mbid = await lookupReleaseMbid(item.artist, item.track, token, headers[\"User-Agent\"]);\n }\n }\n\n // 3. Generate Collage Image (3x3 Grid)\n const collageBuffer = await createCollageBuffer(topAlbums);\n\n // 4. Perform Psychological Analysis via Gemini\n const trackListText = listens\n .map(l => `${l.track_metadata.artist_name} - ${l.track_metadata.track_name}`)\n .slice(0, 50)\n .join(\"\\n\");\n\n const promptText = `Act as an empathetic music psychologist. Analyze this user's daily listening history from the last 24 hours.\nKeep your analysis concise (max 3 short bullet points).\n\nIdentify:\n- Primary Vibe & Energy level\n- Cognitive State (e.g., Focus, Rumination, Comfort-seeking)\n- A brief empathetic daily takeaway\n\nListening Log:\n${trackListText}`;\n\n let psychologicalReport = \"\";\n\n if (geminiKey) {\n try {\n const geminiUrl = `https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash:generateContent?key=${geminiKey}`;\n \n const aiRes = await fetch(geminiUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n contents: [{ parts: [{ text: promptText }] }],\n generationConfig: {\n temperature: 0.7,\n maxOutputTokens: 250\n }\n })\n });\n\n const aiData = await aiRes.json();\n psychologicalReport = aiData.candidates?.[0]?.content?.parts?.[0]?.text || \"\";\n } catch (err) {\n console.error(\"Gemini API Error:\", err);\n }\n }\n\n // 5. Format Telegram Caption with Songs, Listen Counts, and Gemini Insights\n let caption = `📊 *Daily Scrobble Report* (${listens.length} total listens)\\n\\n`;\n\n if (psychologicalReport) {\n caption += `🧠 *Psychological Vibe*\\n${psychologicalReport.trim()}\\n\\n`;\n }\n\n caption += `🔥 *Top Tracks Today*\\n`;\n topTracks.forEach((t, i) => {\n caption += `${i + 1}. *${t.track}* — ${t.artist} (${t.count}x)\\n`;\n });\n\n // 6. Send Photo + Formatted Caption over Telegram\n await sendTelegramPhoto(telegramToken, chatId, collageBuffer, caption);\n\n return \"Collage and detailed scrobble report sent successfully!\";\n}\n\n// --- HELPER FUNCTIONS ---\n\n/**\n * Uses ListenBrainz /1/metadata/lookup/ endpoint to fetch MBID if missing from raw listen payload\n */\nasync function lookupReleaseMbid(artist: string, track: string, token?: string, userAgent?: string): Promise {\n try {\n const params = new URLSearchParams({\n artist_name: artist,\n recording_name: track,\n metadata: \"true\",\n incs: \"release\",\n });\n\n const headers: Record = {\n \"User-Agent\": userAgent || \"ValTown-DailyScrobbleBot/1.0\",\n };\n if (token) {\n headers[\"Authorization\"] = `Token ${token}`;\n }\n\n const res = await fetch(`https://api.listenbrainz.org/1/metadata/lookup/?${params.toString()}`, { headers });\n if (!res.ok) return undefined;\n\n const data = await res.json();\n return data?.metadata?.release?.mbid || data?.metadata?.caa_release_mbid;\n } catch (_) {\n return undefined;\n }\n}\n\nasync function createCollageBuffer(albums: { artist: string; album: string; mbid?: string }[]): Promise {\n const size = 300; // 300x300 per tile\n const cols = 3;\n const rows = 3;\n const canvas = createCanvas(cols * size, rows * size);\n const ctx = canvas.getContext(\"2d\");\n\n // Fill background\n ctx.fillStyle = \"#111111\";\n ctx.fillRect(0, 0, canvas.width, canvas.height);\n\n for (let i = 0; i < 9; i++) {\n const x = (i % cols) * size;\n const y = Math.floor(i / cols) * size;\n const item = albums[i];\n\n let imgLoaded = false;\n if (item && item.mbid) {\n try {\n const imgUrl = `https://coverartarchive.org/release/${item.mbid}/front-250`;\n const img = await loadImage(imgUrl);\n ctx.drawImage(img, x, y, size, size);\n imgLoaded = true;\n } catch (_) {\n // Fall through to text fallback\n }\n }\n\n if (!imgLoaded) {\n // Draw text placeholder\n ctx.fillStyle = \"#222222\";\n ctx.fillRect(x, y, size, size);\n ctx.fillStyle = \"#ffffff\";\n ctx.font = \"16px sans-serif\";\n if (item) {\n ctx.fillText(item.artist.slice(0, 20), x + 10, y + size / 2 - 10);\n ctx.fillText(item.album.slice(0, 20), x + 10, y + size / 2 + 15);\n }\n }\n }\n\n return canvas.toBuffer(\"image/jpeg\");\n}\n\nasync function sendTelegramPhoto(token: string, chatId: string, imageBuffer: Uint8Array, caption: string) {\n const formData = new FormData();\n formData.append(\"chat_id\", chatId);\n formData.append(\"photo\", new Blob([imageBuffer], { type: \"image/jpeg\" }), \"daily_collage.jpg\");\n \n // Enforce Telegram's strict 1024 character limit for image captions\n const trimmedCaption = caption.length > 1000 ? caption.slice(0, 990) + \"...\" : caption;\n \n formData.append(\"caption\", trimmedCaption);\n formData.append(\"parse_mode\", \"Markdown\");\n\n await fetch(`https://api.telegram.org/bot${token}/sendPhoto`, {\n method: \"POST\",\n body: formData,\n });\n}\n\nasync function sendTelegramMessage(token: string, chatId: string, text: string) {\n await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text }),\n });\n}","deleted","label",[107],"1b289ade-70fd-4621-bed1-904b7a0ee5ea","gotify.ts","dc25bc76-86dd-11f1-bc38-1607ee4eb77e",6,["D",1784882243177],5,"interval","/**\n * Val Town Daily Notification Digest Script\n *\n * Workflow:\n * 1. Fetches all notifications from Gotify (handling pagination).\n * 2. Categorizes, sorts, deduplicates, and counts repeated messages.\n * 3. Constructs a clean JSON payload for Gemini 2.5 Flash.\n * 4. Generates a daily markdown summary using Gemini.\n * 5. Sends the summary to Telegram.\n * 6. Deletes processed messages from Gotify ONLY after Telegram succeeds.\n */\n\n// --- TypeScript Interfaces ---\n\ninterface GotifyPaging {\n next?: string;\n since?: number;\n size?: number;\n}\n\ninterface GotifyMessage {\n id: number;\n appid: number;\n message: string;\n title: string;\n priority: number;\n date: string;\n extras?: Record;\n}\n\ninterface GotifyFetchResponse {\n paging?: GotifyPaging;\n messages: GotifyMessage[];\n}\n\ninterface ProcessedNotification {\n title: string;\n message: string;\n count: number;\n firstSeen: string;\n lastSeen: string;\n apps?: string[];\n}\n\ninterface DigestCategories {\n SMS: ProcessedNotification[];\n Messaging: ProcessedNotification[];\n General: ProcessedNotification[];\n}\n\ninterface GeminiResponse {\n candidates?: Array<{\n content?: {\n parts?: Array<{\n text?: string;\n }>;\n };\n }>;\n error?: {\n code: number;\n message: string;\n };\n}\n\n// --- Environment Helpers ---\n\nfunction getEnv(key: string): string {\n // Supports both Val Town (Deno.env) and Node-style process.env environments\n const value = typeof Deno !== \"undefined\"\n ? Deno.env.get(key)\n : typeof process !== \"undefined\"\n ? process.env[key]\n : undefined;\n\n if (!value) {\n throw new Error(`Missing required environment variable: ${key}`);\n }\n return value;\n}\n\n// --- Network Helper with Exponential Backoff ---\n\nasync function fetchWithRetry(\n url: string,\n options: RequestInit = {},\n retries = 3,\n delayMs = 1000,\n): Promise {\n let attempt = 0;\n while (attempt < retries) {\n try {\n const res = await fetch(url, options);\n if (res.ok) {\n return res;\n }\n // If client error (4xx) except 429, don't retry endlessly\n if (res.status >= 400 && res.status < 500 && res.status !== 429) {\n throw new Error(`HTTP ${res.status}: ${res.statusText}`);\n }\n throw new Error(`HTTP ${res.status}: ${res.statusText}`);\n } catch (err: any) {\n attempt++;\n console.warn(\n `Fetch attempt ${attempt}/${retries} failed for ${url}: ${err.message}`,\n );\n if (attempt >= retries) {\n throw err;\n }\n await new Promise((resolve) =>\n setTimeout(resolve, delayMs * Math.pow(2, attempt - 1))\n );\n }\n }\n throw new Error(`Failed to fetch ${url} after ${retries} attempts.`);\n}\n\n// --- Gotify API Functions ---\n\nasync function fetchAllGotifyMessages(\n baseUrl: string,\n token: string,\n): Promise {\n const allMessages: GotifyMessage[] = [];\n let since: number | undefined = undefined;\n const limit = 100;\n const cleanBaseUrl = baseUrl.replace(/\\/+$/, \"\");\n\n console.log(\"Fetching notifications from Gotify...\");\n\n while (true) {\n const queryParams = new URLSearchParams({ limit: limit.toString() });\n if (since !== undefined) {\n queryParams.set(\"since\", since.toString());\n }\n\n const url = `${cleanBaseUrl}/message?${queryParams.toString()}`;\n const response = await fetchWithRetry(url, {\n method: \"GET\",\n headers: {\n \"X-Gotify-Key\": token,\n \"Accept\": \"application/json\",\n },\n });\n\n const data: GotifyFetchResponse = await response.json();\n\n if (!data.messages || data.messages.length === 0) {\n break;\n }\n\n allMessages.push(...data.messages);\n\n if (data.paging && data.paging.since) {\n since = data.paging.since;\n } else {\n // Fallback: use max ID as since parameter if paging object is omitted\n const maxId = Math.max(...data.messages.map((m) => m.id));\n if (maxId === since) break; // Avoid infinite loop\n since = maxId;\n }\n\n if (data.messages.length < limit) {\n break;\n }\n }\n\n console.log(\n `Successfully fetched ${allMessages.length} total messages from Gotify.`,\n );\n return allMessages;\n}\n\n// Replace the old delete function with this single bulk-delete call:\nasync function deleteAllGotifyMessages(baseUrl: string, token: string): Promise {\n const cleanBaseUrl = baseUrl.replace(/\\/+$/, \"\");\n const url = `${cleanBaseUrl}/message`;\n\n console.log(\"Deleting all processed messages from Gotify in a single bulk request...\");\n\n const response = await fetchWithRetry(url, {\n method: \"DELETE\",\n headers: {\n \"X-Gotify-Key\": token,\n },\n });\n\n if (!response.ok) {\n throw new Error(`Failed to delete messages. HTTP Status: ${response.status}`);\n }\n\n console.log(\"Successfully cleared all Gotify messages.\");\n}\n\n// --- Data Processing & Deduplication ---\n\nfunction categorizeMessage(\n msg: GotifyMessage,\n): \"SMS\" | \"Messaging\" | \"General\" {\n const textToTest = `${msg.title} ${msg.message}`.toLowerCase();\n\n // Pattern checks for SMS\n const smsPattern = /\\b(sms|text message)\\b|sms from/i;\n if (smsPattern.test(textToTest)) {\n return \"SMS\";\n }\n\n // Pattern checks for Instant Messaging applications\n const messagingPattern =\n /\\b(telegram|whatsapp|discord|signal|messenger|viber|slack|element|imessage|line|wechat)\\b|\\[(telegram|whatsapp|discord|signal|messenger)\\]/i;\n if (messagingPattern.test(textToTest)) {\n return \"Messaging\";\n }\n\n return \"General\";\n}\n\nfunction processAndGroupNotifications(\n messages: GotifyMessage[],\n): DigestCategories {\n const categories: DigestCategories = {\n SMS: [],\n Messaging: [],\n General: [],\n };\n\n // Group raw messages by category\n const rawGrouped: Record<\"SMS\" | \"Messaging\" | \"General\", GotifyMessage[]> = {\n SMS: [],\n Messaging: [],\n General: [],\n };\n\n for (const msg of messages) {\n const category = categorizeMessage(msg);\n rawGrouped[category].push(msg);\n }\n\n // Deduplicate and aggregate within each category\n for (const cat of [\"SMS\", \"Messaging\", \"General\"] as const) {\n const items = rawGrouped[cat];\n\n // Sort chronologically (oldest first)\n items.sort((a, b) =>\n new Date(a.date).getTime() - new Date(b.date).getTime()\n );\n\n const map = new Map();\n\n for (const item of items) {\n // Normalize key for deduplication\n const cleanTitle = item.title.trim();\n const cleanMessage = item.message.trim();\n const key = `${cleanTitle}|||${cleanMessage}`;\n\n if (map.has(key)) {\n const existing = map.get(key)!;\n existing.count += 1;\n existing.lastSeen = item.date;\n } else {\n map.set(key, {\n title: cleanTitle,\n message: cleanMessage,\n count: 1,\n firstSeen: item.date,\n lastSeen: item.date,\n });\n }\n }\n\n categories[cat] = Array.from(map.values()).map((entry) => {\n // Keep timestamps only if span adds value or count > 1\n const isMulti = entry.count > 1;\n const formattedEntry: ProcessedNotification = {\n title: entry.title,\n message: entry.message,\n count: entry.count,\n firstSeen: entry.firstSeen,\n lastSeen: entry.lastSeen,\n };\n\n if (!isMulti) {\n // Single occurrences keep just the primary timestamp\n delete (formattedEntry as any).lastSeen;\n }\n\n return formattedEntry;\n });\n }\n\n return categories;\n}\n\n// --- Gemini API Call ---\n\nasync function generateDigestWithGemini(\n categories: DigestCategories,\n geminiKey: string,\n): Promise {\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key=${geminiKey}`;\n\n // Replace the system prompt inside generateDigestWithGemini:\n const systemPrompt = `You are my personal notification digest assistant.\n\nSummarize today's notifications.\n\nRules:\n- Group information logically.\n- Mention repeated notifications only once.\n- Report counts where appropriate.\n- Ignore obvious spam and repeated system events.\n- Highlight anything requiring my attention.\n- Mention missed conversations.\n- Mention authentication codes only if still useful.\n- Be concise.\n- Do not hallucinate.\n\nOutput format using Telegram HTML tags (bold, italic, code):\n\nDaily Notification Digest\n\nSMS\n...\n\nMessaging\n...\n\nGeneral\n...\n\nNeeds Attention\n...\n\nExecutive Summary\n2-4 sentences.`;\n\n const payload = {\n contents: [\n {\n role: \"user\",\n parts: [\n { text: systemPrompt },\n {\n text:\n `Here is today's processed notification data in JSON format:\\n\\n${\n JSON.stringify(\n categories,\n null,\n 2,\n )\n }`,\n },\n ],\n },\n ],\n generationConfig: {\n temperature: 0.2,\n maxOutputTokens: 2048,\n },\n };\n\n console.log(\"Sending structured notification payload to Gemini 2.5 Flash...\");\n\n const response = await fetchWithRetry(url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(payload),\n });\n\n const data: GeminiResponse = await response.json();\n\n if (data.error) {\n throw new Error(\n `Gemini API Error (${data.error.code}): ${data.error.message}`,\n );\n }\n\n const generatedText = data.candidates?.[0]?.content?.parts?.[0]?.text;\n\n if (!generatedText) {\n throw new Error(\"Gemini API returned an empty response.\");\n }\n\n return generatedText;\n}\n\n// --- Telegram Delivery ---\n\nasync function sendTelegramMessage(\n text: string,\n botToken: string,\n chatId: string,\n): Promise {\n const url = `https://api.telegram.org/bot${botToken}/sendMessage`;\n\n console.log(\"Sending digest to Telegram...\");\n\n let response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text: text,\n parse_mode: \"HTML\", // <-- Changed from \"Markdown\" to \"HTML\"\n disable_web_page_preview: true,\n }),\n });\n\n // Fallback to plain text if HTML parsing encounters unexpected tags\n if (!response.ok) {\n const errorData = await response.json();\n console.warn(\n \"Telegram HTML delivery failed, attempting plain text fallback:\",\n errorData,\n );\n\n response = await fetchWithRetry(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text: text,\n disable_web_page_preview: true,\n }),\n });\n }\n\n if (!response.ok) {\n throw new Error(`Failed to send Telegram message: ${response.statusText}`);\n }\n\n console.log(\"Successfully delivered notification digest to Telegram.\");\n}\n\n// --- Main Cron Entrypoint for Val Town ---\n\nexport default async function (interval?: any) {\n console.log(\n `[${\n new Date().toISOString()\n }] Starting Daily Notification Digest Execution...`,\n );\n\n // Load secrets\n const gotifyUrl = getEnv(\"GOTIFY_URL\");\n const gotifyToken = getEnv(\"GOTIFY_TOKEN\");\n const geminiApiKey = getEnv(\"GEMINI_API_KEY\");\n const telegramBotToken = getEnv(\"TELEGRAM_BOT_TOKEN\");\n const telegramChatId = getEnv(\"TELEGRAM_CHAT_ID\");\n\n // Step 1 & 2: Fetch all notifications from Gotify\n const rawMessages = await fetchAllGotifyMessages(gotifyUrl, gotifyToken);\n\n if (rawMessages.length === 0) {\n console.log(\"No notifications to process. Exiting gracefully.\");\n return \"No notifications found.\";\n }\n\n // Step 3 & 4: Categorize, sort, deduplicate, and count\n const structuredCategories = processAndGroupNotifications(rawMessages);\n\n // Step 5, 6 & 7: Generate summary using Gemini 2.5 Flash\n const digestMarkdown = await generateDigestWithGemini(\n structuredCategories,\n geminiApiKey,\n );\n\n // Step 8: Deliver summary to Telegram\n await sendTelegramMessage(digestMarkdown, telegramBotToken, telegramChatId);\n\n // Step 9: Safe cleanup - delete all processed notifications at once\n console.log(\n `Cleaning up ${rawMessages.length} processed notifications from Gotify...`,\n );\n try {\n await deleteAllGotifyMessages(gotifyUrl, gotifyToken);\n return `Digest complete! Processed ${rawMessages.length} messages and wiped Gotify in 1 request.`;\n } catch (err: any) {\n console.error(`Failed to bulk delete Gotify messages:`, err.message);\n return `Digest sent to Telegram, but Gotify bulk deletion failed: ${err.message}`;\n }\n}",[125],"pulls","branches",1,"forks","envVars",{"_141":129,"_143":40},"connections",{"_141":40,"_142":40},"count","unfilledCount","emptyCount",{"_18":124,"_20":125,"_108":126,"_110":-5,"_111":66,"_112":127,"_113":114,"_22":150,"_63":129,"_117":130,"_119":131,"_121":26,"_122":-5,"_147":151,"_83":152},{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":66,"_112":64,"_113":114,"_22":146,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_147":148,"_83":149},["D",1784884008919],"children",[],[107],["D",1784882243177],[],[125],["D",1784842286421],{"_16":17,"_81":76},{"_16":17,"_75":76,"_77":76,"_33":34,"_78":79,"_80":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_101":190,"_191":192,"_193":194,"_195":26,"_196":26,"_197":26,"_198":114,"_199":-5,"_200":-7,"_201":-7,"_202":40,"_203":26,"_204":26,"_205":-5,"_206":26,"_207":26,"_208":26,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":65,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"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"]