🤖 AI Telegram Bot

Бот работает! Напиши ему в Telegram.

Функции: AI-чат, генерация картинок, премиум-подписка, промокоды, админ-панель

`,\n { status: 200, headers: { \"content-type\": \"text/html; charset=utf-8\" } },\n );\n};\n","deleted",false,"label",[37],"bc97c59f-1825-46a3-b62a-c2daf9c16fab","db.ts","55c78966-89c1-11f1-9535-1607ee4eb77e",1,["D",1785159888589],0,"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users (\n user_id INTEGER PRIMARY KEY,\n username TEXT,\n first_name TEXT,\n joined_at INTEGER,\n messages_used INTEGER DEFAULT 0,\n is_premium INTEGER DEFAULT 0,\n premium_until INTEGER DEFAULT 0,\n is_banned INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS promo_codes (\n code TEXT PRIMARY KEY,\n days INTEGER,\n used_by INTEGER,\n used_at INTEGER\n )\n `);\n}\n\nexport async function getUser(userId: number) {\n const result = await sqlite.execute({\n sql: `SELECT * FROM users WHERE user_id = ?`,\n args: [userId],\n });\n return result.rows[0] as any;\n}\n\nexport async function createUser(\n userId: number,\n username: string,\n firstName: string,\n) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO users (user_id, username, first_name, joined_at, messages_used, is_premium, premium_until, is_banned)\n VALUES (?, ?, ?, ?, 0, 0, 0, 0)`,\n args: [userId, username, firstName, Date.now()],\n });\n}\n\nexport async function incrementMessages(userId: number) {\n await sqlite.execute({\n sql: `UPDATE users SET messages_used = messages_used + 1 WHERE user_id = ?`,\n args: [userId],\n });\n}\n\nexport async function setPremium(userId: number, days: number) {\n const user = await getUser(userId);\n const now = Date.now();\n const currentUntil = (user?.premium_until || 0) > now\n ? user.premium_until\n : now;\n const newUntil = currentUntil + days * 24 * 60 * 60 * 1000;\n await sqlite.execute({\n sql: `UPDATE users SET is_premium = 1, premium_until = ? WHERE user_id = ?`,\n args: [newUntil, userId],\n });\n return newUntil;\n}\n\nexport async function banUser(userId: number, banned: boolean) {\n await sqlite.execute({\n sql: `UPDATE users SET is_banned = ? WHERE user_id = ?`,\n args: [banned ? 1 : 0, userId],\n });\n}\n\nexport async function getAllUsers() {\n const result = await sqlite.execute(\n `SELECT * FROM users ORDER BY joined_at DESC`,\n );\n return result.rows as any[];\n}\n\nexport async function getStats() {\n const totalUsers = await sqlite.execute(\n `SELECT COUNT(*) as count FROM users`,\n );\n const premiumUsers = await sqlite.execute(\n `SELECT COUNT(*) as count FROM users WHERE is_premium = 1`,\n );\n const totalMessages = await sqlite.execute(\n `SELECT SUM(messages_used) as sum FROM users`,\n );\n const bannedUsers = await sqlite.execute(\n `SELECT COUNT(*) as count FROM users WHERE is_banned = 1`,\n );\n\n return {\n totalUsers: (totalUsers.rows[0] as any)?.count || 0,\n premiumUsers: (premiumUsers.rows[0] as any)?.count || 0,\n totalMessages: (totalMessages.rows[0] as any)?.sum || 0,\n bannedUsers: (bannedUsers.rows[0] as any)?.count || 0,\n };\n}\n\nexport async function addPromoCode(code: string, days: number) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO promo_codes (code, days, used_by, used_at) VALUES (?, ?, 0, 0)`,\n args: [code, days],\n });\n}\n\nexport async function usePromoCode(\n code: string,\n userId: number,\n): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM promo_codes WHERE code = ? AND used_by = 0`,\n args: [code],\n });\n const promo = result.rows[0] as any;\n if (!promo) return null;\n\n await sqlite.execute({\n sql: `UPDATE promo_codes SET used_by = ?, used_at = ? WHERE code = ?`,\n args: [userId, Date.now(), code],\n });\n return promo.days as number;\n}\n\nexport async function checkPremiumExpired(userId: number) {\n const user = await getUser(userId);\n if (user?.is_premium && user.premium_until < Date.now()) {\n await sqlite.execute({\n sql: `UPDATE users SET is_premium = 0 WHERE user_id = ?`,\n args: [userId],\n });\n return true;\n }\n return false;\n}\n",[59],"2617eef0-af43-4573-9a68-113f1a7127f3","ai.ts","55ce403a-89c1-11f1-95c4-1607ee4eb77e",14,["D",1785161006690],6,"// AI Chat using Google Gemini API (primary)\n// Fallback to DuckDuckGo AI Chat, then Pollinations\n// Image generation via Pollinations\n\nconst GEMINI_MODEL = \"gemini-flash-latest\";\nconst SYSTEM_PROMPT =\n \"Ты — дружелюбный AI-ассистент в Telegram. Отвечай кратко, по делу и на русском языке. Используй эмодзи.\";\n\n// ─── Gemini AI ───\nasync function askGemini(\n message: string,\n history: { role: string; content: string }[] = [],\n): Promise {\n const apiKey = Deno.env.get(\"GEMINI_KEY\") || Deno.env.get(\"GEMINI_API_KEY\");\n if (!apiKey) throw new Error(\"No GEMINI key set\");\n\n const contents = [\n ...history.slice(-10).map((h) => ({\n role: h.role === \"user\" ? \"user\" : \"model\",\n parts: [{ text: h.content }],\n })),\n { role: \"user\", parts: [{ text: message }] },\n ];\n\n const resp = await fetch(\n `https://generativelanguage.googleapis.com/v1beta/models/${GEMINI_MODEL}:generateContent?key=${apiKey}`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n contents,\n systemInstruction: { parts: [{ text: SYSTEM_PROMPT }] },\n generationConfig: {\n temperature: 0.7,\n maxOutputTokens: 2048,\n },\n }),\n },\n );\n\n if (!resp.ok) {\n const err = await resp.text();\n throw new Error(`Gemini: ${resp.status} ${err}`);\n }\n\n const data = await resp.json();\n const text = data?.candidates?.[0]?.content?.parts?.[0]?.text;\n if (!text) throw new Error(\"Gemini: empty response\");\n return text.trim();\n}\n\n// ─── DuckDuckGo AI Chat (fallback) ───\nasync function getDDGToken(): Promise {\n try {\n const resp = await fetch(\"https://duckduckgo.com/duckchat/v1/status\", {\n headers: {\n \"x-vqd-accept\": \"1\",\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n });\n const token = resp.headers.get(\"x-vqd-4\");\n return token;\n } catch {\n return null;\n }\n}\n\nasync function askDDG(\n message: string,\n history: { role: string; content: string }[] = [],\n): Promise {\n const token = await getDDGToken();\n if (!token) throw new Error(\"DDG: no token\");\n\n const messages = [\n {\n role: \"system\",\n content: SYSTEM_PROMPT,\n },\n ...history.slice(-10).map((h) => ({\n role: h.role === \"user\" ? \"user\" : \"assistant\",\n content: h.content,\n })),\n { role: \"user\", content: message },\n ];\n\n const resp = await fetch(\"https://duckduckgo.com/duckchat/v1/chat\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-vqd-4\": token,\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n },\n body: JSON.stringify({\n model: \"claude-3-haiku-20240307\",\n messages,\n }),\n });\n\n if (!resp.ok) throw new Error(`DDG: ${resp.status}`);\n\n const text = await resp.text();\n const lines = text.split(\"\\n\").filter((l) => l.startsWith(\"data: \"));\n let result = \"\";\n for (const line of lines) {\n const json = line.slice(6).trim();\n if (json === \"[DONE]\") break;\n try {\n const parsed = JSON.parse(json);\n if (parsed.message) result += parsed.message;\n } catch {}\n }\n\n if (!result) throw new Error(\"DDG: empty response\");\n return result;\n}\n\n// ─── Pollinations fallback ───\nasync function askPollinations(message: string): Promise {\n const resp = await fetch(\n `https://text.pollinations.ai/${\n encodeURIComponent(message + \" (отвечай на русском, кратко)\")\n }?model=openai`,\n {\n headers: { \"Referer\": \"https://pollinations.ai\" },\n },\n );\n if (!resp.ok) throw new Error(`Pollinations: ${resp.status}`);\n const text = await resp.text();\n if (!text) throw new Error(\"Pollinations: empty\");\n return text.trim();\n}\n\n// ─── Main AI function ───\nexport async function askAI(\n message: string,\n history: { role: string; content: string }[] = [],\n): Promise {\n // 1) Try Gemini (primary, with API key)\n try {\n return await askGemini(message, history);\n } catch (e) {\n console.error(\"Gemini failed:\", (e as Error).message);\n }\n\n // 2) Fallback to DuckDuckGo\n try {\n return await askDDG(message, history);\n } catch (e) {\n console.error(\"DDG failed:\", (e as Error).message);\n }\n\n // 3) Fallback to Pollinations\n try {\n return await askPollinations(message);\n } catch (e) {\n console.error(\"Pollinations failed:\", (e as Error).message);\n }\n\n throw new Error(\"AI service unavailable\");\n}\n\nexport async function generateImage(prompt: string): Promise {\n const encoded = encodeURIComponent(prompt);\n return `https://image.pollinations.ai/prompt/${encoded}?width=1024&height=1024&nologo=true&model=flux`;\n}\n",[68],{"_35":67,"_13":68,"_38":69,"_40":-5,"_41":42,"_43":70,"_45":46,"_47":85,"_17":72,"_50":64,"_52":73,"_54":55,"_56":-5,"_79":86,"_18":87},{"_35":58,"_13":59,"_38":60,"_40":-5,"_41":42,"_43":61,"_45":46,"_47":82,"_17":63,"_50":64,"_52":65,"_54":55,"_56":-5,"_79":83,"_18":84},{"_35":36,"_13":37,"_38":39,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":78,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_79":80,"_18":81},["D",1785160746876],"children",[],[37],["D",1785159888589],[],[59],["D",1785161006690],[],[68],"550111d4-bed6-4c5d-b7b4-87531f97557a",["D",1785159864439],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AI Telegram bot powered by Google Gemini API","imageUrl","userId","cbfadac6-d2f4-49b1-af64-37ff02ec6fa1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019fa3ce-ea17-72d6-a242-37e278f266f9","tursoName","550111d4bed64c5db7b487531f97557a","tursoHostname","550111d4bed64c5db7b487531f97557a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789560647748],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_145":141},"org",{"_11":12,"_138":139,"_140":141,"_98":99,"_142":143,"_144":55},"branch",{"_17":70,"_13":16,"_35":42,"_130":88,"_131":-5,"_132":-5,"_133":-5,"_134":-5,"_135":-5,"_136":14,"_137":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Иван Шебанов","avatar","https://lh3.googleusercontent.com/a/ACg8ocI8wmFt15Pe3BPPoaN6Pr2qh6GpPDvp-Nym6CcLxXesNHAUBw1Sdg=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_35":88,"_13":14,"_47":189,"_90":-5,"_91":55,"_92":93,"_94":93,"_95":96,"_97":-5,"_98":99,"_100":39,"_101":46,"_102":-5,"_103":-5,"_104":63,"_105":106,"_107":108,"_109":110,"_111":190,"_113":-5,"_114":115,"_116":115,"_117":118,"_119":118,"_120":118,"_121":115,"_122":115,"_123":191,"_125":192,"_127":193,"_129":55},[180,181,182],"files",[180,181,182],"counts",{"_170":63,"_171":61,"_172":63,"_31":173,"_174":175},[164,165,166],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_35":67,"_13":68,"_38":69,"_40":-5,"_41":42,"_43":70,"_45":46,"_47":71,"_17":72,"_50":64,"_52":73,"_54":55,"_56":-5,"_18":169},{"_35":58,"_13":59,"_38":60,"_40":-5,"_41":42,"_43":61,"_45":46,"_47":62,"_17":63,"_50":64,"_52":65,"_54":55,"_56":-5,"_18":168},{"_35":36,"_13":37,"_38":39,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":167},[37],[59],[68],"pulls","branches","forks",{"_176":178,"_179":63},"connections",{"_176":63,"_177":63},"count","unfilledCount",3,"emptyCount",{"_35":67,"_13":68,"_38":69,"_40":-5,"_41":42,"_43":70,"_45":46,"_47":85,"_17":72,"_50":64,"_52":73,"_54":55,"_56":-5,"_79":187,"_18":188},{"_35":58,"_13":59,"_38":60,"_40":-5,"_41":42,"_43":61,"_45":46,"_47":82,"_17":63,"_50":64,"_52":65,"_54":55,"_56":-5,"_79":185,"_18":186},{"_35":36,"_13":37,"_38":39,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":78,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_79":183,"_18":184},[],[37],[],[59],[],[68],["D",1785159864439],["D",1789560647748],{"_11":12,"_145":141},{"_11":12,"_138":139,"_140":141,"_98":99,"_142":143,"_144":55},{"_17":70,"_13":16,"_35":42,"_130":88,"_131":-5,"_132":-5,"_133":-5,"_134":-5,"_135":-5,"_136":14,"_137":12},"ctx",{"_123":-5,"_161":227,"_228":229,"_230":231,"_232":55,"_233":55,"_234":55,"_235":46,"_236":-5,"_237":-7,"_238":-7,"_239":63,"_240":55,"_241":55,"_242":-5,"_243":55,"_244":55,"_245":55,"_246":-5},"ENV",{"_198":199,"_200":201,"_202":16,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]