[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_223":224,"_225":226},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_113":94,"_32":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":30,"_128":129,"_130":63,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",6,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","bb814565-19af-42e8-85eb-af505fda76e6","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","cron.ts","latestPath","fileId","f150d6e6-5aa3-11f1-8fee-ee650bb23af1","name","fileType","interval","content","import { getSessions } from \"./db.ts\";\nimport { handleAuth, runMonitoringCycle } from \"./worker.ts\";\nimport { getState, setState } from \"./db.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst ADMIN_CHAT_ID = Deno.env.get(\"ADMIN_CHAT_ID\"); // Telegram chat ID for @mqppr\n\nasync function sendBotMessage(text: string) {\n if (!ADMIN_CHAT_ID || !BOT_TOKEN) return;\n try {\n await fetch(`https://api.telegram.org/bot${BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: ADMIN_CHAT_ID,\n text,\n parse_mode: \"Markdown\",\n }),\n });\n } catch (err) {\n console.error(\"Failed to send bot message:\", err);\n }\n}\n\nexport default async function(interval: Interval) {\n console.log(\"⏰ Cron cycle started at\", new Date().toISOString());\n\n // 1. Handle pending auth if any\n try {\n const authStep = await getState(\"auth_step\");\n if (authStep && authStep !== \"done\" && authStep !== \"waiting_code\" && authStep !== \"waiting_2fa\") {\n const result = await handleAuth(BOT_TOKEN);\n if (result) {\n await sendBotMessage(result);\n }\n }\n } catch (err: any) {\n console.error(\"Auth handling error:\", err);\n await sendBotMessage(`❌ Ошибка авторизации: ${err.message}`);\n }\n\n // 2. Run monitoring for all active sessions\n const sessions = await getSessions();\n const activeSessions = sessions.filter(s => s.is_active);\n\n if (activeSessions.length === 0) {\n console.log(\"No active sessions, skipping.\");\n return;\n }\n\n for (const session of activeSessions) {\n try {\n console.log(`🔍 Checking session: ${session.name}`);\n await runMonitoringCycle(session, sendBotMessage);\n console.log(`✅ Session ${session.name} cycle complete`);\n } catch (err: any) {\n console.error(`❌ Session ${session.name} error:`, err);\n await sendBotMessage(`❌ Ошибка в сессии *${session.name}*: ${err.message || String(err)}`);\n }\n }\n\n console.log(\"⏰ Cron cycle complete\");\n}\n","createdAt",["D",1779979559991],"branchVersion","branchId","ab73ea14-5aa3-11f1-a6ce-ee650bb23af1","id","ab732a70-5aa3-11f1-a6ce-ee650bb23af1","jobseo-monitor-bot",["D",1779979442780],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Telegram bot to monitor @jobseo_bot tasks via gramjs userbot","imageUrl","51124e19-8655-49dc-8413-b8c00d6b466f","pinnedFileId","eb3b4b4c-5aa3-11f1-8fee-ee650bb23af1","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e6f08-b055-7649-aaeb-3fbf162849ff","tursoName","ab732a705aa311f1a6ceee650bb23af1","tursoHostname","ab732a705aa311f1a6ceee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789495880338],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_19":59,"_109":110,"_111":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",13,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","zzliporllllliiiiii","handle","displayName","Микпсф","avatar","https://lh3.googleusercontent.com/a/ACg8ocJsvwoGFWUL0HMMMmincSGJBtbI1KoiGeXgQPgBiOOJIUMnmQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":218,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":219,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":220,"_88":221,"_90":222,"_92":30},"tree",[193,194,195,196,197,198],"files",[193,194,195,196,197,198],"counts",{"_183":67,"_184":162,"_185":67,"_186":187,"_188":189},"contents",[135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":176,"_37":177,"_35":178,"_144":-5,"_45":46,"_44":179,"_146":63,"_42":180,"_13":67,"_38":148,"_40":181,"_29":30,"_150":-5,"_32":182},{"_47":173,"_37":33,"_35":36,"_144":-5,"_45":46,"_44":14,"_146":63,"_42":174,"_13":67,"_38":39,"_40":41,"_29":30,"_150":-5,"_32":175},{"_47":166,"_37":167,"_35":168,"_144":-5,"_45":46,"_44":169,"_146":63,"_42":170,"_13":67,"_38":148,"_40":171,"_29":30,"_150":-5,"_32":172},{"_47":159,"_37":160,"_35":161,"_144":-5,"_45":46,"_44":162,"_146":63,"_42":163,"_13":67,"_38":148,"_40":164,"_29":30,"_150":-5,"_32":165},{"_47":152,"_37":153,"_35":61,"_144":-5,"_45":46,"_44":154,"_146":63,"_42":155,"_13":67,"_38":156,"_40":157,"_29":30,"_150":-5,"_32":158},{"_47":141,"_37":142,"_35":143,"_144":-5,"_45":46,"_44":145,"_146":63,"_42":147,"_13":67,"_38":148,"_40":149,"_29":30,"_150":-5,"_32":151},"e6dc60c2-5aa3-11f1-be68-ee650bb23af1","worker.ts","e6dc6158-5aa3-11f1-be68-ee650bb23af1","parentId",3,"latest",["D",1779979542449],"script","import { TelegramClient, Api } from \"npm:telegram@2.26.22\";\nimport { StringSession } from \"npm:telegram@2.26.22/sessions/index.js\";\nimport {\n getSession,\n getSessions,\n saveSession,\n incrementCycles,\n getState,\n setState,\n Session,\n} from \"./db.ts\";\n\nconst JOBSEO_BOT = \"jobseo_bot\";\nconst ADMIN_USERNAME = \"mqppr\";\nconst NOTIFY_FOR_ADMIN = \"SetkaGar\"; // if userbot is mqppr, notify SetkaGar\nconst NOTIFY_FOR_OTHERS = \"mqppr\"; // if userbot is someone else, notify mqppr\n\n/**\n * Handle pending auth flow (send_code / sign_in / sign_in_2fa)\n * Returns a message to send back to the user via the management bot\n */\nexport async function handleAuth(botToken: string): Promise {\n const authStep = await getState(\"auth_step\");\n if (!authStep || authStep === \"done\") return null;\n\n const pendingRaw = await getState(\"pending_auth\");\n if (!pendingRaw) return null;\n\n const pending = JSON.parse(pendingRaw);\n const { name, apiId, apiHash, phone, code, password } = pending;\n\n const session = new StringSession(\"\");\n const client = new TelegramClient(session, apiId, apiHash, {\n connectionRetries: 3,\n baseLogger: { warn: () => {}, info: () => {}, debug: () => {}, error: () => {} },\n });\n\n try {\n await client.connect();\n\n if (authStep === \"send_code\") {\n const result = await client.sendCode(\n { apiId, apiHash },\n phone\n );\n pending.phoneCodeHash = result.phoneCodeHash;\n pending.partialSession = client.session.save() as unknown as string;\n await setState(\"pending_auth\", JSON.stringify(pending));\n await setState(\"auth_step\", \"waiting_code\");\n await client.disconnect();\n return \"📨 Код отправлен! Введи код из Telegram:\";\n }\n\n if (authStep === \"sign_in\") {\n // Restore partial session\n if (pending.partialSession) {\n const partialClient = new TelegramClient(\n new StringSession(pending.partialSession),\n apiId, apiHash,\n { connectionRetries: 3, baseLogger: { warn: () => {}, info: () => {}, debug: () => {}, error: () => {} } }\n );\n await partialClient.connect();\n\n try {\n await partialClient.invoke(\n new Api.auth.SignIn({\n phoneNumber: phone,\n phoneCodeHash: pending.phoneCodeHash,\n phoneCode: code,\n })\n );\n\n const sessionStr = partialClient.session.save() as unknown as string;\n await saveSession({\n name,\n api_id: apiId,\n api_hash: apiHash,\n phone,\n string_session: sessionStr,\n });\n await setState(\"auth_step\", \"done\");\n await setState(\"pending_auth\", \"\");\n await partialClient.disconnect();\n return `✅ Сессия *${name}* сохранена и активирована! Воркер запущен.`;\n } catch (err: any) {\n if (err.errorMessage === \"SESSION_PASSWORD_NEEDED\") {\n pending.partialSession = partialClient.session.save() as unknown as string;\n await setState(\"pending_auth\", JSON.stringify(pending));\n await setState(\"auth_step\", \"waiting_2fa\");\n await partialClient.disconnect();\n return \"🔒 Аккаунт защищён 2FA. Введи пароль:\";\n }\n await partialClient.disconnect();\n throw err;\n }\n }\n }\n\n if (authStep === \"sign_in_2fa\") {\n if (pending.partialSession) {\n const partialClient = new TelegramClient(\n new StringSession(pending.partialSession),\n apiId, apiHash,\n { connectionRetries: 3, baseLogger: { warn: () => {}, info: () => {}, debug: () => {}, error: () => {} } }\n );\n await partialClient.connect();\n\n await partialClient.invoke(\n new Api.auth.CheckPassword({\n password: await partialClient.invoke(new Api.account.GetPassword()).then(async (srpData) => {\n const { computeCheck } = await import(\"npm:telegram@2.26.22/Password.js\");\n return computeCheck(srpData, password);\n }),\n })\n );\n\n const sessionStr = partialClient.session.save() as unknown as string;\n await saveSession({\n name,\n api_id: apiId,\n api_hash: apiHash,\n phone,\n string_session: sessionStr,\n });\n await setState(\"auth_step\", \"done\");\n await setState(\"pending_auth\", \"\");\n await partialClient.disconnect();\n return `✅ Сессия *${name}* сохранена (2FA пройдена)! Воркер запущен.`;\n }\n }\n } catch (err: any) {\n await setState(\"auth_step\", \"done\");\n await setState(\"pending_auth\", \"\");\n return `❌ Ошибка авторизации: ${err.message || err.errorMessage || String(err)}`;\n }\n\n return null;\n}\n\n/**\n * Run monitoring cycle for one active session\n */\nexport async function runMonitoringCycle(session: Session, sendBotMessage: (text: string) => Promise): Promise {\n const client = new TelegramClient(\n new StringSession(session.string_session),\n session.api_id,\n session.api_hash,\n {\n connectionRetries: 3,\n baseLogger: { warn: () => {}, info: () => {}, debug: () => {}, error: () => {} },\n }\n );\n\n try {\n await client.connect();\n\n // Get @jobseo_bot entity\n const jobseoEntity = await client.getEntity(JOBSEO_BOT);\n\n // Get last messages from jobseo_bot\n const messages = await client.getMessages(jobseoEntity, { limit: 5 });\n\n // Find \"Приступить к заданию\" button and click it\n let clickedTask = false;\n for (const msg of messages) {\n if (msg.replyMarkup && \"rows\" in msg.replyMarkup) {\n for (const row of msg.replyMarkup.rows) {\n for (const button of row.buttons) {\n if (button.text && button.text.includes(\"Приступить к заданию\")) {\n if (\"data\" in button && button.data) {\n try {\n await client.invoke(\n new Api.messages.GetBotCallbackAnswer({\n peer: jobseoEntity,\n msgId: msg.id,\n data: button.data,\n })\n );\n clickedTask = true;\n } catch {\n // Sometimes button press fails, try sending text\n await client.sendMessage(jobseoEntity, { message: \"Приступить к заданию ✍️\" });\n clickedTask = true;\n }\n }\n break;\n }\n }\n if (clickedTask) break;\n }\n }\n if (clickedTask) break;\n }\n\n if (!clickedTask) {\n // Try sending the text directly\n await client.sendMessage(jobseoEntity, { message: \"/start\" });\n await new Promise(r => setTimeout(r, 3000));\n\n const newMsgs = await client.getMessages(jobseoEntity, { limit: 3 });\n for (const msg of newMsgs) {\n if (msg.replyMarkup && \"rows\" in msg.replyMarkup) {\n for (const row of msg.replyMarkup.rows) {\n for (const button of row.buttons) {\n if (button.text && button.text.includes(\"Приступить к заданию\")) {\n if (\"data\" in button && button.data) {\n await client.invoke(\n new Api.messages.GetBotCallbackAnswer({\n peer: jobseoEntity,\n msgId: msg.id,\n data: button.data,\n })\n );\n clickedTask = true;\n }\n }\n }\n }\n }\n }\n }\n\n // Wait for response\n await new Promise(r => setTimeout(r, 5000));\n\n // Read response\n const responseMsgs = await client.getMessages(jobseoEntity, { limit: 3 });\n let hasNewTasks = false;\n\n for (const msg of responseMsgs) {\n if (msg.replyMarkup && \"rows\" in msg.replyMarkup) {\n const allButtons: string[] = [];\n for (const row of msg.replyMarkup.rows) {\n for (const button of row.buttons) {\n if (button.text) allButtons.push(button.text);\n }\n }\n\n // Check if there are buttons OTHER than \"Назад в меню\" and \"Доп. задания\"\n const ignoreButtons = [\"Назад в меню\", \"Доп. задания\"];\n const meaningfulButtons = allButtons.filter(b =>\n !ignoreButtons.some(ib => b.includes(ib))\n );\n\n if (meaningfulButtons.length > 0) {\n hasNewTasks = true;\n break;\n }\n\n // If only menu/extra buttons, click \"Назад в меню\"\n if (!hasNewTasks) {\n for (const row of msg.replyMarkup.rows) {\n for (const button of row.buttons) {\n if (button.text?.includes(\"Назад в меню\") && \"data\" in button && button.data) {\n try {\n await client.invoke(\n new Api.messages.GetBotCallbackAnswer({\n peer: jobseoEntity,\n msgId: msg.id,\n data: button.data,\n })\n );\n } catch { /* ignore */ }\n }\n }\n }\n }\n }\n }\n\n if (hasNewTasks) {\n // Determine who to notify\n const me = await client.getMe() as Api.User;\n const myUsername = me.username || \"\";\n const notifyTarget = myUsername.toLowerCase() === ADMIN_USERNAME.toLowerCase()\n ? NOTIFY_FOR_ADMIN\n : NOTIFY_FOR_OTHERS;\n\n // Send notification via userbot\n try {\n const target = await client.getEntity(notifyTarget);\n await client.sendMessage(target, {\n message: \"🔥 НОВЫЕ ЗАДАНИЯ В JOBSEO! Зайди в @jobseo_bot → Приступить к заданию\",\n });\n } catch (e) {\n console.error(`Failed to notify @${notifyTarget}:`, e);\n }\n\n // Notify admin via management bot\n await sendBotMessage(`✅ Найдены новые задания! (сессия: ${session.name})`);\n\n // Start spam loop — but in serverless we can only do a few iterations\n const spamKey = `spam_active:${session.name}`;\n await setState(spamKey, \"true\");\n\n // Send a few notifications (serverless constraint — max ~25 seconds)\n for (let i = 0; i < 3; i++) {\n const isActive = await getState(spamKey);\n if (isActive !== \"true\") break;\n await new Promise(r => setTimeout(r, 10000));\n try {\n const target = await client.getEntity(notifyTarget);\n await client.sendMessage(target, {\n message: \"🔥 НОВЫЕ ЗАДАНИЯ В JOBSEO! Зайди в @jobseo_bot → Приступить к заданию\",\n });\n } catch { break; }\n }\n }\n\n await incrementCycles(session.name);\n await client.disconnect();\n } catch (err: any) {\n console.error(`Worker error for session ${session.name}:`, err);\n try { await client.disconnect(); } catch {}\n throw err;\n }\n}\n","label",[142],"eb3b4a70-5aa3-11f1-8fee-ee650bb23af1","webhook.ts",4,["D",1779979549782],"http","import { createBot } from \"./bot.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst bot = createBot(BOT_TOKEN);\n\n// Webhook handler for Telegraf\nexport default async function(req: Request): Promise {\n if (req.method === \"POST\") {\n try {\n const body = await req.json();\n await bot.handleUpdate(body);\n } catch (err) {\n console.error(\"Webhook error:\", err);\n }\n return new Response(\"ok\");\n }\n\n // GET = setup webhook\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const webhookUrl = `${url.origin}${url.pathname}`;\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${BOT_TOKEN}/setWebhook`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ url: webhookUrl }),\n }\n );\n const data = await res.json();\n return Response.json({\n message: \"Webhook setup\",\n result: data,\n webhookUrl,\n });\n } catch (err: any) {\n return Response.json({ error: err.message }, { status: 500 });\n }\n }\n\n return new Response(\"Method not allowed\", { status: 405 });\n}\n",[153],"b5b4519e-5aa3-11f1-9bfe-ee650bb23af1","db.ts","b5b45298-5aa3-11f1-9bfe-ee650bb23af1",1,["D",1779979459978],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Initialize database tables\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS sessions (\n name TEXT PRIMARY KEY,\n api_id INTEGER NOT NULL,\n api_hash TEXT NOT NULL,\n phone TEXT NOT NULL,\n string_session TEXT NOT NULL,\n is_active INTEGER DEFAULT 0,\n cycles_count INTEGER DEFAULT 0,\n last_check TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS state (\n key TEXT PRIMARY KEY,\n value TEXT\n)`);\n\nexport interface Session {\n name: string;\n api_id: number;\n api_hash: string;\n phone: string;\n string_session: string;\n is_active: number;\n cycles_count: number;\n last_check: string | null;\n}\n\nexport async function saveSession(s: Omit) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO sessions (name, api_id, api_hash, phone, string_session, is_active)\n VALUES (?, ?, ?, ?, ?, 1)`,\n args: [s.name, s.api_id, s.api_hash, s.phone, s.string_session],\n });\n}\n\nexport async function getSessions(): Promise {\n const r = await sqlite.execute(\"SELECT * FROM sessions\");\n return r.rows as unknown as Session[];\n}\n\nexport async function getSession(name: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM sessions WHERE name = ?\", args: [name] });\n return (r.rows[0] as unknown as Session) ?? null;\n}\n\nexport async function setSessionActive(name: string, active: boolean) {\n await sqlite.execute({\n sql: \"UPDATE sessions SET is_active = ? WHERE name = ?\",\n args: [active ? 1 : 0, name],\n });\n}\n\nexport async function incrementCycles(name: string) {\n await sqlite.execute({\n sql: \"UPDATE sessions SET cycles_count = cycles_count + 1, last_check = datetime('now') WHERE name = ?\",\n args: [name],\n });\n}\n\nexport async function deleteSession(name: string) {\n await sqlite.execute({ sql: \"DELETE FROM sessions WHERE name = ?\", args: [name] });\n}\n\n// Simple key-value state\nexport async function setState(key: string, value: string) {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO state (key, value) VALUES (?, ?)\",\n args: [key, value],\n });\n}\n\nexport async function getState(key: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT value FROM state WHERE key = ?\", args: [key] });\n return (r.rows[0] as any)?.value ?? null;\n}\n",[160],"efcd183e-5aa3-11f1-9b17-ee650bb23af1","database.ts","efcd1942-5aa3-11f1-9b17-ee650bb23af1",5,["D",1779979557445],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS sessions (\n name TEXT PRIMARY KEY,\n api_id INTEGER NOT NULL,\n api_hash TEXT NOT NULL,\n phone TEXT NOT NULL,\n string_session TEXT NOT NULL,\n is_active INTEGER DEFAULT 0,\n cycles_count INTEGER DEFAULT 0,\n last_check TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS auth_state (\n chat_id INTEGER PRIMARY KEY,\n step TEXT NOT NULL,\n session_name TEXT,\n api_id INTEGER,\n api_hash TEXT,\n phone TEXT,\n phone_code_hash TEXT,\n string_session TEXT\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS worker_state (\n session_name TEXT PRIMARY KEY,\n spam_active INTEGER DEFAULT 0\n)`);\n\nexport interface Session {\n name: string;\n api_id: number;\n api_hash: string;\n phone: string;\n string_session: string;\n is_active: number;\n cycles_count: number;\n last_check: string | null;\n}\n\nexport interface AuthState {\n chat_id: number;\n step: string;\n session_name: string | null;\n api_id: number | null;\n api_hash: string | null;\n phone: string | null;\n phone_code_hash: string | null;\n string_session: string | null;\n}\n\nexport async function saveSession(s: { name: string; api_id: number; api_hash: string; phone: string; string_session: string }) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO sessions (name, api_id, api_hash, phone, string_session, is_active, cycles_count)\n VALUES (?, ?, ?, ?, ?, 1, 0)`,\n args: [s.name, s.api_id, s.api_hash, s.phone, s.string_session],\n });\n}\n\nexport async function getSessions(): Promise {\n const r = await sqlite.execute(\"SELECT * FROM sessions\");\n return r.rows as unknown as Session[];\n}\n\nexport async function getSession(name: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM sessions WHERE name = ?\", args: [name] });\n return (r.rows[0] as unknown as Session) ?? null;\n}\n\nexport async function getActiveSessions(): Promise {\n const r = await sqlite.execute(\"SELECT * FROM sessions WHERE is_active = 1\");\n return r.rows as unknown as Session[];\n}\n\nexport async function setSessionActive(name: string, active: boolean) {\n await sqlite.execute({\n sql: \"UPDATE sessions SET is_active = ? WHERE name = ?\",\n args: [active ? 1 : 0, name],\n });\n}\n\nexport async function incrementCycles(name: string) {\n await sqlite.execute({\n sql: \"UPDATE sessions SET cycles_count = cycles_count + 1, last_check = datetime('now') WHERE name = ?\",\n args: [name],\n });\n}\n\nexport async function deleteSession(name: string) {\n await sqlite.execute({ sql: \"DELETE FROM sessions WHERE name = ?\", args: [name] });\n await sqlite.execute({ sql: \"DELETE FROM worker_state WHERE session_name = ?\", args: [name] });\n}\n\n// Auth state (persisted in DB so survives cold starts)\nexport async function setAuthState(state: Partial & { chat_id: number; step: string }) {\n const existing = await getAuthState(state.chat_id);\n const merged = { ...existing, ...state };\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO auth_state (chat_id, step, session_name, api_id, api_hash, phone, phone_code_hash, string_session)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [merged.chat_id, merged.step, merged.session_name ?? null, merged.api_id ?? null, merged.api_hash ?? null, merged.phone ?? null, merged.phone_code_hash ?? null, merged.string_session ?? null],\n });\n}\n\nexport async function getAuthState(chatId: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM auth_state WHERE chat_id = ?\", args: [chatId] });\n return (r.rows[0] as unknown as AuthState) ?? null;\n}\n\nexport async function clearAuthState(chatId: number) {\n await sqlite.execute({ sql: \"DELETE FROM auth_state WHERE chat_id = ?\", args: [chatId] });\n}\n\n// Worker/spam state\nexport async function setSpamActive(sessionName: string, active: boolean) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO worker_state (session_name, spam_active) VALUES (?, ?)`,\n args: [sessionName, active ? 1 : 0],\n });\n}\n\nexport async function isSpamActive(sessionName: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT spam_active FROM worker_state WHERE session_name = ?\", args: [sessionName] });\n return (r.rows[0] as any)?.spam_active === 1;\n}\n",[167],"f150d632-5aa3-11f1-8fee-ee650bb23af1",["D",1779979559991],[33],"cbf346c2-5aa3-11f1-a97b-ee650bb23af1","bot.ts","cbf34794-5aa3-11f1-a97b-ee650bb23af1",2,["D",1779979497299],"import { Telegraf, Markup } from \"npm:telegraf@4.16.3\";\nimport {\n getSessions,\n getSession,\n setSessionActive,\n setState,\n getState,\n deleteSession,\n} from \"./db.ts\";\n\nconst ADMIN_USERNAME = \"mqppr\";\n\n// We store conversation state in memory (reset on cold start, which is fine)\nconst userState: Record;\n}> = {};\n\nexport function createBot(token: string) {\n const bot = new Telegraf(token);\n\n // Admin-only middleware\n bot.use(async (ctx, next) => {\n const username = ctx.from?.username;\n if (username !== ADMIN_USERNAME) {\n if (ctx.callbackQuery) {\n await ctx.answerCbQuery(\"⛔ Доступ запрещён\");\n } else {\n await ctx.reply(\"⛔ Доступ запрещён. Бот только для @\" + ADMIN_USERNAME);\n }\n return;\n }\n return next();\n });\n\n // /start\n bot.start(async (ctx) => {\n delete userState[ctx.from!.id];\n await ctx.reply(\"👋 Привет! Выбери действие:\", Markup.inlineKeyboard([\n [Markup.button.callback(\"📱 Создать новую сессию\", \"new_session\")],\n [Markup.button.callback(\"▶️ Запустить сохранённую сессию\", \"list_sessions\")],\n [Markup.button.callback(\"📊 Статус всех сессий\", \"status_all\")],\n [Markup.button.callback(\"🗑 Удалить сессию\", \"delete_session\")],\n ]));\n });\n\n // New session flow\n bot.action(\"new_session\", async (ctx) => {\n await ctx.answerCbQuery();\n userState[ctx.from!.id] = { step: \"name\", data: {} };\n await ctx.reply(\"📝 Введи название сессии (например: myaccount):\");\n });\n\n // List sessions to start\n bot.action(\"list_sessions\", async (ctx) => {\n await ctx.answerCbQuery();\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await ctx.reply(\"❌ Нет сохранённых сессий. Создай новую через /start\");\n return;\n }\n const buttons = sessions.map(s =>\n [Markup.button.callback(\n `${s.is_active ? \"🟢\" : \"⚪\"} ${s.name} (${s.phone})`,\n `start_session:${s.name}`\n )]\n );\n await ctx.reply(\"📋 Выбери сессию для запуска:\", Markup.inlineKeyboard(buttons));\n });\n\n // Start a specific session\n bot.action(/^start_session:(.+)$/, async (ctx) => {\n const name = ctx.match![1];\n await ctx.answerCbQuery();\n await setSessionActive(name, true);\n await ctx.reply(\n `✅ Сессия *${name}* активирована!\\\\nВоркер подхватит её при следующем цикле \\\$каждые 3 мин\\\$\\\\.`,\n { parse_mode: \"MarkdownV2\", ...Markup.inlineKeyboard([\n [Markup.button.callback(\"⏹ Остановить\", `stop_session:${name}`)],\n [Markup.button.callback(\"📊 Статус\", `status_session:${name}`)],\n [Markup.button.callback(\"🏠 Меню\", \"menu\")],\n ])}\n );\n });\n\n // Stop session\n bot.action(/^stop_session:(.+)$/, async (ctx) => {\n const name = ctx.match![1];\n await ctx.answerCbQuery(\"Остановлено\");\n await setSessionActive(name, false);\n // Clear spamming flag\n await setState(`spam_active:${name}`, \"false\");\n await ctx.reply(`⏹ Сессия *${name}* остановлена\\\\.`, {\n parse_mode: \"MarkdownV2\",\n ...Markup.inlineKeyboard([[Markup.button.callback(\"🏠 Меню\", \"menu\")]]),\n });\n });\n\n // Session status\n bot.action(/^status_session:(.+)$/, async (ctx) => {\n const name = ctx.match![1];\n await ctx.answerCbQuery();\n const s = await getSession(name);\n if (!s) {\n await ctx.reply(\"❌ Сессия не найдена\");\n return;\n }\n await ctx.reply(\n `📊 *Сессия:* ${s.name}\\n` +\n `*Статус:* ${s.is_active ? \"🟢 Активна\" : \"⚪ Остановлена\"}\\n` +\n `*Циклов выполнено:* ${s.cycles_count}\\n` +\n `*Последняя проверка:* ${s.last_check || \"—\"}\\n` +\n `*Телефон:* ${s.phone}`,\n { parse_mode: \"Markdown\", ...Markup.inlineKeyboard([\n [\n s.is_active\n ? Markup.button.callback(\"⏹ Остановить\", `stop_session:${name}`)\n : Markup.button.callback(\"▶️ Запустить\", `start_session:${name}`),\n ],\n [Markup.button.callback(\"🏠 Меню\", \"menu\")],\n ])}\n );\n });\n\n // Status all\n bot.action(\"status_all\", async (ctx) => {\n await ctx.answerCbQuery();\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await ctx.reply(\"❌ Нет сессий\");\n return;\n }\n let text = \"📊 *Все сессии:*\\n\\n\";\n for (const s of sessions) {\n text += `${s.is_active ? \"🟢\" : \"⚪\"} *${s.name}* — ${s.phone}\\n`;\n text += ` Циклов: ${s.cycles_count} | Последняя: ${s.last_check || \"—\"}\\n\\n`;\n }\n await ctx.reply(text, {\n parse_mode: \"Markdown\",\n ...Markup.inlineKeyboard([[Markup.button.callback(\"🏠 Меню\", \"menu\")]]),\n });\n });\n\n // Delete session\n bot.action(\"delete_session\", async (ctx) => {\n await ctx.answerCbQuery();\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await ctx.reply(\"❌ Нет сессий для удаления\");\n return;\n }\n const buttons = sessions.map(s =>\n [Markup.button.callback(`🗑 ${s.name} (${s.phone})`, `confirm_delete:${s.name}`)]\n );\n await ctx.reply(\"Выбери сессию для удаления:\", Markup.inlineKeyboard(buttons));\n });\n\n bot.action(/^confirm_delete:(.+)$/, async (ctx) => {\n const name = ctx.match![1];\n await ctx.answerCbQuery();\n await deleteSession(name);\n await ctx.reply(`🗑 Сессия *${name}* удалена\\\\.`, {\n parse_mode: \"MarkdownV2\",\n ...Markup.inlineKeyboard([[Markup.button.callback(\"🏠 Меню\", \"menu\")]]),\n });\n });\n\n // Menu\n bot.action(\"menu\", async (ctx) => {\n await ctx.answerCbQuery();\n delete userState[ctx.from!.id];\n await ctx.reply(\"Выбери действие:\", Markup.inlineKeyboard([\n [Markup.button.callback(\"📱 Создать новую сессию\", \"new_session\")],\n [Markup.button.callback(\"▶️ Запустить сохранённую сессию\", \"list_sessions\")],\n [Markup.button.callback(\"📊 Статус всех сессий\", \"status_all\")],\n [Markup.button.callback(\"🗑 Удалить сессию\", \"delete_session\")],\n ]));\n });\n\n // Handle text messages for session creation flow\n bot.on(\"text\", async (ctx) => {\n const state = userState[ctx.from!.id];\n if (!state) return;\n\n const text = ctx.message.text.trim();\n\n switch (state.step) {\n case \"name\":\n if (!/^[a-zA-Z0-9_-]+$/.test(text)) {\n await ctx.reply(\"❌ Название может содержать только латиницу, цифры, - и _. Попробуй снова:\");\n return;\n }\n state.data.name = text;\n state.step = \"api_id\";\n await ctx.reply(\"🔑 Введи API ID (число с my.telegram.org):\");\n break;\n\n case \"api_id\":\n const apiId = parseInt(text);\n if (isNaN(apiId)) {\n await ctx.reply(\"❌ API ID должен быть числом. Попробуй снова:\");\n return;\n }\n state.data.apiId = apiId;\n state.step = \"api_hash\";\n await ctx.reply(\"🔐 Введи API Hash (строка с my.telegram.org):\");\n break;\n\n case \"api_hash\":\n state.data.apiHash = text;\n state.step = \"phone\";\n await ctx.reply(\"📱 Введи номер телефона (формат: +79991234567):\");\n break;\n\n case \"phone\":\n if (!/^\\+\\d{10,15}$/.test(text)) {\n await ctx.reply(\"❌ Формат: +79991234567. Попробуй снова:\");\n return;\n }\n state.data.phone = text;\n state.step = \"waiting_code\";\n await ctx.reply(\"⏳ Отправляю запрос на вход... Подожди.\");\n\n // Store auth data so worker can pick it up\n await setState(\"pending_auth\", JSON.stringify(state.data));\n await setState(\"auth_step\", \"send_code\");\n await ctx.reply(\n \"📨 Запрос отправлен! Когда получишь код — введи его сюда.\\n\" +\n \"⚠️ Код будет обработан при следующем цикле воркера (до 30 сек).\"\n );\n state.step = \"code\";\n break;\n\n case \"code\":\n state.data.code = text;\n await setState(\"pending_auth\", JSON.stringify(state.data));\n await setState(\"auth_step\", \"sign_in\");\n state.step = \"waiting_signin\";\n await ctx.reply(\"⏳ Вхожу в аккаунт... Подожди.\");\n break;\n\n case \"2fa\":\n state.data.password = text;\n await setState(\"pending_auth\", JSON.stringify(state.data));\n await setState(\"auth_step\", \"sign_in_2fa\");\n state.step = \"waiting_2fa\";\n await ctx.reply(\"⏳ Вхожу с 2FA... Подожди.\");\n break;\n\n default:\n await ctx.reply(\"Используй /start для начала.\");\n }\n });\n\n return bot;\n}\n\n// Export userState so worker can update steps\nexport { userState };\n",[177],"pulls","branches","forks","envVars",{"_190":67,"_192":67},"connections",{"_190":67,"_191":67},"count","unfilledCount","emptyCount",{"_47":176,"_37":177,"_35":178,"_144":-5,"_45":46,"_44":179,"_146":63,"_42":215,"_13":67,"_38":148,"_40":181,"_29":30,"_150":-5,"_200":216,"_32":217},{"_47":173,"_37":33,"_35":36,"_144":-5,"_45":46,"_44":14,"_146":63,"_42":212,"_13":67,"_38":39,"_40":41,"_29":30,"_150":-5,"_200":213,"_32":214},{"_47":166,"_37":167,"_35":168,"_144":-5,"_45":46,"_44":169,"_146":63,"_42":209,"_13":67,"_38":148,"_40":171,"_29":30,"_150":-5,"_200":210,"_32":211},{"_47":159,"_37":160,"_35":161,"_144":-5,"_45":46,"_44":162,"_146":63,"_42":206,"_13":67,"_38":148,"_40":164,"_29":30,"_150":-5,"_200":207,"_32":208},{"_47":152,"_37":153,"_35":61,"_144":-5,"_45":46,"_44":154,"_146":63,"_42":203,"_13":67,"_38":156,"_40":157,"_29":30,"_150":-5,"_200":204,"_32":205},{"_47":141,"_37":142,"_35":143,"_144":-5,"_45":46,"_44":145,"_146":63,"_42":199,"_13":67,"_38":148,"_40":149,"_29":30,"_150":-5,"_200":201,"_32":202},["D",1779979542449],"children",[],[142],["D",1779979549782],[],[153],["D",1779979459978],[],[160],["D",1779979557445],[],[167],["D",1779979559991],[],[33],["D",1779979497299],[],[177],["D",1779979442780],["D",1789495880338],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_19":59,"_109":110,"_111":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_132":256,"_257":258,"_259":260,"_261":30,"_262":30,"_263":30,"_264":63,"_265":-5,"_266":-7,"_267":-7,"_268":67,"_269":30,"_270":30,"_271":-5,"_272":30,"_273":30,"_274":30,"_275":-5},"ENV",{"_227":228,"_229":230,"_231":94,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255},"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 · v6