🤖 AI Telegram Bot

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

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

`,\n { status: 200, headers: { \"content-type\": \"text/html; charset=utf-8\" } },\n );\n};\n","deleted","label",[121],"bc97c59f-1825-46a3-b62a-c2daf9c16fab","db.ts","55c78966-89c1-11f1-9535-1607ee4eb77e",1,["D",1785159888589],"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",[138],"2617eef0-af43-4573-9a68-113f1a7127f3","ai.ts","55ce403a-89c1-11f1-95c4-1607ee4eb77e",["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",[146],"pulls","forks","envVars",{"_158":160,"_161":54},"connections",{"_158":54,"_159":54},"count","unfilledCount",3,"emptyCount",{"_20":145,"_13":146,"_122":147,"_123":-5,"_124":21,"_125":30,"_127":50,"_22":172,"_29":149,"_130":142,"_132":150,"_134":38,"_135":-5,"_166":173,"_94":174},{"_20":137,"_13":138,"_122":139,"_123":-5,"_124":21,"_125":140,"_127":50,"_22":169,"_29":54,"_130":142,"_132":143,"_134":38,"_135":-5,"_166":170,"_94":171},{"_20":120,"_13":121,"_122":48,"_123":-5,"_124":21,"_125":126,"_127":50,"_22":165,"_29":129,"_130":131,"_132":133,"_134":38,"_135":-5,"_166":167,"_94":168},["D",1785160746876],"children",[],[121],["D",1785159888589],[],[138],["D",1785161006690],[],[146],["D",1785159864439],["D",1789560647748],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_114":213,"_214":215,"_216":217,"_218":38,"_219":38,"_220":38,"_221":50,"_222":-5,"_223":-7,"_224":-7,"_225":54,"_226":38,"_227":38,"_228":-5,"_229":38,"_230":38,"_231":38,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":26,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

Branches1

Branches
1