[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_102":103,"_104":105},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","eldarjzj","name","Dnevnik","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/eldarjzj/Dnevnik/code/main.ts","extension","id","71001227-7164-4cf7-bcc1-a1a539d32b23","fileId","36d647b2-af5b-11f1-951b-1607ee4eb77e","parentId","branchId","839d65fb-ce61-4321-be54-2a03e5bff27f","branchVersion",4,"latest",true,"createdAt",["D",1789294208688],"version",3,"fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst USERS_KEY = \"tg_bot_users_v1\";\nconst WEBHOOK_KEY = \"tg_bot_webhook_state_v1\";\nconst BROADCAST_KEY = \"tg_bot_broadcast_state_v1\";\nconst WEBHOOK_TTL = 60 * 60 * 1000;\n\n/* Веб-приложение по умолчанию — GitHub Pages.\n Можно переопределить через env WEB_APP_URL */\nconst DEFAULT_WEB_APP = \"https://the-eldarz.github.io/TerchDnevnik/index.html\";\n\n/* ===================== ХРАНИЛИЩЕ ===================== */\nasync function getUsers() {\n try {\n return (await blob.getJSON(USERS_KEY)) || {};\n } catch {\n return {};\n }\n}\nasync function saveUsers(u) {\n await blob.setJSON(USERS_KEY, u);\n}\n\nasync function getBroadcastState() {\n try {\n return (await blob.getJSON(BROADCAST_KEY)) || {};\n } catch {\n return {};\n }\n}\nasync function saveBroadcastState(s) {\n await blob.setJSON(BROADCAST_KEY, s);\n}\n\n/* ===================== УТИЛИТЫ ===================== */\nfunction esc(s) {\n return String(s ?? \"\").replace(\n /[&<>]/g,\n (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\" }[c]),\n );\n}\nfunction apiUrl(token, method) {\n return `https://api.telegram.org/bot${token}/${method}`;\n}\nasync function tg(token, method, payload) {\n const r = await fetch(apiUrl(token, method), {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n return r.json().catch(() => null);\n}\nasync function send(token, chat_id, text, keyboard) {\n const payload = {\n chat_id,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n };\n if (keyboard) payload.reply_markup = { inline_keyboard: keyboard };\n return tg(token, \"sendMessage\", payload);\n}\nfunction userLine(u) {\n const name = [u.first_name, u.last_name].filter(Boolean).join(\" \");\n const un = u.username ? \"@\" + u.username : \"—\";\n return `${esc(name) || \"Без имени\"}\\n Юзернейм: ${\n esc(un)\n }\\n ID: ${u.id}`;\n}\nfunction menuKeyboard(url) {\n return [[{ text: \"📅 Открыть расписание\", web_app: { url } }]];\n}\n\nfunction sleep(ms) {\n return new Promise((r) => setTimeout(r, ms));\n}\n\n/* ===================== АВТОВЕБХУК ===================== */\nasync function ensureWebhook(token, req) {\n const fromEnv = (process.env.WEBHOOK_URL || \"\").trim();\n const fromReq = req.url\n ? (new URL(req.url).origin + new URL(req.url).pathname)\n : \"\";\n const target = fromEnv || fromReq;\n if (!target || !target.startsWith(\"https://\")) return;\n\n let cache = {};\n try {\n cache = (await blob.getJSON(WEBHOOK_KEY)) || {};\n } catch {}\n const now = Date.now();\n if (cache.url === target && cache.ts && now - cache.ts < WEBHOOK_TTL) return;\n\n try {\n const info = await fetch(apiUrl(token, \"getWebhookInfo\")).then((r) =>\n r.json()\n );\n const current = info?.result?.url || \"\";\n if (current !== target) {\n const res = await fetch(\n apiUrl(token, \"setWebhook\") + \"?url=\" + encodeURIComponent(target) +\n \"&drop_pending_updates=false\",\n ).then((r) => r.json());\n if (!res?.ok) console.error(\"setWebhook failed:\", res);\n else console.log(\"Webhook установлен:\", target);\n }\n await blob.setJSON(WEBHOOK_KEY, { url: target, ts: now });\n } catch (e) {\n console.error(\"ensureWebhook error:\", e);\n }\n}\n\n/* ===================== ГЛАВНЫЙ ОБРАБОТЧИК ===================== */\nexport default async function (req) {\n const BOT_TOKEN = process.env.BOT_TOKEN;\n const ADMIN_ID = Number(process.env.ADMIN_ID);\n const WEB_APP_URL = process.env.WEB_APP_URL || DEFAULT_WEB_APP;\n const BOT_NAME = process.env.BOT_NAME || \"Расписание\";\n\n if (!BOT_TOKEN) {\n return new Response(\"BOT_TOKEN не задан в env\", { status: 500 });\n }\n if (!ADMIN_ID) {\n return new Response(\"ADMIN_ID не задан в env\", { status: 500 });\n }\n\n const url = new URL(req.url);\n\n await ensureWebhook(BOT_TOKEN, req);\n\n if (req.method === \"GET\" && url.searchParams.get(\"setWebhook\") === \"1\") {\n const webhook = process.env.WEBHOOK_URL || (url.origin + url.pathname);\n const r = await fetch(\n apiUrl(BOT_TOKEN, \"setWebhook\") + \"?url=\" + encodeURIComponent(webhook),\n );\n const data = await r.text();\n return new Response(\n \"Webhook URL: \" + webhook + \"\\n\\nОтвет Telegram: \" + data,\n );\n }\n\n if (req.method === \"GET\") {\n const info = await fetch(apiUrl(BOT_TOKEN, \"getWebhookInfo\"))\n .then((r) => r.json()).catch(() => null);\n return new Response(\n \"Бот работает.\\nWebhook: \" + (info?.result?.url || \"(не установлен)\") +\n \"\\nWeb App URL: \" + WEB_APP_URL,\n );\n }\n\n if (req.method !== \"POST\") return new Response(\"OK\");\n\n let update;\n try {\n update = await req.json();\n } catch {\n return new Response(\"OK\");\n }\n\n try {\n await handle(update, { BOT_TOKEN, ADMIN_ID, WEB_APP_URL, BOT_NAME });\n } catch (e) {\n console.error(\"Ошибка обработки update:\", e);\n }\n return new Response(\"OK\");\n}\n\n/* ===================== ЛОГИКА БОТА ===================== */\nasync function handle(update, cfg) {\n const { BOT_TOKEN, ADMIN_ID, WEB_APP_URL, BOT_NAME } = cfg;\n\n /* ---------- Callback-кнопки ---------- */\n if (update.callback_query) {\n const cq = update.callback_query;\n const from = cq.from;\n await tg(BOT_TOKEN, \"answerCallbackQuery\", { callback_query_id: cq.id });\n\n if (from.id !== ADMIN_ID) return;\n\n if (cq.data === \"admin_panel\") {\n const users = await getUsers();\n const count = Object.keys(users).length;\n await send(\n BOT_TOKEN,\n from.id,\n `🛠 Панель администратора\\n\\nВсего пользователей: ${count}`,\n [\n [{\n text: `👥 Все пользователи (${count})`,\n callback_data: \"users_list\",\n }],\n [{ text: `📢 Рассылка`, callback_data: \"broadcast_menu\" }],\n ],\n );\n return;\n }\n\n if (cq.data === \"users_list\") {\n const users = await getUsers();\n const list = Object.values(users).sort((a, b) =>\n (a.added || 0) - (b.added || 0)\n );\n if (!list.length) {\n await send(BOT_TOKEN, from.id, \"Пока никто не пользовался ботом.\");\n return;\n }\n let text = `👥 Пользователи бота — ${list.length}\\n\\n`;\n list.forEach((u, i) => {\n text += `${i + 1}. ${userLine(u)}\\n\\n`;\n });\n\n if (text.length > 4000) {\n const chunks = [];\n let cur = \"\";\n for (const block of text.split(\"\\n\\n\")) {\n if ((cur + block).length > 3800) {\n chunks.push(cur);\n cur = \"\";\n }\n cur += block + \"\\n\\n\";\n }\n if (cur) chunks.push(cur);\n for (const chunk of chunks) await send(BOT_TOKEN, from.id, chunk);\n } else {\n await send(BOT_TOKEN, from.id, text);\n }\n return;\n }\n\n if (cq.data === \"broadcast_menu\") {\n await send(\n BOT_TOKEN,\n from.id,\n `📢 Рассылка\\n\\nВыберите тип рассылки:`,\n [\n [\n { text: \"✏️ Ручная\", callback_data: \"broadcast_manual\" },\n { text: \"⚡ Авто\", callback_data: \"broadcast_auto\" },\n ],\n [{ text: \"⬅️ Назад\", callback_data: \"admin_panel\" }],\n ],\n );\n return;\n }\n\n if (cq.data === \"broadcast_manual\") {\n await saveBroadcastState({ waiting_admin: from.id });\n await send(\n BOT_TOKEN,\n from.id,\n `✏️ Ручная рассылка\\n\\n` +\n `Отправьте текст следующим сообщением — он уйдёт всем пользователям бота.\\n\\n` +\n `Чтобы отменить — нажмите кнопку ниже или отправьте /cancel.`,\n [[{ text: \"❌ Отмена\", callback_data: \"broadcast_cancel\" }]],\n );\n return;\n }\n\n if (cq.data === \"broadcast_cancel\") {\n await saveBroadcastState({});\n await send(BOT_TOKEN, from.id, \"Рассылка отменена.\");\n return;\n }\n\n if (cq.data === \"broadcast_auto\") {\n const users = await getUsers();\n const ids = Object.keys(users);\n if (!ids.length) {\n await send(BOT_TOKEN, from.id, \"Пользователей пока нет.\");\n return;\n }\n await send(\n BOT_TOKEN,\n from.id,\n `⚡ Начинаю авто-рассылку для ${ids.length} пользователей…`,\n );\n\n const text = `🔄 Бот обновился!\\n\\n` +\n `Нажмите /start, чтобы обновить меню и продолжить работу с дневником.`;\n\n let sent = 0, failed = 0;\n for (const id of ids) {\n const r = await send(BOT_TOKEN, id, text);\n if (r && r.ok) sent++;\n else failed++;\n await sleep(50); // ~20 msg/sec, чтобы не словить лимит Telegram\n }\n await send(\n BOT_TOKEN,\n from.id,\n `✅ Готово\\n\\nОтправлено: ${sent}\\nНе доставлено: ${failed}`,\n );\n return;\n }\n\n return;\n }\n\n /* ---------- Обычные сообщения ---------- */\n const msg = update.message;\n if (!msg || !msg.from) return;\n\n const from = msg.from;\n const chatId = msg.chat.id;\n const text = msg.text || \"\";\n\n const users = await getUsers();\n const key = String(from.id);\n const isNew = !users[key];\n\n users[key] = {\n id: from.id,\n first_name: from.first_name || \"\",\n last_name: from.last_name || \"\",\n username: from.username || \"\",\n added: users[key]?.added || Date.now(),\n };\n await saveUsers(users);\n\n if (isNew && from.id !== ADMIN_ID) {\n await send(\n BOT_TOKEN,\n ADMIN_ID,\n `🆕 Новый пользователь\\n\\n${userLine(users[key])}`,\n );\n }\n\n /* Проверяем, ждём ли мы от админа текст для ручной рассылки */\n const bs = await getBroadcastState();\n if (bs.waiting_admin === from.id) {\n // Если это команда — отменяем рассылку и обрабатываем команду дальше\n if (text === \"/cancel\") {\n await saveBroadcastState({});\n await send(BOT_TOKEN, chatId, \"Рассылка отменена.\");\n return;\n }\n if (text.startsWith(\"/\")) {\n await saveBroadcastState({});\n // не возвращаемся — дадим команде обработаться ниже\n } else {\n // Это текст для рассылки\n await saveBroadcastState({});\n\n const ids = Object.keys(users);\n if (!ids.length) {\n await send(BOT_TOKEN, chatId, \"Пользователей пока нет.\");\n return;\n }\n await send(\n BOT_TOKEN,\n chatId,\n `✏️ Начинаю рассылку для ${ids.length} пользователей…`,\n );\n\n let sent = 0, failed = 0;\n for (const id of ids) {\n const r = await send(BOT_TOKEN, id, text);\n if (r && r.ok) sent++;\n else failed++;\n await sleep(50);\n }\n await send(\n BOT_TOKEN,\n chatId,\n `✅ Готово\\n\\nОтправлено: ${sent}\\nНе доставлено: ${failed}`,\n );\n return;\n }\n }\n\n if (text.startsWith(\"/start\")) {\n await send(\n BOT_TOKEN,\n chatId,\n `Привет, ${esc(from.first_name || \"друг\")}! 👋\\n\\n` +\n `Это бот ${\n esc(BOT_NAME)\n }. Нажми на кнопку ниже, чтобы открыть дневник 👇`,\n menuKeyboard(WEB_APP_URL),\n );\n return;\n }\n\n if (text === \"/admin\") {\n if (from.id !== ADMIN_ID) {\n await send(BOT_TOKEN, chatId, \"Доступ запрещён.\");\n return;\n }\n const count = Object.keys(users).length;\n await send(\n BOT_TOKEN,\n chatId,\n `🛠 Панель администратора\\n\\nВсего пользователей: ${count}`,\n [\n [{\n text: `👥 Все пользователи (${count})`,\n callback_data: \"users_list\",\n }],\n [{ text: `📢 Рассылка`, callback_data: \"broadcast_menu\" }],\n ],\n );\n return;\n }\n\n await send(\n BOT_TOKEN,\n chatId,\n \"Нажми на кнопку ниже 👇\",\n menuKeyboard(WEB_APP_URL),\n );\n}","deleted",false,"label",[14],"4303ce7f-ee4f-4cec-a4dc-304c38c562ed",["D",1789294172172],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","75c74a35-f63f-4364-86a0-619436fc8b56","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8156-70bb-7444-a99c-191ee2a95e63","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_101":97},"org",{"_9":10,"_94":95,"_96":97,"_55":56,"_98":99,"_100":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Эльдар","avatar","https://lh3.googleusercontent.com/a/ACg8ocJdctuUMupnroZ9VQYY7hdioaiyckuWtRYjbMrlA7zHrIBrw4KU=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_135":136,"_137":138,"_139":140,"_141":42,"_142":42,"_143":42,"_144":32,"_145":-5,"_146":-7,"_147":-7,"_148":62,"_149":42,"_150":42,"_151":-5,"_152":42,"_153":42,"_154":42,"_155":-5},"ENV",{"_106":107,"_108":109,"_110":85,"_111":112,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]