[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":53,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":58,"_121":-5,"_122":-5,"_123":124},"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":31,"_57":58,"_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":25},"version",4,"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","main.ts","latestPath","fileId","36d647b2-af5b-11f1-951b-1607ee4eb77e","name","fileType","http","content","// Learn more: https://docs.val.town/vals/http/\nexport default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}","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}","createdAt",["D",1789294208688],"branchVersion","branchId","839d65fb-ce61-4321-be54-2a03e5bff27f","id","4303ce7f-ee4f-4cec-a4dc-304c38c562ed","Dnevnik",["D",1789294172172],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","75c74a35-f63f-4364-86a0-619436fc8b56","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8156-70bb-7444-a99c-191ee2a95e63","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","eldarjzj","handle","displayName","Эльдар","avatar","https://lh3.googleusercontent.com/a/ACg8ocJdctuUMupnroZ9VQYY7hdioaiyckuWtRYjbMrlA7zHrIBrw4KU=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":149,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_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":150,"_80":151,"_82":152,"_84":25},"tree",[144],"files",[144],"counts",{"_133":62,"_134":135,"_136":62,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":58,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"71001227-7164-4cf7-bcc1-a1a539d32b23","parentId","latest",["D",1789294208688],3,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":130,"_143":62},"connections",{"_141":62,"_142":62},"count","unfilledCount","emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":58,"_38":145,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_146":147,"_27":148},["D",1789294208688],"children",[],[28],["D",1789294172172],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_78":-5,"_122":186,"_187":188,"_189":190,"_191":25,"_192":25,"_193":25,"_194":58,"_195":-5,"_196":-7,"_197":-7,"_198":62,"_199":25,"_200":25,"_201":-5,"_202":25,"_203":25,"_204":25,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":85,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v4