[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_96":95,"_33":46,"_104":86,"_27":98,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":30},"file",{"_31":32,"_33":28,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_31":32,"_33":28,"_34":35,"_36":37},"deleted",false,"deletedHere","path","main.ts","latestPath","gotify.ts","fileId","dc25bc76-86dd-11f1-bc38-1607ee4eb77e","name","fileType","interval","content","/**\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\nasync function deleteGotifyMessage(\n baseUrl: string,\n token: string,\n messageId: number,\n): Promise {\n const cleanBaseUrl = baseUrl.replace(/\\/+$/, \"\");\n const url = `${cleanBaseUrl}/message/${messageId}`;\n\n await fetchWithRetry(url, {\n method: \"DELETE\",\n headers: {\n \"X-Gotify-Key\": token,\n },\n });\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 const systemPrompt = `You are my personal notification digest assistant.\n\nSummarize today's notifications.\n\nRules:\n\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:\n\n# Daily Notification Digest\n\n## SMS\n...\n\n## Messaging\n...\n\n## General\n...\n\n## Needs Attention\n...\n\n## Executive 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 // Send message using Markdown parse_mode\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: \"Markdown\",\n disable_web_page_preview: true,\n }),\n });\n\n // If Markdown parsing fails due to special characters in notification text, fallback to plain text\n if (!response.ok) {\n const errorData = await response.json();\n console.warn(\n \"Telegram Markdown 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 processed notifications ONLY after successful Telegram delivery\n console.log(\n `Cleaning up ${rawMessages.length} processed notifications from Gotify...`,\n );\n let deletedCount = 0;\n\n for (const msg of rawMessages) {\n try {\n await deleteGotifyMessage(gotifyUrl, gotifyToken, msg.id);\n deletedCount++;\n } catch (err: any) {\n console.error(`Failed to delete message ID ${msg.id}:`, err.message);\n }\n }\n\n console.log(\n `Cleanup complete. Successfully deleted ${deletedCount}/${rawMessages.length} messages.`,\n );\n return `Digest complete! Processed ${rawMessages.length} messages. Deleted ${deletedCount}.`;\n}","/**\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\nasync function deleteGotifyMessage(\n baseUrl: string,\n token: string,\n messageId: number,\n): Promise {\n const cleanBaseUrl = baseUrl.replace(/\\/+$/, \"\");\n const url = `${cleanBaseUrl}/message/${messageId}`;\n\n await fetchWithRetry(url, {\n method: \"DELETE\",\n headers: {\n \"X-Gotify-Key\": token,\n },\n });\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 processed notifications ONLY after successful Telegram delivery\n console.log(\n `Cleaning up ${rawMessages.length} processed notifications from Gotify...`,\n );\n let deletedCount = 0;\n\n for (const msg of rawMessages) {\n try {\n await deleteGotifyMessage(gotifyUrl, gotifyToken, msg.id);\n deletedCount++;\n } catch (err: any) {\n console.error(`Failed to delete message ID ${msg.id}:`, err.message);\n }\n }\n\n console.log(\n `Cleanup complete. Successfully deleted ${deletedCount}/${rawMessages.length} messages.`,\n );\n return `Digest complete! Processed ${rawMessages.length} messages. Deleted ${deletedCount}.`;\n}","createdAt",["D",1784876026013],"branchVersion","branchId","7f8b9bae-5c95-4159-97f7-11bbd10966fc","id","ff305588-ab9a-4c83-9c16-9ebf1af9f41d","daily-summary",["D",1784842286421],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AI-powered daily Gotify digest for Telegram","imageUrl","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",{"_96":95,"_103":98},"org",{"_96":95,"_97":98,"_99":98,"_18":56,"_100":101,"_102":25},"branch",{"_13":85,"_33":86,"_44":43,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":46,"_94":95},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ibrainbytes","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_33":46,"_39":150,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":151,"_80":152,"_82":153,"_84":25},"tree",[145],"files",[145],"counts",{"_133":62,"_134":135,"_136":62,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":126,"_33":28,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":25,"_39":129,"_13":130,"_34":35,"_36":38,"_24":25,"_131":-5,"_27":132},"e1f39b76-32ab-48af-a48f-68f303380049","parentId","latest",["D",1784876026013],3,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":62},"connections",{"_141":62,"_142":62},"count","unfilledCount",5,"emptyCount",{"_44":126,"_33":28,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":25,"_39":146,"_13":130,"_34":35,"_36":38,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1784876026013],"children",[],[28],["D",1784842286421],{"_96":95,"_103":98},{"_96":95,"_97":98,"_99":98,"_18":56,"_100":101,"_102":25},{"_13":85,"_33":86,"_44":43,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":46,"_94":95},"ctx",{"_78":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":196,"_197":-5,"_198":-7,"_199":-7,"_200":62,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_158":159,"_160":161,"_162":86,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v4