([\\s\\S]*?)<\\/title>/i)?.[1] || '').replace(\n /\\s+—\\s+купить билеты.*/i,\n '',\n ) ||\n fallback.title;\n\n const prices = [...plain.matchAll(/(?:от|до)?\\s*([0-9]+(?:[,.][0-9]+)?)\\s*BYN/gi)]\n .map((match) => toNumber(match[1]))\n .filter((value): value is number => typeof value === 'number');\n const priceMin = prices.length > 0 ? Math.min(...prices) : fallback.priceMin;\n const priceMax = prices.length > 0 ? Math.max(...prices) : fallback.priceMax;\n const dateLabel =\n plain.match(/(\\d{1,2}\\s+[а-яА-Я]+\\s+\\d{4}(?:,\\s*\\d{1,2}[.:]\\d{2})?)/)?.[1] ||\n plain.match(/с\\s+(\\d{1,2}\\s+[а-яА-Я]+)/)?.[1] ||\n fallback.dateLabel;\n const eventDate = dateLabel ? parseRuDate(dateLabel) || fallback.eventDate : fallback.eventDate;\n const venueName =\n normalizeText(\n plain.match(/Место проведения\\s*[-—]\\s*[\"«]?([^\"»\\n\\r]+)[\"»]?/i)?.[1] ||\n plain.match(/Возраст\\s*[-—]\\s*\\d+\\+?\\s+([А-ЯЁA-Z][^,]{3,60})/i)?.[1] ||\n '',\n ) || fallback.venueName;\n\n return {\n ...fallback,\n title,\n venueName,\n eventDate,\n dateLabel,\n priceMin,\n priceMax,\n currency: priceMin || priceMax ? 'BYN' : fallback.currency,\n };\n}\n\nexport async function fetchAfishaEvents(query?: string, enrich = false): Promise<AfishaEvent[]> {\n const response = await fetch(AFISHA_HOME_URL, {\n headers: {\n 'user-agent':\n 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/131 Safari/537.36',\n accept: 'text/html,application/xhtml+xml',\n 'accept-language': 'ru-RU,ru;q=0.9',\n },\n });\n\n if (!response.ok) {\n throw new Error(`${SOURCE_LABEL} returned ${response.status}`);\n }\n\n const events = parseAfishaEventAnchors(await response.text(), query);\n if (!enrich) return events;\n\n const enriched: AfishaEvent[] = [];\n for (const event of events.slice(0, MAX_DETAIL_FETCHES)) {\n try {\n const detailResponse = await fetch(event.url, {\n headers: {\n 'user-agent':\n 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/131 Safari/537.36',\n accept: 'text/html,application/xhtml+xml',\n 'accept-language': 'ru-RU,ru;q=0.9',\n },\n });\n if (!detailResponse.ok) {\n enriched.push(event);\n continue;\n }\n enriched.push(parseEventDetailHtml(await detailResponse.text(), event));\n } catch {\n enriched.push(event);\n }\n }\n\n return [...enriched, ...events.slice(MAX_DETAIL_FETCHES)];\n}\n\nasync function upsertEvent(sqlite: SqliteClient, event: AfishaEvent): Promise<void> {\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO events (\n id, source_id, external_id, title, category, venue_name, venue_address,\n event_date, date_label, external_url, is_active, last_seen_at, checked_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 1, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n title = excluded.title,\n category = excluded.category,\n venue_name = excluded.venue_name,\n venue_address = excluded.venue_address,\n event_date = excluded.event_date,\n date_label = excluded.date_label,\n external_url = excluded.external_url,\n is_active = 1,\n last_seen_at = excluded.last_seen_at,\n checked_at = excluded.checked_at`,\n args: [\n event.id,\n SOURCE_ID,\n event.externalId,\n event.title,\n event.category || 'Афиша',\n event.venueName || null,\n event.venueAddress || null,\n event.eventDate || null,\n event.dateLabel || null,\n event.url,\n now,\n now,\n ],\n });\n\n if (event.priceMin || event.priceMax) {\n const latest = await sqlite.execute({\n sql: `SELECT price_min, price_max, time FROM price_history\n WHERE event_id = ? ORDER BY time DESC LIMIT 1`,\n args: [event.id],\n });\n const row = latest.rows[0];\n const latestTime = row?.time ? new Date(String(row.time)).getTime() : 0;\n const isOld = Date.now() - latestTime > 12 * 60 * 60 * 1000;\n const changed =\n Number(row?.price_min ?? 0) !== Number(event.priceMin ?? 0) ||\n Number(row?.price_max ?? 0) !== Number(event.priceMax ?? 0);\n\n if (!row || changed || isOld) {\n await sqlite.execute({\n sql: `INSERT INTO price_history (\n id, event_id, price_min, price_max, currency, is_available,\n available_count, source_url, checked_at, time\n ) VALUES (?, ?, ?, ?, ?, 1, ?, ?, ?, ?)`,\n args: [\n crypto.randomUUID(),\n event.id,\n event.priceMin || null,\n event.priceMax || null,\n event.currency || 'BYN',\n event.availableCount || null,\n event.url,\n now,\n now,\n ],\n });\n }\n }\n}\n\nasync function scrapeAndStore(\n limit = 18,\n): Promise<{ found: number; stored: number; checkedAt: string }> {\n return requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const events = (await fetchAfishaEvents(undefined, true)).slice(0, limit);\n for (const event of events) {\n await upsertEvent(sqlite, event);\n }\n return { found: events.length, stored: events.length, checkedAt: getNow() };\n });\n}\n\nfunction mapEventRow(row: Record<string, unknown>, price?: Record<string, unknown>): AfishaEvent {\n return {\n id: String(row.id),\n externalId: String(row.external_id || ''),\n title: String(row.title || ''),\n url: String(row.external_url || ''),\n category: row.category ? String(row.category) : undefined,\n venueName: row.venue_name ? String(row.venue_name) : undefined,\n venueAddress: row.venue_address ? String(row.venue_address) : undefined,\n eventDate: row.event_date ? String(row.event_date) : undefined,\n dateLabel: row.date_label ? String(row.date_label) : undefined,\n priceMin: toNumber(price?.price_min),\n priceMax: toNumber(price?.price_max),\n currency: price?.currency ? String(price.currency) : 'BYN',\n availableCount: toNumber(price?.available_count),\n checkedAt: row.checked_at ? String(row.checked_at) : undefined,\n };\n}\n\nasync function getStoredEvents(query?: string, limit = 8): Promise<AfishaEvent[]> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const params: unknown[] = [];\n let where = 'WHERE e.is_active = 1';\n if (query) {\n where += ' AND LOWER(e.title) LIKE ?';\n params.push(`%${query.toLowerCase()}%`);\n }\n params.push(limit);\n\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM events e\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n ${where}\n ORDER BY COALESCE(e.event_date, e.last_seen_at) ASC\n LIMIT ?`,\n args: params,\n });\n\n return result.rows.map((row) => mapEventRow(row, row));\n }, []);\n}\n\nasync function getEventById(eventId: string): Promise<AfishaEvent | undefined> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM events e\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n WHERE e.id = ?\n LIMIT 1`,\n args: [eventId],\n });\n return result.rows[0] ? mapEventRow(result.rows[0], result.rows[0]) : undefined;\n }, undefined);\n}\n\nasync function getOrCreateUser(\n telegramId: number,\n firstName?: string,\n): Promise<string | undefined> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const existing = await sqlite.execute({\n sql: 'SELECT id FROM users WHERE telegram_id = ? LIMIT 1',\n args: [telegramId],\n });\n if (existing.rows[0]?.id) return String(existing.rows[0].id);\n\n const id = crypto.randomUUID();\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO users (id, telegram_id, name, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?)`,\n args: [id, telegramId, firstName || null, now, now],\n });\n return id;\n }, undefined);\n}\n\nasync function isSubscribed(userId: string | undefined, eventId: string): Promise<boolean> {\n if (!userId) return false;\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT id FROM alert_subscriptions\n WHERE user_id = ? AND event_id = ? AND is_active = 1 LIMIT 1`,\n args: [userId, eventId],\n });\n return Boolean(result.rows[0]);\n }, false);\n}\n\nasync function setSubscription(\n userId: string | undefined,\n eventId: string,\n active: boolean,\n threshold = MIN_DROP_PERCENT,\n): Promise<void> {\n if (!userId) return;\n await requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO alert_subscriptions (\n id, user_id, event_id, min_discount_percent, is_active, created_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(user_id, event_id) DO UPDATE SET\n min_discount_percent = excluded.min_discount_percent,\n is_active = excluded.is_active,\n updated_at = excluded.updated_at`,\n args: [crypto.randomUUID(), userId, eventId, threshold, active ? 1 : 0, now, now],\n });\n });\n}\n\nasync function getPriceHistory(\n eventId: string,\n limit = 5,\n): Promise<Array<Record<string, unknown>>> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT price_min, price_max, currency, checked_at, time\n FROM price_history\n WHERE event_id = ?\n ORDER BY time DESC\n LIMIT ?`,\n args: [eventId, limit],\n });\n return result.rows;\n }, []);\n}\n\nasync function getSubscriptions(userId: string | undefined): Promise<AfishaEvent[]> {\n if (!userId) return [];\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM alert_subscriptions s\n JOIN events e ON e.id = s.event_id\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n WHERE s.user_id = ? AND s.is_active = 1\n ORDER BY COALESCE(e.event_date, e.last_seen_at) ASC\n LIMIT 20`,\n args: [userId],\n });\n return result.rows.map((row) => mapEventRow(row, row));\n }, []);\n}\n\nasync function getGlobalPriceDrops(\n limit = 8,\n): Promise<Array<{ event: AfishaEvent; oldPrice: number; newPrice: number; dropPercent: number }>> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const events = await getStoredEvents(undefined, 40);\n const drops = [];\n for (const event of events) {\n const history = await getPriceHistory(event.id, 2);\n if (history.length < 2) continue;\n const latest = toNumber(history[0].price_min);\n const previous = toNumber(history[1].price_min);\n if (!latest || !previous || latest >= previous) continue;\n const dropPercent = ((previous - latest) / previous) * 100;\n if (dropPercent < MIN_DROP_PERCENT) continue;\n drops.push({ event, oldPrice: previous, newPrice: latest, dropPercent });\n }\n return drops.sort((a, b) => b.dropPercent - a.dropPercent).slice(0, limit);\n }, []);\n}\n\nasync function sendDueAlerts(maxMessages = 20): Promise<{ checked: number; sent: number }> {\n return requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const subscriptions = await sqlite.execute({\n sql: `SELECT\n s.id AS subscription_id,\n s.user_id,\n s.event_id,\n s.min_discount_percent,\n u.telegram_id,\n e.title,\n e.event_date,\n e.date_label,\n e.external_url\n FROM alert_subscriptions s\n JOIN users u ON u.id = s.user_id\n JOIN events e ON e.id = s.event_id\n WHERE s.is_active = 1\n LIMIT 100`,\n });\n\n let sent = 0;\n for (const subscription of subscriptions.rows) {\n if (sent >= maxMessages) break;\n const history = await getPriceHistory(String(subscription.event_id), 2);\n if (history.length < 2) continue;\n const latest = toNumber(history[0].price_min);\n const previous = toNumber(history[1].price_min);\n if (!latest || !previous || latest >= previous) continue;\n\n const dropPercent = ((previous - latest) / previous) * 100;\n const threshold = toNumber(subscription.min_discount_percent) || MIN_DROP_PERCENT;\n if (dropPercent < threshold) continue;\n\n const already = await sqlite.execute({\n sql: `SELECT id FROM price_drop_notifications\n WHERE subscription_id = ? AND price_history_time = ?\n LIMIT 1`,\n args: [subscription.subscription_id, history[0].time],\n });\n if (already.rows[0]) continue;\n\n await sendMessage(\n Number(subscription.telegram_id),\n `🔻 Цена снизилась\\n\\n${escapeHtml(subscription.title)}\\n` +\n `💰 ${previous} → ${latest} BYN (−${dropPercent.toFixed(1)}%)\\n` +\n `📅 ${escapeHtml(subscription.date_label || subscription.event_date || 'дата уточняется')}\\n` +\n `🛒 ${escapeHtml(subscription.external_url)}`,\n {\n inline_keyboard: [[{ text: 'Открыть событие', url: String(subscription.external_url) }]],\n },\n );\n\n await sqlite.execute({\n sql: `INSERT INTO price_drop_notifications (\n id, subscription_id, user_id, event_id, old_price_min, new_price_min,\n drop_percent, price_history_time, sent_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n crypto.randomUUID(),\n subscription.subscription_id,\n subscription.user_id,\n subscription.event_id,\n previous,\n latest,\n Number(dropPercent.toFixed(2)),\n history[0].time,\n getNow(),\n ],\n });\n sent += 1;\n }\n\n return { checked: subscriptions.rows.length, sent };\n });\n}\n\nasync function getDbStats(): Promise<Record<string, unknown>> {\n return optionalDb(\n async (sqlite) => {\n await ensureSchema(sqlite);\n const stats: Record<string, unknown> = {};\n for (const table of ['events', 'price_history', 'users', 'alert_subscriptions']) {\n const result = await sqlite.execute(`SELECT COUNT(*) AS count FROM ${table}`);\n stats[table] = Number(result.rows[0]?.count || 0);\n }\n return stats;\n },\n { unavailable: true },\n );\n}\n\nfunction welcomeText(firstName?: string): string {\n const name = firstName ? `, ${firstName}` : '';\n return (\n `👋 Привет${escapeHtml(name)}!\\n\\n` +\n `Я слежу за билетами на мероприятия в Минске.\\n\\n` +\n `🎭 Показываю афишу с ценами\\n` +\n `📊 Храню историю цен после проверок\\n` +\n `🔔 Запоминаю подписки и пороги скидок\\n` +\n `📉 Присылаю падения цен после cron-проверки\\n\\n` +\n `Выбери действие:`\n );\n}\n\nasync function loadEventsForDisplay(query?: string): Promise<AfishaEvent[]> {\n const stored = await getStoredEvents(query, 8);\n if (stored.length > 0) return stored;\n\n const live = await fetchAfishaEvents(query, false);\n const visible = live.slice(0, 8);\n await optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n for (const event of visible) {\n await upsertEvent(sqlite, event);\n }\n return true;\n }, false);\n\n return visible;\n}\n\nasync function showEvents(chatId: number, query?: string) {\n const events = await loadEventsForDisplay(query);\n if (events.length === 0) {\n await sendMessage(\n chatId,\n query\n ? `По запросу «${escapeHtml(query)}» пока ничего не найдено. Попробуй другое название.`\n : 'Сейчас не удалось найти события. Попробуй позже.',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = events\n .slice(0, 8)\n .map((event, index) => {\n const price =\n event.priceMin || event.priceMax ? ` — ${formatPrice(event.priceMin, event.priceMax)}` : '';\n return `${index + 1}. ${escapeHtml(event.title)}${escapeHtml(price)}\\n${escapeHtml(\n formatDateLabel(event),\n )}`;\n })\n .join('\\n\\n');\n\n await sendMessage(\n chatId,\n `🎭 Афиша Минска\\n\\n${lines}\\n\\nИсточник: ${SOURCE_LABEL}`,\n eventListKeyboard(events),\n );\n}\n\nasync function showEventDetail(chatId: number, userId: string | undefined, eventId: string) {\n const event = await getEventById(eventId);\n if (!event) {\n await sendMessage(\n chatId,\n 'Событие не найдено в сохраненной базе. Нажми «🎭 Афиша» для обновления.',\n mainKeyboard(),\n );\n return;\n }\n\n const subscribed = await isSubscribed(userId, eventId);\n const text =\n `🎫 ${escapeHtml(event.title)}\\n\\n` +\n `📅 ${escapeHtml(formatDateLabel(event))}\\n` +\n `📍 ${escapeHtml(event.venueName || 'площадка уточняется')}\\n` +\n `💰 ${escapeHtml(formatPrice(event.priceMin, event.priceMax, event.currency))}\\n` +\n `🛡 Проверено: ${escapeHtml(event.checkedAt || 'только что')}\\n\\n` +\n `Источник: ${SOURCE_LABEL}`;\n\n await sendMessage(chatId, text, eventDetailKeyboard(event, subscribed));\n}\n\nasync function showHistory(chatId: number, eventId: string) {\n const event = await getEventById(eventId);\n const history = await getPriceHistory(eventId, 6);\n if (!event || history.length === 0) {\n await sendMessage(\n chatId,\n 'История цен пока не накоплена. Она появится после нескольких проверок.',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = history\n .map((row) => {\n return `• ${escapeHtml(String(row.checked_at || row.time))}: ${escapeHtml(\n formatPrice(\n toNumber(row.price_min),\n toNumber(row.price_max),\n String(row.currency || 'BYN'),\n ),\n )}`;\n })\n .join('\\n');\n await sendMessage(chatId, `📊 ${escapeHtml(event.title)}\\n\\n${lines}`, {\n inline_keyboard: [[{ text: '⬅️ К событию', callback_data: `event:${event.id}` }]],\n });\n}\n\nasync function showAdvice(chatId: number, eventId: string) {\n const event = await getEventById(eventId);\n if (!event) {\n await sendMessage(chatId, 'Событие не найдено.');\n return;\n }\n\n const price = event.priceMin || event.priceMax;\n const advice = price\n ? `Если важна цена, начинай с диапазона ${formatPrice(event.priceMin, event.priceMax)}. ` +\n `Для точной схемы мест открой продажу на сайте: Val Town fetch-only режим не видит полную карту зала.`\n : 'Цена пока не проверена. Я покажу точнее после следующей scrape-проверки.';\n\n await sendMessage(chatId, `🪑 Совет по выбору\\n\\n${escapeHtml(advice)}`, {\n inline_keyboard: [[{ text: '🛒 Купить билет', url: event.url }]],\n });\n}\n\nasync function showSubscriptions(chatId: number, userId: string | undefined) {\n const subscriptions = await getSubscriptions(userId);\n if (subscriptions.length === 0) {\n await sendMessage(\n chatId,\n '🔔 У тебя пока нет активных подписок. Открой событие и нажми «Следить за ценой».',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = subscriptions\n .map(\n (event, index) =>\n `${index + 1}. ${escapeHtml(event.title)} — ${escapeHtml(formatPrice(event.priceMin, event.priceMax))}`,\n )\n .join('\\n\\n');\n await sendMessage(chatId, `🔔 Мои подписки\\n\\n${lines}`, eventListKeyboard(subscriptions));\n}\n\nasync function showPriceDrops(chatId: number) {\n const drops = await getGlobalPriceDrops();\n if (drops.length === 0) {\n await sendMessage(\n chatId,\n '📉 Пока нет сохраненных падений цены. Нужно минимум две проверки цен.',\n mainKeyboard(),\n );\n return;\n }\n\n const text = drops\n .map((drop, index) => {\n return `${index + 1}. ${escapeHtml(drop.event.title)}\\n${drop.oldPrice} → ${drop.newPrice} BYN (−${drop.dropPercent.toFixed(1)}%)`;\n })\n .join('\\n\\n');\n await sendMessage(chatId, `📉 Скидки и падения цены\\n\\n${text}`);\n}\n\nasync function handleMessage(update: TelegramUpdate): Promise<void> {\n const chatId = update.message?.chat?.id;\n const telegramId = update.message?.from?.id || chatId;\n const text = update.message?.text?.trim() || '';\n const firstName = update.message?.from?.first_name;\n if (!chatId || !telegramId) return;\n\n const userId = await getOrCreateUser(telegramId, firstName);\n\n if (!text || text.startsWith('/start')) {\n await sendMessage(chatId, welcomeText(firstName), mainKeyboard());\n return;\n }\n\n if (text.startsWith('/help') || text === labels.help) {\n await sendMessage(\n chatId,\n 'Команды: /start, /help, /search.\\n\\nНажми «🎭 Афиша», чтобы получить список событий. Открой событие, чтобы подписаться на падение цены.',\n mainKeyboard(),\n );\n return;\n }\n\n if (text === labels.events || text.toLowerCase() === 'афиша') {\n await showEvents(chatId);\n return;\n }\n\n if (text === labels.search || text.startsWith('/search')) {\n await sendMessage(\n chatId,\n '🔎 Напиши название события или артиста, я попробую найти его в текущей афише.',\n mainKeyboard(),\n );\n return;\n }\n\n if (text === labels.subscriptions) {\n await showSubscriptions(chatId, userId);\n return;\n }\n\n if (text === labels.priceDrops) {\n await showPriceDrops(chatId);\n return;\n }\n\n if (text === labels.aiChat) {\n await sendMessage(\n chatId,\n '🤖 Полный AI-чат требует отдельного LLM/API. Здесь работает честный serverless-режим: афиша, цены, история, подписки и эвристический совет по событию.',\n mainKeyboard(),\n );\n return;\n }\n\n await showEvents(chatId, text);\n}\n\nasync function handleCallback(update: TelegramUpdate): Promise<void> {\n const callback = update.callback_query;\n if (!callback) return;\n const chatId = callback.message?.chat?.id;\n const telegramId = callback.from?.id || chatId;\n const data = callback.data || '';\n if (!chatId || !telegramId) return;\n\n const userId = await getOrCreateUser(telegramId, callback.from?.first_name);\n await answerCallbackQuery(callback.id);\n\n if (data === 'back:list') {\n await showEvents(chatId);\n return;\n }\n\n if (data.startsWith('event:')) {\n await showEventDetail(chatId, userId, data.slice('event:'.length));\n return;\n }\n\n if (data.startsWith('sub:')) {\n const eventId = data.slice('sub:'.length);\n await setSubscription(userId, eventId, true, MIN_DROP_PERCENT);\n await sendMessage(\n chatId,\n '✅ Подписка включена. Сообщу, если цена снизится после следующих проверок.',\n );\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('unsub:')) {\n const eventId = data.slice('unsub:'.length);\n await setSubscription(userId, eventId, false);\n await sendMessage(chatId, '🔕 Подписка отключена.');\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('pct:')) {\n const parsed = parsePercentCallback(data);\n if (!parsed) {\n await sendMessage(\n chatId,\n 'Не удалось прочитать порог скидки. Открой карточку события заново.',\n );\n return;\n }\n const { eventId, threshold } = parsed;\n await setSubscription(userId, eventId, true, threshold);\n await sendMessage(chatId, `✅ Порог скидки установлен: ${threshold}%`);\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('hist:')) {\n await showHistory(chatId, data.slice('hist:'.length));\n return;\n }\n\n if (data.startsWith('adv:')) {\n await showAdvice(chatId, data.slice('adv:'.length));\n }\n}\n\nasync function handleAdmin(url: URL, request: Request): Promise<Response> {\n const expected = env('AFISHA_ADMIN_SECRET');\n const actual = request.headers.get('x-afisha-admin-secret') || '';\n if (!expected || actual !== expected) {\n return json({ ok: false, error: 'unauthorized' }, 401);\n }\n\n const action = url.searchParams.get('admin');\n if (action === 'scrape') {\n const limit = Math.max(1, Math.min(40, Number(url.searchParams.get('limit')) || 18));\n return json({ ok: true, scrape: await scrapeAndStore(limit) });\n }\n\n if (action === 'alerts') {\n return json({ ok: true, alerts: await sendDueAlerts() });\n }\n\n if (action === 'run') {\n const scrape = await scrapeAndStore(\n Math.max(1, Math.min(40, Number(url.searchParams.get('limit')) || 18)),\n );\n const alerts = await sendDueAlerts();\n return json({ ok: true, scrape, alerts });\n }\n\n return json({ ok: false, error: 'unknown_admin_action' }, 400);\n}\n\nexport default async function handler(request: Request): Promise<Response> {\n const url = new URL(request.url);\n\n if (url.searchParams.has('admin')) {\n return handleAdmin(url, request);\n }\n\n if (request.method === 'GET') {\n if (url.searchParams.has('events')) {\n const events = await fetchAfishaEvents(url.searchParams.get('q') || undefined);\n return json({\n ok: true,\n count: events.length,\n events,\n checkedAt: getNow(),\n });\n }\n\n if (url.searchParams.has('state')) {\n return json({\n ok: true,\n db: await getDbStats(),\n checkedAt: getNow(),\n });\n }\n\n return json({\n ok: true,\n service: 'afisha-minsk-bot',\n mode: 'val-town-webhook-sqlite',\n source: SOURCE_LABEL,\n db: await getDbStats(),\n checkedAt: getNow(),\n });\n }\n\n if (request.method !== 'POST') {\n return json({ ok: false, error: 'method_not_allowed' }, 405);\n }\n\n const expectedSecret = env('TELEGRAM_WEBHOOK_SECRET');\n const actualSecret = request.headers.get('x-telegram-bot-api-secret-token') || '';\n if (expectedSecret && actualSecret !== expectedSecret) {\n return json({ ok: false, error: 'unauthorized' }, 401);\n }\n\n try {\n const update = (await request.json()) as TelegramUpdate;\n if (update.callback_query) {\n await handleCallback(update);\n } else {\n await handleMessage(update);\n }\n return json({ ok: true });\n } catch (error) {\n console.error(error);\n return json({ ok: false, error: error instanceof Error ? error.message : String(error) }, 500);\n }\n}\n",[140],"pulls","branches","forks","envVars",{"_155":14,"_157":61},"connections",{"_155":61,"_156":61},"count","unfilledCount","emptyCount",{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":164,"_13":144,"_33":145,"_35":146,"_24":25,"_137":-5,"_161":165,"_27":166},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":160,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_161":162,"_27":163},["D",1779100944045],"children",[],[28],["D",1779100943629],[],[140],["D",1779098075354],["D",1789470042795],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_127":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":125,"_214":-5,"_215":-7,"_216":-7,"_217":61,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":88,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":125,"_126":-5,"_127":-5,"_128":129},"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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","scraper.interval.ts","latestPath","fileId","4b70eea6-52a5-11f1-bc17-ee650bb23af1","name","fileType","interval","content","declare const Deno: {\n env: {\n get(key: string): string | undefined;\n };\n};\n\ntype Interval = {\n lastRunAt?: Date;\n};\n\nasync function callAdmin(endpoint: string, secret: string, action: string) {\n const url = new URL(endpoint);\n url.searchParams.set('admin', action);\n url.searchParams.set('key', secret);\n\n const response = await fetch(url);\n const body = await response.text();\n if (!response.ok) {\n throw new Error(`${action} failed: ${response.status} ${body.slice(0, 500)}`);\n }\n\n return JSON.parse(body);\n}\n\nexport default async function scraperInterval(interval: Interval) {\n const endpoint = Deno.env.get('AFISHA_VAL_ENDPOINT');\n const secret = Deno.env.get('AFISHA_ADMIN_SECRET');\n\n if (!endpoint || !secret) {\n throw new Error('AFISHA_VAL_ENDPOINT and AFISHA_ADMIN_SECRET must be configured.');\n }\n\n const scrape = await callAdmin(endpoint, secret, 'scrape');\n const alerts = await callAdmin(endpoint, secret, 'alerts');\n\n console.log(\n JSON.stringify({\n ok: true,\n lastRunAt: interval.lastRunAt?.toISOString(),\n checkedAt: new Date().toISOString(),\n scrape: scrape.scrape,\n alerts: alerts.alerts,\n }),\n );\n}\n","declare const Deno: {\n env: {\n get(key: string): string | undefined;\n };\n};\n\ntype Interval = {\n lastRunAt?: Date;\n};\n\nasync function callAdmin(endpoint: string, secret: string, action: string) {\n const url = new URL(endpoint);\n url.searchParams.set('admin', action);\n\n const response = await fetch(url, {\n headers: {\n 'x-afisha-admin-secret': secret,\n },\n });\n const body = await response.text();\n if (!response.ok) {\n throw new Error(`${action} failed: ${response.status} ${body.slice(0, 500)}`);\n }\n\n return JSON.parse(body);\n}\n\nexport default async function scraperInterval(interval: Interval) {\n const endpoint = Deno.env.get('AFISHA_VAL_ENDPOINT');\n const secret = Deno.env.get('AFISHA_ADMIN_SECRET');\n\n if (!endpoint || !secret) {\n throw new Error('AFISHA_VAL_ENDPOINT and AFISHA_ADMIN_SECRET must be configured.');\n }\n\n const scrape = await callAdmin(endpoint, secret, 'scrape');\n const alerts = await callAdmin(endpoint, secret, 'alerts');\n\n console.log(\n JSON.stringify({\n ok: true,\n lastRunAt: interval.lastRunAt?.toISOString(),\n checkedAt: new Date().toISOString(),\n scrape: scrape.scrape,\n alerts: alerts.alerts,\n }),\n );\n}\n","createdAt",["D",1779100944045],"branchVersion","branchId","93873340-529f-11f1-96be-ee650bb23af1","id","938690ca-529f-11f1-96be-ee650bb23af1","afisha-minsk-bot",["D",1779098075354],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Afisha Minsk Telegram webhook","imageUrl","55df4d4c-21d7-4019-91c7-dd22f90c1825","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e3a7b-623d-703c-acfd-b877b7e90ebe","tursoName","938690ca529f11f196beee650bb23af1","tursoHostname","938690ca529f11f196beee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789470042795],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",34,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","zerxaaiart","handle","displayName","Zerxa Aiart","avatar","https://lh3.googleusercontent.com/a/ACg8ocINrz87qPEjzPyltc4pgrYzUpAK25aR-y7cGCRaVYjUeVAfMQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":167,"_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":65,"_66":67,"_68":168,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":169,"_82":170,"_84":171,"_86":25},"tree",[158,159],"files",[158,159],"counts",{"_148":61,"_149":136,"_150":61,"_151":152,"_153":154},"contents",[130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":143,"_13":144,"_33":145,"_35":146,"_24":25,"_137":-5,"_27":147},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":135,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":138},"416ef758-52a6-11f1-888e-ee650bb23af1","parentId","latest",["D",1779100944045],1,"label",[28],"4128de76-52a6-11f1-a50c-ee650bb23af1","index.http.ts","93a64488-529f-11f1-96be-ee650bb23af1",6,["D",1779100943629],4,"http","declare const Deno: {\n env: {\n get(key: string): string | undefined;\n };\n};\n\ntype SqliteResult = {\n rows: Array>;\n rowsAffected?: number;\n lastInsertRowid?: unknown;\n};\n\ntype SqliteClient = {\n execute(\n input:\n | string\n | {\n sql: string;\n args?: unknown[] | Record;\n },\n ): Promise;\n batch(\n input: Array<\n | string\n | {\n sql: string;\n args?: unknown[] | Record;\n }\n >,\n ): Promise;\n};\n\ntype TelegramUpdate = {\n update_id?: number;\n message?: {\n chat?: { id?: number };\n text?: string;\n from?: { id?: number; first_name?: string };\n };\n callback_query?: {\n id?: string;\n data?: string;\n from?: { id?: number; first_name?: string };\n message?: {\n chat?: { id?: number };\n message_id?: number;\n };\n };\n};\n\ntype AfishaEvent = {\n id: string;\n externalId: string;\n title: string;\n url: string;\n category?: string;\n venueName?: string;\n venueAddress?: string;\n eventDate?: string;\n dateLabel?: string;\n priceMin?: number;\n priceMax?: number;\n currency?: string;\n availableCount?: number;\n checkedAt?: string;\n};\n\nconst AFISHA_HOME_URL = 'https://24afisha.by/ru/minsk';\nconst SOURCE_ID = 'afisha24-by';\nconst SOURCE_LABEL = '24afisha.by';\nconst MIN_DROP_PERCENT = 5;\nconst MAX_LIVE_EVENTS = 18;\nconst MAX_DETAIL_FETCHES = 10;\n\nconst labels = {\n events: '🎭 Афиша',\n search: '🔎 Поиск',\n aiChat: '🤖 ИИ-чат',\n subscriptions: '🔔 Подписки',\n priceDrops: '📉 Скидки',\n help: 'ℹ️ Помощь',\n} as const;\n\nlet sqlitePromise: Promise | undefined;\n\nfunction env(name: string): string {\n return Deno.env.get(name) || '';\n}\n\nfunction getNow(): string {\n return new Date().toISOString();\n}\n\nfunction json(body: unknown, status = 200): Response {\n return new Response(JSON.stringify(body, null, 2), {\n status,\n headers: {\n 'content-type': 'application/json; charset=utf-8',\n },\n });\n}\n\nfunction escapeHtml(input: unknown): string {\n return String(input ?? '')\n .replace(/&/g, '&')\n .replace(//g, '>')\n .replace(/\"/g, '"');\n}\n\nfunction normalizeText(input: string): string {\n return input\n .replace(/"/g, '\"')\n .replace(/&/g, '&')\n .replace(/'/g, \"'\")\n .replace(/ /g, ' ')\n .replace(/—/g, '—')\n .replace(/«/g, '«')\n .replace(/»/g, '»')\n .replace(/\\s+/g, ' ')\n .trim();\n}\n\nfunction stripTags(input: string): string {\n return normalizeText(input.replace(/<[^>]+>/g, ' '));\n}\n\nfunction compactEventId(url: string): string {\n const match = url.match(/\\/event\\/(\\d+)/);\n return match ? `${SOURCE_ID}:${match[1]}` : `${SOURCE_ID}:${simpleHash(url)}`;\n}\n\nfunction simpleHash(input: string): string {\n let hash = 0;\n for (let i = 0; i < input.length; i += 1) {\n hash = (hash * 31 + input.charCodeAt(i)) >>> 0;\n }\n return hash.toString(16);\n}\n\nfunction toNumber(input: unknown): number | undefined {\n if (typeof input === 'number' && Number.isFinite(input)) return input;\n if (typeof input !== 'string') return undefined;\n const value = Number(input.replace(',', '.').replace(/[^\\d.]/g, ''));\n return Number.isFinite(value) && value > 0 ? value : undefined;\n}\n\nfunction formatPrice(min?: number, max?: number, currency = 'BYN'): string {\n if (!min && !max) return 'цена не указана';\n if (!max || min === max) return `${min} ${currency}`;\n return `${min}–${max} ${currency}`;\n}\n\nfunction formatDateLabel(event: AfishaEvent): string {\n if (event.dateLabel) return event.dateLabel;\n if (!event.eventDate) return 'дата уточняется';\n try {\n return new Intl.DateTimeFormat('ru-RU', {\n day: 'numeric',\n month: 'long',\n year: 'numeric',\n hour: '2-digit',\n minute: '2-digit',\n timeZone: 'Europe/Minsk',\n }).format(new Date(event.eventDate));\n } catch {\n return event.eventDate;\n }\n}\n\nfunction parseRuDate(text: string): string | undefined {\n const monthMap: Record = {\n января: 0,\n январь: 0,\n янв: 0,\n февраля: 1,\n февраль: 1,\n фев: 1,\n марта: 2,\n март: 2,\n мар: 2,\n апреля: 3,\n апрель: 3,\n апр: 3,\n мая: 4,\n май: 4,\n июня: 5,\n июнь: 5,\n июля: 6,\n июль: 6,\n августа: 7,\n август: 7,\n сентября: 8,\n сентябрь: 8,\n сен: 8,\n октября: 9,\n октябрь: 9,\n окт: 9,\n ноября: 10,\n ноябрь: 10,\n ноя: 10,\n декабря: 11,\n декабрь: 11,\n дек: 11,\n };\n\n const match = text\n .toLowerCase()\n .match(/(\\d{1,2})\\s+([а-я.]+)\\s+(\\d{4})(?:[,\\s]+(\\d{1,2})[:.](\\d{2}))?/i);\n if (!match) return undefined;\n\n const day = Number(match[1]);\n const month = monthMap[match[2].replace('.', '')];\n const year = Number(match[3]);\n const hour = match[4] ? Number(match[4]) : 19;\n const minute = match[5] ? Number(match[5]) : 0;\n if (!Number.isFinite(day) || month === undefined || !Number.isFinite(year)) return undefined;\n\n return new Date(Date.UTC(year, month, day, hour - 3, minute, 0)).toISOString();\n}\n\nasync function getSqlite(): Promise {\n const testSqlite = (globalThis as unknown as { __AFISHA_TEST_SQLITE__?: SqliteClient })\n .__AFISHA_TEST_SQLITE__;\n if (testSqlite) return testSqlite;\n\n // @ts-ignore Val Town/Deno supports https imports; local Node typecheck does not.\n sqlitePromise ??= import('https://esm.town/v/std/sqlite/main.ts').then((mod) => {\n return (mod as { sqlite: SqliteClient }).sqlite;\n });\n return sqlitePromise;\n}\n\nasync function optionalDb(\n operation: (sqlite: SqliteClient) => Promise,\n fallback: T,\n): Promise {\n if (env('AFISHA_DISABLE_DB') === '1') return fallback;\n\n try {\n return await operation(await getSqlite());\n } catch (error) {\n console.warn('Optional Val Town SQLite operation failed:', error);\n return fallback;\n }\n}\n\nasync function requiredDb(operation: (sqlite: SqliteClient) => Promise): Promise {\n return operation(await getSqlite());\n}\n\nasync function ensureSchema(sqlite: SqliteClient): Promise {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS users (\n id TEXT PRIMARY KEY,\n telegram_id INTEGER UNIQUE NOT NULL,\n name TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS events (\n id TEXT PRIMARY KEY,\n source_id TEXT NOT NULL,\n external_id TEXT NOT NULL,\n title TEXT NOT NULL,\n category TEXT,\n venue_name TEXT,\n venue_address TEXT,\n event_date TEXT,\n date_label TEXT,\n external_url TEXT NOT NULL,\n is_active INTEGER NOT NULL DEFAULT 1,\n last_seen_at TEXT NOT NULL,\n checked_at TEXT NOT NULL,\n UNIQUE(source_id, external_id)\n )`,\n `CREATE TABLE IF NOT EXISTS price_history (\n id TEXT PRIMARY KEY,\n event_id TEXT NOT NULL,\n price_min REAL,\n price_max REAL,\n currency TEXT NOT NULL DEFAULT 'BYN',\n is_available INTEGER NOT NULL DEFAULT 1,\n available_count INTEGER,\n source_url TEXT,\n checked_at TEXT NOT NULL,\n time TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS alert_subscriptions (\n id TEXT PRIMARY KEY,\n user_id TEXT NOT NULL,\n event_id TEXT NOT NULL,\n min_discount_percent REAL NOT NULL DEFAULT 5,\n is_active INTEGER NOT NULL DEFAULT 1,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n UNIQUE(user_id, event_id)\n )`,\n `CREATE TABLE IF NOT EXISTS price_drop_notifications (\n id TEXT PRIMARY KEY,\n subscription_id TEXT NOT NULL,\n user_id TEXT NOT NULL,\n event_id TEXT NOT NULL,\n old_price_min REAL,\n new_price_min REAL,\n drop_percent REAL,\n price_history_time TEXT NOT NULL,\n sent_at TEXT NOT NULL,\n UNIQUE(subscription_id, price_history_time)\n )`,\n `CREATE INDEX IF NOT EXISTS idx_events_date ON events(is_active, event_date)`,\n `CREATE INDEX IF NOT EXISTS idx_events_title ON events(title)`,\n `CREATE INDEX IF NOT EXISTS idx_price_history_event ON price_history(event_id, time DESC)`,\n `CREATE INDEX IF NOT EXISTS idx_subscriptions_user ON alert_subscriptions(user_id, is_active)`,\n ]);\n}\n\nfunction mainKeyboard() {\n return {\n keyboard: [\n [{ text: labels.events }, { text: labels.search }],\n [{ text: labels.aiChat }, { text: labels.subscriptions }],\n [{ text: labels.priceDrops }, { text: labels.help }],\n ],\n resize_keyboard: true,\n };\n}\n\nfunction eventListKeyboard(events: AfishaEvent[]) {\n return {\n inline_keyboard: events.slice(0, 8).map((event) => [\n {\n text: event.title.slice(0, 60),\n callback_data: `event:${event.id}`,\n },\n ]),\n };\n}\n\nfunction eventDetailKeyboard(event: AfishaEvent, subscribed = false) {\n return {\n inline_keyboard: [\n [{ text: '🛒 Купить билет', url: event.url }],\n [\n {\n text: subscribed ? '🔕 Отключить уведомления' : '🔔 Следить за ценой',\n callback_data: subscribed ? `unsub:${event.id}` : `sub:${event.id}`,\n },\n ],\n [\n { text: '3%', callback_data: `pct:${event.id}:3` },\n { text: '5%', callback_data: `pct:${event.id}:5` },\n { text: '10%', callback_data: `pct:${event.id}:10` },\n ],\n [\n { text: '📊 История цен', callback_data: `hist:${event.id}` },\n { text: '🪑 Совет по местам', callback_data: `adv:${event.id}` },\n ],\n [{ text: '⬅️ К афише', callback_data: 'back:list' }],\n ],\n };\n}\n\nfunction parsePercentCallback(data: string): { eventId: string; threshold: number } | undefined {\n const payload = data.slice('pct:'.length);\n const separator = payload.lastIndexOf(':');\n if (separator <= 0) return undefined;\n\n const eventId = payload.slice(0, separator);\n const rawValue = payload.slice(separator + 1);\n const threshold = Math.max(1, Math.min(90, Math.round(Number(rawValue) || MIN_DROP_PERCENT)));\n return { eventId, threshold };\n}\n\nasync function telegram(method: string, payload: Record) {\n const token = env('TELEGRAM_BOT_TOKEN');\n if (!token) {\n throw new Error('TELEGRAM_BOT_TOKEN is not configured');\n }\n\n const response = await fetch(`https://api.telegram.org/bot${token}/${method}`, {\n method: 'POST',\n headers: {\n 'content-type': 'application/json',\n },\n body: JSON.stringify(payload),\n });\n\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`Telegram ${method} failed: ${response.status} ${text.slice(0, 300)}`);\n }\n\n return response.json();\n}\n\nasync function sendMessage(chatId: number, text: string, replyMarkup?: Record) {\n await telegram('sendMessage', {\n chat_id: chatId,\n text,\n parse_mode: 'HTML',\n disable_web_page_preview: true,\n ...(replyMarkup ? { reply_markup: replyMarkup } : {}),\n });\n}\n\nasync function answerCallbackQuery(callbackQueryId?: string, text?: string) {\n if (!callbackQueryId) return;\n await telegram('answerCallbackQuery', {\n callback_query_id: callbackQueryId,\n ...(text ? { text } : {}),\n });\n}\n\nfunction parseAfishaEventAnchors(html: string, query?: string): AfishaEvent[] {\n const events = new Map();\n const anchorRe =\n /]*>([\\s\\S]*?)<\\/a>/gi;\n\n for (const match of html.matchAll(anchorRe)) {\n const rawUrl = match[1].split('?')[0];\n const url = rawUrl.startsWith('http') ? rawUrl : `https://24afisha.by${rawUrl}`;\n const body = match[2];\n const title =\n body.match(\n /class=\"[^\"]*(?:slide__title|card__title|poster-title|event-title)[^\"]*\"[^>]*>([\\s\\S]*?)<\\//i,\n )?.[1] ||\n body.match(/alt=\"([^\"]+)\"/)?.[1] ||\n body.replace(/<[^>]+>/g, ' ');\n const normalized = normalizeText(title);\n\n if (!normalized || normalized.length < 4) continue;\n if (query && !normalized.toLowerCase().includes(query.toLowerCase())) continue;\n if (!events.has(url)) {\n events.set(url, {\n id: compactEventId(url),\n externalId: compactEventId(url).split(':')[1],\n title: normalized,\n url,\n category: 'Афиша',\n checkedAt: getNow(),\n });\n }\n if (events.size >= MAX_LIVE_EVENTS) break;\n }\n\n return [...events.values()];\n}\n\nexport function parseAfishaEventsFromHtml(html: string, query?: string): AfishaEvent[] {\n return parseAfishaEventAnchors(html, query);\n}\n\nexport function parseEventDetailHtml(html: string, fallback: AfishaEvent): AfishaEvent {\n const plain = stripTags(html);\n const title =\n stripTags(\n html.match(\n /]*class=\"[^\"]*event-image__data__title[^\"]*\"[^>]*>([\\s\\S]*?)<\\/h1>/i,\n )?.[1] || '',\n ) ||\n normalizeText(html.match(/([\\s\\S]*?)<\\/title>/i)?.[1] || '').replace(\n /\\s+—\\s+купить билеты.*/i,\n '',\n ) ||\n fallback.title;\n\n const prices = [...plain.matchAll(/(?:от|до)?\\s*([0-9]+(?:[,.][0-9]+)?)\\s*BYN/gi)]\n .map((match) => toNumber(match[1]))\n .filter((value): value is number => typeof value === 'number');\n const priceMin = prices.length > 0 ? Math.min(...prices) : fallback.priceMin;\n const priceMax = prices.length > 0 ? Math.max(...prices) : fallback.priceMax;\n const dateLabel =\n plain.match(/(\\d{1,2}\\s+[а-яА-Я]+\\s+\\d{4}(?:,\\s*\\d{1,2}[.:]\\d{2})?)/)?.[1] ||\n plain.match(/с\\s+(\\d{1,2}\\s+[а-яА-Я]+)/)?.[1] ||\n fallback.dateLabel;\n const eventDate = dateLabel ? parseRuDate(dateLabel) || fallback.eventDate : fallback.eventDate;\n const venueName =\n normalizeText(\n plain.match(/Место проведения\\s*[-—]\\s*[\"«]?([^\"»\\n\\r]+)[\"»]?/i)?.[1] ||\n plain.match(/Возраст\\s*[-—]\\s*\\d+\\+?\\s+([А-ЯЁA-Z][^,]{3,60})/i)?.[1] ||\n '',\n ) || fallback.venueName;\n\n return {\n ...fallback,\n title,\n venueName,\n eventDate,\n dateLabel,\n priceMin,\n priceMax,\n currency: priceMin || priceMax ? 'BYN' : fallback.currency,\n };\n}\n\nexport async function fetchAfishaEvents(query?: string, enrich = false): Promise<AfishaEvent[]> {\n const response = await fetch(AFISHA_HOME_URL, {\n headers: {\n 'user-agent':\n 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/131 Safari/537.36',\n accept: 'text/html,application/xhtml+xml',\n 'accept-language': 'ru-RU,ru;q=0.9',\n },\n });\n\n if (!response.ok) {\n throw new Error(`${SOURCE_LABEL} returned ${response.status}`);\n }\n\n const events = parseAfishaEventAnchors(await response.text(), query);\n if (!enrich) return events;\n\n const enriched: AfishaEvent[] = [];\n for (const event of events.slice(0, MAX_DETAIL_FETCHES)) {\n try {\n const detailResponse = await fetch(event.url, {\n headers: {\n 'user-agent':\n 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/131 Safari/537.36',\n accept: 'text/html,application/xhtml+xml',\n 'accept-language': 'ru-RU,ru;q=0.9',\n },\n });\n if (!detailResponse.ok) {\n enriched.push(event);\n continue;\n }\n enriched.push(parseEventDetailHtml(await detailResponse.text(), event));\n } catch {\n enriched.push(event);\n }\n }\n\n return [...enriched, ...events.slice(MAX_DETAIL_FETCHES)];\n}\n\nasync function upsertEvent(sqlite: SqliteClient, event: AfishaEvent): Promise<void> {\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO events (\n id, source_id, external_id, title, category, venue_name, venue_address,\n event_date, date_label, external_url, is_active, last_seen_at, checked_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 1, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n title = excluded.title,\n category = excluded.category,\n venue_name = excluded.venue_name,\n venue_address = excluded.venue_address,\n event_date = excluded.event_date,\n date_label = excluded.date_label,\n external_url = excluded.external_url,\n is_active = 1,\n last_seen_at = excluded.last_seen_at,\n checked_at = excluded.checked_at`,\n args: [\n event.id,\n SOURCE_ID,\n event.externalId,\n event.title,\n event.category || 'Афиша',\n event.venueName || null,\n event.venueAddress || null,\n event.eventDate || null,\n event.dateLabel || null,\n event.url,\n now,\n now,\n ],\n });\n\n if (event.priceMin || event.priceMax) {\n const latest = await sqlite.execute({\n sql: `SELECT price_min, price_max, time FROM price_history\n WHERE event_id = ? ORDER BY time DESC LIMIT 1`,\n args: [event.id],\n });\n const row = latest.rows[0];\n const latestTime = row?.time ? new Date(String(row.time)).getTime() : 0;\n const isOld = Date.now() - latestTime > 12 * 60 * 60 * 1000;\n const changed =\n Number(row?.price_min ?? 0) !== Number(event.priceMin ?? 0) ||\n Number(row?.price_max ?? 0) !== Number(event.priceMax ?? 0);\n\n if (!row || changed || isOld) {\n await sqlite.execute({\n sql: `INSERT INTO price_history (\n id, event_id, price_min, price_max, currency, is_available,\n available_count, source_url, checked_at, time\n ) VALUES (?, ?, ?, ?, ?, 1, ?, ?, ?, ?)`,\n args: [\n crypto.randomUUID(),\n event.id,\n event.priceMin || null,\n event.priceMax || null,\n event.currency || 'BYN',\n event.availableCount || null,\n event.url,\n now,\n now,\n ],\n });\n }\n }\n}\n\nasync function scrapeAndStore(\n limit = 18,\n): Promise<{ found: number; stored: number; checkedAt: string }> {\n return requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const events = (await fetchAfishaEvents(undefined, true)).slice(0, limit);\n for (const event of events) {\n await upsertEvent(sqlite, event);\n }\n return { found: events.length, stored: events.length, checkedAt: getNow() };\n });\n}\n\nfunction mapEventRow(row: Record<string, unknown>, price?: Record<string, unknown>): AfishaEvent {\n return {\n id: String(row.id),\n externalId: String(row.external_id || ''),\n title: String(row.title || ''),\n url: String(row.external_url || ''),\n category: row.category ? String(row.category) : undefined,\n venueName: row.venue_name ? String(row.venue_name) : undefined,\n venueAddress: row.venue_address ? String(row.venue_address) : undefined,\n eventDate: row.event_date ? String(row.event_date) : undefined,\n dateLabel: row.date_label ? String(row.date_label) : undefined,\n priceMin: toNumber(price?.price_min),\n priceMax: toNumber(price?.price_max),\n currency: price?.currency ? String(price.currency) : 'BYN',\n availableCount: toNumber(price?.available_count),\n checkedAt: row.checked_at ? String(row.checked_at) : undefined,\n };\n}\n\nasync function getStoredEvents(query?: string, limit = 8): Promise<AfishaEvent[]> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const params: unknown[] = [];\n let where = 'WHERE e.is_active = 1';\n if (query) {\n where += ' AND LOWER(e.title) LIKE ?';\n params.push(`%${query.toLowerCase()}%`);\n }\n params.push(limit);\n\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM events e\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n ${where}\n ORDER BY COALESCE(e.event_date, e.last_seen_at) ASC\n LIMIT ?`,\n args: params,\n });\n\n return result.rows.map((row) => mapEventRow(row, row));\n }, []);\n}\n\nasync function getEventById(eventId: string): Promise<AfishaEvent | undefined> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM events e\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n WHERE e.id = ?\n LIMIT 1`,\n args: [eventId],\n });\n return result.rows[0] ? mapEventRow(result.rows[0], result.rows[0]) : undefined;\n }, undefined);\n}\n\nasync function getOrCreateUser(\n telegramId: number,\n firstName?: string,\n): Promise<string | undefined> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const existing = await sqlite.execute({\n sql: 'SELECT id FROM users WHERE telegram_id = ? LIMIT 1',\n args: [telegramId],\n });\n if (existing.rows[0]?.id) return String(existing.rows[0].id);\n\n const id = crypto.randomUUID();\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO users (id, telegram_id, name, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?)`,\n args: [id, telegramId, firstName || null, now, now],\n });\n return id;\n }, undefined);\n}\n\nasync function isSubscribed(userId: string | undefined, eventId: string): Promise<boolean> {\n if (!userId) return false;\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT id FROM alert_subscriptions\n WHERE user_id = ? AND event_id = ? AND is_active = 1 LIMIT 1`,\n args: [userId, eventId],\n });\n return Boolean(result.rows[0]);\n }, false);\n}\n\nasync function setSubscription(\n userId: string | undefined,\n eventId: string,\n active: boolean,\n threshold = MIN_DROP_PERCENT,\n): Promise<void> {\n if (!userId) return;\n await requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const now = getNow();\n await sqlite.execute({\n sql: `INSERT INTO alert_subscriptions (\n id, user_id, event_id, min_discount_percent, is_active, created_at, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(user_id, event_id) DO UPDATE SET\n min_discount_percent = excluded.min_discount_percent,\n is_active = excluded.is_active,\n updated_at = excluded.updated_at`,\n args: [crypto.randomUUID(), userId, eventId, threshold, active ? 1 : 0, now, now],\n });\n });\n}\n\nasync function getPriceHistory(\n eventId: string,\n limit = 5,\n): Promise<Array<Record<string, unknown>>> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT price_min, price_max, currency, checked_at, time\n FROM price_history\n WHERE event_id = ?\n ORDER BY time DESC\n LIMIT ?`,\n args: [eventId, limit],\n });\n return result.rows;\n }, []);\n}\n\nasync function getSubscriptions(userId: string | undefined): Promise<AfishaEvent[]> {\n if (!userId) return [];\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const result = await sqlite.execute({\n sql: `SELECT e.*, ph.price_min, ph.price_max, ph.currency, ph.available_count\n FROM alert_subscriptions s\n JOIN events e ON e.id = s.event_id\n LEFT JOIN price_history ph ON ph.id = (\n SELECT id FROM price_history\n WHERE event_id = e.id\n ORDER BY time DESC LIMIT 1\n )\n WHERE s.user_id = ? AND s.is_active = 1\n ORDER BY COALESCE(e.event_date, e.last_seen_at) ASC\n LIMIT 20`,\n args: [userId],\n });\n return result.rows.map((row) => mapEventRow(row, row));\n }, []);\n}\n\nasync function getGlobalPriceDrops(\n limit = 8,\n): Promise<Array<{ event: AfishaEvent; oldPrice: number; newPrice: number; dropPercent: number }>> {\n return optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const events = await getStoredEvents(undefined, 40);\n const drops = [];\n for (const event of events) {\n const history = await getPriceHistory(event.id, 2);\n if (history.length < 2) continue;\n const latest = toNumber(history[0].price_min);\n const previous = toNumber(history[1].price_min);\n if (!latest || !previous || latest >= previous) continue;\n const dropPercent = ((previous - latest) / previous) * 100;\n if (dropPercent < MIN_DROP_PERCENT) continue;\n drops.push({ event, oldPrice: previous, newPrice: latest, dropPercent });\n }\n return drops.sort((a, b) => b.dropPercent - a.dropPercent).slice(0, limit);\n }, []);\n}\n\nasync function sendDueAlerts(maxMessages = 20): Promise<{ checked: number; sent: number }> {\n return requiredDb(async (sqlite) => {\n await ensureSchema(sqlite);\n const subscriptions = await sqlite.execute({\n sql: `SELECT\n s.id AS subscription_id,\n s.user_id,\n s.event_id,\n s.min_discount_percent,\n u.telegram_id,\n e.title,\n e.event_date,\n e.date_label,\n e.external_url\n FROM alert_subscriptions s\n JOIN users u ON u.id = s.user_id\n JOIN events e ON e.id = s.event_id\n WHERE s.is_active = 1\n LIMIT 100`,\n });\n\n let sent = 0;\n for (const subscription of subscriptions.rows) {\n if (sent >= maxMessages) break;\n const history = await getPriceHistory(String(subscription.event_id), 2);\n if (history.length < 2) continue;\n const latest = toNumber(history[0].price_min);\n const previous = toNumber(history[1].price_min);\n if (!latest || !previous || latest >= previous) continue;\n\n const dropPercent = ((previous - latest) / previous) * 100;\n const threshold = toNumber(subscription.min_discount_percent) || MIN_DROP_PERCENT;\n if (dropPercent < threshold) continue;\n\n const already = await sqlite.execute({\n sql: `SELECT id FROM price_drop_notifications\n WHERE subscription_id = ? AND price_history_time = ?\n LIMIT 1`,\n args: [subscription.subscription_id, history[0].time],\n });\n if (already.rows[0]) continue;\n\n await sendMessage(\n Number(subscription.telegram_id),\n `🔻 Цена снизилась\\n\\n${escapeHtml(subscription.title)}\\n` +\n `💰 ${previous} → ${latest} BYN (−${dropPercent.toFixed(1)}%)\\n` +\n `📅 ${escapeHtml(subscription.date_label || subscription.event_date || 'дата уточняется')}\\n` +\n `🛒 ${escapeHtml(subscription.external_url)}`,\n {\n inline_keyboard: [[{ text: 'Открыть событие', url: String(subscription.external_url) }]],\n },\n );\n\n await sqlite.execute({\n sql: `INSERT INTO price_drop_notifications (\n id, subscription_id, user_id, event_id, old_price_min, new_price_min,\n drop_percent, price_history_time, sent_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n crypto.randomUUID(),\n subscription.subscription_id,\n subscription.user_id,\n subscription.event_id,\n previous,\n latest,\n Number(dropPercent.toFixed(2)),\n history[0].time,\n getNow(),\n ],\n });\n sent += 1;\n }\n\n return { checked: subscriptions.rows.length, sent };\n });\n}\n\nasync function getDbStats(): Promise<Record<string, unknown>> {\n return optionalDb(\n async (sqlite) => {\n await ensureSchema(sqlite);\n const stats: Record<string, unknown> = {};\n for (const table of ['events', 'price_history', 'users', 'alert_subscriptions']) {\n const result = await sqlite.execute(`SELECT COUNT(*) AS count FROM ${table}`);\n stats[table] = Number(result.rows[0]?.count || 0);\n }\n return stats;\n },\n { unavailable: true },\n );\n}\n\nfunction welcomeText(firstName?: string): string {\n const name = firstName ? `, ${firstName}` : '';\n return (\n `👋 Привет${escapeHtml(name)}!\\n\\n` +\n `Я слежу за билетами на мероприятия в Минске.\\n\\n` +\n `🎭 Показываю афишу с ценами\\n` +\n `📊 Храню историю цен после проверок\\n` +\n `🔔 Запоминаю подписки и пороги скидок\\n` +\n `📉 Присылаю падения цен после cron-проверки\\n\\n` +\n `Выбери действие:`\n );\n}\n\nasync function loadEventsForDisplay(query?: string): Promise<AfishaEvent[]> {\n const stored = await getStoredEvents(query, 8);\n if (stored.length > 0) return stored;\n\n const live = await fetchAfishaEvents(query, false);\n const visible = live.slice(0, 8);\n await optionalDb(async (sqlite) => {\n await ensureSchema(sqlite);\n for (const event of visible) {\n await upsertEvent(sqlite, event);\n }\n return true;\n }, false);\n\n return visible;\n}\n\nasync function showEvents(chatId: number, query?: string) {\n const events = await loadEventsForDisplay(query);\n if (events.length === 0) {\n await sendMessage(\n chatId,\n query\n ? `По запросу «${escapeHtml(query)}» пока ничего не найдено. Попробуй другое название.`\n : 'Сейчас не удалось найти события. Попробуй позже.',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = events\n .slice(0, 8)\n .map((event, index) => {\n const price =\n event.priceMin || event.priceMax ? ` — ${formatPrice(event.priceMin, event.priceMax)}` : '';\n return `${index + 1}. ${escapeHtml(event.title)}${escapeHtml(price)}\\n${escapeHtml(\n formatDateLabel(event),\n )}`;\n })\n .join('\\n\\n');\n\n await sendMessage(\n chatId,\n `🎭 Афиша Минска\\n\\n${lines}\\n\\nИсточник: ${SOURCE_LABEL}`,\n eventListKeyboard(events),\n );\n}\n\nasync function showEventDetail(chatId: number, userId: string | undefined, eventId: string) {\n const event = await getEventById(eventId);\n if (!event) {\n await sendMessage(\n chatId,\n 'Событие не найдено в сохраненной базе. Нажми «🎭 Афиша» для обновления.',\n mainKeyboard(),\n );\n return;\n }\n\n const subscribed = await isSubscribed(userId, eventId);\n const text =\n `🎫 ${escapeHtml(event.title)}\\n\\n` +\n `📅 ${escapeHtml(formatDateLabel(event))}\\n` +\n `📍 ${escapeHtml(event.venueName || 'площадка уточняется')}\\n` +\n `💰 ${escapeHtml(formatPrice(event.priceMin, event.priceMax, event.currency))}\\n` +\n `🛡 Проверено: ${escapeHtml(event.checkedAt || 'только что')}\\n\\n` +\n `Источник: ${SOURCE_LABEL}`;\n\n await sendMessage(chatId, text, eventDetailKeyboard(event, subscribed));\n}\n\nasync function showHistory(chatId: number, eventId: string) {\n const event = await getEventById(eventId);\n const history = await getPriceHistory(eventId, 6);\n if (!event || history.length === 0) {\n await sendMessage(\n chatId,\n 'История цен пока не накоплена. Она появится после нескольких проверок.',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = history\n .map((row) => {\n return `• ${escapeHtml(String(row.checked_at || row.time))}: ${escapeHtml(\n formatPrice(\n toNumber(row.price_min),\n toNumber(row.price_max),\n String(row.currency || 'BYN'),\n ),\n )}`;\n })\n .join('\\n');\n await sendMessage(chatId, `📊 ${escapeHtml(event.title)}\\n\\n${lines}`, {\n inline_keyboard: [[{ text: '⬅️ К событию', callback_data: `event:${event.id}` }]],\n });\n}\n\nasync function showAdvice(chatId: number, eventId: string) {\n const event = await getEventById(eventId);\n if (!event) {\n await sendMessage(chatId, 'Событие не найдено.');\n return;\n }\n\n const price = event.priceMin || event.priceMax;\n const advice = price\n ? `Если важна цена, начинай с диапазона ${formatPrice(event.priceMin, event.priceMax)}. ` +\n `Для точной схемы мест открой продажу на сайте: Val Town fetch-only режим не видит полную карту зала.`\n : 'Цена пока не проверена. Я покажу точнее после следующей scrape-проверки.';\n\n await sendMessage(chatId, `🪑 Совет по выбору\\n\\n${escapeHtml(advice)}`, {\n inline_keyboard: [[{ text: '🛒 Купить билет', url: event.url }]],\n });\n}\n\nasync function showSubscriptions(chatId: number, userId: string | undefined) {\n const subscriptions = await getSubscriptions(userId);\n if (subscriptions.length === 0) {\n await sendMessage(\n chatId,\n '🔔 У тебя пока нет активных подписок. Открой событие и нажми «Следить за ценой».',\n mainKeyboard(),\n );\n return;\n }\n\n const lines = subscriptions\n .map(\n (event, index) =>\n `${index + 1}. ${escapeHtml(event.title)} — ${escapeHtml(formatPrice(event.priceMin, event.priceMax))}`,\n )\n .join('\\n\\n');\n await sendMessage(chatId, `🔔 Мои подписки\\n\\n${lines}`, eventListKeyboard(subscriptions));\n}\n\nasync function showPriceDrops(chatId: number) {\n const drops = await getGlobalPriceDrops();\n if (drops.length === 0) {\n await sendMessage(\n chatId,\n '📉 Пока нет сохраненных падений цены. Нужно минимум две проверки цен.',\n mainKeyboard(),\n );\n return;\n }\n\n const text = drops\n .map((drop, index) => {\n return `${index + 1}. ${escapeHtml(drop.event.title)}\\n${drop.oldPrice} → ${drop.newPrice} BYN (−${drop.dropPercent.toFixed(1)}%)`;\n })\n .join('\\n\\n');\n await sendMessage(chatId, `📉 Скидки и падения цены\\n\\n${text}`);\n}\n\nasync function handleMessage(update: TelegramUpdate): Promise<void> {\n const chatId = update.message?.chat?.id;\n const telegramId = update.message?.from?.id || chatId;\n const text = update.message?.text?.trim() || '';\n const firstName = update.message?.from?.first_name;\n if (!chatId || !telegramId) return;\n\n const userId = await getOrCreateUser(telegramId, firstName);\n\n if (!text || text.startsWith('/start')) {\n await sendMessage(chatId, welcomeText(firstName), mainKeyboard());\n return;\n }\n\n if (text.startsWith('/help') || text === labels.help) {\n await sendMessage(\n chatId,\n 'Команды: /start, /help, /search.\\n\\nНажми «🎭 Афиша», чтобы получить список событий. Открой событие, чтобы подписаться на падение цены.',\n mainKeyboard(),\n );\n return;\n }\n\n if (text === labels.events || text.toLowerCase() === 'афиша') {\n await showEvents(chatId);\n return;\n }\n\n if (text === labels.search || text.startsWith('/search')) {\n await sendMessage(\n chatId,\n '🔎 Напиши название события или артиста, я попробую найти его в текущей афише.',\n mainKeyboard(),\n );\n return;\n }\n\n if (text === labels.subscriptions) {\n await showSubscriptions(chatId, userId);\n return;\n }\n\n if (text === labels.priceDrops) {\n await showPriceDrops(chatId);\n return;\n }\n\n if (text === labels.aiChat) {\n await sendMessage(\n chatId,\n '🤖 Полный AI-чат требует отдельного LLM/API. Здесь работает честный serverless-режим: афиша, цены, история, подписки и эвристический совет по событию.',\n mainKeyboard(),\n );\n return;\n }\n\n await showEvents(chatId, text);\n}\n\nasync function handleCallback(update: TelegramUpdate): Promise<void> {\n const callback = update.callback_query;\n if (!callback) return;\n const chatId = callback.message?.chat?.id;\n const telegramId = callback.from?.id || chatId;\n const data = callback.data || '';\n if (!chatId || !telegramId) return;\n\n const userId = await getOrCreateUser(telegramId, callback.from?.first_name);\n await answerCallbackQuery(callback.id);\n\n if (data === 'back:list') {\n await showEvents(chatId);\n return;\n }\n\n if (data.startsWith('event:')) {\n await showEventDetail(chatId, userId, data.slice('event:'.length));\n return;\n }\n\n if (data.startsWith('sub:')) {\n const eventId = data.slice('sub:'.length);\n await setSubscription(userId, eventId, true, MIN_DROP_PERCENT);\n await sendMessage(\n chatId,\n '✅ Подписка включена. Сообщу, если цена снизится после следующих проверок.',\n );\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('unsub:')) {\n const eventId = data.slice('unsub:'.length);\n await setSubscription(userId, eventId, false);\n await sendMessage(chatId, '🔕 Подписка отключена.');\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('pct:')) {\n const parsed = parsePercentCallback(data);\n if (!parsed) {\n await sendMessage(\n chatId,\n 'Не удалось прочитать порог скидки. Открой карточку события заново.',\n );\n return;\n }\n const { eventId, threshold } = parsed;\n await setSubscription(userId, eventId, true, threshold);\n await sendMessage(chatId, `✅ Порог скидки установлен: ${threshold}%`);\n await showEventDetail(chatId, userId, eventId);\n return;\n }\n\n if (data.startsWith('hist:')) {\n await showHistory(chatId, data.slice('hist:'.length));\n return;\n }\n\n if (data.startsWith('adv:')) {\n await showAdvice(chatId, data.slice('adv:'.length));\n }\n}\n\nasync function handleAdmin(url: URL, request: Request): Promise<Response> {\n const expected = env('AFISHA_ADMIN_SECRET');\n const actual = request.headers.get('x-afisha-admin-secret') || '';\n if (!expected || actual !== expected) {\n return json({ ok: false, error: 'unauthorized' }, 401);\n }\n\n const action = url.searchParams.get('admin');\n if (action === 'scrape') {\n const limit = Math.max(1, Math.min(40, Number(url.searchParams.get('limit')) || 18));\n return json({ ok: true, scrape: await scrapeAndStore(limit) });\n }\n\n if (action === 'alerts') {\n return json({ ok: true, alerts: await sendDueAlerts() });\n }\n\n if (action === 'run') {\n const scrape = await scrapeAndStore(\n Math.max(1, Math.min(40, Number(url.searchParams.get('limit')) || 18)),\n );\n const alerts = await sendDueAlerts();\n return json({ ok: true, scrape, alerts });\n }\n\n return json({ ok: false, error: 'unknown_admin_action' }, 400);\n}\n\nexport default async function handler(request: Request): Promise<Response> {\n const url = new URL(request.url);\n\n if (url.searchParams.has('admin')) {\n return handleAdmin(url, request);\n }\n\n if (request.method === 'GET') {\n if (url.searchParams.has('events')) {\n const events = await fetchAfishaEvents(url.searchParams.get('q') || undefined);\n return json({\n ok: true,\n count: events.length,\n events,\n checkedAt: getNow(),\n });\n }\n\n if (url.searchParams.has('state')) {\n return json({\n ok: true,\n db: await getDbStats(),\n checkedAt: getNow(),\n });\n }\n\n return json({\n ok: true,\n service: 'afisha-minsk-bot',\n mode: 'val-town-webhook-sqlite',\n source: SOURCE_LABEL,\n db: await getDbStats(),\n checkedAt: getNow(),\n });\n }\n\n if (request.method !== 'POST') {\n return json({ ok: false, error: 'method_not_allowed' }, 405);\n }\n\n const expectedSecret = env('TELEGRAM_WEBHOOK_SECRET');\n const actualSecret = request.headers.get('x-telegram-bot-api-secret-token') || '';\n if (expectedSecret && actualSecret !== expectedSecret) {\n return json({ ok: false, error: 'unauthorized' }, 401);\n }\n\n try {\n const update = (await request.json()) as TelegramUpdate;\n if (update.callback_query) {\n await handleCallback(update);\n } else {\n await handleMessage(update);\n }\n return json({ ok: true });\n } catch (error) {\n console.error(error);\n return json({ ok: false, error: error instanceof Error ? error.message : String(error) }, 500);\n }\n}\n",[140],"pulls","branches","forks","envVars",{"_155":14,"_157":61},"connections",{"_155":61,"_156":61},"count","unfilledCount","emptyCount",{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":164,"_13":144,"_33":145,"_35":146,"_24":25,"_137":-5,"_161":165,"_27":166},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":160,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_161":162,"_27":163},["D",1779100944045],"children",[],[28],["D",1779100943629],[],[140],["D",1779098075354],["D",1789470042795],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_127":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":125,"_214":-5,"_215":-7,"_216":-7,"_217":61,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":88,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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 · v7