[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_120":-5,"_20":121,"_22":122,"_123":124,"_125":126,"_26":127,"_24":128,"_129":-5,"_130":-5,"_131":52,"_132":133,"_134":43,"_135":-5,"_136":-5,"_137":138},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","SkylineXd","name","Special","branchName","main","version","path","main.ts","project",{"_33":60,"_13":14,"_44":61,"_62":-5,"_63":52,"_64":65,"_66":65,"_67":68,"_69":70,"_71":72,"_73":36,"_74":43,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":86,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":98,"_99":100,"_101":102,"_103":52},"tree",[55],"file",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":54},"contents",[],"upstream","pull","ahead","behind","envVars","id","0ad12b95-9ef3-4788-9f31-9ae1350a5c2b","fileId","5b52b030-b037-11f1-be7e-1607ee4eb77e","parentId","branchId","b7127562-9699-468e-b928-8d2bb16b7109","branchVersion",24,"latest",true,"createdAt",["D",1789452504597],23,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n\nif (!TOKEN) {\n throw new Error(\"TELEGRAM_BOT_TOKEN is not configured\");\n}\n\nconst API = `https://api.telegram.org/bot${TOKEN}`;\nconst BOT_USERNAME = \"Special_Mafiabot\";\n\nconst MIN_PLAYERS = 4;\nconst MAX_PLAYERS = 20;\n\ntype Phase =\n | \"registration\"\n | \"starting\"\n | \"night\"\n | \"day\"\n | \"voting\"\n | \"voting_confirm\"\n | \"kamikaze_lynch\"\n | \"finished\";\n\ntype Role =\n | \"don\"\n | \"mafia\"\n | \"doctor\"\n | \"commissioner\"\n | \"jester\"\n | \"suicide\"\n | \"kamikaze\"\n | \"bum\"\n | \"lover\"\n | \"sergeant\"\n | \"maniac\"\n | \"lawyer\"\n | \"peaceful\";\n\ntype Player = {\n id: number;\n chatId: number;\n firstName: string;\n lastName: string;\n username: string;\n role: Role | null;\n alive: boolean;\n doctorSelfHealUsed: boolean;\n blockedUntil: number;\n protectedUntil: number;\n};\n\ntype Game = {\n chatId: number;\n creatorId: number;\n phase: Phase;\n round: number;\n phaseEndsAt: number;\n lynchTarget: number | null;\n kamikazeId: number | null;\n};\n\nconst ROLE_NAMES: Record = {\n don: \"🤵🏻 Дон\",\n mafia: \"🤵🏼 Мафия\",\n doctor: \"👨🏼‍⚕️ Доктор\",\n commissioner: \"🕵️‍ Комиссар Каттани\",\n jester: \"🃏 Шут\",\n suicide: \"🤦🏼‍♂️ Самоубийца\",\n kamikaze: \"💣 Камикадзе\",\n bum: \"🧙🏼‍♂️ Бомж\",\n lover: \"💃🏼 Любовница\",\n sergeant: \"👮🏼‍♂️ Сержант\",\n maniac: \"🔪 Маньяк\",\n lawyer: \"👨🏼‍💼 Адвокат\",\n peaceful: \"👨🏼 Мирный житель\",\n};\n\nconst ROLE_DESCRIPTIONS: Record = {\n don:\n \"Ты главный в мафии. Ночью принимаешь финальное решение о жертве.\",\n\n mafia:\n \"Ты член мафии. Ночью предлагай жертву Дону.\",\n\n doctor:\n \"Ночью можешь лечить одного игрока. Один раз за игру можешь вылечить себя.\",\n\n commissioner:\n \"Ночью можешь проверить игрока или выйти на охоту.\",\n\n jester:\n \"Ты Шут. Твоя особая цель связана с дневным голосованием.\",\n\n suicide:\n \"Ты Самоубийца. Твоя особая механика связана с дневным голосованием.\",\n\n kamikaze:\n \"Если тебя убивают ночью, можешь забрать убийцу при выполнении условий. Если тебя линчуют — выбираешь, кого забрать с собой.\",\n\n bum:\n \"Ночью можешь выбрать игрока и узнать, кто его посещал.\",\n\n lover:\n \"Ночью можешь посетить игрока и заблокировать его ночное действие. Также блокируешь его участие в следующем голосовании.\",\n\n sergeant:\n \"После смерти Комиссара становишься новым Комиссаром.\",\n\n maniac:\n \"Ночью можешь убить выбранного игрока.\",\n\n lawyer:\n \"Ночью можешь защитить игрока от проверки Комиссара.\",\n\n peaceful:\n \"Ты мирный житель. Найди мафию и помоги городу победить.\",\n};\n\nlet dbReady: Promise | null = null;\n\nfunction ensureDb() {\n if (!dbReady) {\n dbReady = initDb();\n }\n\n return dbReady;\n}\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_games_v4 (\n chat_id INTEGER PRIMARY KEY,\n creator_id INTEGER NOT NULL,\n phase TEXT NOT NULL,\n round INTEGER NOT NULL DEFAULT 0,\n phase_ends_at INTEGER NOT NULL DEFAULT 0,\n lynch_target INTEGER,\n kamikaze_id INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_players_v4 (\n chat_id INTEGER NOT NULL,\n user_id INTEGER NOT NULL,\n first_name TEXT NOT NULL DEFAULT '',\n last_name TEXT NOT NULL DEFAULT '',\n username TEXT NOT NULL DEFAULT '',\n role TEXT,\n alive INTEGER NOT NULL DEFAULT 1,\n doctor_self_heal_used INTEGER NOT NULL DEFAULT 0,\n blocked_until INTEGER NOT NULL DEFAULT 0,\n protected_until INTEGER NOT NULL DEFAULT 0,\n PRIMARY KEY(chat_id, user_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_night_v4 (\n chat_id INTEGER NOT NULL,\n round INTEGER NOT NULL,\n actor_id INTEGER NOT NULL,\n action TEXT NOT NULL,\n target_id INTEGER,\n PRIMARY KEY(chat_id, round, actor_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_votes_v4 (\n chat_id INTEGER NOT NULL,\n round INTEGER NOT NULL,\n voter_id INTEGER NOT NULL,\n target_id INTEGER NOT NULL,\n PRIMARY KEY(chat_id, round, voter_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_confirm_v4 (\n chat_id INTEGER NOT NULL,\n round INTEGER NOT NULL,\n voter_id INTEGER NOT NULL,\n vote TEXT NOT NULL,\n PRIMARY KEY(chat_id, round, voter_id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS mafia_profiles_v4 (\n user_id INTEGER PRIMARY KEY,\n money INTEGER NOT NULL DEFAULT 0,\n protection INTEGER NOT NULL DEFAULT 0,\n documents INTEGER NOT NULL DEFAULT 0\n )\n `);\n}\n\nasync function tg(method: string, body: Record = {}) {\n const res = await fetch(`${API}/${method}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n\n const json = await res.json();\n\n if (!json.ok) {\n console.error(\"Telegram API error:\", method, json);\n }\n\n return json;\n}\n\nfunction now() {\n return Date.now();\n}\n\nfunction esc(value: string) {\n return value\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\");\n}\n\nfunction nameOf(p: Player) {\n const name =\n `${p.firstName}${p.lastName ? \" \" + p.lastName : \"\"}`.trim();\n\n return name || \"Игрок\";\n}\n\nfunction linkOf(p: Player) {\n const name = esc(nameOf(p));\n\n if (p.username) {\n return `${name}`;\n }\n\n return `${name}`;\n}\n\nfunction encodeChatId(id: number) {\n return String(id).replace(\"-\", \"m\");\n}\n\nfunction decodeChatId(value: string) {\n return Number(\n value.startsWith(\"m\")\n ? \"-\" + value.slice(1)\n : value,\n );\n}\n\nfunction botUrl(payload?: string) {\n return payload\n ? `https://t.me/${BOT_USERNAME}?start=${payload}`\n : `https://t.me/${BOT_USERNAME}`;\n}\n\nfunction dmKeyboard() {\n return {\n inline_keyboard: [\n [\n {\n text: \"перейти в бота\",\n url: botUrl(),\n },\n ],\n ],\n };\n}\nasync function getGame(chatId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM mafia_games_v4 WHERE chat_id = ?`,\n [chatId],\n );\n\n if (!result.rows?.length) {\n return null;\n }\n\n const r: any = result.rows[0];\n\n return {\n chatId: Number(r.chat_id),\n creatorId: Number(r.creator_id),\n phase: r.phase as Phase,\n round: Number(r.round),\n phaseEndsAt: Number(r.phase_ends_at),\n lynchTarget:\n r.lynch_target == null\n ? null\n : Number(r.lynch_target),\n kamikazeId:\n r.kamikaze_id == null\n ? null\n : Number(r.kamikaze_id),\n };\n}\n\nasync function getPlayers(chatId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM mafia_players_v4\n WHERE chat_id = ?\n ORDER BY rowid`,\n [chatId],\n );\n\n return (result.rows || []).map((r: any) => ({\n id: Number(r.user_id),\n chatId: Number(r.chat_id),\n firstName: r.first_name || \"\",\n lastName: r.last_name || \"\",\n username: r.username || \"\",\n role: r.role || null,\n alive: Boolean(r.alive),\n doctorSelfHealUsed:\n Boolean(r.doctor_self_heal_used),\n blockedUntil: Number(r.blocked_until || 0),\n protectedUntil: Number(r.protected_until || 0),\n }));\n}\n\nasync function getPlayer(\n chatId: number,\n userId: number,\n) {\n const players = await getPlayers(chatId);\n\n return (\n players.find((p) => p.id === userId) ||\n null\n );\n}\n\nasync function createLobby(\n chatId: number,\n creator: any,\n) {\n await sqlite.execute(\n `DELETE FROM mafia_players_v4\n WHERE chat_id = ?`,\n [chatId],\n );\n\n await sqlite.execute(\n `DELETE FROM mafia_games_v4\n WHERE chat_id = ?`,\n [chatId],\n );\n\n await sqlite.execute(\n `INSERT INTO mafia_games_v4\n (chat_id, creator_id, phase, round, phase_ends_at)\n VALUES (?, ?, 'registration', 0, ?)`,\n [\n chatId,\n Number(creator.id),\n now() + 15 * 60 * 1000,\n ],\n );\n\n await addPlayer(chatId, creator);\n}\n\nasync function addPlayer(\n chatId: number,\n user: any,\n) {\n const existing = await getPlayer(\n chatId,\n Number(user.id),\n );\n\n if (existing) {\n return false;\n }\n\n const players = await getPlayers(chatId);\n\n if (players.length >= MAX_PLAYERS) {\n return false;\n }\n\n await sqlite.execute(\n `INSERT INTO mafia_players_v4\n (\n chat_id,\n user_id,\n first_name,\n last_name,\n username,\n role,\n alive\n )\n VALUES (?, ?, ?, ?, ?, NULL, 1)`,\n [\n chatId,\n Number(user.id),\n user.first_name || \"\",\n user.last_name || \"\",\n user.username || \"\",\n ],\n );\n\n return true;\n}\n\nfunction lobbyText(players: Player[]) {\n const list = players.length\n ? players\n .map((p) => `🤵🏻 ${linkOf(p)}`)\n .join(\"\\n\")\n : \"Пока никто не присоединился.\";\n\n return [\n \"Ведётся набор в игру\",\n \"\",\n \"Зарегистрировались::\",\n \"\",\n list,\n \"\",\n `Итого ${players.length} чел.`,\n ].join(\"\\n\");\n}\n\nfunction lobbyKeyboard(chatId: number) {\n return {\n inline_keyboard: [\n [\n {\n text: \"🤵🏻 Присоединиться\",\n url: botUrl(\n `join_${encodeChatId(chatId)}`,\n ),\n },\n ],\n ],\n };\n}\n\nasync function sendLobby(chatId: number) {\n const game = await getGame(chatId);\n\n if (!game || game.phase !== \"registration\") {\n return;\n }\n\n const players = await getPlayers(chatId);\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text: lobbyText(players),\n parse_mode: \"HTML\",\n reply_markup: lobbyKeyboard(chatId),\n });\n}\n\nfunction shuffle(items: T[]): T[] {\n const result = [...items];\n\n for (let i = result.length - 1; i > 0; i--) {\n const j = Math.floor(\n Math.random() * (i + 1),\n );\n\n [result[i], result[j]] =\n [result[j], result[i]];\n }\n\n return result;\n}\n\nfunction makeRoles(count: number): Role[] {\n const roles: Role[] = [];\n\n // Дон не считается в количестве обычной мафии.\n roles.push(\"don\");\n\n let mafia = 0;\n\n if (count >= 6 && count <= 8) {\n mafia = 1;\n } else if (count >= 9 && count <= 11) {\n mafia = 2;\n } else if (count >= 12 && count <= 14) {\n mafia = 3;\n } else if (count >= 15 && count <= 17) {\n mafia = 4;\n } else if (count >= 18) {\n mafia = 5;\n }\n\n for (let i = 0; i < mafia; i++) {\n roles.push(\"mafia\");\n }\n\n if (count >= 4) roles.push(\"doctor\");\n if (count >= 6) roles.push(\"commissioner\");\n if (count >= 7) roles.push(\"jester\");\n if (count >= 8) roles.push(\"suicide\");\n if (count >= 9) roles.push(\"kamikaze\");\n if (count >= 10) roles.push(\"bum\");\n if (count >= 11) roles.push(\"lover\");\n if (count >= 14) roles.push(\"sergeant\");\n if (count >= 16) roles.push(\"maniac\");\n if (count >= 18) roles.push(\"lawyer\");\n\n while (roles.length < count) {\n roles.push(\"peaceful\");\n }\n\n return roles;\n}\n\nasync function startGame(chatId: number) {\n const game = await getGame(chatId);\n\n if (!game || game.phase !== \"registration\") {\n return;\n }\n\n const players = await getPlayers(chatId);\n\n if (players.length < MIN_PLAYERS) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `Недостаточно игроков.\\n` +\n `Нужно минимум ${MIN_PLAYERS}.`,\n });\n\n return;\n }\n\n const roles = shuffle(\n makeRoles(players.length),\n );\n\n for (let i = 0; i < players.length; i++) {\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET role = ?, alive = 1\n WHERE chat_id = ? AND user_id = ?`,\n [\n roles[i],\n chatId,\n players[i].id,\n ],\n );\n }\n\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'starting',\n round = 0,\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n now() + 8_000,\n chatId,\n ],\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Игра начинается!\\n\\n\" +\n \"В течение нескольких секунд бот пришлёт вам личное сообщение с ролью и её описанием.\",\n });\n\n const updated = await getPlayers(chatId);\n\n for (const player of updated) {\n await tg(\"sendMessage\", {\n chat_id: player.id,\n text:\n `${ROLE_NAMES[player.role!]}\\n\\n` +\n ROLE_DESCRIPTIONS[player.role!],\n });\n }\n\n scheduleRecovery(chatId);\n}\n\nasync function joinGame(\n chatId: number,\n user: any,\n) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"registration\"\n ) {\n await tg(\"sendMessage\", {\n chat_id: Number(user.id),\n text:\n \"Сейчас нет открытого набора в игру.\",\n });\n\n return;\n }\n\n const players = await getPlayers(chatId);\n\n if (players.length >= MAX_PLAYERS) {\n await tg(\"sendMessage\", {\n chat_id: Number(user.id),\n text:\n \"В игре уже максимальное количество игроков — 20.\",\n });\n\n return;\n }\n\n if (\n players.some(\n (p) => p.id === Number(user.id),\n )\n ) {\n await tg(\"sendMessage\", {\n chat_id: Number(user.id),\n text:\n \"Ты уже присоединился к этой игре.\",\n });\n\n return;\n }\n\n await addPlayer(chatId, user);\n\n await tg(\"sendMessage\", {\n chat_id: Number(user.id),\n text:\n \"Ты присоединился к игре 🤵🏻\",\n });\n\n await sendLobby(chatId);\n}\nasync function saveNight(\n chatId: number,\n round: number,\n actorId: number,\n action: string,\n targetId: number | null,\n) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO mafia_night_v4\n (chat_id, round, actor_id, action, target_id)\n VALUES (?, ?, ?, ?, ?)`,\n [\n chatId,\n round,\n actorId,\n action,\n targetId,\n ],\n );\n}\n\nasync function getNight(\n chatId: number,\n round: number,\n) {\n const result = await sqlite.execute(\n `SELECT * FROM mafia_night_v4\n WHERE chat_id = ? AND round = ?`,\n [chatId, round],\n );\n\n return result.rows || [];\n}\n\nasync function startNight(chatId: number) {\n const game = await getGame(chatId);\n\n if (!game || game.phase === \"finished\") {\n return;\n }\n\n const round = game.round + 1;\n\n await sqlite.execute(\n `DELETE FROM mafia_night_v4\n WHERE chat_id = ? AND round = ?`,\n [chatId, round],\n );\n\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET blocked_until = 0,\n protected_until = 0\n WHERE chat_id = ?`,\n [chatId],\n );\n\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'night',\n round = ?,\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n round,\n now() + 90_000,\n chatId,\n ],\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"🌃 Наступает ночь \\n\" +\n \"На улицы города выходят лишь самые отважные и бесстрашные. Утром попробуем сосчитать их головы...\",\n reply_markup: dmKeyboard(),\n });\n\n const players = await getPlayers(chatId);\n\n for (const p of players.filter(\n (x) => x.alive,\n )) {\n if (\n [\n \"don\",\n \"mafia\",\n \"doctor\",\n \"commissioner\",\n \"bum\",\n \"lover\",\n \"maniac\",\n \"lawyer\",\n ].includes(p.role || \"\")\n ) {\n await sendNightMenu(\n chatId,\n round,\n p,\n );\n }\n }\n\n scheduleRecovery(chatId);\n}\n\nasync function sendNightMenu(\n chatId: number,\n round: number,\n actor: Player,\n) {\n const players = (await getPlayers(chatId))\n .filter(\n (p) =>\n p.alive &&\n p.id !== actor.id,\n );\n\n const buttons: any[][] = [];\n\n if (actor.role === \"commissioner\") {\n buttons.push([\n {\n text: \"🕵️ Проверить\",\n callback_data:\n `c|${encodeChatId(chatId)}|${round}|${actor.id}|check`,\n },\n {\n text: \"🔫 Убить\",\n callback_data:\n `c|${encodeChatId(chatId)}|${round}|${actor.id}|kill`,\n },\n ]);\n }\n\n if (\n actor.role === \"doctor\" &&\n !actor.doctorSelfHealUsed\n ) {\n buttons.push([\n {\n text: \"❤️ Вылечить себя\",\n callback_data:\n `n|${encodeChatId(chatId)}|${round}|${actor.id}|${actor.id}`,\n },\n ]);\n }\n\n for (const target of players) {\n buttons.push([\n {\n text: nameOf(target),\n callback_data:\n `n|${encodeChatId(chatId)}|${round}|${actor.id}|${target.id}`,\n },\n ]);\n }\n\n await tg(\"sendMessage\", {\n chat_id: actor.id,\n text:\n `🌃 Ночь ${round}\\n\\n` +\n \"Выбери действие:\",\n reply_markup: {\n inline_keyboard: buttons,\n },\n });\n}\n\nasync function processNightAction(\n chatId: number,\n round: number,\n actorId: number,\n targetId: number,\n) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"night\" ||\n game.round !== round\n ) {\n return;\n }\n\n const actor = await getPlayer(\n chatId,\n actorId,\n );\n\n const target = await getPlayer(\n chatId,\n targetId,\n );\n\n if (\n !actor ||\n !target ||\n !actor.alive ||\n !target.alive\n ) {\n return;\n }\n\n let menuAction: string | null = null;\n\n const previous = await sqlite.execute(\n `SELECT action FROM mafia_night_v4\n WHERE chat_id = ? AND round = ? AND actor_id = ?`,\n [\n chatId,\n round,\n actorId,\n ],\n );\n\n if (previous.rows?.length) {\n menuAction =\n String(\n (previous.rows[0] as any).action,\n );\n }\n\n let action = \"kill\";\n\n if (\n actor.role === \"doctor\"\n ) {\n action = \"heal\";\n } else if (\n actor.role === \"lover\"\n ) {\n action = \"block\";\n } else if (\n actor.role === \"bum\"\n ) {\n action = \"visit\";\n } else if (\n actor.role === \"lawyer\"\n ) {\n action = \"protect\";\n } else if (\n actor.role === \"commissioner\"\n ) {\n if (\n menuAction === \"commissioner_check\"\n ) {\n action = \"check\";\n } else if (\n menuAction === \"commissioner_kill\"\n ) {\n action = \"kill\";\n } else {\n return;\n }\n }\n\n if (\n actor.role === \"doctor\" &&\n target.id === actor.id\n ) {\n if (actor.doctorSelfHealUsed) {\n return;\n }\n\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET doctor_self_heal_used = 1\n WHERE chat_id = ? AND user_id = ?`,\n [\n chatId,\n actorId,\n ],\n );\n }\n\n await saveNight(\n chatId,\n round,\n actorId,\n action,\n targetId,\n );\n\n await tg(\"sendMessage\", {\n chat_id: actorId,\n text:\n `Выбрано: ${nameOf(target)}`,\n });\n\n await maybeResolveNight(chatId, round);\n}\n\nasync function maybeResolveNight(\n chatId: number,\n round: number,\n) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"night\" ||\n game.round !== round\n ) {\n return;\n }\n\n const alive = (await getPlayers(chatId))\n .filter((p) => p.alive);\n\n const required = alive.filter((p) =>\n [\n \"don\",\n \"mafia\",\n \"doctor\",\n \"commissioner\",\n \"bum\",\n \"lover\",\n \"maniac\",\n \"lawyer\",\n ].includes(p.role || \"\"),\n );\n\n const actions = await getNight(\n chatId,\n round,\n );\n\n const done = required.every((p) =>\n actions.some(\n (a: any) =>\n Number(a.actor_id) === p.id &&\n a.target_id != null,\n ),\n );\n\n if (done) {\n await resolveNight(chatId);\n }\n}\n\nasync function resolveNight(chatId: number) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"night\"\n ) {\n return;\n }\n\n const players = await getPlayers(chatId);\n const alive = players.filter(\n (p) => p.alive,\n );\n\n const actions = await getNight(\n chatId,\n game.round,\n );\n\n let victim: Player | null = null;\n\n // Дон принимает финальное решение.\n const don = alive.find(\n (p) => p.role === \"don\",\n );\n\n if (don) {\n const action = actions.find(\n (a: any) =>\n Number(a.actor_id) === don.id &&\n a.action === \"kill\",\n );\n\n if (action) {\n victim =\n players.find(\n (p) =>\n p.id ===\n Number(action.target_id),\n ) || null;\n }\n }\n\n // Если Дона нет — используется предложение мафии.\n if (!victim) {\n const mafiaAction =\n actions.find(\n (a: any) =>\n players.some(\n (p) =>\n p.id ===\n Number(a.actor_id) &&\n p.alive &&\n p.role === \"mafia\",\n ) &&\n a.action === \"kill\",\n );\n\n if (mafiaAction) {\n victim =\n players.find(\n (p) =>\n p.id ===\n Number(mafiaAction.target_id),\n ) || null;\n }\n }\n\n // Маньяк.\n const maniac = alive.find(\n (p) => p.role === \"maniac\",\n );\n\n const maniacAction =\n actions.find(\n (a: any) =>\n maniac &&\n Number(a.actor_id) === maniac.id &&\n a.action === \"kill\",\n );\n\n // Доктор.\n const doctor = alive.find(\n (p) => p.role === \"doctor\",\n );\n\n const healAction =\n actions.find(\n (a: any) =>\n doctor &&\n Number(a.actor_id) === doctor.id &&\n a.action === \"heal\",\n );\n\n const healedId =\n healAction?.target_id == null\n ? null\n : Number(healAction.target_id);\n\n // Защита адвоката.\n const lawyer = alive.find(\n (p) => p.role === \"lawyer\",\n );\n\n const lawyerAction =\n actions.find(\n (a: any) =>\n lawyer &&\n Number(a.actor_id) === lawyer.id &&\n a.action === \"protect\",\n );\n\n const protectedId =\n lawyerAction?.target_id == null\n ? null\n : Number(lawyerAction.target_id);\n\n // Маньяк может создать вторую жертву.\n const victims = new Set();\n\n if (\n victim &&\n victim.id !== healedId &&\n victim.id !== protectedId\n ) {\n victims.add(victim.id);\n }\n\n if (\n maniacAction &&\n maniacAction.target_id != null\n ) {\n const id = Number(\n maniacAction.target_id,\n );\n\n if (\n id !== healedId &&\n id !== protectedId\n ) {\n victims.add(id);\n }\n }\n\n // Любовница.\n const lover = alive.find(\n (p) => p.role === \"lover\",\n );\n\n const loverAction =\n actions.find(\n (a: any) =>\n lover &&\n Number(a.actor_id) === lover.id &&\n a.action === \"block\",\n );\n\n if (\n loverAction &&\n loverAction.target_id != null\n ) {\n const blockedId = Number(\n loverAction.target_id,\n );\n\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET blocked_until = ?\n WHERE chat_id = ? AND user_id = ?`,\n [\n now() + 24 * 60 * 60 * 1000,\n chatId,\n blockedId,\n ],\n );\n\n victims.delete(blockedId);\n }\n\n // Убиваем.\n for (const id of victims) {\n await killPlayer(\n chatId,\n id,\n \"night\",\n );\n }\n\n // Камikадзе.\n for (const id of victims) {\n const dead = players.find(\n (p) => p.id === id,\n );\n\n if (\n dead?.role === \"kamikaze\"\n ) {\n const killer =\n victim &&\n victim.id === id\n ? don\n : maniac;\n\n if (\n killer &&\n killer.alive &&\n killer.id !== healedId\n ) {\n await killPlayer(\n chatId,\n killer.id,\n \"night\",\n );\n }\n }\n }\n\n await promoteSergeant(chatId);\n await promoteDon(chatId);\n\n const deadPlayers =\n (await getPlayers(chatId))\n .filter(\n (p) =>\n !p.alive &&\n victims.has(p.id),\n );\n\n if (!deadPlayers.length) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"🤷 Удивительно, но этой ночью все выжили\",\n });\n } else {\n for (const dead of deadPlayers) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `Сегодня был жестоко убит ${nameOf(dead)}!`,\n });\n\n await tg(\"sendMessage\", {\n chat_id: dead.id,\n text:\n \"Тебя убили :(\\n\" +\n \"Ты можешь отправить сюда своё предсмертное сообщение\",\n });\n }\n }\n\n if (\n doctor &&\n healedId === doctor.id &&\n !victims.has(doctor.id)\n ) {\n await tg(\"sendMessage\", {\n chat_id: doctor.id,\n text:\n \"Бинты, скальпель и ножницы не пригодились... И хорошо!\",\n });\n }\n\n await checkVictory(chatId);\n\n const current = await getGame(chatId);\n\n if (\n !current ||\n current.phase === \"finished\"\n ) {\n return;\n }\n\n await startDay(chatId);\n}\n\nasync function killPlayer(\n chatId: number,\n userId: number,\n reason: \"night\" | \"lynch\",\n) {\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET alive = 0\n WHERE chat_id = ? AND user_id = ?`,\n [chatId, userId],\n );\n\n // При дневном линчевании специальное сообщение в ЛС не отправляем.\n if (reason === \"lynch\") {\n return;\n }\n}\n\nasync function promoteDon(chatId: number) {\n const players = await getPlayers(chatId);\n\n const don = players.find(\n (p) =>\n p.alive &&\n p.role === \"don\",\n );\n\n if (don) return;\n\n const mafia = players.filter(\n (p) =>\n p.alive &&\n p.role === \"mafia\",\n );\n\n if (!mafia.length) return;\n\n const newDon =\n mafia[\n Math.floor(\n Math.random() * mafia.length,\n )\n ];\n\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET role = 'don'\n WHERE chat_id = ? AND user_id = ?`,\n [chatId, newDon.id],\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `${nameOf(newDon)} - новый 🤵🏻 Дон`,\n });\n\n await tg(\"sendMessage\", {\n chat_id: newDon.id,\n text:\n \"Ты стал новым 🤵🏻 Доном.\",\n });\n}\n\nasync function promoteSergeant(\n chatId: number,\n) {\n const players = await getPlayers(chatId);\n\n const commissioner = players.find(\n (p) =>\n p.alive &&\n p.role === \"commissioner\",\n );\n\n if (commissioner) return;\n\n const sergeant = players.find(\n (p) =>\n p.alive &&\n p.role === \"sergeant\",\n );\n\n if (!sergeant) return;\n\n await sqlite.execute(\n `UPDATE mafia_players_v4\n SET role = 'commissioner'\n WHERE chat_id = ? AND user_id = ?`,\n [chatId, sergeant.id],\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `${nameOf(sergeant)} стал новым 🕵️‍ Комиссаром Каттани.`,\n });\n\n await tg(\"sendMessage\", {\n chat_id: sergeant.id,\n text:\n \"Ты стал 🕵️‍ Комиссаром Каттани.\",\n });\n}\nasync function startDay(chatId: number) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase === \"finished\"\n ) {\n return;\n }\n\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'day',\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n now() + 60_000,\n chatId,\n ],\n );\n\n const alive =\n (await getPlayers(chatId))\n .filter((p) => p.alive);\n\n const list = alive.length\n ? alive\n .map((p) => `• ${linkOf(p)}`)\n .join(\"\\n\")\n : \"Никого не осталось.\";\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `🏙 День ${game.round}\\n` +\n \"Солнце всходит, подсушивая на тротуарах пролитой ночью крови...\\n\\n\" +\n \"Живые игроки:\\n\" +\n list,\n parse_mode: \"HTML\",\n reply_markup: dmKeyboard(),\n });\n\n scheduleRecovery(chatId);\n}\n\nasync function startVoting(chatId: number) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase === \"finished\"\n ) {\n return;\n }\n\n await sqlite.execute(\n `DELETE FROM mafia_votes_v4\n WHERE chat_id = ? AND round = ?`,\n [chatId, game.round],\n );\n\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'voting',\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n now() + 45_000,\n chatId,\n ],\n );\n\n const alive =\n (await getPlayers(chatId))\n .filter((p) => p.alive);\n\n for (const voter of alive) {\n if (\n voter.blockedUntil > now()\n ) {\n await tg(\"sendMessage\", {\n chat_id: voter.id,\n text:\n \"Ты не можешь голосовать — Любовница заблокировала тебя.\",\n });\n\n continue;\n }\n\n const targets =\n alive.filter(\n (p) =>\n p.id !== voter.id,\n );\n\n const buttons = targets.map(\n (target) => [\n {\n text: nameOf(target),\n callback_data:\n `v|${encodeChatId(chatId)}|${game.round}|${voter.id}|${target.id}`,\n },\n ],\n );\n\n await tg(\"sendMessage\", {\n chat_id: voter.id,\n text:\n \"Пришло время искать виноватых!\\n\" +\n \"Кого ты хочешь линчевать?\",\n reply_markup: {\n inline_keyboard: buttons,\n },\n });\n }\n\n scheduleRecovery(chatId);\n}\n\nasync function saveVote(\n chatId: number,\n round: number,\n voterId: number,\n targetId: number,\n) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO mafia_votes_v4\n (chat_id, round, voter_id, target_id)\n VALUES (?, ?, ?, ?)`,\n [\n chatId,\n round,\n voterId,\n targetId,\n ],\n );\n}\n\nasync function resolveVoting(chatId: number) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"voting\"\n ) {\n return;\n }\n\n const result = await sqlite.execute(\n `SELECT target_id, COUNT(*) AS cnt\n FROM mafia_votes_v4\n WHERE chat_id = ? AND round = ?\n GROUP BY target_id\n ORDER BY cnt DESC`,\n [\n chatId,\n game.round,\n ],\n );\n\n const rows = result.rows || [];\n\n if (!rows.length) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Мнения жителей разошлись (0 👍 | 0 👎 )...\\n\" +\n \"Разошлись и сами жители, так никого и не повесив...\",\n });\n\n await startNight(chatId);\n return;\n }\n\n const highest =\n Number((rows[0] as any).cnt);\n\n const winners = rows.filter(\n (r: any) =>\n Number(r.cnt) === highest,\n );\n\n if (winners.length !== 1) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Мнения жителей разошлись (0 👍 | 0 👎 )...\\n\" +\n \"Разошлись и сами жители, так никого и не повесив...\",\n });\n\n await startNight(chatId);\n return;\n }\n\n const targetId =\n Number(\n (winners[0] as any).target_id,\n );\n\n const target =\n (await getPlayers(chatId))\n .find(\n (p) => p.id === targetId,\n );\n\n if (!target) {\n await startNight(chatId);\n return;\n }\n\n await sqlite.execute(\n `DELETE FROM mafia_confirm_v4\n WHERE chat_id = ? AND round = ?`,\n [\n chatId,\n game.round,\n ],\n );\n\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'voting_confirm',\n lynch_target = ?,\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n targetId,\n now() + 30_000,\n chatId,\n ],\n );\n\n const alive =\n (await getPlayers(chatId))\n .filter((p) => p.alive);\n\n for (const voter of alive) {\n if (\n voter.blockedUntil > now()\n ) {\n continue;\n }\n\n await tg(\"sendMessage\", {\n chat_id: voter.id,\n text:\n \"Пришло время искать виноватых!\\n\" +\n \"Кого ты хочешь линчевать?\\n\\n\" +\n `Ты выбрал ${nameOf(target)}.`,\n reply_markup: {\n inline_keyboard: [\n [\n {\n text: \"👍\",\n callback_data:\n `l|${encodeChatId(chatId)}|${game.round}|${voter.id}|yes`,\n },\n {\n text: \"👎\",\n callback_data:\n `l|${encodeChatId(chatId)}|${game.round}|${voter.id}|no`,\n },\n ],\n ],\n },\n });\n }\n\n scheduleRecovery(chatId);\n}\n\nasync function saveConfirm(\n chatId: number,\n round: number,\n voterId: number,\n vote: string,\n) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO mafia_confirm_v4\n (chat_id, round, voter_id, vote)\n VALUES (?, ?, ?, ?)`,\n [\n chatId,\n round,\n voterId,\n vote,\n ],\n );\n}\n\nasync function resolveConfirmation(\n chatId: number,\n) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"voting_confirm\"\n ) {\n return;\n }\n\n const result = await sqlite.execute(\n `SELECT vote, COUNT(*) AS cnt\n FROM mafia_confirm_v4\n WHERE chat_id = ? AND round = ?\n GROUP BY vote`,\n [\n chatId,\n game.round,\n ],\n );\n\n let yes = 0;\n let no = 0;\n\n for (const row of result.rows || []) {\n const r: any = row;\n\n if (r.vote === \"yes\") {\n yes = Number(r.cnt);\n }\n\n if (r.vote === \"no\") {\n no = Number(r.cnt);\n }\n }\n\n if (yes <= no) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `Мнения жителей разошлись (${yes} 👍 | ${no} 👎 )...\\n` +\n \"Разошлись и сами жители, так никого и не повесив...\",\n });\n\n await startNight(chatId);\n return;\n }\n\n const targetId =\n game.lynchTarget;\n\n if (!targetId) {\n await startNight(chatId);\n return;\n }\n\n const target =\n (await getPlayers(chatId))\n .find(\n (p) => p.id === targetId,\n );\n\n if (!target || !target.alive) {\n await startNight(chatId);\n return;\n }\n\n // Камикдзе после успешного линчевания\n // получает право выбрать жертву.\n if (\n target.role === \"kamikaze\"\n ) {\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'kamikaze_lynch',\n kamikaze_id = ?,\n phase_ends_at = ?\n WHERE chat_id = ?`,\n [\n target.id,\n now() + 30_000,\n chatId,\n ],\n );\n\n const alive =\n (await getPlayers(chatId))\n .filter(\n (p) =>\n p.alive &&\n p.id !== target.id,\n );\n\n await tg(\"sendMessage\", {\n chat_id: target.id,\n text:\n \"Тебя линчуют.\\n\\n\" +\n \"Кого ты хочешь забрать с собой?\",\n reply_markup: {\n inline_keyboard:\n alive.map((p) => [\n {\n text: nameOf(p),\n callback_data:\n `k|${encodeChatId(chatId)}|${game.round}|${target.id}|${p.id}`,\n },\n ]),\n },\n });\n\n scheduleRecovery(chatId);\n return;\n }\n\n await killPlayer(\n chatId,\n target.id,\n \"lynch\",\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `${nameOf(target)} был повешен.`,\n });\n\n await checkVictory(chatId);\n\n const current =\n await getGame(chatId);\n\n if (\n !current ||\n current.phase === \"finished\"\n ) {\n return;\n }\n\n await startNight(chatId);\n}\n\nasync function handleKamikazeChoice(\n chatId: number,\n kamikazeId: number,\n targetId: number,\n) {\n const game = await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"kamikaze_lynch\"\n ) {\n return;\n }\n\n if (\n game.kamikazeId !==\n kamikazeId\n ) {\n return;\n }\n\n const kamikaze =\n await getPlayer(\n chatId,\n kamikazeId,\n );\n\n const target =\n await getPlayer(\n chatId,\n targetId,\n );\n\n if (\n !kamikaze ||\n !target ||\n !kamikaze.alive ||\n !target.alive\n ) {\n return;\n }\n\n await killPlayer(\n chatId,\n kamikazeId,\n \"lynch\",\n );\n\n await killPlayer(\n chatId,\n targetId,\n \"lynch\",\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `${nameOf(kamikaze)} был повешен и забрал с собой ${nameOf(target)}!`,\n });\n\n await checkVictory(chatId);\n\n const current =\n await getGame(chatId);\n\n if (\n !current ||\n current.phase === \"finished\"\n ) {\n return;\n }\n\n await startNight(chatId);\n}\nasync function handleCallback(query: any) {\n const data = String(\n query.data || \"\",\n );\n\n const userId =\n Number(query.from.id);\n\n await tg(\"answerCallbackQuery\", {\n callback_query_id: query.id,\n });\n\n const parts = data.split(\"|\");\n const type = parts[0];\n\n try {\n /*\n * НОЧНЫЕ ДЕЙСТВИЯ\n */\n if (type === \"n\") {\n const chatId =\n decodeChatId(parts[1]);\n\n const round =\n Number(parts[2]);\n\n const actorId =\n Number(parts[3]);\n\n const targetId =\n Number(parts[4]);\n\n if (userId !== actorId) {\n return;\n }\n\n await processNightAction(\n chatId,\n round,\n actorId,\n targetId,\n );\n\n return;\n }\n\n /*\n * КОМИССАР: ПРОВЕРКА / УБИЙСТВО\n */\n if (type === \"c\") {\n const chatId =\n decodeChatId(parts[1]);\n\n const round =\n Number(parts[2]);\n\n const actorId =\n Number(parts[3]);\n\n const action =\n parts[4];\n\n if (userId !== actorId) {\n return;\n }\n\n const game =\n await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"night\" ||\n game.round !== round\n ) {\n return;\n }\n\n const actor =\n await getPlayer(\n chatId,\n actorId,\n );\n\n if (\n !actor ||\n !actor.alive ||\n actor.role !==\n \"commissioner\"\n ) {\n return;\n }\n\n await saveNight(\n chatId,\n round,\n actorId,\n `commissioner_${action}`,\n null,\n );\n\n const players =\n (await getPlayers(chatId))\n .filter(\n (p) =>\n p.alive &&\n p.id !== actorId,\n );\n\n await tg(\"sendMessage\", {\n chat_id: actorId,\n text:\n action === \"kill\"\n ? \"Кого убить?\"\n : \"Кого проверить?\",\n reply_markup: {\n inline_keyboard:\n players.map((p) => [\n {\n text: nameOf(p),\n callback_data:\n `n|${encodeChatId(chatId)}|${round}|${actorId}|${p.id}`,\n },\n ]),\n },\n });\n\n return;\n }\n\n /*\n * ДНЕВНОЙ ВЫБОР\n */\n if (type === \"v\") {\n const chatId =\n decodeChatId(parts[1]);\n\n const round =\n Number(parts[2]);\n\n const voterId =\n Number(parts[3]);\n\n const targetId =\n Number(parts[4]);\n\n if (userId !== voterId) {\n return;\n }\n\n const game =\n await getGame(chatId);\n\n if (\n !game ||\n game.phase !== \"voting\" ||\n game.round !== round\n ) {\n return;\n }\n\n const voter =\n await getPlayer(\n chatId,\n voterId,\n );\n\n const target =\n await getPlayer(\n chatId,\n targetId,\n );\n\n if (\n !voter ||\n !target ||\n !voter.alive ||\n !target.alive ||\n voter.id === target.id\n ) {\n return;\n }\n\n if (\n voter.blockedUntil >\n now()\n ) {\n return;\n }\n\n const already =\n await sqlite.execute(\n `SELECT 1\n FROM mafia_votes_v4\n WHERE chat_id = ?\n AND round = ?\n AND voter_id = ?`,\n [\n chatId,\n round,\n voterId,\n ],\n );\n\n if (already.rows?.length) {\n return;\n }\n\n await saveVote(\n chatId,\n round,\n voterId,\n targetId,\n );\n\n await tg(\"sendMessage\", {\n chat_id: voterId,\n text:\n `Ты выбрал ${nameOf(target)}.`,\n });\n\n return;\n }\n\n /*\n * ПОДТВЕРЖДЕНИЕ ЛИНЧЕВАНИЯ\n */\n if (type === \"l\") {\n const chatId =\n decodeChatId(parts[1]);\n\n const round =\n Number(parts[2]);\n\n const voterId =\n Number(parts[3]);\n\n const vote =\n parts[4];\n\n const game =\n await getGame(chatId);\n\n if (\n !game ||\n game.phase !==\n \"voting_confirm\" ||\n game.round !== round\n ) {\n return;\n }\n\n const voter =\n await getPlayer(\n chatId,\n voterId,\n );\n\n if (\n !voter ||\n !voter.alive ||\n voter.blockedUntil >\n now()\n ) {\n return;\n }\n\n await saveConfirm(\n chatId,\n round,\n voterId,\n vote,\n );\n\n return;\n }\n\n /*\n * КАМИКАДЗЕ ПОСЛЕ ЛИНЧЕВАНИЯ\n */\n if (type === \"k\") {\n const chatId =\n decodeChatId(parts[1]);\n\n const kamikazeId =\n Number(parts[3]);\n\n const targetId =\n Number(parts[4]);\n\n if (\n userId !== kamikazeId\n ) {\n return;\n }\n\n await handleKamikazeChoice(\n chatId,\n kamikazeId,\n targetId,\n );\n\n return;\n }\n } catch (error) {\n console.error(\n \"Callback error:\",\n error,\n );\n }\n}\n\nasync function handleMessage(\n message: any,\n) {\n const chat = message.chat;\n const user = message.from;\n const text =\n String(message.text || \"\");\n\n if (!user) return;\n\n const chatId =\n Number(chat.id);\n\n const isGroup =\n chat.type === \"group\" ||\n chat.type === \"supergroup\";\n\n /*\n * ЛИЧКА\n */\n if (!isGroup) {\n const match =\n text.match(\n /^\\/start(?:@\\w+)?(?:\\s+(.+))?$/i,\n );\n\n if (!match) {\n return;\n }\n\n const payload =\n match[1] || \"\";\n\n /*\n * Кнопка \"Присоединиться\"\n */\n if (\n payload.startsWith(\"join_\")\n ) {\n const encoded =\n payload.slice(5);\n\n const targetChatId =\n decodeChatId(encoded);\n\n await recoverGame(\n targetChatId,\n );\n\n await joinGame(\n targetChatId,\n user,\n );\n\n return;\n }\n\n /*\n * Обычный /start в ЛС\n */\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Привет!\\n\" +\n \"Я бот-ведущий для игры в 🤵🏻Мафию.\",\n });\n\n return;\n }\n\n /*\n * ГРУППА\n *\n * Принимаем именно:\n *\n * /start@Special_Mafiabot\n */\n const startCommand =\n new RegExp(\n `^\\\\/start@${BOT_USERNAME}$`,\n \"i\",\n );\n\n if (\n !startCommand.test(text)\n ) {\n return;\n }\n\n const game =\n await getGame(chatId);\n\n /*\n * Если игры нет —\n * создаём лобби.\n */\n if (\n !game ||\n game.phase === \"finished\"\n ) {\n await createLobby(\n chatId,\n user,\n );\n\n await sendLobby(chatId);\n\n return;\n }\n\n /*\n * Если набор уже идёт —\n * стартовать может только создатель.\n */\n if (\n game.phase === \"registration\"\n ) {\n if (\n game.creatorId !==\n Number(user.id)\n ) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Только создатель игры может её начать.\",\n });\n\n return;\n }\n\n const players =\n await getPlayers(chatId);\n\n if (\n players.length <\n MIN_PLAYERS\n ) {\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n `Для начала игры нужно минимум ${MIN_PLAYERS} игрока.\\n` +\n `Сейчас зарегистрировано: ${players.length}.`,\n });\n\n return;\n }\n\n await startGame(chatId);\n\n return;\n }\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"В этой группе уже идёт игра.\",\n });\n}\n\nasync function recoverGame(\n chatId: number,\n) {\n const game =\n await getGame(chatId);\n\n if (\n !game ||\n !game.phaseEndsAt\n ) {\n return;\n }\n\n if (\n now() <\n game.phaseEndsAt\n ) {\n return;\n }\n\n switch (game.phase) {\n case \"registration\": {\n const players =\n await getPlayers(chatId);\n\n if (\n players.length >=\n MIN_PLAYERS\n ) {\n await startGame(chatId);\n } else {\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'finished'\n WHERE chat_id = ?`,\n [chatId],\n );\n }\n\n break;\n }\n\n case \"starting\":\n await startNight(chatId);\n break;\n\n case \"night\":\n await resolveNight(chatId);\n break;\n\n case \"day\":\n await startVoting(chatId);\n break;\n\n case \"voting\":\n await resolveVoting(chatId);\n break;\n\n case \"voting_confirm\":\n await resolveConfirmation(\n chatId,\n );\n break;\n\n case \"kamikaze_lynch\": {\n const kamikaze =\n game.kamikazeId;\n\n if (kamikaze) {\n await killPlayer(\n chatId,\n kamikaze,\n \"lynch\",\n );\n\n await tg(\"sendMessage\", {\n chat_id: chatId,\n text:\n \"Камикадзе не успел выбрать жертву и погиб.\",\n });\n }\n\n await checkVictory(chatId);\n\n const current =\n await getGame(chatId);\n\n if (\n !current ||\n current.phase ===\n \"finished\"\n ) {\n return;\n }\n\n await startNight(chatId);\n break;\n }\n }\n}\n\nfunction scheduleRecovery(\n chatId: number,\n) {\n /*\n * Это только быстрый переход.\n *\n * Основное состояние хранится\n * в SQLite, поэтому после\n * перезапуска Val оно не теряется.\n */\n setTimeout(async () => {\n try {\n await recoverGame(\n chatId,\n );\n } catch (error) {\n console.error(\n \"Recovery error:\",\n error,\n );\n }\n }, 2_000);\n}\n\nasync function checkVictory(\n chatId: number,\n) {\n const game =\n await getGame(chatId);\n\n if (\n !game ||\n game.phase === \"finished\"\n ) {\n return;\n }\n\n const alive =\n (await getPlayers(chatId))\n .filter((p) => p.alive);\n\n const mafia =\n alive.filter(\n (p) =>\n p.role === \"don\" ||\n p.role === \"mafia\",\n );\n\n const town =\n alive.filter(\n (p) =>\n p.role !== \"don\" &&\n p.role !== \"mafia\",\n );\n\n if (!mafia.length) {\n await finishGame(\n chatId,\n \"town\",\n );\n\n return;\n }\n\n if (\n mafia.length >= town.length\n ) {\n await finishGame(\n chatId,\n \"mafia\",\n );\n }\n}\n\nasync function finishGame(\n chatId: number,\n winner: \"mafia\" | \"town\",\n) {\n await sqlite.execute(\n `UPDATE mafia_games_v4\n SET phase = 'finished',\n phase_ends_at = 0\n WHERE chat_id = ?`,\n [chatId],\n );\n\n const players =\n await getPlayers(chatId);\n\n for (const player of players) {\n if (!player.role) {\n continue;\n }\n\n const won =\n winner === \"mafia\"\n ? player.role === \"don\" ||\n player.role === \"mafia\"\n : player.role !== \"don\" &&\n player.role !== \"mafia\";\n\n const profile =\n await sqlite.execute(\n `SELECT money\n FROM mafia_profiles_v4\n WHERE user_id = ?`,\n [player.id],\n );\n\n let money = 0;\n\n if (profile.rows?.length) {\n money = Number(\n (profile.rows[0] as any)\n .money || 0,\n );\n } else {\n await sqlite.execute(\n `INSERT OR IGNORE INTO mafia_profiles_v4\n (user_id, money, protection, documents)\n VALUES (?, 0, 0, 0)`,\n [player.id],\n );\n }\n\n if (won) {\n money += 20;\n\n await sqlite.execute(\n `UPDATE mafia_profiles_v4\n SET money = ?\n WHERE user_id = ?`,\n [\n money,\n player.id,\n ],\n );\n }\n\n const moneyRow =\n await sqlite.execute(\n `SELECT money, protection, documents\n FROM mafia_profiles_v4\n WHERE user_id = ?`,\n [player.id],\n );\n\n const stats: any =\n moneyRow.rows?.[0] || {};\n\n await tg(\"sendMessage\", {\n chat_id: player.id,\n text: won\n ? [\n \"Игра завершена\",\n \"\",\n `За победу в роли \"${ROLE_NAMES[player.role]}\" тебе начислили 💵 20!`,\n \"\",\n `👤 ${nameOf(player)}`,\n \"\",\n `💵 Деньги: ${Number(stats.money || money)}`,\n \"\",\n `🛡 Защита: ${Number(stats.protection || 0)}`,\n `📂 Документы: ${Number(stats.documents || 0)}`,\n ].join(\"\\n\")\n : [\n \"Игра завершена\",\n \"\",\n `👤 ${nameOf(player)}`,\n \"\",\n `💵 Деньги: ${Number(stats.money || money)}`,\n \"\",\n `🛡 Защита: ${Number(stats.protection || 0)}`,\n `📂 Документы: ${Number(stats.documents || 0)}`,\n ].join(\"\\n\"),\n });\n }\n}\n\n/*\n * =====================================================\n * HTTP VAL ДЛЯ VAL TOWN\n * =====================================================\n *\n * ВАЖНО:\n * НИКАКОГО Deno.serve() ЗДЕСЬ НЕТ.\n *\n * Val Town сам вызывает эту функцию.\n */\nexport default async function (\n req: Request,\n): Promise {\n try {\n await ensureDb();\n\n if (\n req.method !== \"POST\"\n ) {\n return new Response(\n \"OK\",\n { status: 200 },\n );\n }\n\n const update =\n await req.json();\n\n if (\n update.callback_query\n ) {\n await handleCallback(\n update.callback_query,\n );\n } else if (\n update.message\n ) {\n const chat =\n update.message.chat;\n\n /*\n * Проверяем просроченную\n * фазу только для групп.\n */\n if (\n chat.type === \"group\" ||\n chat.type === \"supergroup\"\n ) {\n await recoverGame(\n Number(chat.id),\n );\n }\n\n await handleMessage(\n update.message,\n );\n }\n\n return new Response(\n \"OK\",\n {\n status: 200,\n },\n );\n } catch (error) {\n console.error(\n \"HTTP handler error:\",\n error,\n );\n\n /*\n * Telegram должен получить\n * 200, чтобы не зацикливать\n * повторную доставку update.\n */\n return new Response(\n \"OK\",\n {\n status: 200,\n },\n );\n }\n}\n","deleted",false,"label",[19],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":56,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_57":58,"_18":59},["D",1789452504597],"children",[],[19],"e0f3bb77-83b2-453f-a03f-ab4a63fd22f2",["D",1789388722677],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a5eb2194-a886-4450-96f3-4e1975745201/square512?exp=1789527599&sig=eca6a606fe04d4bae9894c5e2ec8c97f1646ffbf9e83a87616b61b65a18d0789","userId","f70e2956-3025-45c0-b976-28a5da33884e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a09fde-ae49-7015-9e61-f4852486d9e7","tursoName","e0f3bb7783b2453fa03fab4a63fd22f2","tursoHostname","e0f3bb7783b2453fa03fab4a63fd22f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476033740],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_119":115},"org",{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":52},"branch",{"_17":41,"_13":16,"_33":39,"_104":60,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Farm2","avatar","https://lh3.googleusercontent.com/a/ACg8ocLUID6nbEpakXgXgCKKdd7Jv1pRhrQ2DYXBFSb3lBMORtVCRg=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":60,"_13":14,"_44":153,"_62":-5,"_63":52,"_64":65,"_66":65,"_67":68,"_69":70,"_71":72,"_73":36,"_74":43,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":154,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":155,"_99":156,"_101":157,"_103":52},[150],"files",[150],"counts",{"_140":78,"_141":142,"_143":78,"_32":144,"_145":146},[],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":139},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],"pulls","branches",1,"forks",{"_147":142,"_149":78},"connections",{"_147":78,"_148":78},"count","unfilledCount","emptyCount",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":56,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_57":151,"_18":152},[],[19],["D",1789388722677],["D",1789476033740],{"_11":12,"_119":115},{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":52},{"_17":41,"_13":16,"_33":39,"_104":60,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"ctx",{"_97":-5,"_136":191,"_192":193,"_194":195,"_196":52,"_197":52,"_198":52,"_199":43,"_200":-5,"_201":-7,"_202":-7,"_203":78,"_204":52,"_205":52,"_206":-5,"_207":52,"_208":52,"_209":52,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":16,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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"]