[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_102":85,"_27":37,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":25,"_119":-5,"_120":-5,"_121":122},"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":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","listenbrainz.ts","latestPath","fileId","f4f2b676-873e-11f1-b035-1607ee4eb77e","name","new-file-6431.ts","fileType","script","content","","createdAt",["D",1784884001498],"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",{"_95":94,"_101":37},"org",{"_95":94,"_96":37,"_97":37,"_18":55,"_98":99,"_100":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ibrainbytes","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":161,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":162,"_79":163,"_81":164,"_83":25},"tree",[152,153],"files",[152,153],"counts",{"_142":61,"_143":129,"_144":61,"_145":146,"_147":148},"contents",[123,124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":132,"_32":133,"_30":134,"_126":-5,"_41":42,"_40":135,"_127":136,"_38":137,"_13":138,"_34":139,"_36":140,"_24":25,"_130":-5,"_27":141},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":128,"_13":129,"_34":35,"_36":37,"_24":25,"_130":-5,"_27":131},"a7deccb9-4993-4ddf-8ffe-3752447b8c13","parentId","latest",["D",1784884001498],1,"label",[28],"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}",[133],"pulls","branches","forks","envVars",{"_149":138,"_151":61},"connections",{"_149":61,"_150":61},"count","unfilledCount","emptyCount",{"_43":132,"_32":133,"_30":134,"_126":-5,"_41":42,"_40":135,"_127":136,"_38":158,"_13":138,"_34":139,"_36":140,"_24":25,"_130":-5,"_155":159,"_27":160},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":25,"_38":154,"_13":129,"_34":35,"_36":37,"_24":25,"_130":-5,"_155":156,"_27":157},["D",1784884001498],"children",[],[28],["D",1784882243177],[],[133],["D",1784842286421],{"_95":94,"_101":37},{"_95":94,"_96":37,"_97":37,"_18":55,"_98":99,"_100":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_120":198,"_199":200,"_201":202,"_203":25,"_204":25,"_205":25,"_206":136,"_207":-5,"_208":-7,"_209":-7,"_210":61,"_211":25,"_212":25,"_213":-5,"_214":25,"_215":25,"_216":25,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":85,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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 · v8