[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_164":165,"_166":167},"routes/_app.x.$handle.$name",{"_94":93,"_32":44,"_101":84,"_26":36,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":24,"_115":116,"_117":24,"_118":-5,"_119":-5,"_120":121},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":24},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":29},"file",{"_30":31,"_32":27,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","new-file-6431.ts","latestPath","listenbrainz.ts","fileId","f4f2b676-873e-11f1-b035-1607ee4eb77e","name","fileType","script","content","","createdAt",["D",1784883989190],"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",{"_94":93,"_100":36},"org",{"_94":93,"_95":36,"_96":36,"_18":54,"_97":98,"_99":24},"branch",{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ibrainbytes","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":160,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":161,"_78":162,"_80":163,"_82":24},"tree",[151,152],"files",[151,152],"counts",{"_140":60,"_141":142,"_143":60,"_144":145,"_146":147},"contents",[122,123],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":130,"_32":131,"_30":132,"_125":-5,"_40":41,"_39":133,"_126":134,"_37":135,"_13":136,"_33":137,"_35":138,"_23":24,"_128":-5,"_26":139},{"_42":124,"_32":27,"_30":31,"_125":-5,"_40":41,"_39":14,"_126":24,"_37":127,"_13":60,"_33":34,"_35":36,"_23":24,"_128":-5,"_26":129},"df67c30d-7077-4088-bc85-839a719fd729","parentId","latest",["D",1784883989190],"label",[27],"1b289ade-70fd-4621-bed1-904b7a0ee5ea","gotify.ts","dc25bc76-86dd-11f1-bc38-1607ee4eb77e",6,true,["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}",[131],"pulls","branches",1,"forks","envVars",{"_148":136,"_150":60},"connections",{"_148":60,"_149":60},"count","unfilledCount","emptyCount",{"_42":130,"_32":131,"_30":132,"_125":-5,"_40":41,"_39":133,"_126":134,"_37":157,"_13":136,"_33":137,"_35":138,"_23":24,"_128":-5,"_154":158,"_26":159},{"_42":124,"_32":27,"_30":31,"_125":-5,"_40":41,"_39":14,"_126":24,"_37":153,"_13":60,"_33":34,"_35":36,"_23":24,"_128":-5,"_154":155,"_26":156},["D",1784883989190],"children",[],[27],["D",1784882243177],[],[131],["D",1784842286421],{"_94":93,"_100":36},{"_94":93,"_95":36,"_96":36,"_18":54,"_97":98,"_99":24},{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"ctx",{"_76":-5,"_119":197,"_198":199,"_200":201,"_202":24,"_203":24,"_204":24,"_205":134,"_206":-5,"_207":-7,"_208":-7,"_209":60,"_210":24,"_211":24,"_212":-5,"_213":24,"_214":24,"_215":24,"_216":-5},"ENV",{"_168":169,"_170":171,"_172":84,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196},"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 · v7