[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_306":307,"_308":309},"routes/_app.x.$handle.$name",{"_103":102,"_37":49,"_112":93,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":63,"_130":-5,"_131":-5,"_132":133},"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",13,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","38b225fa-a898-4047-b98c-b8f5f3f5c205","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","api.ts","latestPath","fileId","48cf0366-5aa4-11f1-93ce-ee650bb23af1","name","fileType","http","content","// Main HTTP webhook endpoint for Telegram Bot\nimport { handleUpdate } from \"./telegram-bot.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\")!;\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n\n // GET — health check + webhook setup\n if (req.method === \"GET\") {\n if (url.searchParams.get(\"setup\") === \"1\" && BOT_TOKEN) {\n const webhookUrl = `${url.origin}${url.pathname}`;\n const resp = await fetch(\n `https://api.telegram.org/bot${BOT_TOKEN}/setWebhook?url=${encodeURIComponent(webhookUrl)}`\n );\n const data = await resp.json();\n return Response.json({ webhook_setup: data, webhook_url: webhookUrl });\n }\n\n return new Response(\n \"🤖 Jobseo Monitor Bot is running!\\n\\n\" +\n \"• Add ?setup=1 to this URL to register the Telegram webhook\\n\" +\n \"• Set BOT_TOKEN in environment variables\\n\" +\n \"• Then open your bot in Telegram and send /start\",\n { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } }\n );\n }\n\n // POST — Telegram sends updates here\n if (req.method === \"POST\") {\n try {\n const update = await req.json();\n console.log(\"TG Update:\", JSON.stringify(update).slice(0, 300));\n\n if (!BOT_TOKEN) {\n return Response.json({ error: \"BOT_TOKEN not set\" }, { status: 500 });\n }\n\n // Don't await — respond quickly to Telegram\n handleUpdate(BOT_TOKEN, update).catch(e =>\n console.error(\"handleUpdate error:\", e)\n );\n\n return Response.json({ ok: true });\n } catch (e: any) {\n console.error(\"Webhook error:\", e);\n return Response.json({ error: e.message }, { status: 500 });\n }\n }\n\n return new Response(\"Method not allowed\", { status: 405 });\n}\n","createdAt",["D",1779979706778],"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",{"_103":102,"_111":107},"org",{"_103":102,"_104":105,"_106":107,"_19":59,"_108":109,"_110":30},"branch",{"_13":14,"_37":93,"_47":46,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":49,"_101":102},"isOwned","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":301,"_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":302,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":303,"_88":304,"_90":305,"_92":30},"tree",[248,249,250,251,252,253,254,255,256,257,258,259,260],"files",[248,249,250,251,252,253,254,255,256,257,258,259,260],"counts",{"_238":67,"_239":196,"_240":67,"_241":242,"_243":244},"contents",[134,135,136,137,138,139,140,141,142,143,144,145,146],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":231,"_37":232,"_35":233,"_150":-5,"_45":46,"_44":234,"_152":63,"_42":235,"_13":67,"_38":26,"_40":236,"_29":30,"_156":-5,"_32":237},{"_47":228,"_37":33,"_35":36,"_150":-5,"_45":46,"_44":14,"_152":63,"_42":229,"_13":67,"_38":39,"_40":41,"_29":30,"_156":-5,"_32":230},{"_47":221,"_37":222,"_35":223,"_150":-5,"_45":46,"_44":224,"_152":63,"_42":225,"_13":67,"_38":154,"_40":226,"_29":30,"_156":-5,"_32":227},{"_47":214,"_37":215,"_35":216,"_150":-5,"_45":46,"_44":217,"_152":63,"_42":218,"_13":67,"_38":183,"_40":219,"_29":30,"_156":-5,"_32":220},{"_47":207,"_37":208,"_35":209,"_150":-5,"_45":46,"_44":210,"_152":63,"_42":211,"_13":67,"_38":183,"_40":212,"_29":30,"_156":-5,"_32":213},{"_47":200,"_37":201,"_35":202,"_150":-5,"_45":46,"_44":203,"_152":63,"_42":204,"_13":67,"_38":154,"_40":205,"_29":30,"_156":-5,"_32":206},{"_47":193,"_37":194,"_35":195,"_150":-5,"_45":46,"_44":196,"_152":63,"_42":197,"_13":67,"_38":154,"_40":198,"_29":30,"_156":-5,"_32":199},{"_47":186,"_37":187,"_35":188,"_150":-5,"_45":46,"_44":189,"_152":63,"_42":190,"_13":67,"_38":39,"_40":191,"_29":30,"_156":-5,"_32":192},{"_47":178,"_37":179,"_35":180,"_150":-5,"_45":46,"_44":181,"_152":63,"_42":182,"_13":67,"_38":183,"_40":184,"_29":30,"_156":-5,"_32":185},{"_47":171,"_37":172,"_35":173,"_150":-5,"_45":46,"_44":174,"_152":63,"_42":175,"_13":67,"_38":154,"_40":176,"_29":30,"_156":-5,"_32":177},{"_47":164,"_37":165,"_35":166,"_150":-5,"_45":46,"_44":167,"_152":63,"_42":168,"_13":67,"_38":154,"_40":169,"_29":30,"_156":-5,"_32":170},{"_47":158,"_37":159,"_35":61,"_150":-5,"_45":46,"_44":160,"_152":63,"_42":161,"_13":67,"_38":39,"_40":162,"_29":30,"_156":-5,"_32":163},{"_47":147,"_37":148,"_35":149,"_150":-5,"_45":46,"_44":151,"_152":63,"_42":153,"_13":67,"_38":154,"_40":155,"_29":30,"_156":-5,"_32":157},"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",[148],"eb3b4a70-5aa3-11f1-8fee-ee650bb23af1","webhook.ts",4,["D",1779979549782],"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",[159],"0344fe5e-5aa4-11f1-ac25-ee650bb23af1","userbot.ts","0344ff3a-5aa4-11f1-ac25-ee650bb23af1",8,["D",1779979590109],"// gramjs (grm) — MTProto client for Deno\n// Handles: auth flow, checking jobseo_bot, sending notifications\nimport { TelegramClient, Api } from \"npm:telegram@2.26.22\";\nimport { StringSession } from \"npm:telegram@2.26.22/sessions/index.js\";\n\nconst JOBSEO_BOT = \"jobseo_bot\";\n\ninterface AuthResult {\n success: boolean;\n stringSession?: string;\n error?: string;\n needs2FA?: boolean;\n phoneCodeHash?: string;\n}\n\n// Step 1: Send code request\nexport async function sendCode(apiId: number, apiHash: string, phone: string): Promise {\n const session = new StringSession(\"\");\n const client = new TelegramClient(session, apiId, apiHash, {\n connectionRetries: 3,\n });\n \n try {\n await client.connect();\n const result = await client.sendCode(\n { apiId, apiHash },\n phone\n );\n const savedSession = client.session.save() as unknown as string;\n await client.disconnect();\n \n return {\n success: true,\n phoneCodeHash: result.phoneCodeHash,\n stringSession: savedSession,\n };\n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n return { success: false, error: e.message || String(e) };\n }\n}\n\n// Step 2: Sign in with code\nexport async function signIn(\n apiId: number,\n apiHash: string,\n phone: string,\n code: string,\n phoneCodeHash: string,\n savedSession: string\n): Promise {\n const session = new StringSession(savedSession);\n const client = new TelegramClient(session, apiId, apiHash, {\n connectionRetries: 3,\n });\n \n try {\n await client.connect();\n await client.invoke(\n new Api.auth.SignIn({\n phoneNumber: phone,\n phoneCodeHash: phoneCodeHash,\n phoneCode: code,\n })\n );\n const finalSession = client.session.save() as unknown as string;\n await client.disconnect();\n return { success: true, stringSession: finalSession };\n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n if (e.errorMessage === \"SESSION_PASSWORD_NEEDED\") {\n const tempSession = client.session.save() as unknown as string;\n return { success: false, needs2FA: true, stringSession: savedSession };\n }\n return { success: false, error: e.message || String(e) };\n }\n}\n\n// Step 2b: Sign in with 2FA password\nexport async function signIn2FA(\n apiId: number,\n apiHash: string,\n password: string,\n savedSession: string\n): Promise {\n const session = new StringSession(savedSession);\n const client = new TelegramClient(session, apiId, apiHash, {\n connectionRetries: 3,\n });\n \n try {\n await client.connect();\n await client.signInWithPassword(\n { apiId, apiHash },\n { password: () => password }\n );\n const finalSession = client.session.save() as unknown as string;\n await client.disconnect();\n return { success: true, stringSession: finalSession };\n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n return { success: false, error: e.message || String(e) };\n }\n}\n\n// Get username of logged-in account\nexport async function getMe(apiId: number, apiHash: string, stringSession: string): Promise<{ username: string | null; firstName: string }> {\n const session = new StringSession(stringSession);\n const client = new TelegramClient(session, apiId, apiHash, { connectionRetries: 3 });\n \n try {\n await client.connect();\n const me = await client.getMe() as any;\n await client.disconnect();\n return { username: me.username || null, firstName: me.firstName || \"\" };\n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n return { username: null, firstName: \"\" };\n }\n}\n\n// Check jobseo_bot for tasks\nexport interface CheckResult {\n hasTasks: boolean;\n error?: string;\n buttons?: string[];\n}\n\nexport async function checkJobseoBot(\n apiId: number,\n apiHash: string,\n stringSession: string\n): Promise {\n const session = new StringSession(stringSession);\n const client = new TelegramClient(session, apiId, apiHash, { connectionRetries: 3 });\n \n try {\n await client.connect();\n \n // Get the jobseo_bot entity\n const entity = await client.getEntity(JOBSEO_BOT);\n \n // Get recent messages to find buttons\n const messages = await client.getMessages(entity, { limit: 5 });\n \n // Look for the \"Приступить к заданию ✍️\" button in recent messages\n let targetMsg: any = null;\n let targetButton: any = null;\n \n for (const msg of messages) {\n if (msg.replyMarkup && \"rows\" in msg.replyMarkup) {\n for (const row of (msg.replyMarkup as any).rows) {\n for (const btn of row.buttons) {\n if (btn.text && btn.text.includes(\"Приступить к заданию\")) {\n targetMsg = msg;\n targetButton = btn;\n }\n }\n }\n }\n }\n \n if (!targetButton || !targetMsg) {\n // Try sending /start first, then look for the button\n await client.sendMessage(entity, { message: \"/start\" });\n await new Promise(r => setTimeout(r, 3000));\n \n const newMessages = await client.getMessages(entity, { limit: 5 });\n for (const msg of newMessages) {\n if (msg.replyMarkup && \"rows\" in msg.replyMarkup) {\n for (const row of (msg.replyMarkup as any).rows) {\n for (const btn of row.buttons) {\n if (btn.text && btn.text.includes(\"Приступить к заданию\")) {\n targetMsg = msg;\n targetButton = btn;\n }\n }\n }\n }\n }\n }\n \n if (!targetButton || !targetMsg) {\n await client.disconnect();\n return { hasTasks: false, error: \"Кнопка 'Приступить к заданию' не найдена\" };\n }\n \n // Click the button\n if (targetButton.data) {\n // Inline button — use callback\n await client.invoke(\n new Api.messages.GetBotCallbackAnswer({\n peer: entity,\n msgId: targetMsg.id,\n data: targetButton.data,\n })\n );\n } else {\n // Reply keyboard button — send text\n await client.sendMessage(entity, { message: targetButton.text });\n }\n \n // Wait for response\n await new Promise(r => setTimeout(r, 5000));\n \n // Read response\n const responseMessages = await client.getMessages(entity, { limit: 3 });\n const latestMsg = responseMessages[0];\n \n const allButtons: string[] = [];\n if (latestMsg?.replyMarkup && \"rows\" in latestMsg.replyMarkup) {\n for (const row of (latestMsg.replyMarkup as any).rows) {\n for (const btn of row.buttons) {\n if (btn.text) allButtons.push(btn.text);\n }\n }\n }\n \n // Check if only \"Назад в меню\" and/or \"Доп. задания\" — no tasks\n const noTaskButtons = [\"Назад в меню\", \"Доп. задания\"];\n const hasOnlyNoTaskButtons = allButtons.length > 0 && \n allButtons.every(b => noTaskButtons.some(ntb => b.includes(ntb)));\n \n if (allButtons.length === 0 || hasOnlyNoTaskButtons) {\n // No tasks — press \"Назад в меню\" if it exists\n const backButton = allButtons.find(b => b.includes(\"Назад в меню\"));\n if (backButton) {\n await client.sendMessage(entity, { message: backButton });\n }\n await client.disconnect();\n return { hasTasks: false, buttons: allButtons };\n }\n \n // Tasks found!\n await client.disconnect();\n return { hasTasks: true, buttons: allButtons };\n \n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n return { hasTasks: false, error: e.message || String(e) };\n }\n}\n\n// Send notification message from userbot\nexport async function sendNotification(\n apiId: number,\n apiHash: string,\n stringSession: string,\n targetUsername: string,\n message: string\n): Promise {\n const session = new StringSession(stringSession);\n const client = new TelegramClient(session, apiId, apiHash, { connectionRetries: 3 });\n \n try {\n await client.connect();\n const entity = await client.getEntity(targetUsername);\n await client.sendMessage(entity, { message });\n await client.disconnect();\n return true;\n } catch (e: any) {\n try { await client.disconnect(); } catch {}\n console.error(`Failed to send notification to ${targetUsername}:`, e.message);\n return false;\n }\n}\n",[165],"1e9e61a4-5aa4-11f1-9b17-ee650bb23af1","telegram-bot.ts","1e9e6294-5aa4-11f1-9b17-ee650bb23af1",10,["D",1779979635994],"// Управляющий Telegram-бот (webhook mode)\n// Handles: session creation, auth flow, start/stop/status\nimport {\n getSessions, getSession, setSessionActive, deleteSession, saveSession,\n setAuthState, getAuthState, clearAuthState, setSpamActive,\n type AuthState,\n} from \"./database.ts\";\nimport { sendCode, signIn, signIn2FA, getMe } from \"./userbot.ts\";\n\nconst ADMIN_USERNAME = \"mqppr\";\n\n// Bot API helper\nasync function callApi(token: string, method: string, body?: any) {\n const resp = await fetch(`https://api.telegram.org/bot${token}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: body ? JSON.stringify(body) : undefined,\n });\n return resp.json();\n}\n\nasync function sendMessage(token: string, chatId: number, text: string, replyMarkup?: any) {\n return callApi(token, \"sendMessage\", {\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n ...(replyMarkup ? { reply_markup: replyMarkup } : {}),\n });\n}\n\nasync function answerCallback(token: string, callbackQueryId: string, text?: string) {\n return callApi(token, \"answerCallbackQuery\", {\n callback_query_id: callbackQueryId,\n text: text || \"\",\n });\n}\n\n// Main menu keyboard\nfunction mainMenuKb() {\n return {\n inline_keyboard: [\n [{ text: \"📱 Создать новую сессию\", callback_data: \"new_session\" }],\n [{ text: \"▶️ Запустить сохранённую сессию\", callback_data: \"list_sessions\" }],\n [{ text: \"📊 Статус всех сессий\", callback_data: \"status_all\" }],\n [{ text: \"🗑 Удалить сессию\", callback_data: \"delete_session\" }],\n ],\n };\n}\n\nexport async function handleUpdate(token: string, update: any) {\n // Handle callback queries\n if (update.callback_query) {\n const cb = update.callback_query;\n const username = cb.from?.username;\n const chatId = cb.message?.chat?.id;\n \n if (username !== ADMIN_USERNAME) {\n await answerCallback(token, cb.id, \"⛔ Доступ запрещён\");\n return;\n }\n \n const data = cb.data;\n await answerCallback(token, cb.id);\n \n if (data === \"new_session\") {\n await setAuthState({ chat_id: chatId, step: \"name\" });\n await sendMessage(token, chatId, \"📝 Введи название сессии (например: myaccount):\");\n return;\n }\n \n if (data === \"list_sessions\") {\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await sendMessage(token, chatId, \"❌ Нет сохранённых сессий. Создай новую.\", mainMenuKb());\n return;\n }\n const buttons = sessions.map(s => ([{\n text: `${s.is_active ? \"🟢\" : \"⚪\"} ${s.name} (${s.phone})`,\n callback_data: `start:${s.name}`,\n }]));\n buttons.push([{ text: \"🏠 Меню\", callback_data: \"menu\" }]);\n await sendMessage(token, chatId, \"📋 Выбери сессию:\", { inline_keyboard: buttons });\n return;\n }\n \n if (data?.startsWith(\"start:\")) {\n const name = data.slice(6);\n await setSessionActive(name, true);\n await sendMessage(token, chatId,\n `✅ Сессия ${name} активирована!\\nВоркер подхватит при следующем цикле (каждые 3 мин).`, {\n inline_keyboard: [\n [{ text: \"⏹ Остановить\", callback_data: `stop:${name}` }],\n [{ text: \"📊 Статус\", callback_data: `status:${name}` }],\n [{ text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n });\n return;\n }\n \n if (data?.startsWith(\"stop:\")) {\n const name = data.slice(5);\n await setSessionActive(name, false);\n await setSpamActive(name, false);\n await sendMessage(token, chatId, `⏹ Сессия ${name} остановлена.`, {\n inline_keyboard: [\n [{ text: \"▶️ Запустить снова\", callback_data: `start:${name}` }],\n [{ text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n });\n return;\n }\n \n if (data?.startsWith(\"status:\")) {\n const name = data.slice(7);\n const s = await getSession(name);\n if (!s) {\n await sendMessage(token, chatId, \"❌ Сессия не найдена.\");\n return;\n }\n await sendMessage(token, chatId,\n `📊 Сессия: ${s.name}\\n` +\n `Статус: ${s.is_active ? \"🟢 Активна\" : \"⚪ Остановлена\"}\\n` +\n `Циклов: ${s.cycles_count}\\n` +\n `Последняя проверка: ${s.last_check || \"—\"}\\n` +\n `Телефон: ${s.phone}`, {\n inline_keyboard: [\n [s.is_active\n ? { text: \"⏹ Остановить\", callback_data: `stop:${s.name}` }\n : { text: \"▶️ Запустить\", callback_data: `start:${s.name}` }],\n [{ text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n });\n return;\n }\n \n if (data === \"status_all\") {\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await sendMessage(token, chatId, \"❌ Нет сессий.\", mainMenuKb());\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 sendMessage(token, chatId, text, mainMenuKb());\n return;\n }\n \n if (data === \"delete_session\") {\n const sessions = await getSessions();\n if (sessions.length === 0) {\n await sendMessage(token, chatId, \"❌ Нет сессий для удаления.\", mainMenuKb());\n return;\n }\n const buttons = sessions.map(s => ([{\n text: `🗑 ${s.name} (${s.phone})`,\n callback_data: `del:${s.name}`,\n }]));\n buttons.push([{ text: \"🏠 Меню\", callback_data: \"menu\" }]);\n await sendMessage(token, chatId, \"Выбери сессию для удаления:\", { inline_keyboard: buttons });\n return;\n }\n \n if (data?.startsWith(\"del:\")) {\n const name = data.slice(4);\n await deleteSession(name);\n await sendMessage(token, chatId, `🗑 Сессия ${name} удалена.`, mainMenuKb());\n return;\n }\n \n if (data === \"menu\") {\n await clearAuthState(chatId);\n await sendMessage(token, chatId, \"👋 Выбери действие:\", mainMenuKb());\n return;\n }\n \n return;\n }\n \n // Handle text messages\n if (update.message?.text) {\n const msg = update.message;\n const chatId = msg.chat.id;\n const username = msg.from?.username;\n const text = msg.text.trim();\n \n if (username !== ADMIN_USERNAME) {\n await sendMessage(token, chatId, \"⛔ Доступ запрещён. Бот только для @\" + ADMIN_USERNAME);\n return;\n }\n \n // /start command\n if (text === \"/start\") {\n await clearAuthState(chatId);\n await sendMessage(token, chatId, \"👋 Привет! Выбери действие:\", mainMenuKb());\n return;\n }\n \n // Check auth flow\n const auth = await getAuthState(chatId);\n if (!auth) return;\n \n switch (auth.step) {\n case \"name\": {\n if (!/^[a-zA-Z0-9_-]+$/.test(text)) {\n await sendMessage(token, chatId, \"❌ Только латиница, цифры, - и _. Попробуй снова:\");\n return;\n }\n await setAuthState({ chat_id: chatId, step: \"api_id\", session_name: text });\n await sendMessage(token, chatId, \"🔑 Введи API ID (число с my.telegram.org):\");\n break;\n }\n \n case \"api_id\": {\n const apiId = parseInt(text);\n if (isNaN(apiId)) {\n await sendMessage(token, chatId, \"❌ API ID должен быть числом. Попробуй снова:\");\n return;\n }\n await setAuthState({ chat_id: chatId, step: \"api_hash\", api_id: apiId });\n await sendMessage(token, chatId, \"🔐 Введи API Hash (строка с my.telegram.org):\");\n break;\n }\n \n case \"api_hash\": {\n await setAuthState({ chat_id: chatId, step: \"phone\", api_hash: text });\n await sendMessage(token, chatId, \"📱 Введи номер телефона (формат: +79991234567):\");\n break;\n }\n \n case \"phone\": {\n if (!/^\\+\\d{10,15}$/.test(text)) {\n await sendMessage(token, chatId, \"❌ Формат: +79991234567. Попробуй снова:\");\n return;\n }\n await setAuthState({ chat_id: chatId, step: \"sending_code\", phone: text });\n await sendMessage(token, chatId, \"⏳ Отправляю код...\");\n \n const result = await sendCode(auth.api_id!, auth.api_hash!, text);\n \n if (!result.success) {\n await sendMessage(token, chatId, `❌ Ошибка: ${result.error}`, mainMenuKb());\n await clearAuthState(chatId);\n return;\n }\n \n await setAuthState({\n chat_id: chatId,\n step: \"code\",\n phone_code_hash: result.phoneCodeHash!,\n string_session: result.stringSession!,\n });\n await sendMessage(token, chatId, \"📨 Код отправлен! Введи код из Telegram:\");\n break;\n }\n \n case \"code\": {\n await sendMessage(token, chatId, \"⏳ Вхожу в аккаунт...\");\n \n const result = await signIn(\n auth.api_id!, auth.api_hash!, auth.phone!, text,\n auth.phone_code_hash!, auth.string_session!\n );\n \n if (result.needs2FA) {\n await setAuthState({ chat_id: chatId, step: \"2fa\" });\n await sendMessage(token, chatId, \"🔒 Аккаунт защищён 2FA. Введи пароль:\");\n return;\n }\n \n if (!result.success) {\n await sendMessage(token, chatId, `❌ Ошибка: ${result.error}\\nПопробуй код ещё раз:`);\n return;\n }\n \n // Success! Save session\n await saveSession({\n name: auth.session_name!,\n api_id: auth.api_id!,\n api_hash: auth.api_hash!,\n phone: auth.phone!,\n string_session: result.stringSession!,\n });\n \n await clearAuthState(chatId);\n \n const me = await getMe(auth.api_id!, auth.api_hash!, result.stringSession!);\n await sendMessage(token, chatId,\n `✅ Сессия ${auth.session_name} сохранена и активирована!\\n` +\n `👤 Аккаунт: ${me.firstName} ${me.username ? \"@\" + me.username : \"\"}\\n` +\n `🚀 Воркер начнёт мониторинг при следующем цикле.`, {\n inline_keyboard: [\n [{ text: \"⏹ Остановить\", callback_data: `stop:${auth.session_name}` }],\n [{ text: \"📊 Статус\", callback_data: `status:${auth.session_name}` }],\n [{ text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n });\n break;\n }\n \n case \"2fa\": {\n await sendMessage(token, chatId, \"⏳ Вхожу с 2FA...\");\n \n const result = await signIn2FA(\n auth.api_id!, auth.api_hash!, text, auth.string_session!\n );\n \n if (!result.success) {\n await sendMessage(token, chatId, `❌ Ошибка: ${result.error}\\nПопробуй пароль ещё раз:`);\n return;\n }\n \n await saveSession({\n name: auth.session_name!,\n api_id: auth.api_id!,\n api_hash: auth.api_hash!,\n phone: auth.phone!,\n string_session: result.stringSession!,\n });\n \n await clearAuthState(chatId);\n \n const me = await getMe(auth.api_id!, auth.api_hash!, result.stringSession!);\n await sendMessage(token, chatId,\n `✅ Сессия ${auth.session_name} сохранена и активирована!\\n` +\n `👤 Аккаунт: ${me.firstName} ${me.username ? \"@\" + me.username : \"\"}\\n` +\n `🚀 Воркер начнёт мониторинг при следующем цикле.`, {\n inline_keyboard: [\n [{ text: \"⏹ Остановить\", callback_data: `stop:${auth.session_name}` }],\n [{ text: \"📊 Статус\", callback_data: `status:${auth.session_name}` }],\n [{ text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n });\n break;\n }\n }\n }\n}\n",[172],"39ba3b7a-5aa4-11f1-93ce-ee650bb23af1","monitor.ts","39ba3c38-5aa4-11f1-93ce-ee650bb23af1",12,["D",1779979681474],"interval","// Cron monitor — runs every 3 minutes\n// Checks active sessions for tasks in @jobseo_bot\nimport {\n getActiveSessions, incrementCycles, setSpamActive,\n} from \"./database.ts\";\nimport { checkJobseoBot, sendNotification, getMe } from \"./userbot.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\")!;\nconst ADMIN_USERNAME = \"mqppr\";\nconst NOTIFY_FOR_MQPPR = \"SetkaGar\";\nconst NOTIFY_DEFAULT = \"mqppr\";\n\nasync function notifyAdmin(text: string) {\n try {\n const resp = await fetch(`https://api.telegram.org/bot${BOT_TOKEN}/getUpdates?limit=5&offset=-5`);\n const data = await resp.json();\n let chatId: number | null = null;\n for (const upd of (data.result || []).reverse()) {\n const from = upd.message?.from?.username || upd.callback_query?.from?.username;\n if (from === ADMIN_USERNAME) {\n chatId = upd.message?.chat?.id || upd.callback_query?.message?.chat?.id;\n break;\n }\n }\n if (chatId) {\n await fetch(`https://api.telegram.org/bot${BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\" }),\n });\n }\n } catch (e) {\n console.error(\"notifyAdmin failed:\", e);\n }\n}\n\nexport default async function (_interval: Interval) {\n if (!BOT_TOKEN) {\n console.log(\"BOT_TOKEN not set\");\n return;\n }\n\n const sessions = await getActiveSessions();\n if (sessions.length === 0) {\n console.log(\"No active sessions\");\n return;\n }\n\n for (const session of sessions) {\n console.log(`[${session.name}] Checking @jobseo_bot...`);\n\n try {\n const result = await checkJobseoBot(\n session.api_id, session.api_hash, session.string_session\n );\n\n await incrementCycles(session.name);\n\n if (result.error) {\n console.error(`[${session.name}] Error: ${result.error}`);\n await notifyAdmin(`⚠️ [${session.name}] Ошибка: ${result.error}`);\n continue;\n }\n\n if (result.hasTasks) {\n console.log(`[${session.name}] 🔥 TASKS FOUND!`);\n\n const me = await getMe(session.api_id, session.api_hash, session.string_session);\n const target = me.username === ADMIN_USERNAME ? NOTIFY_FOR_MQPPR : NOTIFY_DEFAULT;\n\n await sendNotification(\n session.api_id, session.api_hash, session.string_session,\n target,\n \"🔥 НОВЫЕ ЗАДАНИЯ В JOBSEO!\\nЗайди в @jobseo_bot → Приступить к заданию\"\n );\n\n await setSpamActive(session.name, true);\n\n await notifyAdmin(\n `✅ Задания найдены!\\nСессия: ${session.name}\\nКнопки: ${result.buttons?.join(\", \") || \"—\"}\\nУведомление → @${target}`\n );\n } else {\n console.log(`[${session.name}] No tasks`);\n }\n } catch (e: any) {\n console.error(`[${session.name}] CRITICAL:`, e);\n await notifyAdmin(`🔴 Ошибка [${session.name}]: ${e.message}`);\n }\n }\n}\n",[179],"05429ef0-5aa4-11f1-88b5-ee650bb23af1","main.ts","05429fb8-5aa4-11f1-88b5-ee650bb23af1",9,["D",1779979593442],"import { Hono } from \"npm:hono\";\nimport {\n getSessions,\n getSession,\n saveSession,\n setSessionActive,\n deleteSession,\n incrementCycles,\n} from \"./db.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\") || \"\";\nconst ADMIN_USERNAME = \"mqppr\";\n\n// In-memory conversation state (per chat)\nconst conversations: Record }> = {};\n\nasync function tg(method: string, body: any) {\n const r = await fetch(`https://api.telegram.org/bot${BOT_TOKEN}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n return r.json();\n}\n\nfunction isAdmin(username?: string) {\n return username === ADMIN_USERNAME;\n}\n\nasync function send(chatId: number, text: string, reply_markup?: any) {\n await tg(\"sendMessage\", { chat_id: chatId, text, parse_mode: \"HTML\", reply_markup });\n}\n\nasync function handleStart(chatId: number) {\n await send(chatId, \"🤖 Jobseo Monitor\\n\\nВыбери действие:\", {\n inline_keyboard: [\n [{ text: \"📱 Новая сессия\", callback_data: \"new_session\" }],\n [{ text: \"📋 Мои сессии\", callback_data: \"list_sessions\" }],\n [{ text: \"📊 Статус\", callback_data: \"status\" }],\n ],\n });\n}\n\nasync function handleMessage(msg: any) {\n const chatId = msg.chat.id;\n const text = msg.text?.trim() || \"\";\n const username = msg.from?.username;\n\n if (!isAdmin(username)) {\n return send(chatId, \"⛔ Нет доступа.\");\n }\n\n if (text === \"/start\") {\n delete conversations[chatId];\n return handleStart(chatId);\n }\n\n const conv = conversations[chatId];\n if (!conv) return handleStart(chatId);\n\n // === FLOW: Create session ===\n if (conv.step === \"name\") {\n const name = text.replace(/[^a-zA-Z0-9_-]/g, \"\");\n if (!name) return send(chatId, \"❌ Только латиница, цифры, - и _. Ещё раз:\");\n const exists = await getSession(name);\n if (exists) return send(chatId, \"❌ Такое имя уже есть. Другое:\");\n conv.data.name = name;\n conv.step = \"api_id\";\n return send(chatId, `✅ Имя: ${name}\\n\\nВведи API ID (число с my.telegram.org):`);\n }\n\n if (conv.step === \"api_id\") {\n const id = parseInt(text);\n if (isNaN(id)) return send(chatId, \"❌ Должно быть число:\");\n conv.data.api_id = id;\n conv.step = \"api_hash\";\n return send(chatId, `✅ API ID: ${id}\\n\\nВведи API Hash:`);\n }\n\n if (conv.step === \"api_hash\") {\n if (text.length < 10) return send(chatId, \"❌ Слишком короткий. Ещё раз:\");\n conv.data.api_hash = text;\n conv.step = \"phone\";\n return send(chatId, \"✅ Hash сохранён.\\n\\n📱 Введи номер телефона (+79991234567):\");\n }\n\n if (conv.step === \"phone\") {\n if (!text.startsWith(\"+\") || text.length < 10) return send(chatId, \"❌ Формат: +79991234567\");\n conv.data.phone = text;\n conv.step = \"connecting\";\n\n await send(chatId, \"⏳ Подключаюсь к Telegram...\");\n\n try {\n const { TelegramClient } = await import(\"npm:telegram@2.26.22\");\n const { StringSession } = await import(\"npm:telegram@2.26.22/sessions/index.js\");\n\n const client = new TelegramClient(\n new StringSession(\"\"),\n conv.data.api_id,\n conv.data.api_hash,\n { connectionRetries: 3 }\n );\n await client.connect();\n\n const result = await client.sendCode(\n { apiId: conv.data.api_id, apiHash: conv.data.api_hash },\n conv.data.phone\n );\n\n conv.data.phoneCodeHash = result.phoneCodeHash;\n conv.data._client = client;\n conv.step = \"code\";\n await send(chatId, \"✅ Код отправлен!\\n\\n🔑 Введи код из Telegram:\");\n } catch (err: any) {\n delete conversations[chatId];\n await send(chatId, `❌ Ошибка: ${err.message}\\n\\n/start чтобы заново`);\n }\n return;\n }\n\n if (conv.step === \"code\") {\n const code = text.replace(/\\s/g, \"\");\n const client = conv.data._client;\n\n try {\n const { Api } = await import(\"npm:telegram@2.26.22/tl/index.js\");\n await client.invoke(\n new Api.auth.SignIn({\n phoneNumber: conv.data.phone,\n phoneCodeHash: conv.data.phoneCodeHash,\n phoneCode: code,\n })\n );\n\n const ss = client.session.save() as unknown as string;\n await client.disconnect();\n\n await saveSession({\n name: conv.data.name,\n api_id: conv.data.api_id,\n api_hash: conv.data.api_hash,\n phone: conv.data.phone,\n string_session: ss,\n });\n delete conversations[chatId];\n\n await send(chatId, `🎉 Сессия ${conv.data.name} создана и активна!`, {\n inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]],\n });\n } catch (err: any) {\n if (\n err.message?.includes(\"SESSION_PASSWORD_NEEDED\") ||\n err.errorMessage === \"SESSION_PASSWORD_NEEDED\"\n ) {\n conv.step = \"2fa\";\n await send(chatId, \"🔐 Нужен пароль 2FA.\\n\\nВведи пароль:\");\n } else {\n try { await client.disconnect(); } catch {}\n delete conversations[chatId];\n await send(chatId, `❌ Ошибка: ${err.message || err.errorMessage}\\n\\n/start`);\n }\n }\n return;\n }\n\n if (conv.step === \"2fa\") {\n const client = conv.data._client;\n try {\n await client.signInWithPassword({ apiId: conv.data.api_id, apiHash: conv.data.api_hash }, {\n password: async () => text,\n onError: (e: any) => { throw e; },\n });\n\n const ss = client.session.save() as unknown as string;\n await client.disconnect();\n\n await saveSession({\n name: conv.data.name,\n api_id: conv.data.api_id,\n api_hash: conv.data.api_hash,\n phone: conv.data.phone,\n string_session: ss,\n });\n delete conversations[chatId];\n\n await send(chatId, `🎉 Сессия ${conv.data.name} создана!`, {\n inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]],\n });\n } catch (err: any) {\n await send(chatId, `❌ Неверный пароль: ${err.message}\\n\\nПопробуй ещё:`);\n }\n return;\n }\n\n return handleStart(chatId);\n}\n\nasync function handleCallback(cb: any) {\n const chatId = cb.message.chat.id;\n const data = cb.data;\n const username = cb.from?.username;\n\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id });\n if (!isAdmin(username)) return send(chatId, \"⛔ Нет доступа.\");\n\n if (data === \"menu\") {\n delete conversations[chatId];\n return handleStart(chatId);\n }\n\n if (data === \"new_session\") {\n conversations[chatId] = { step: \"name\", data: {} };\n return send(chatId, \"📝 Введи название сессии (латиница, без пробелов):\");\n }\n\n if (data === \"list_sessions\") {\n const sessions = await getSessions();\n if (!sessions.length) {\n return send(chatId, \"📭 Нет сессий.\", {\n inline_keyboard: [[{ text: \"📱 Создать\", callback_data: \"new_session\" }, { text: \"🏠 Меню\", callback_data: \"menu\" }]],\n });\n }\n const btns = sessions.map((s) => [\n { text: `${s.is_active ? \"🟢\" : \"🔴\"} ${s.name} (${s.phone})`, callback_data: `m_${s.name}` },\n ]);\n btns.push([{ text: \"🏠 Меню\", callback_data: \"menu\" }]);\n return send(chatId, \"📋 Сессии:\", { inline_keyboard: btns });\n }\n\n if (data === \"status\") {\n const sessions = await getSessions();\n if (!sessions.length) return send(chatId, \"📭 Нет сессий.\", { inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]] });\n\n let t = \"📊 Статус:\\n\\n\";\n for (const s of sessions) {\n t += `${s.is_active ? \"🟢\" : \"🔴\"} ${s.name} — ${s.phone}\\n`;\n t += ` Циклов: ${s.cycles_count} | Посл.: ${s.last_check || \"—\"}\\n\\n`;\n }\n return send(chatId, t, { inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]] });\n }\n\n // Manage session\n if (data.startsWith(\"m_\")) {\n const name = data.slice(2);\n const s = await getSession(name);\n if (!s) return send(chatId, \"❌ Не найдена.\");\n\n return send(chatId,\n `⚙️ ${s.name}\\n📱 ${s.phone}\\n${s.is_active ? \"🟢 Активна\" : \"🔴 Стоп\"}\\n🔄 Циклов: ${s.cycles_count}\\n🕐 ${s.last_check || \"—\"}`,\n {\n inline_keyboard: [\n [s.is_active\n ? { text: \"⏹ Остановить\", callback_data: `stop_${name}` }\n : { text: \"▶️ Запустить\", callback_data: `run_${name}` }],\n [{ text: \"🗑 Удалить\", callback_data: `del_${name}` }],\n [{ text: \"◀️ Назад\", callback_data: \"list_sessions\" }, { text: \"🏠 Меню\", callback_data: \"menu\" }],\n ],\n }\n );\n }\n\n if (data.startsWith(\"stop_\")) {\n await setSessionActive(data.slice(5), false);\n return send(chatId, `⏹ Остановлена: ${data.slice(5)}`, { inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]] });\n }\n\n if (data.startsWith(\"run_\")) {\n await setSessionActive(data.slice(4), true);\n return send(chatId, `▶️ Запущена: ${data.slice(4)}\\nПроверка в следующем цикле крона.`, { inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]] });\n }\n\n if (data.startsWith(\"del_\")) {\n await deleteSession(data.slice(4));\n return send(chatId, `🗑 Удалена: ${data.slice(4)}`, { inline_keyboard: [[{ text: \"🏠 Меню\", callback_data: \"menu\" }]] });\n }\n}\n\n// === ROUTES ===\napp.post(\"/webhook\", async (c) => {\n try {\n const update = await c.req.json();\n if (update.message) await handleMessage(update.message);\n else if (update.callback_query) await handleCallback(update.callback_query);\n } catch (err) {\n console.error(\"Webhook error:\", err);\n }\n return c.json({ ok: true });\n});\n\napp.get(\"/setup\", async (c) => {\n const url = new URL(\"/webhook\", c.req.url).toString();\n const result = await tg(\"setWebhook\", { url });\n return c.json({ webhook: url, result });\n});\n\napp.get(\"/\", (c) => c.text(\"Jobseo Monitor Bot 🤖\"));\n\nexport default app.fetch;\n",[187],"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",[194],"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",[201],"f150d632-5aa3-11f1-8fee-ee650bb23af1","cron.ts","f150d6e6-5aa3-11f1-8fee-ee650bb23af1",6,["D",1779979559991],"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",[208],"21ee1390-5aa4-11f1-88e6-ee650bb23af1","cron-worker.ts","21ee144e-5aa4-11f1-88e6-ee650bb23af1",11,["D",1779979641540],"import { getSessions, incrementCycles } from \"./db.ts\";\n\nconst BOT_TOKEN = Deno.env.get(\"BOT_TOKEN\") || \"\";\nconst ADMIN_USERNAME = \"mqppr\";\n\nasync function tgNotify(text: string) {\n const ADMIN_CHAT_ID = Deno.env.get(\"ADMIN_CHAT_ID\") || \"\";\n if (!ADMIN_CHAT_ID) return;\n await fetch(`https://api.telegram.org/bot${BOT_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: ADMIN_CHAT_ID, text, parse_mode: \"HTML\" }),\n });\n}\n\nasync function checkJobseo(session: {\n name: string;\n api_id: number;\n api_hash: string;\n string_session: string;\n}) {\n const { TelegramClient } = await import(\"npm:telegram@2.26.22\");\n const { StringSession } = await import(\"npm:telegram@2.26.22/sessions/index.js\");\n const { Api } = await import(\"npm:telegram@2.26.22/tl/index.js\");\n\n const client = new TelegramClient(\n new StringSession(session.string_session),\n session.api_id,\n session.api_hash,\n { connectionRetries: 3 }\n );\n\n try {\n await client.connect();\n console.log(`[${session.name}] Connected`);\n\n const jobseoBot = await client.getEntity(\"jobseo_bot\");\n\n // Try to find \"Приступить к заданию\" button\n let msgs = await client.getMessages(jobseoBot, { limit: 5 });\n let targetMsg: any = null;\n let targetButton: any = null;\n\n function findButton(messages: any[]) {\n for (const msg of messages) {\n if (!msg.replyMarkup?.rows) continue;\n for (const row of msg.replyMarkup.rows) {\n for (const btn of row.buttons) {\n if (btn.text?.includes(\"Приступить к заданию\")) {\n return { msg, btn };\n }\n }\n }\n }\n return null;\n }\n\n let found = findButton(msgs);\n if (!found) {\n await client.sendMessage(jobseoBot, { message: \"/start\" });\n await new Promise((r) => setTimeout(r, 3000));\n msgs = await client.getMessages(jobseoBot, { limit: 5 });\n found = findButton(msgs);\n }\n\n if (!found) {\n console.log(`[${session.name}] Button not found, skipping`);\n await client.disconnect();\n return;\n }\n\n targetMsg = found.msg;\n targetButton = found.btn;\n\n // Click button\n if (targetButton.data) {\n await client.invoke(new Api.messages.GetBotCallbackAnswer({\n peer: jobseoBot, msgId: targetMsg.id, data: targetButton.data,\n }));\n } else {\n await client.sendMessage(jobseoBot, { message: targetButton.text });\n }\n\n console.log(`[${session.name}] Pressed button`);\n await new Promise((r) => setTimeout(r, 5000));\n\n // Check response\n const newMsgs = await client.getMessages(jobseoBot, { limit: 3 });\n const latest = newMsgs[0];\n const buttons: string[] = [];\n if (latest?.replyMarkup?.rows) {\n for (const row of latest.replyMarkup.rows) {\n for (const btn of row.buttons) buttons.push(btn.text || \"\");\n }\n }\n\n console.log(`[${session.name}] Buttons:`, buttons);\n\n const skip = [\"Назад в меню\", \"Доп. задания\", \"Доп задания\"];\n const hasNew = buttons.some((b) => b && !skip.some((s) => b.includes(s)));\n\n if (hasNew) {\n console.log(`[${session.name}] 🔥 NEW TASKS!`);\n\n const me = await client.getMe() as any;\n const myUser = me.username || \"\";\n const target = myUser === ADMIN_USERNAME ? \"SetkaGar\" : ADMIN_USERNAME;\n\n try {\n const entity = await client.getEntity(target);\n await client.sendMessage(entity, {\n message: \"🔥 НОВЫЕ ЗАДАНИЯ В JOBSEO!\\nЗайди в @jobseo_bot → Приступить к заданию\",\n });\n } catch (e: any) {\n console.error(`Notify @${target} failed:`, e.message);\n }\n\n await tgNotify(`✅ ${session.name}: Новые задания! Кнопки: ${buttons.join(\", \")}`);\n } else {\n // Press \"Назад в меню\"\n if (latest?.replyMarkup?.rows) {\n for (const row of latest.replyMarkup.rows) {\n for (const btn of row.buttons) {\n if (btn.text?.includes(\"Назад в меню\")) {\n if (btn.data) {\n await client.invoke(new Api.messages.GetBotCallbackAnswer({\n peer: jobseoBot, msgId: latest.id, data: btn.data,\n }));\n } else {\n await client.sendMessage(jobseoBot, { message: btn.text });\n }\n }\n }\n }\n }\n }\n\n await incrementCycles(session.name);\n await client.disconnect();\n } catch (err: any) {\n console.error(`[${session.name}] Error:`, err.message);\n await tgNotify(`❌ ${session.name}: ${err.message}`);\n try { await client.disconnect(); } catch {}\n }\n}\n\nexport default async function (_interval: Interval) {\n console.log(\"⏰ Cron check:\", new Date().toISOString());\n const sessions = await getSessions();\n const active = sessions.filter((s) => s.is_active);\n\n if (!active.length) {\n console.log(\"No active sessions\");\n return;\n }\n\n for (const s of active) {\n await checkJobseo(s);\n }\n console.log(\"✅ Cron done\");\n}\n",[215],"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",[222],"48cf024e-5aa4-11f1-93ce-ee650bb23af1",["D",1779979706778],[33],"f8e74c32-5aa3-11f1-8605-ee650bb23af1","README.md","f8e74cfa-5aa3-11f1-8605-ee650bb23af1",7,["D",1779979572527],"# 🤖 JobSEO Monitor Bot\n\nTelegram-бот для мониторинга заданий в @jobseo_bot через юзербот (gramjs MTProto).\n\n## Архитектура\n\n```mermaid\ngraph TD\n A[Telegram User @mqppr] -->|команды| B[Управляющий бот webhook.ts]\n B -->|сохраняет сессии| C[(SQLite DB)]\n D[Cron каждые 3 мин cron.ts] -->|читает активные сессии| C\n D -->|gramjs MTProto| E[@jobseo_bot]\n D -->|уведомления| F[Целевой пользователь]\n D -->|статус| B\n```\n\n## Настройка\n\n### 1. Создай нового бота через @BotFather и получи токен\n\n### 2. Установи переменные окружения:\n\n- `TELEGRAM_BOT_TOKEN` — токен бота от BotFather\n- `ADMIN_CHAT_ID` — твой Telegram chat ID (узнай через @userinfobot)\n\n### 3. Открой webhook.ts endpoint в браузере — это зарегистрирует вебхук\n\n### 4. Напиши боту /start и создай сессию\n\n## Команды бота\n\n- `/start` — главное меню\n- 📱 Создать сессию — ввод API ID, Hash, телефона, кода\n- ▶️ Запустить — активирует сессию для мониторинга\n- ⏹ Остановить — деактивирует\n- 📊 Статус — инфо о сессии\n- 🗑 Удалить — удаляет сессию\n\n## Как работает мониторинг\n\n1. Cron запускается каждые 3 минуты\n2. Для каждой активной сессии подключается через gramjs\n3. Нажимает \"Приступить к заданию\" в @jobseo_bot\n4. Если есть новые задания — шлёт уведомления\n5. Если заданий нет — нажимает \"Назад в меню\"\n",[232],"pulls","branches","forks","envVars",{"_245":67,"_247":67},"connections",{"_245":67,"_246":67},"count","unfilledCount","emptyCount",{"_47":231,"_37":232,"_35":233,"_150":-5,"_45":46,"_44":234,"_152":63,"_42":298,"_13":67,"_38":26,"_40":236,"_29":30,"_156":-5,"_262":299,"_32":300},{"_47":228,"_37":33,"_35":36,"_150":-5,"_45":46,"_44":14,"_152":63,"_42":295,"_13":67,"_38":39,"_40":41,"_29":30,"_156":-5,"_262":296,"_32":297},{"_47":221,"_37":222,"_35":223,"_150":-5,"_45":46,"_44":224,"_152":63,"_42":292,"_13":67,"_38":154,"_40":226,"_29":30,"_156":-5,"_262":293,"_32":294},{"_47":214,"_37":215,"_35":216,"_150":-5,"_45":46,"_44":217,"_152":63,"_42":289,"_13":67,"_38":183,"_40":219,"_29":30,"_156":-5,"_262":290,"_32":291},{"_47":207,"_37":208,"_35":209,"_150":-5,"_45":46,"_44":210,"_152":63,"_42":286,"_13":67,"_38":183,"_40":212,"_29":30,"_156":-5,"_262":287,"_32":288},{"_47":200,"_37":201,"_35":202,"_150":-5,"_45":46,"_44":203,"_152":63,"_42":283,"_13":67,"_38":154,"_40":205,"_29":30,"_156":-5,"_262":284,"_32":285},{"_47":193,"_37":194,"_35":195,"_150":-5,"_45":46,"_44":196,"_152":63,"_42":280,"_13":67,"_38":154,"_40":198,"_29":30,"_156":-5,"_262":281,"_32":282},{"_47":186,"_37":187,"_35":188,"_150":-5,"_45":46,"_44":189,"_152":63,"_42":277,"_13":67,"_38":39,"_40":191,"_29":30,"_156":-5,"_262":278,"_32":279},{"_47":178,"_37":179,"_35":180,"_150":-5,"_45":46,"_44":181,"_152":63,"_42":274,"_13":67,"_38":183,"_40":184,"_29":30,"_156":-5,"_262":275,"_32":276},{"_47":171,"_37":172,"_35":173,"_150":-5,"_45":46,"_44":174,"_152":63,"_42":271,"_13":67,"_38":154,"_40":176,"_29":30,"_156":-5,"_262":272,"_32":273},{"_47":164,"_37":165,"_35":166,"_150":-5,"_45":46,"_44":167,"_152":63,"_42":268,"_13":67,"_38":154,"_40":169,"_29":30,"_156":-5,"_262":269,"_32":270},{"_47":158,"_37":159,"_35":61,"_150":-5,"_45":46,"_44":160,"_152":63,"_42":265,"_13":67,"_38":39,"_40":162,"_29":30,"_156":-5,"_262":266,"_32":267},{"_47":147,"_37":148,"_35":149,"_150":-5,"_45":46,"_44":151,"_152":63,"_42":261,"_13":67,"_38":154,"_40":155,"_29":30,"_156":-5,"_262":263,"_32":264},["D",1779979542449],"children",[],[148],["D",1779979549782],[],[159],["D",1779979590109],[],[165],["D",1779979635994],[],[172],["D",1779979681474],[],[179],["D",1779979593442],[],[187],["D",1779979459978],[],[194],["D",1779979557445],[],[201],["D",1779979559991],[],[208],["D",1779979641540],[],[215],["D",1779979497299],[],[222],["D",1779979706778],[],[33],["D",1779979572527],[],[232],["D",1779979442780],["D",1789495880338],{"_103":102,"_111":107},{"_103":102,"_104":105,"_106":107,"_19":59,"_108":109,"_110":30},{"_13":14,"_37":93,"_47":46,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":49,"_101":102},"ctx",{"_86":-5,"_131":339,"_340":341,"_342":343,"_344":30,"_345":30,"_346":30,"_347":63,"_348":-5,"_349":-7,"_350":-7,"_351":67,"_352":30,"_353":30,"_354":-5,"_355":30,"_356":30,"_357":30,"_358":-5},"ENV",{"_310":311,"_312":313,"_314":93,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338},"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 · v13