(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/title>/)?.[1]?.trim() ?? \"\";\n const link = block.match(/<link>([\\s\\S]*?)<\\/link>/)?.[1]?.trim() ?? \"\";\n const pubDateStr = block.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/)?.[1]?.trim() ?? \"\";\n const sourceName = block.match(/<source[^>]*>([\\s\\S]*?)<\\/source>/)?.[1]?.trim() ?? \"\";\n const description = block.match(/<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/)?.[1]?.trim() ?? \"\";\n\n // Strip HTML from description\n const snippet = description.replace(/<[^>]+>/g, \"\").trim();\n\n const pubDate = pubDateStr ? new Date(pubDateStr) : new Date();\n\n if (title && link) {\n items.push({\n title: decodeEntities(title),\n url: link,\n source: sourceName || \"Google News\",\n pubDate,\n snippet: decodeEntities(snippet).slice(0, 300),\n });\n }\n }\n\n return items;\n}\n\nfunction decodeEntities(text: string): string {\n return text\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/'/g, \"'\");\n}\n\n/** Build Google News RSS query for UAE disasters */\nfunction buildRSSUrl(): string {\n const location = encodeURIComponent(\n '(\"Dubai\" OR \"UAE\" OR \"United Arab Emirates\" OR \"Abu Dhabi\" OR \"Sharjah\" OR \"Al Ain\")',\n );\n const disasters = encodeURIComponent(\n '(disaster OR emergency OR crisis OR outbreak OR epidemic OR pandemic OR attack OR explosion OR earthquake OR flood OR fire OR evacuation OR \"security alert\" OR \"security warning\" OR war OR missile OR conflict OR bombing OR \"chemical spill\" OR contamination OR casualties OR killed OR injured OR \"state of emergency\" OR lockdown OR curfew OR \"air strike\" OR \"drone strike\" OR shelling OR rocket OR terror OR kidnapping OR hostage)',\n );\n const exclude = encodeURIComponent(\n \"-sports -football -cricket -golf -tennis -movie -film -celebrity -entertainment -fashion -restaurant -recipe -travel -tourism -property -\" +\n '\"real estate\" -\"stock market\" -crypto -bitcoin -gaming -esports -concert -festival -exhibition',\n );\n\n return `https://news.google.com/rss/search?q=${location}+AND+${disasters}+${exclude}&hl=en&gl=AE&ceid=AE:en`;\n}\n\n/** Fetch latest disaster news for Dubai/UAE */\nexport async function fetchDisasterNews(): Promise<NewsItem[]> {\n const url = buildRSSUrl();\n console.log(`Fetching news from: ${url}`);\n\n const res = await fetch(url, {\n headers: { \"User-Agent\": \"DubaiDisasterAlerts/1.0\" },\n });\n\n if (!res.ok) {\n console.error(`RSS fetch failed: ${res.status}`);\n return [];\n }\n\n const xml = await res.text();\n const items = parseXML(xml);\n console.log(`Parsed ${items.length} RSS items`);\n\n // Filter to only relevant disaster alerts\n const relevant = items.filter(isRelevantAlert);\n\n // Sort by severity (highest first)\n relevant.sort((a, b) => getSeverity(b) - getSeverity(a));\n\n console.log(`${relevant.length} items passed relevance filter`);\n return relevant;\n}\n",[],[168,213],"51302463-47dd-40a1-a604-038bba9daf95","db.ts","89c484e4-85ca-11f1-9ed2-1607ee4eb77e",4,["D",1784724036590],"// SQLite helpers for deduplication and settings\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface SentAlert {\n url: string;\n title: string;\n sent_at: string;\n}\n\nexport async function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sent_alerts (\n url TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n source TEXT,\n sent_at TEXT NOT NULL\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )\n `);\n}\n\n/** Check if we've already sent an alert for this URL */\nexport async function isAlreadySent(url: string): Promise<boolean> {\n const result = await sqlite.execute({\n sql: \"SELECT 1 FROM sent_alerts WHERE url = ?\",\n args: [url],\n });\n return result.rows.length > 0;\n}\n\n/** Record a sent alert */\nexport async function recordAlert(\n url: string,\n title: string,\n source: string,\n): Promise<void> {\n await sqlite.execute({\n sql:\n \"INSERT OR IGNORE INTO sent_alerts (url, title, source, sent_at) VALUES (?, ?, ?, ?)\",\n args: [url, title, source, new Date().toISOString()],\n });\n}\n\n/** Get a setting value */\nexport async function getSetting(key: string): Promise<string | null> {\n const result = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key = ?\",\n args: [key],\n });\n return result.rows[0]?.value ?? null;\n}\n\n/** Set a setting value */\nexport async function setSetting(key: string, value: string): Promise<void> {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO settings (key, value) VALUES (?, ?)\",\n args: [key, value],\n });\n}\n\n/** Get the Telegram chat ID (stored when user first messages the bot) */\nexport async function getChatId(): Promise<string | null> {\n return await getSetting(\"telegram_chat_id\");\n}\n\n/** Clean up alerts older than 30 days */\nexport async function cleanupOldAlerts(): Promise<void> {\n const cutoff = new Date();\n cutoff.setDate(cutoff.getDate() - 30);\n await sqlite.execute({\n sql: \"DELETE FROM sent_alerts WHERE sent_at < ?\",\n args: [cutoff.toISOString()],\n });\n}\n",[],[168,221],["D",1784723989388],[185,186,187],[168],["D",1784723916048],["D",1789473046147],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":58,"_107":108,"_109":30},{"_13":92,"_37":93,"_46":45,"_94":47,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":48,"_101":102},"ctx",{"_85":-5,"_129":269,"_270":271,"_272":273,"_274":30,"_275":30,"_276":30,"_277":62,"_278":-5,"_279":-7,"_280":-7,"_281":66,"_282":30,"_283":30,"_284":-5,"_285":30,"_286":30,"_287":30,"_288":-5},"ENV",{"_240":241,"_242":243,"_244":93,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268},"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"] </article></body></html>

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_236":237,"_238":239},"routes/_app.x.$handle.$name",{"_103":102,"_37":48,"_111":93,"_32":105,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_26":-5,"_122":-5,"_123":-5,"_124":30,"_125":126,"_127":62,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_46":47,"_37":48,"_41":49,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":30},"version",8,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","41dee2cc-e5d7-4919-a5ee-bc00e30d69f8","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":26,"_39":40,"_41":42,"_43":14,"_44":45,"_29":30},"previous","deleted",false,"deletedHere","path","README.md","latestPath","fileId","ba0cabd6-85ca-11f1-8e16-1607ee4eb77e","name","fileType","content","# 🚨 Dubai Disaster Alerts\n\nReal-time disaster monitoring for Dubai & UAE — sends you a **Telegram DM** the moment something happens that affects **health, security, or war**.\n\n## How it works\n\n1. **`monitor.ts`** (interval, every 15 min) — fetches disaster news from Google News RSS filtered for UAE/Dubai + disaster keywords\n2. **`lib/news.ts`** — parses RSS, filters by relevance (UAE location + disaster keywords, excludes sports/entertainment), scores severity\n3. **`lib/db.ts`** — SQLite tracks sent alerts (deduplication) and stores your Telegram chat ID\n4. **`lib/telegram.ts`** — sends messages via the Telegram Bot API\n5. **`webhook.ts`** (HTTP endpoint) — receives Telegram messages so you can register your chat ID with `/start`\n\n## Setup (3 steps)\n\n### Step 1: Create a Telegram bot\n\n1. Open Telegram and message [@BotFather](https://t.me/botfather)\n2. Send `/newbot`\n3. Give it a name (e.g. \"Dubai Disaster Alerts\") and a username\n4. **Copy the bot token** it gives you\n\n### Step 2: Add the bot token as an env var\n\n👉 Add TELEGRAM_TOKEN here: https://www.val.town/x/aunova/dubai-disaster-alerts/environment-variables?key=TELEGRAM_TOKEN\n\n### Step 3: Register your webhook & chat ID\n\n1. **Run `main.ts`** (click Run) — this registers the webhook with Telegram\n2. Open Telegram, find your bot, and **send `/start`**\n3. The bot will confirm registration ✅\n\nYou're done! You'll receive disaster alerts every 15 minutes.\n\n## Bot commands\n\n| Command | Description |\n|---------|-------------|\n| `/start` | Register your chat ID to receive alerts |\n| `/test` | Send a test alert to verify everything works |\n| `/status` | Check system status |\n\n## What it monitors\n\n- 🚨 **Disasters & emergencies** — earthquakes, floods, fires, explosions, storms, building collapses\n- 🏥 **Health crises** — disease outbreaks, epidemics, contamination, chemical spills, biohazards\n- 🔒 **Security threats** — attacks, terrorism, bombings, kidnappings, evacuations, state of emergency\n- ⚔️ **War & conflict** — missiles, airstrikes, shelling, military operations, casualties\n\n## Architecture\n\n```\nGoogle News RSS (UAE-focused)\n │\n ▼\n monitor.ts (every 15 min)\n │\n ├── lib/news.ts ──► Parse + filter (disaster keywords + UAE location)\n ├── lib/db.ts ─────► Deduplicate via SQLite\n └── lib/telegram.ts ► Send DM via Telegram Bot API\n │\n ▼\n Your Telegram inbox 📱\n```\n\n## Notes\n\n- **Free tier**: checks every 15 minutes (minimum interval on free plan). Upgrade to Pro for 1-minute checks.\n- **Deduplication**: each article URL is stored in SQLite — you'll never get the same alert twice.\n- **Auto-cleanup**: sent alert records older than 30 days are automatically removed.\n- **Source**: Google News RSS aggregating from Khaleej Times, The National, Gulf News, Reuters, AP, and many more.\n\n## Environment Variables\n\n| Key | Description |\n|-----|-------------|\n| `TELEGRAM_TOKEN` | Bot token from @BotFather |\n","createdAt",["D",1784724117555],"branchVersion","branchId","f5b5b918-d99f-4261-8c4e-a16e53bcdccd","id","45ff8560-3531-44fa-b704-3180b654d85b","dubai-disaster-alerts",["D",1784723916048],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Real-time Dubai/UAE disaster alerts via Telegram DM","imageUrl","4d8af6d5-db18-44a4-9d3e-2d363035660b","pinnedFileId","a5b9d7e4-85ca-11f1-895f-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019ebb30-aa71-751d-8f8c-b9a92d90b000","tursoName","45ff8560353144fab7043180b654d85b","tursoHostname","45ff8560353144fab7043180b654d85b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789473046147],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_110":105},"org",{"_103":102,"_104":105,"_106":105,"_19":58,"_107":108,"_109":30},"branch",{"_13":92,"_37":93,"_46":45,"_94":47,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":48,"_101":102},"isOwned",12,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","aunova","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_46":47,"_37":48,"_41":231,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":232,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":233,"_87":234,"_89":235,"_91":30},"tree",[184,188,189,190,191],"files",[184,185,186,187,188,189,190,191],"counts",{"_174":66,"_175":160,"_176":66,"_177":178,"_179":180},"contents",[132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_46":167,"_37":168,"_35":169,"_139":-5,"_44":45,"_43":170,"_141":62,"_41":171,"_13":66,"_38":172,"_39":-5,"_29":30,"_145":-5,"_32":173},{"_46":164,"_37":33,"_35":36,"_139":-5,"_44":45,"_43":14,"_141":62,"_41":165,"_13":66,"_38":26,"_39":40,"_29":30,"_145":-5,"_32":166},{"_46":155,"_37":156,"_35":157,"_139":-5,"_44":45,"_43":158,"_141":62,"_41":159,"_13":160,"_38":161,"_39":162,"_29":30,"_145":-5,"_32":163},{"_46":147,"_37":148,"_35":149,"_139":-5,"_44":45,"_43":150,"_141":30,"_41":151,"_13":66,"_38":152,"_39":153,"_29":30,"_145":-5,"_32":154},{"_46":137,"_37":138,"_35":60,"_139":-5,"_44":45,"_43":140,"_141":62,"_41":142,"_13":66,"_38":143,"_39":144,"_29":30,"_145":-5,"_32":146},"c6f42285-fdbc-48c6-85cf-ee8b3d7afffe","webhook.ts","parentId",5,"latest",["D",1784724083541],"http","// Telegram Webhook Handler\n// Receives messages from Telegram (e.g. /start) to register the user's chat ID.\n// This is the endpoint you register with Telegram as your bot webhook.\n\nimport { sendMessage, escapeHTML } from \"./lib/telegram.ts\";\nimport { initDB, setSetting, getChatId } from \"./lib/db.ts\";\n\nconst SECRET_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")?.split(\":\")[1];\n\nexport default async (req: Request): Promise => {\n // Handle GET — health check\n if (req.method === \"GET\") {\n return new Response(\n \"Dubai Disaster Alert bot is running. Send /start to the bot on Telegram to register.\",\n { status: 200, headers: { \"Content-Type\": \"text/plain\" } },\n );\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n // Verify secret token header from Telegram\n const secretHeader = req.headers.get(\"x-telegram-bot-api-secret-token\");\n if (SECRET_TOKEN && secretHeader !== SECRET_TOKEN) {\n return new Response(\"Unauthorized\", { status: 401 });\n }\n\n try {\n const update = await req.json();\n const message = update.message;\n if (!message) {\n return new Response(\"OK\", { status: 200 });\n }\n\n const chatId = String(message.chat.id);\n const text = message.text ?? \"\";\n\n await initDB();\n\n // Handle /start command — register the chat ID\n if (text.startsWith(\"/start\")) {\n await setSetting(\"telegram_chat_id\", chatId);\n\n const botName = \"Dubai Disaster Alerts\";\n await sendMessage(\n chatId,\n [\n `✅ ${escapeHTML(botName)} — Registered!`,\n ``,\n `You will now receive real-time disaster alerts for Dubai & UAE via DM.`,\n ``,\n `Monitored categories:`,\n `🚨 Disasters & emergencies`,\n `🏥 Health crises & outbreaks`,\n `🔒 Security threats & attacks`,\n `⚔️ War & conflict`,\n ``,\n `Alerts are checked every 15 minutes.`,\n ``,\n `Commands:`,\n `/start — Re-register this chat`,\n `/test — Send a test alert`,\n `/status — Check system status`,\n ].join(\"\\n\"),\n { parseMode: \"HTML\" },\n );\n\n return new Response(\"OK\", { status: 200 });\n }\n\n // Handle /test command — send a fake alert to verify delivery\n if (text.startsWith(\"/test\")) {\n await sendMessage(\n chatId,\n [\n `🚨 Test Alert — Dubai/UAE Disaster Alert`,\n ``,\n `This is a test message to verify alerts are working.`,\n ``,\n `If you received this, your bot is correctly configured!`,\n ``,\n `📰 Source: Test System`,\n `🔥 Severity: TEST`,\n `🕐 ${new Date().toISOString().replace(\"T\", \" \").slice(0, 16)} UTC`,\n ].join(\"\\n\"),\n { parseMode: \"HTML\" },\n );\n return new Response(\"OK\", { status: 200 });\n }\n\n // Handle /status command\n if (text.startsWith(\"/status\")) {\n const registeredChatId = await getChatId();\n const status = registeredChatId\n ? `✅ Chat ID registered: ${escapeHTML(registeredChatId)}`\n : `❌ No chat ID registered. Send /start first.`;\n\n await sendMessage(\n chatId,\n [\n `📊 System Status`,\n ``,\n status,\n `🤖 Bot: Active`,\n `⏱️ Check interval: Every 15 minutes`,\n `📡 Source: Google News RSS (UAE-focused)`,\n ].join(\"\\n\"),\n { parseMode: \"HTML\" },\n );\n return new Response(\"OK\", { status: 200 });\n }\n\n // Default response for unrecognized messages\n await sendMessage(\n chatId,\n \"Send /start to register for disaster alerts, /test for a test alert, or /status for system info.\",\n { parseMode: \"HTML\" },\n );\n\n return new Response(\"OK\", { status: 200 });\n } catch (err) {\n console.error(\"Webhook error:\", err);\n return new Response(\"Internal error\", { status: 500 });\n }\n};\n","label",[138],"4da88fb2-0c03-4f1b-85d6-1f684f2e1431","monitor.ts","a5c16b76-85ca-11f1-8e16-1607ee4eb77e",6,["D",1784724083548],"interval","// Dubai Disaster Alert Monitor\n// Runs on a schedule (every 15 min on free tier) to check for new disasters\n// and sends Telegram DM alerts for anything affecting health, security, or war.\n\nimport { fetchDisasterNews, getSeverity, type NewsItem } from \"./lib/news.ts\";\nimport { sendMessage, escapeHTML } from \"./lib/telegram.ts\";\nimport {\n initDB,\n isAlreadySent,\n recordAlert,\n getChatId,\n cleanupOldAlerts,\n} from \"./lib/db.ts\";\n\nexport default async function (interval: Interval) {\n console.log(`[${new Date().toISOString()}] Dubai disaster monitor running...`);\n\n // 1. Initialize database\n await initDB();\n\n // 2. Get the user's Telegram chat ID\n const chatId = await getChatId();\n if (!chatId) {\n console.log(\n \"No Telegram chat ID found. Send /start to the bot to register. Skipping.\",\n );\n return;\n }\n\n // 3. Fetch latest disaster news\n const newsItems = await fetchDisasterNews();\n if (newsItems.length === 0) {\n console.log(\"No disaster news found this cycle.\");\n return;\n }\n\n // 4. Filter to only new (unsent) alerts\n const newAlerts: NewsItem[] = [];\n for (const item of newsItems) {\n const alreadySent = await isAlreadySent(item.url);\n if (!alreadySent) {\n newAlerts.push(item);\n }\n }\n\n console.log(\n `${newAlerts.length} new alerts to send (out of ${newsItems.length} relevant)`,\n );\n\n // 5. Send each new alert via Telegram\n let sentCount = 0;\n for (const alert of newAlerts) {\n const severity = getSeverity(alert);\n const emoji = severity >= 5 ? \"🚨\" : severity >= 3 ? \"⚠️\" : \"📢\";\n const severityLabel = severity >= 5 ? \"HIGH\" : severity >= 3 ? \"MEDIUM\" : \"LOW\";\n\n const message = [\n `${emoji} Dubai/UAE Disaster Alert`,\n ``,\n `${escapeHTML(alert.title)}`,\n ``,\n `${escapeHTML(alert.snippet)}`,\n ``,\n `📰 Source: ${escapeHTML(alert.source)}`,\n `🔥 Severity: ${severityLabel}`,\n `🕐 ${alert.pubDate.toISOString().replace(\"T\", \" \").slice(0, 16)} UTC`,\n ``,\n `Read full article →`,\n ].join(\"\\n\");\n\n const success = await sendMessage(chatId, message, {\n parseMode: \"HTML\",\n disableWebPagePreview: false,\n });\n\n if (success) {\n await recordAlert(alert.url, alert.title, alert.source);\n sentCount++;\n // Small delay to avoid Telegram rate limiting\n await new Promise((r) => setTimeout(r, 500));\n }\n }\n\n // 6. Cleanup old records monthly-ish\n await cleanupOldAlerts();\n\n console.log(\n `Done. Sent ${sentCount}/${newAlerts.length} alerts. Next run: ${\n new Date(Date.now() + (interval?.lastRunAt ? 0 : 15 * 60 * 1000))\n .toISOString()\n }`,\n );\n}\n",[148],"2c2f9340-add3-41e3-b5ea-9963beeaa5b1","main.ts","41e92cd8-85ca-11f1-895f-1607ee4eb77e",7,["D",1784724117547],1,"script","// Setup helper — run this once to register your webhook with Telegram.\n// You need TELEGRAM_TOKEN set as an env var first.\n//\n// Usage: click \"Run\" on this file after setting TELEGRAM_TOKEN.\n\nimport { getBotInfo } from \"./lib/telegram.ts\";\n\nconst token = Deno.env.get(\"TELEGRAM_TOKEN\");\nif (!token) {\n console.error(\"❌ TELEGRAM_TOKEN env var not set!\");\n console.error(\"Add it here: https://www.val.town/x/aunova/dubai-disaster-alerts/environment-variables?key=TELEGRAM_TOKEN\");\n throw new Error(\"TELEGRAM_TOKEN not set\");\n}\n\n// 1. Get bot info\nconst botInfo = await getBotInfo();\nconsole.log(`✅ Bot connected: @${botInfo.username} (${botInfo.first_name})`);\n\n// 2. Register webhook\nconst webhookUrl = \"https://aunova--a5b9d7e485ca11f1895f1607ee4eb77e.web.val.run\";\nconst secretToken = token.split(\":\")[1];\n\nconst res = await fetch(\n `https://api.telegram.org/bot${token}/setWebhook`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n url: webhookUrl,\n secret_token: secretToken,\n }),\n },\n);\n\nconst data = await res.json();\nif (data.ok) {\n console.log(`✅ Webhook registered: ${webhookUrl}`);\n console.log(\"\");\n console.log(\"Next steps:\");\n console.log(`1. Open Telegram and search for @${botInfo.username}`);\n console.log(\"2. Send /start to the bot\");\n console.log(\"3. You're done! Disaster alerts will arrive every 15 minutes.\");\n} else {\n console.error(\"❌ Webhook registration failed:\", data.description);\n}\n",[156],"8a8c0827-474e-400d-b724-61ab5789a0bf",["D",1784724117555],[33],"aeded871-3ce2-4fc2-baaf-34162a827ca5","lib","68482a73-cd4b-4008-b783-6ee3527844d6",2,["D",1784723989388],"directory",[168],"pulls","branches","forks","envVars",{"_181":160,"_183":66},"connections",{"_181":66,"_182":66},"count","unfilledCount","emptyCount",{"_46":167,"_37":168,"_35":169,"_139":-5,"_44":45,"_43":170,"_141":62,"_41":228,"_13":66,"_38":172,"_39":-5,"_29":30,"_145":-5,"_193":229,"_32":230},{"_46":220,"_37":221,"_35":222,"_139":169,"_44":45,"_43":223,"_141":62,"_41":224,"_13":66,"_38":161,"_39":225,"_29":30,"_145":-5,"_193":226,"_32":227},{"_46":212,"_37":213,"_35":214,"_139":169,"_44":45,"_43":215,"_141":62,"_41":216,"_13":66,"_38":161,"_39":217,"_29":30,"_145":-5,"_193":218,"_32":219},{"_46":205,"_37":206,"_35":207,"_139":169,"_44":45,"_43":170,"_141":62,"_41":208,"_13":66,"_38":161,"_39":209,"_29":30,"_145":-5,"_193":210,"_32":211},{"_46":164,"_37":33,"_35":36,"_139":-5,"_44":45,"_43":14,"_141":62,"_41":202,"_13":66,"_38":26,"_39":40,"_29":30,"_145":-5,"_193":203,"_32":204},{"_46":155,"_37":156,"_35":157,"_139":-5,"_44":45,"_43":158,"_141":62,"_41":199,"_13":160,"_38":161,"_39":162,"_29":30,"_145":-5,"_193":200,"_32":201},{"_46":147,"_37":148,"_35":149,"_139":-5,"_44":45,"_43":150,"_141":30,"_41":196,"_13":66,"_38":152,"_39":153,"_29":30,"_145":-5,"_193":197,"_32":198},{"_46":137,"_37":138,"_35":60,"_139":-5,"_44":45,"_43":140,"_141":62,"_41":192,"_13":66,"_38":143,"_39":144,"_29":30,"_145":-5,"_193":194,"_32":195},["D",1784724083541],"children",[],[138],["D",1784724083548],[],[148],["D",1784724117547],[],[156],["D",1784724117555],[],[33],"bccdc65e-d358-4e22-bd88-27d55dd4fa1d","telegram.ts","6d9e6d66-85ca-11f1-b078-1607ee4eb77e",["D",1784723989388],"// Telegram Bot API helpers\n// Docs: https://core.telegram.org/bots/api\n\nexport async function sendMessage(\n chatId: string,\n text: string,\n options: {\n parseMode?: \"HTML\" | \"MarkdownV2\";\n disableWebPagePreview?: boolean;\n } = {},\n): Promise {\n const token = Deno.env.get(\"TELEGRAM_TOKEN\");\n if (!token) throw new Error(\"TELEGRAM_TOKEN env var not set\");\n\n const res = await fetch(\n `https://api.telegram.org/bot${token}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: options.parseMode ?? \"HTML\",\n disable_web_page_preview: options.disableWebPagePreview ?? false,\n }),\n },\n );\n\n if (!res.ok) {\n const body = await res.text();\n console.error(`Telegram sendMessage failed: ${res.status}`, body);\n return false;\n }\n return true;\n}\n\nexport async function getBotInfo() {\n const token = Deno.env.get(\"TELEGRAM_TOKEN\");\n if (!token) throw new Error(\"TELEGRAM_TOKEN env var not set\");\n\n const res = await fetch(`https://api.telegram.org/bot${token}/getMe`);\n const data = await res.json();\n return data.result;\n}\n\n/** Escape text for HTML parse mode */\nexport function escapeHTML(text: string): string {\n return text\n .replace(/&/g, \"&\")\n .replace(//g, \">\");\n}\n",[],[168,206],"47c834fd-0935-4a9f-b961-c3d8d0c29bbc","news.ts","89be1fd2-85ca-11f1-a614-1607ee4eb77e",3,["D",1784724036589],"// News fetching & disaster filtering for Dubai/UAE\n// Uses Google News RSS as the primary source\n\nexport interface NewsItem {\n title: string;\n url: string;\n source: string;\n pubDate: Date;\n snippet: string;\n}\n\n// Keywords that indicate a real disaster / emergency / security / health / war event\nconst DISASTER_KEYWORDS = [\n // Disasters & emergencies\n \"disaster\", \"emergency\", \"crisis\", \"catastrophe\", \"calamity\",\n \"earthquake\", \"flood\", \"fire\", \"storm\", \"cyclone\", \"hurricane\",\n \"explosion\", \"blast\", \"collapse\", \"landslide\", \"dust storm\",\n // Health\n \"outbreak\", \"epidemic\", \"pandemic\", \"virus\", \"contamination\",\n \"poisoning\", \"radiation\", \"chemical spill\", \"toxic\", \"biohazard\",\n \"food poisoning\", \"water contamination\", \"disease\", \"infection\",\n // Security\n \"attack\", \"assault\", \"stabbing\", \"shooting\", \"terror\", \"terrorism\",\n \"bomb\", \"bombing\", \"explosion\", \"threat\", \"security alert\",\n \"security warning\", \"kidnap\", \"hostage\", \"unrest\", \"protest\",\n \"riot\", \"curfew\", \"lockdown\", \"evacuation\", \"state of emergency\",\n // War / conflict\n \"war\", \"missile\", \"airstrike\", \"air strike\", \"drone strike\",\n \"conflict\", \"military\", \"invasion\", \"shelling\", \"rocket\",\n \"ceasefire\", \"casualties\", \"killed\", \"dead\", \"injured\", \"wounded\",\n \"casualty\", \"fatalities\", \"deaths\",\n];\n\n// Keywords to exclude (false positives)\nconst EXCLUDE_KEYWORDS = [\n \"sports\", \"football\", \"cricket\", \"golf\", \"tennis\", \"basketball\",\n \"movie\", \"film\", \"celebrity\", \"entertainment\", \"fashion\",\n \"restaurant\", \"recipe\", \"travel\", \"tourism\", \"property\",\n \"real estate\", \"stock market\", \"crypto\", \"bitcoin\",\n \"gaming\", \"esports\", \"concert\", \"festival\", \"exhibition\",\n];\n\n// UAE location keywords\nconst UAE_KEYWORDS = [\n \"dubai\", \"abu dhabi\", \"sharjah\", \"ajman\", \"fujairah\",\n \"ras al khaimah\", \"umm al quwain\", \"uae\", \"emirates\",\n \"united arab emirates\", \"al ain\",\n];\n\nfunction normalize(text: string): string {\n return text.toLowerCase();\n}\n\nfunction containsAny(text: string, keywords: string[]): boolean {\n const normalized = normalize(text);\n return keywords.some((kw) => normalized.includes(kw));\n}\n\n/** Check if a news item is relevant (UAE + disaster keywords, no exclusions) */\nexport function isRelevantAlert(item: NewsItem): boolean {\n const fullText = `${item.title} ${item.snippet}`;\n\n // Must mention UAE/Dubai\n if (!containsAny(fullText, UAE_KEYWORDS)) return false;\n\n // Must contain at least one disaster keyword\n if (!containsAny(fullText, DISASTER_KEYWORDS)) return false;\n\n // Exclude false positives\n if (containsAny(fullText, EXCLUDE_KEYWORDS)) return false;\n\n return true;\n}\n\n/** Severity score — higher means more urgent */\nexport function getSeverity(item: NewsItem): number {\n const text = normalize(`${item.title} ${item.snippet}`);\n let score = 0;\n\n const highSeverity = [\n \"war\", \"missile\", \"airstrike\", \"air strike\", \"bomb\", \"bombing\",\n \"terror\", \"terrorism\", \"earthquake\", \"explosion\", \"blast\",\n \"casualties\", \"killed\", \"dead\", \"injured\", \"evacuation\",\n \"state of emergency\", \"outbreak\", \"epidemic\", \"pandemic\",\n \"chemical spill\", \"radiation\", \"biohazard\",\n ];\n const mediumSeverity = [\n \"attack\", \"shooting\", \"stabbing\", \"flood\", \"fire\", \"storm\",\n \"crisis\", \"emergency\", \"threat\", \"security alert\", \"curfew\",\n \"lockdown\", \"hostage\", \"unrest\", \"riot\", \"contamination\",\n \"poisoning\", \"disease\", \"infection\",\n ];\n\n if (containsAny(text, highSeverity)) score += 3;\n if (containsAny(text, mediumSeverity)) score += 2;\n\n // Recent items are more severe\n const ageHours = (Date.now() - item.pubDate.getTime()) / (1000 * 60 * 60);\n if (ageHours < 3) score += 2;\n else if (ageHours < 12) score += 1;\n\n return score;\n}\n\nfunction parseXML(xml: string): NewsItem[] {\n const items: NewsItem[] = [];\n\n // Simple RSS XML parser using regex (no DOMParser in Deno)\n const itemRegex = /([\\s\\S]*?)<\\/item>/g;\n let match: RegExpExecArray | null;\n\n while ((match = itemRegex.exec(xml)) !== null) {\n const block = match[1];\n\n const title = block.match(/(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/title>/)?.[1]?.trim() ?? \"\";\n const link = block.match(/<link>([\\s\\S]*?)<\\/link>/)?.[1]?.trim() ?? \"\";\n const pubDateStr = block.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/)?.[1]?.trim() ?? \"\";\n const sourceName = block.match(/<source[^>]*>([\\s\\S]*?)<\\/source>/)?.[1]?.trim() ?? \"\";\n const description = block.match(/<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/)?.[1]?.trim() ?? \"\";\n\n // Strip HTML from description\n const snippet = description.replace(/<[^>]+>/g, \"\").trim();\n\n const pubDate = pubDateStr ? new Date(pubDateStr) : new Date();\n\n if (title && link) {\n items.push({\n title: decodeEntities(title),\n url: link,\n source: sourceName || \"Google News\",\n pubDate,\n snippet: decodeEntities(snippet).slice(0, 300),\n });\n }\n }\n\n return items;\n}\n\nfunction decodeEntities(text: string): string {\n return text\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/'/g, \"'\");\n}\n\n/** Build Google News RSS query for UAE disasters */\nfunction buildRSSUrl(): string {\n const location = encodeURIComponent(\n '(\"Dubai\" OR \"UAE\" OR \"United Arab Emirates\" OR \"Abu Dhabi\" OR \"Sharjah\" OR \"Al Ain\")',\n );\n const disasters = encodeURIComponent(\n '(disaster OR emergency OR crisis OR outbreak OR epidemic OR pandemic OR attack OR explosion OR earthquake OR flood OR fire OR evacuation OR \"security alert\" OR \"security warning\" OR war OR missile OR conflict OR bombing OR \"chemical spill\" OR contamination OR casualties OR killed OR injured OR \"state of emergency\" OR lockdown OR curfew OR \"air strike\" OR \"drone strike\" OR shelling OR rocket OR terror OR kidnapping OR hostage)',\n );\n const exclude = encodeURIComponent(\n \"-sports -football -cricket -golf -tennis -movie -film -celebrity -entertainment -fashion -restaurant -recipe -travel -tourism -property -\" +\n '\"real estate\" -\"stock market\" -crypto -bitcoin -gaming -esports -concert -festival -exhibition',\n );\n\n return `https://news.google.com/rss/search?q=${location}+AND+${disasters}+${exclude}&hl=en&gl=AE&ceid=AE:en`;\n}\n\n/** Fetch latest disaster news for Dubai/UAE */\nexport async function fetchDisasterNews(): Promise<NewsItem[]> {\n const url = buildRSSUrl();\n console.log(`Fetching news from: ${url}`);\n\n const res = await fetch(url, {\n headers: { \"User-Agent\": \"DubaiDisasterAlerts/1.0\" },\n });\n\n if (!res.ok) {\n console.error(`RSS fetch failed: ${res.status}`);\n return [];\n }\n\n const xml = await res.text();\n const items = parseXML(xml);\n console.log(`Parsed ${items.length} RSS items`);\n\n // Filter to only relevant disaster alerts\n const relevant = items.filter(isRelevantAlert);\n\n // Sort by severity (highest first)\n relevant.sort((a, b) => getSeverity(b) - getSeverity(a));\n\n console.log(`${relevant.length} items passed relevance filter`);\n return relevant;\n}\n",[],[168,213],"51302463-47dd-40a1-a604-038bba9daf95","db.ts","89c484e4-85ca-11f1-9ed2-1607ee4eb77e",4,["D",1784724036590],"// SQLite helpers for deduplication and settings\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface SentAlert {\n url: string;\n title: string;\n sent_at: string;\n}\n\nexport async function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sent_alerts (\n url TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n source TEXT,\n sent_at TEXT NOT NULL\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )\n `);\n}\n\n/** Check if we've already sent an alert for this URL */\nexport async function isAlreadySent(url: string): Promise<boolean> {\n const result = await sqlite.execute({\n sql: \"SELECT 1 FROM sent_alerts WHERE url = ?\",\n args: [url],\n });\n return result.rows.length > 0;\n}\n\n/** Record a sent alert */\nexport async function recordAlert(\n url: string,\n title: string,\n source: string,\n): Promise<void> {\n await sqlite.execute({\n sql:\n \"INSERT OR IGNORE INTO sent_alerts (url, title, source, sent_at) VALUES (?, ?, ?, ?)\",\n args: [url, title, source, new Date().toISOString()],\n });\n}\n\n/** Get a setting value */\nexport async function getSetting(key: string): Promise<string | null> {\n const result = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key = ?\",\n args: [key],\n });\n return result.rows[0]?.value ?? null;\n}\n\n/** Set a setting value */\nexport async function setSetting(key: string, value: string): Promise<void> {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO settings (key, value) VALUES (?, ?)\",\n args: [key, value],\n });\n}\n\n/** Get the Telegram chat ID (stored when user first messages the bot) */\nexport async function getChatId(): Promise<string | null> {\n return await getSetting(\"telegram_chat_id\");\n}\n\n/** Clean up alerts older than 30 days */\nexport async function cleanupOldAlerts(): Promise<void> {\n const cutoff = new Date();\n cutoff.setDate(cutoff.getDate() - 30);\n await sqlite.execute({\n sql: \"DELETE FROM sent_alerts WHERE sent_at < ?\",\n args: [cutoff.toISOString()],\n });\n}\n",[],[168,221],["D",1784723989388],[185,186,187],[168],["D",1784723916048],["D",1789473046147],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":58,"_107":108,"_109":30},{"_13":92,"_37":93,"_46":45,"_94":47,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":48,"_101":102},"ctx",{"_85":-5,"_129":269,"_270":271,"_272":273,"_274":30,"_275":30,"_276":30,"_277":62,"_278":-5,"_279":-7,"_280":-7,"_281":66,"_282":30,"_283":30,"_284":-5,"_285":30,"_286":30,"_287":30,"_288":-5},"ENV",{"_240":241,"_242":243,"_244":93,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268},"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"] </article></body></html>

Diff · v8