(?:<!\\[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",[],[150,187],"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",[],[150,195],["D",1784723989388],[167,168,169],[150],["D",1784723916048],["D",1789473046147],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":59,"_107":108,"_109":30},{"_13":92,"_37":93,"_47":46,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":49,"_101":102},"ctx",{"_85":-5,"_129":243,"_244":245,"_246":247,"_248":30,"_249":30,"_250":30,"_251":62,"_252":-5,"_253":-7,"_254":-7,"_255":66,"_256":30,"_257":30,"_258":-5,"_259":30,"_260":30,"_261":30,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":93,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"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",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_103":102,"_37":49,"_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",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":36,"_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",5,"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":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","webhook.ts","latestPath","fileId","a5b9d7e4-85ca-11f1-895f-1607ee4eb77e","name","fileType","http","content","// 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","createdAt",["D",1784724083541],"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","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":59,"_107":108,"_109":30},"branch",{"_13":92,"_37":93,"_47":46,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":49,"_101":102},"isOwned",12,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","aunova","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_47":48,"_37":49,"_42":205,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":36,"_61":62,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":206,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":207,"_87":208,"_89":209,"_91":30},"tree",[166,170,171],"files",[166,167,168,169,170,171],"counts",{"_156":66,"_157":144,"_158":66,"_159":160,"_161":162},"contents",[132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":149,"_37":150,"_35":151,"_136":-5,"_45":46,"_44":152,"_137":62,"_42":153,"_13":66,"_38":154,"_40":-5,"_29":30,"_139":-5,"_32":155},{"_47":141,"_37":142,"_35":143,"_136":-5,"_45":46,"_44":144,"_137":30,"_42":145,"_13":66,"_38":146,"_40":147,"_29":30,"_139":-5,"_32":148},{"_47":135,"_37":33,"_35":36,"_136":-5,"_45":46,"_44":14,"_137":62,"_42":138,"_13":66,"_38":39,"_40":41,"_29":30,"_139":-5,"_32":140},"c6f42285-fdbc-48c6-85cf-ee8b3d7afffe","parentId","latest",["D",1784724083541],"label",[33],"34a61c43-6ebb-473b-8038-3f040f622103","main.ts","41e92cd8-85ca-11f1-895f-1607ee4eb77e",1,["D",1784723916078],"script","// Dubai Disaster Alerts — see README.md for setup instructions\n",[142],"aeded871-3ce2-4fc2-baaf-34162a827ca5","lib","68482a73-cd4b-4008-b783-6ee3527844d6",2,["D",1784723989388],"directory",[150],"pulls","branches","forks","envVars",{"_163":144,"_165":66},"connections",{"_163":66,"_164":66},"count","unfilledCount","emptyCount",{"_47":149,"_37":150,"_35":151,"_136":-5,"_45":46,"_44":152,"_137":62,"_42":202,"_13":66,"_38":154,"_40":-5,"_29":30,"_139":-5,"_173":203,"_32":204},{"_47":194,"_37":195,"_35":196,"_136":151,"_45":46,"_44":197,"_137":62,"_42":198,"_13":66,"_38":146,"_40":199,"_29":30,"_139":-5,"_173":200,"_32":201},{"_47":186,"_37":187,"_35":188,"_136":151,"_45":46,"_44":189,"_137":62,"_42":190,"_13":66,"_38":146,"_40":191,"_29":30,"_139":-5,"_173":192,"_32":193},{"_47":179,"_37":180,"_35":181,"_136":151,"_45":46,"_44":152,"_137":62,"_42":182,"_13":66,"_38":146,"_40":183,"_29":30,"_139":-5,"_173":184,"_32":185},{"_47":141,"_37":142,"_35":143,"_136":-5,"_45":46,"_44":144,"_137":30,"_42":176,"_13":66,"_38":146,"_40":147,"_29":30,"_139":-5,"_173":177,"_32":178},{"_47":135,"_37":33,"_35":36,"_136":-5,"_45":46,"_44":14,"_137":62,"_42":172,"_13":66,"_38":39,"_40":41,"_29":30,"_139":-5,"_173":174,"_32":175},["D",1784724083541],"children",[],[33],["D",1784723916078],[],[142],"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",[],[150,180],"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",[],[150,187],"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",[],[150,195],["D",1784723989388],[167,168,169],[150],["D",1784723916048],["D",1789473046147],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":59,"_107":108,"_109":30},{"_13":92,"_37":93,"_47":46,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":49,"_101":102},"ctx",{"_85":-5,"_129":243,"_244":245,"_246":247,"_248":30,"_249":30,"_250":30,"_251":62,"_252":-5,"_253":-7,"_254":-7,"_255":66,"_256":30,"_257":30,"_258":-5,"_259":30,"_260":30,"_261":30,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":93,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"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 · v5