[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":53,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",62,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","http.ts","latestPath","fileId","6f170686-8600-11f1-bb06-1607ee4eb77e","name","fileType","http","content","// ============================================================\n// ЕДИНЫЙ БОТ-ЗАГРУЗЧИК (TikTok, Instagram, VK, Pinterest, Cobalt)\n// Всё в одном файле, вебхук – из переменной окружения WEBHOOK_URL\n// ============================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ---------- Хранилище (используем стандартный blob) ----------\nasync function safeGetJSON(key: string): Promise {\n try {\n return await blob.getJSON(key);\n } catch {\n return null;\n }\n}\nasync function setJSON(key: string, value: unknown) {\n await blob.setJSON(key, value);\n}\n\n// ---------- Telegram API ----------\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nconst TG_API = `https://api.telegram.org/bot${TOKEN}/`;\nconst OWNER = Number(Deno.env.get(\"OWNER_CHAT_ID\") || \"0\");\n\nasync function callTelegram(method: string, payload: any) {\n const res = await fetch(TG_API + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n return res.json();\n}\n\nconst sendMessage = (chatId: number, text: string, replyMarkup?: any) =>\n callTelegram(\"sendMessage\", {\n chat_id: chatId,\n text,\n reply_markup: replyMarkup,\n });\nconst sendTyping = (chatId: number, action = \"typing\") =>\n callTelegram(\"sendChatAction\", { chat_id: chatId, action });\nconst sendVideoByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendVideo\", { chat_id: chatId, video: url, caption });\nconst sendPhotoByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendPhoto\", { chat_id: chatId, photo: url, caption });\nconst sendAudioByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendAudio\", { chat_id: chatId, audio: url, caption });\nconst answerCallback = (id: string) =>\n callTelegram(\"answerCallbackQuery\", { callback_query_id: id });\nconst setWebhook = (url: string) => callTelegram(\"setWebhook\", { url });\nconst notifyOwner = (text: string) =>\n OWNER ? sendMessage(OWNER, \"🐞 \" + text) : Promise.resolve();\n\n// ---------- Утилиты ----------\nasync function fetchHtml(url: string, headers = {}): Promise {\n const res = await fetch(url, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0\",\n ...headers,\n },\n });\n return res.text();\n}\nfunction decodeEntities(str: string): string {\n return str.replace(/&/g, \"&\").replace(/"/g, '\"').replace(\n /'/g,\n \"'\",\n );\n}\n\n// ==================== ОБРАБОТЧИКИ ====================\n\n// ---------- TikTok ----------\nexport async function handleTikTok(chatId: number, url: string) {\n await sendTyping(chatId, \"upload_video\");\n const res = await fetch(\n `https://www.tikwm.com/api/?url=${encodeURIComponent(url)}`,\n );\n const data = await res.json();\n if (data.code !== 0 || !data.data?.play) {\n await sendMessage(chatId, \"❌ Не удалось найти видео TikTok.\");\n return;\n }\n const d = data.data;\n const abs = (\n u: string,\n ) => (u.startsWith(\"http\") ? u : \"https://www.tikwm.com\" + u);\n const pending = {\n sd: abs(d.play),\n hd: d.hdplay ? abs(d.hdplay) : null,\n music: d.music ? abs(d.music) : null,\n };\n await setJSON(`dlPending_${chatId}`, pending);\n const buttons = [[{ text: \"📹 SD\", callback_data: \"tt_sd\" }]];\n if (pending.hd) buttons[0].push({ text: \"🎬 HD\", callback_data: \"tt_hd\" });\n if (pending.music) {\n buttons[0].push({ text: \"🎵 Только звук\", callback_data: \"tt_audio\" });\n }\n await sendMessage(chatId, \"🎵 Видео найдено! Выбери качество:\", {\n inline_keyboard: buttons,\n });\n}\n\nexport async function handleTikTokCallback(chatId: number, action: string) {\n const pending = await safeGetJSON(`dlPending_${chatId}`);\n if (!pending) {\n await sendMessage(chatId, \"⚠️ Ссылка устарела, пришли видео заново.\");\n return;\n }\n await sendTyping(chatId, \"upload_video\");\n let url, caption;\n if (action === \"tt_sd\") {\n url = pending.sd;\n caption = \"📹 SD — без водяного знака\";\n } else if (action === \"tt_hd\") {\n url = pending.hd;\n caption = \"🎬 HD — без водяного знака\";\n } else if (action === \"tt_audio\") {\n url = pending.music;\n caption = \"🎵 Аудио из TikTok\";\n } else return;\n const r = await sendVideoByUrl(chatId, url, caption);\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${url}`,\n );\n }\n}\n\n// ---------- VK ----------\nasync function fetchVkHtml(url: string): Promise {\n const headers = {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0\",\n \"Accept\": \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n \"Accept-Language\": \"ru-RU,ru;q=0.9\",\n \"Cookie\": \"remixlang=0\",\n };\n let current = url;\n for (let i = 0; i < 8; i++) {\n const res = await fetch(current, { headers, redirect: \"manual\" });\n if (res.status >= 300 && res.status < 400) {\n const loc = res.headers.get(\"location\");\n if (!loc) break;\n current = new URL(loc, current).toString();\n continue;\n }\n return res.text();\n }\n throw new Error(\"VK: слишком много редиректов\");\n}\n\nexport async function handleVK(chatId: number, url: string) {\n await sendTyping(chatId);\n let html;\n try {\n html = await fetchVkHtml(url);\n } catch {\n await sendMessage(\n chatId,\n \"❌ VK не отвечает (возможно, требует авторизации). Попробуй позже.\",\n );\n return;\n }\n const qualities: { label: string; url: string }[] = [];\n const patterns: [string, RegExp][] = [\n [\"1080p\", /\"url1080\":\"([^\"]+)\"/],\n [\"720p\", /\"url720\":\"([^\"]+)\"/],\n [\"480p\", /\"url480\":\"([^\"]+)\"/],\n [\"360p\", /\"url360\":\"([^\"]+)\"/],\n [\"240p\", /\"url240\":\"([^\"]+)\"/],\n ];\n for (const [label, re] of patterns) {\n const m = html.match(re);\n if (m) {\n qualities.push({\n label,\n url: decodeEntities(m[1].replace(/\\\\\\//g, \"/\")),\n });\n }\n }\n if (qualities.length === 0) {\n await sendMessage(chatId, \"❌ Не найдено видео. Возможно, приватное.\");\n return;\n }\n await setJSON(`dlPendingVK_${chatId}`, qualities);\n const buttons = [\n qualities.slice(0, 3).map((q, i) => ({\n text: q.label,\n callback_data: \"vk_\" + i,\n })),\n ];\n await sendMessage(chatId, \"📹 Видео найдено! Выбери качество:\", {\n inline_keyboard: buttons,\n });\n}\n\nexport async function handleVKCallback(chatId: number, action: string) {\n const idx = Number(action.replace(\"vk_\", \"\"));\n const qualities = await safeGetJSON(`dlPendingVK_${chatId}`);\n if (!qualities || !qualities[idx]) {\n await sendMessage(chatId, \"⚠️ Ссылка устарела.\");\n return;\n }\n await sendTyping(chatId, \"upload_video\");\n const r = await sendVideoByUrl(\n chatId,\n qualities[idx].url,\n `📹 VK — ${qualities[idx].label}`,\n );\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${qualities[idx].url}`,\n );\n }\n}\n\n// ---------- Pinterest ----------\nexport async function handlePinterest(chatId: number, url: string) {\n await sendTyping(chatId, \"upload_video\");\n const html = await fetchHtml(url);\n const videoMatch = html.match(\n /https:\\\\?\\/\\\\?\\/v1\\.pinimg\\.com\\\\?\\/videos\\\\?\\/[^\"]+?\\.mp4/,\n );\n if (videoMatch) {\n const videoUrl = videoMatch[0].replace(/\\\\\\//g, \"/\");\n const r = await sendVideoByUrl(chatId, videoUrl, \"📌 Pinterest\");\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${videoUrl}`,\n );\n }\n return;\n }\n const imageMatch = html.match(/ {\n if (!url.includes(\"/share/\")) return url;\n try {\n const res = await fetch(url, { redirect: \"follow\" });\n return res.url || url;\n } catch {\n return url;\n }\n}\n\nasync function sendInstagramCarousel(\n chatId: number,\n items: any[],\n total: number,\n) {\n let anySent = false;\n for (let i = 0; i < items.length; i++) {\n const item = items[i];\n const cap = total > 1 ? `📸 Instagram (${i + 1}/${total})` : \"📸 Instagram\";\n const vid = item?.video_versions?.[0]?.url;\n if (vid) {\n const r = await sendVideoByUrl(chatId, vid, cap);\n if (r.ok) {\n anySent = true;\n continue;\n }\n }\n const img = item?.image_versions2?.candidates?.[0]?.url;\n if (img) {\n await sendPhotoByUrl(chatId, img, cap);\n anySent = true;\n }\n }\n return anySent;\n}\n\nexport async function handleInstagram(chatId: number, rawUrl: string) {\n await sendTyping(chatId, \"upload_video\");\n const url = await resolveInstagramShare(rawUrl);\n const match = url.match(/instagram\\.com\\/(?:reels?|p|tv)\\/([A-Za-z0-9_-]+)/);\n if (!match) {\n await sendMessage(chatId, \"❌ Не распознана ссылка Instagram.\");\n return;\n }\n const shortcode = match[1];\n\n // Попытка через API\n try {\n const mediaId = shortcodeToMediaId(shortcode);\n const apiRes = await fetch(\n `https://i.instagram.com/api/v1/media/${mediaId}/info/`,\n {\n headers: {\n \"x-ig-app-id\": \"936619743392459\",\n \"User-Agent\": \"Instagram 219.0.0.12.117 Android\",\n },\n },\n );\n const apiData = await apiRes.json();\n const item = apiData?.items?.[0];\n if (item?.carousel_media?.length) {\n const sent = await sendInstagramCarousel(\n chatId,\n item.carousel_media,\n item.carousel_media.length,\n );\n if (sent) return;\n } else if (item) {\n const sent = await sendInstagramCarousel(chatId, [item], 1);\n if (sent) return;\n }\n } catch { /* fallback */ }\n\n // Резерв через embed\n try {\n const embedUrl =\n `https://www.instagram.com/reel/${shortcode}/embed/captioned/`;\n const html = await fetchHtml(embedUrl);\n const videoMatch = html.match(/\"video_url\":\"([^\"]+)\"/) ||\n html.match(/]+src=\"([^\"]+)\"/);\n if (videoMatch) {\n const videoUrl = decodeEntities(\n videoMatch[1].replace(/\\\\u0026/g, \"&\").replace(/\\\\\\//g, \"/\"),\n );\n const r = await sendVideoByUrl(chatId, videoUrl, \"📸 Instagram\");\n if (r.ok) return;\n }\n const imageMatch = html.match(\n / 1\n ? `🔗 Загружено (${i + 1}/${data.picker.length})`\n : \"🔗 Загружено\";\n const ok = await sendResolved(chatId, kind, item.url, cap);\n anySent = anySent || ok;\n }\n if (data.audio) {\n await sendResolved(chatId, \"audio\", data.audio, \"🎵 Звук\");\n }\n if (!anySent) {\n await sendMessage(chatId, \"❌ Не удалось отправить ни один файл.\");\n }\n return;\n }\n\n const errCode = data?.error?.code;\n await sendMessage(\n chatId,\n errCode\n ? `❌ Ошибка ${errCode}. Проверь ссылку.`\n : \"❌ Не удалось найти медиа по этой ссылке.\",\n );\n}\n\n// ==================== ГЛАВНЫЙ ОБРАБОТЧИК ====================\n// Вебхук читаем из переменной окружения WEBHOOK_URL\nconst WEBHOOK_URL = Deno.env.get(\"WEBHOOK_URL\");\nif (!WEBHOOK_URL) {\n console.error(\"❌ WEBHOOK_URL не задан в переменных окружения!\");\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n if (!WEBHOOK_URL) {\n return new Response(\n \"❌ Ошибка: WEBHOOK_URL не задан. Установи переменную окружения.\",\n );\n }\n const res = await setWebhook(WEBHOOK_URL);\n return new Response(\n res.ok\n ? \"✅ Бот активен. Вебхук настроен.\"\n : `⚠️ Ошибка вебхука: ${JSON.stringify(res)}`,\n );\n }\n\n try {\n const data = await req.json();\n\n // Дедупликация\n const updateId = data.update_id;\n const lastId = (await safeGetJSON(\"dlLastUpdateId_v2\")) || 0;\n if (lastId && Number(lastId) >= updateId) return new Response(\"OK\");\n await setJSON(\"dlLastUpdateId_v2\", updateId);\n\n if (data.message) await handleMessage(data.message);\n else if (data.callback_query) await handleCallback(data.callback_query);\n } catch (err) {\n console.error(\"Handler error:\", err);\n await notifyOwner(\"Ошибка: \" + err);\n }\n return new Response(\"OK\");\n}\n\nasync function handleMessage(message: any) {\n const chatId = message.chat.id;\n const text = (message.text || \"\").trim();\n\n if (text === \"/start\") {\n await sendMessage(\n chatId,\n \"Привет! Пришли ссылку на видео из TikTok, Instagram, Pinterest, VK или любого другого сайта.\\n\\n\" +\n \"🎵 TikTok — выбор качества и звука.\\n\" +\n \"📌 Pinterest — видео/фото.\\n\" +\n \"📸 Instagram — reels/посты.\\n\" +\n \"🌐 Остальные — через универсальный загрузчик (Cobalt).\",\n );\n return;\n }\n\n const urlMatch = text.match(/https?:\\/\\/\\S+/);\n if (!urlMatch) {\n await sendMessage(chatId, \"Пришли ссылку на видео.\");\n return;\n }\n const url = urlMatch[0];\n\n try {\n if (url.includes(\"tiktok.com\")) await handleTikTok(chatId, url);\n else if (url.includes(\"instagram.com\")) await handleInstagram(chatId, url);\n else if (url.includes(\"pinterest.com\") || url.includes(\"pin.it\")) {\n await handlePinterest(chatId, url);\n } else if (url.includes(\"vk.com/video\") || url.includes(\"vkvideo.ru\")) {\n await handleVK(chatId, url);\n } else await handleUniversal(chatId, url);\n } catch (err) {\n console.error(\"Link error:\", err);\n await notifyOwner(\"Ошибка обработки ссылки: \" + err);\n await sendMessage(chatId, \"⚠️ Не удалось скачать. Попробуй другую ссылку.\");\n }\n}\n\nasync function handleCallback(cb: any) {\n const chatId = cb.message.chat.id;\n const action = cb.data;\n await answerCallback(cb.id);\n\n if (action === \"tt_sd\" || action === \"tt_hd\" || action === \"tt_audio\") {\n await handleTikTokCallback(chatId, action);\n return;\n }\n if (action.startsWith(\"vk_\")) {\n await handleVKCallback(chatId, action);\n return;\n }\n}","// ============================================================\n// ЕДИНЫЙ БОТ-ЗАГРУЗЧИК (TikTok, Instagram, VK, Pinterest, Cobalt)\n// Версия 2.0 – с фото Pinterest, улучшенным Instagram, диагностикой\n// ============================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ---------- Хранилище ----------\nasync function safeGetJSON(key: string): Promise {\n try {\n return await blob.getJSON(key);\n } catch {\n return null;\n }\n}\nasync function setJSON(key: string, value: unknown) {\n await blob.setJSON(key, value);\n}\n\n// ---------- Telegram API ----------\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nif (!TOKEN) throw new Error(\"TELEGRAM_BOT_TOKEN not set\");\nconst TG_API = `https://api.telegram.org/bot${TOKEN}/`;\nconst OWNER = Number(Deno.env.get(\"OWNER_CHAT_ID\") || \"0\");\n\nasync function callTelegram(method: string, payload: any) {\n const res = await fetch(TG_API + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n return res.json();\n}\n\nconst sendMessage = (chatId: number, text: string, replyMarkup?: any) =>\n callTelegram(\"sendMessage\", {\n chat_id: chatId,\n text,\n reply_markup: replyMarkup,\n });\nconst sendTyping = (chatId: number, action = \"typing\") =>\n callTelegram(\"sendChatAction\", { chat_id: chatId, action });\nconst sendVideoByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendVideo\", { chat_id: chatId, video: url, caption });\nconst sendPhotoByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendPhoto\", { chat_id: chatId, photo: url, caption });\nconst sendAudioByUrl = (chatId: number, url: string, caption = \"\") =>\n callTelegram(\"sendAudio\", { chat_id: chatId, audio: url, caption });\nconst answerCallback = (id: string) =>\n callTelegram(\"answerCallbackQuery\", { callback_query_id: id });\nconst setWebhook = (url: string) => callTelegram(\"setWebhook\", { url });\nconst notifyOwner = (text: string) =>\n OWNER ? sendMessage(OWNER, \"🐞 \" + text) : Promise.resolve();\n\n// ---------- Утилиты ----------\nasync function fetchHtml(url: string, headers = {}): Promise {\n const res = await fetch(url, {\n headers: {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0\",\n ...headers,\n },\n });\n return res.text();\n}\n\nfunction decodeEntities(str: string): string {\n return str.replace(/&/g, \"&\").replace(/"/g, '\"').replace(\n /'/g,\n \"'\",\n );\n}\n\n// ==================== ОБРАБОТЧИКИ ====================\n\n// ---------- TikTok (без изменений) ----------\nexport async function handleTikTok(chatId: number, url: string) {\n await sendTyping(chatId, \"upload_video\");\n const res = await fetch(\n `https://www.tikwm.com/api/?url=${encodeURIComponent(url)}`,\n );\n const data = await res.json();\n if (data.code !== 0 || !data.data?.play) {\n await sendMessage(chatId, \"❌ Не удалось найти видео TikTok.\");\n return;\n }\n const d = data.data;\n const abs = (\n u: string,\n ) => (u.startsWith(\"http\") ? u : \"https://www.tikwm.com\" + u);\n const pending = {\n sd: abs(d.play),\n hd: d.hdplay ? abs(d.hdplay) : null,\n music: d.music ? abs(d.music) : null,\n };\n await setJSON(`dlPending_${chatId}`, pending);\n const buttons = [[{ text: \"📹 SD\", callback_data: \"tt_sd\" }]];\n if (pending.hd) buttons[0].push({ text: \"🎬 HD\", callback_data: \"tt_hd\" });\n if (pending.music) {\n buttons[0].push({ text: \"🎵 Только звук\", callback_data: \"tt_audio\" });\n }\n await sendMessage(chatId, \"🎵 Видео найдено! Выбери качество:\", {\n inline_keyboard: buttons,\n });\n}\n\nexport async function handleTikTokCallback(chatId: number, action: string) {\n const pending = await safeGetJSON(`dlPending_${chatId}`);\n if (!pending) {\n await sendMessage(chatId, \"⚠️ Ссылка устарела, пришли видео заново.\");\n return;\n }\n await sendTyping(chatId, \"upload_video\");\n let url, caption;\n if (action === \"tt_sd\") {\n url = pending.sd;\n caption = \"📹 SD — без водяного знака\";\n } else if (action === \"tt_hd\") {\n url = pending.hd;\n caption = \"🎬 HD — без водяного знака\";\n } else if (action === \"tt_audio\") {\n url = pending.music;\n caption = \"🎵 Аудио из TikTok\";\n } else return;\n const r = await sendVideoByUrl(chatId, url, caption);\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${url}`,\n );\n }\n}\n\n// ---------- VK (без изменений) ----------\nasync function fetchVkHtml(url: string): Promise {\n const headers = {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0\",\n \"Accept\": \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n \"Accept-Language\": \"ru-RU,ru;q=0.9\",\n \"Cookie\": \"remixlang=0\",\n };\n let current = url;\n for (let i = 0; i < 8; i++) {\n const res = await fetch(current, { headers, redirect: \"manual\" });\n if (res.status >= 300 && res.status < 400) {\n const loc = res.headers.get(\"location\");\n if (!loc) break;\n current = new URL(loc, current).toString();\n continue;\n }\n return res.text();\n }\n throw new Error(\"VK: слишком много редиректов\");\n}\n\nexport async function handleVK(chatId: number, url: string) {\n await sendTyping(chatId);\n let html;\n try {\n html = await fetchVkHtml(url);\n } catch {\n await sendMessage(\n chatId,\n \"❌ VK не отвечает (возможно, требует авторизации). Попробуй позже.\",\n );\n return;\n }\n const qualities: { label: string; url: string }[] = [];\n const patterns: [string, RegExp][] = [\n [\"1080p\", /\"url1080\":\"([^\"]+)\"/],\n [\"720p\", /\"url720\":\"([^\"]+)\"/],\n [\"480p\", /\"url480\":\"([^\"]+)\"/],\n [\"360p\", /\"url360\":\"([^\"]+)\"/],\n [\"240p\", /\"url240\":\"([^\"]+)\"/],\n ];\n for (const [label, re] of patterns) {\n const m = html.match(re);\n if (m) {\n qualities.push({\n label,\n url: decodeEntities(m[1].replace(/\\\\\\//g, \"/\")),\n });\n }\n }\n if (qualities.length === 0) {\n await sendMessage(chatId, \"❌ Не найдено видео. Возможно, приватное.\");\n return;\n }\n await setJSON(`dlPendingVK_${chatId}`, qualities);\n const buttons = [\n qualities.slice(0, 3).map((q, i) => ({\n text: q.label,\n callback_data: \"vk_\" + i,\n })),\n ];\n await sendMessage(chatId, \"📹 Видео найдено! Выбери качество:\", {\n inline_keyboard: buttons,\n });\n}\n\nexport async function handleVKCallback(chatId: number, action: string) {\n const idx = Number(action.replace(\"vk_\", \"\"));\n const qualities = await safeGetJSON(`dlPendingVK_${chatId}`);\n if (!qualities || !qualities[idx]) {\n await sendMessage(chatId, \"⚠️ Ссылка устарела.\");\n return;\n }\n await sendTyping(chatId, \"upload_video\");\n const r = await sendVideoByUrl(\n chatId,\n qualities[idx].url,\n `📹 VK — ${qualities[idx].label}`,\n );\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${qualities[idx].url}`,\n );\n }\n}\n\n// ---------- Pinterest (видео + фото) ----------\nexport async function handlePinterest(chatId: number, url: string) {\n await sendTyping(chatId, \"upload_video\");\n const html = await fetchHtml(url);\n\n // 1. Ищем видео\n const videoMatch = html.match(\n /https:\\\\?\\/\\\\?\\/v1\\.pinimg\\.com\\\\?\\/videos\\\\?\\/[^\"]+?\\.mp4/,\n );\n if (videoMatch) {\n const videoUrl = videoMatch[0].replace(/\\\\\\//g, \"/\");\n const r = await sendVideoByUrl(chatId, videoUrl, \"📌 Pinterest (видео)\");\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${videoUrl}`,\n );\n }\n return;\n }\n\n // 2. Ищем фото (og:image или другие большие изображения)\n const imageMatches =\n html.match(/]+src=[\"']([^\"']+\\.(jpg|jpeg|png|webp))[\"']/gi);\n if (imageMatches) {\n let imgUrl = imageMatches[0];\n if (imgUrl.startsWith(\" {\n if (!url.includes(\"/share/\")) return url;\n try {\n const res = await fetch(url, { redirect: \"follow\" });\n return res.url || url;\n } catch {\n return url;\n }\n}\n\nasync function sendInstagramCarousel(\n chatId: number,\n items: any[],\n total: number,\n) {\n let anySent = false;\n for (let i = 0; i < items.length; i++) {\n const item = items[i];\n const cap = total > 1 ? `📸 Instagram (${i + 1}/${total})` : \"📸 Instagram\";\n const vid = item?.video_versions?.[0]?.url;\n if (vid) {\n const r = await sendVideoByUrl(chatId, vid, cap);\n if (r.ok) {\n anySent = true;\n continue;\n }\n }\n const img = item?.image_versions2?.candidates?.[0]?.url;\n if (img) {\n await sendPhotoByUrl(chatId, img, cap);\n anySent = true;\n }\n }\n return anySent;\n}\n\nexport async function handleInstagram(chatId: number, rawUrl: string) {\n await sendTyping(chatId, \"upload_video\");\n const url = await resolveInstagramShare(rawUrl);\n const match = url.match(/instagram\\.com\\/(?:reels?|p|tv)\\/([A-Za-z0-9_-]+)/);\n if (!match) {\n await sendMessage(chatId, \"❌ Не распознана ссылка Instagram.\");\n return;\n }\n const shortcode = match[1];\n\n // Способ 1: официальный API (может быть заблокирован)\n try {\n const mediaId = shortcodeToMediaId(shortcode);\n const apiRes = await fetch(\n `https://i.instagram.com/api/v1/media/${mediaId}/info/`,\n {\n headers: {\n \"x-ig-app-id\": \"936619743392459\",\n \"User-Agent\": \"Instagram 219.0.0.12.117 Android\",\n },\n },\n );\n const apiData = await apiRes.json();\n const item = apiData?.items?.[0];\n if (item?.carousel_media?.length) {\n const sent = await sendInstagramCarousel(\n chatId,\n item.carousel_media,\n item.carousel_media.length,\n );\n if (sent) return;\n } else if (item) {\n const sent = await sendInstagramCarousel(chatId, [item], 1);\n if (sent) return;\n }\n } catch { /* fallback */ }\n\n // Способ 2: embed-страница\n try {\n const embedUrl =\n `https://www.instagram.com/reel/${shortcode}/embed/captioned/`;\n const html = await fetchHtml(embedUrl);\n const videoMatch = html.match(/\"video_url\":\"([^\"]+)\"/) ||\n html.match(/]+src=\"([^\"]+)\"/);\n if (videoMatch) {\n const videoUrl = decodeEntities(\n videoMatch[1].replace(/\\\\u0026/g, \"&\").replace(/\\\\\\//g, \"/\"),\n );\n const r = await sendVideoByUrl(chatId, videoUrl, \"📸 Instagram\");\n if (r.ok) return;\n }\n const imageMatch = html.match(\n / 1\n ? `📸 Instagram (${i + 1}/${edges.length})`\n : \"📸 Instagram\";\n if (node.video_url) {\n const r = await sendVideoByUrl(chatId, node.video_url, cap);\n if (r.ok) {\n anySent = true;\n continue;\n }\n }\n if (node.display_url) {\n await sendPhotoByUrl(chatId, node.display_url, cap);\n anySent = true;\n }\n }\n if (anySent) return;\n }\n }\n }\n } catch { /* всё */ }\n\n await sendMessage(\n chatId,\n \"❌ Не удалось скачать. Попробуй ещё раз или пост приватный.\",\n );\n}\n\n// ---------- Универсальный загрузчик (Cobalt) ----------\nconst PUBLIC_COBALT = \"https://cobalt-api.vercel.app\";\n\nasync function callCobalt(url: string, apiUrl: string, apiKey?: string) {\n const res = await fetch(apiUrl, {\n method: \"POST\",\n headers: {\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/json\",\n ...(apiKey ? { \"Authorization\": `Api-Key ${apiKey}` } : {}),\n },\n body: JSON.stringify({ url, downloadMode: \"auto\", filenameStyle: \"basic\" }),\n });\n return res.json();\n}\n\nfunction guessKind(filename?: string): \"video\" | \"audio\" | \"photo\" {\n const ext = (filename || \"\").toLowerCase().split(\".\").pop() || \"\";\n if ([\"mp3\", \"m4a\", \"ogg\", \"opus\", \"wav\", \"flac\"].includes(ext)) {\n return \"audio\";\n }\n if ([\"jpg\", \"jpeg\", \"png\", \"webp\"].includes(ext)) return \"photo\";\n return \"video\";\n}\n\nasync function sendResolved(\n chatId: number,\n kind: \"video\" | \"audio\" | \"photo\",\n url: string,\n caption: string,\n) {\n const sender = kind === \"audio\"\n ? sendAudioByUrl\n : kind === \"photo\"\n ? sendPhotoByUrl\n : sendVideoByUrl;\n const r = await sender(chatId, url, caption);\n if (!r.ok) {\n await sendMessage(\n chatId,\n `⚠️ Не удалось отправить. Прямая ссылка:\\n${url}`,\n );\n }\n return r.ok;\n}\n\nexport async function handleUniversal(chatId: number, url: string) {\n const apiUrl = Deno.env.get(\"COBALT_API_URL\") || PUBLIC_COBALT;\n const apiKey = Deno.env.get(\"COBALT_API_KEY\");\n\n await sendTyping(chatId, \"upload_video\");\n let data;\n try {\n data = await callCobalt(url, apiUrl, apiKey);\n } catch (err) {\n await sendMessage(\n chatId,\n \"❌ Не удалось связаться с сервисом загрузки. Проверь интернет.\",\n );\n return;\n }\n\n // Если публичный инстанс вернул ошибку 404 или другую – подсказываем\n if (data.status === \"error\" || data.error) {\n const code = data.error?.code || \"\";\n if (code === 404 || code === \"404\") {\n await sendMessage(\n chatId,\n \"❌ Ссылка не найдена или сервис временно недоступен.\\n\" +\n \"Для YouTube и некоторых сайтов публичный Cobalt часто блокирует запросы. \" +\n \"Рекомендую развернуть свой инстанс Cobalt (бесплатно на Railway) и задать COBALT_API_URL в переменных окружения Val Town.\\n\" +\n \"Инструкция: https://github.com/imputnet/cobalt\",\n );\n } else {\n await sendMessage(\n chatId,\n `❌ Ошибка ${code || \"неизвестная\"}. Проверь ссылку.`,\n );\n }\n return;\n }\n\n // Успешный результат\n if (data.status === \"tunnel\" || data.status === \"redirect\") {\n const kind = guessKind(data.filename);\n await sendResolved(chatId, kind, data.url, \"🔗 Загружено\");\n return;\n }\n\n if (\n data.status === \"picker\" && Array.isArray(data.picker) && data.picker.length\n ) {\n let anySent = false;\n for (let i = 0; i < data.picker.length; i++) {\n const item = data.picker[i];\n const kind = item.type === \"photo\" ? \"photo\" : \"video\";\n const cap = data.picker.length > 1\n ? `🔗 Загружено (${i + 1}/${data.picker.length})`\n : \"🔗 Загружено\";\n const ok = await sendResolved(chatId, kind, item.url, cap);\n anySent = anySent || ok;\n }\n if (data.audio) {\n await sendResolved(chatId, \"audio\", data.audio, \"🎵 Звук\");\n }\n if (!anySent) {\n await sendMessage(chatId, \"❌ Не удалось отправить ни один файл.\");\n }\n return;\n }\n\n await sendMessage(chatId, \"❌ Не удалось найти медиа по этой ссылке.\");\n}\n\n// ==================== ГЛАВНЫЙ ОБРАБОТЧИК ====================\nconst WEBHOOK_URL = Deno.env.get(\"WEBHOOK_URL\");\nif (!WEBHOOK_URL) {\n console.error(\"❌ WEBHOOK_URL не задан в переменных окружения!\");\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n if (!WEBHOOK_URL) {\n return new Response(\n \"❌ Ошибка: WEBHOOK_URL не задан. Установи переменную окружения.\",\n );\n }\n const res = await setWebhook(WEBHOOK_URL);\n return new Response(\n res.ok\n ? \"✅ Бот активен. Вебхук настроен.\"\n : `⚠️ Ошибка вебхука: ${JSON.stringify(res)}`,\n );\n }\n\n try {\n const data = await req.json();\n\n // Дедупликация\n const updateId = data.update_id;\n const lastId = (await safeGetJSON(\"dlLastUpdateId_v2\")) || 0;\n if (lastId && Number(lastId) >= updateId) return new Response(\"OK\");\n await setJSON(\"dlLastUpdateId_v2\", updateId);\n\n if (data.message) await handleMessage(data.message);\n else if (data.callback_query) await handleCallback(data.callback_query);\n } catch (err) {\n console.error(\"Handler error:\", err);\n await notifyOwner(\"Ошибка: \" + err);\n }\n return new Response(\"OK\");\n}\n\nasync function handleMessage(message: any) {\n const chatId = message.chat.id;\n const text = (message.text || \"\").trim();\n\n if (text === \"/start\") {\n await sendMessage(\n chatId,\n \"Привет! Пришли ссылку на видео из TikTok, Instagram, Pinterest, VK или любого другого сайта.\\n\\n\" +\n \"🎵 TikTok — выбор качества и звука.\\n\" +\n \"📌 Pinterest — видео и фото.\\n\" +\n \"📸 Instagram — reels/посты (карусели тоже).\\n\" +\n \"🌐 Остальные — через универсальный загрузчик (Cobalt).\\n\\n\" +\n \"Для YouTube и некоторых сайтов нужен свой Cobalt-инстанс (инструкция в /help).\",\n );\n return;\n }\n\n if (text === \"/help\") {\n await sendMessage(\n chatId,\n \"Если бот не может скачать YouTube или другой сайт:\\n\" +\n \"1. Разверни свой Cobalt на Railway (шаблон «Cobalt Self-Hosted»).\\n\" +\n \"2. В Val Town → Settings → Environment Variables добавь:\\n\" +\n \" COBALT_API_URL = https://твой-инстанс.up.railway.app\\n\" +\n \"3. Перезапусти вал (или открой его URL в браузере).\\n\" +\n \"После этого всё будет работать.\",\n );\n return;\n }\n\n const urlMatch = text.match(/https?:\\/\\/\\S+/);\n if (!urlMatch) {\n await sendMessage(chatId, \"Пришли ссылку на видео или фото.\");\n return;\n }\n const url = urlMatch[0];\n\n try {\n if (url.includes(\"tiktok.com\")) await handleTikTok(chatId, url);\n else if (url.includes(\"instagram.com\")) await handleInstagram(chatId, url);\n else if (url.includes(\"pinterest.com\") || url.includes(\"pin.it\")) {\n await handlePinterest(chatId, url);\n } else if (url.includes(\"vk.com/video\") || url.includes(\"vkvideo.ru\")) {\n await handleVK(chatId, url);\n } else await handleUniversal(chatId, url);\n } catch (err) {\n console.error(\"Link error:\", err);\n await notifyOwner(\"Ошибка обработки ссылки: \" + err);\n await sendMessage(chatId, \"⚠️ Не удалось скачать. Попробуй другую ссылку.\");\n }\n}\n\nasync function handleCallback(cb: any) {\n const chatId = cb.message.chat.id;\n const action = cb.data;\n await answerCallback(cb.id);\n\n if (action === \"tt_sd\" || action === \"tt_hd\" || action === \"tt_audio\") {\n await handleTikTokCallback(chatId, action);\n return;\n }\n if (action.startsWith(\"vk_\")) {\n await handleVKCallback(chatId, action);\n return;\n }\n}","createdAt",["D",1786701602562],"branchVersion","branchId","329cc411-22a6-4412-98c0-3d332b67f9c8","id","6c575c4c-4f90-4931-a54b-799be476a78c","tiktok_insta_pinterestSaverbot",["D",1784747184691],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","75c74a35-f63f-4364-86a0-619436fc8b56","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8156-70bb-7444-a99c-191ee2a95e63","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",64,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","eldarjzj","handle","displayName","Эльдар","avatar","https://lh3.googleusercontent.com/a/ACg8ocJdctuUMupnroZ9VQYY7hdioaiyckuWtRYjbMrlA7zHrIBrw4KU=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":152,"_80":153,"_82":154,"_84":25},"tree",[146],"files",[146],"counts",{"_134":62,"_135":136,"_137":62,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"5a458194-f1d1-4c81-96fc-5265f0830975","parentId","latest",["D",1786701602562],22,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":62},"connections",{"_142":62,"_143":62},"count","unfilledCount",3,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1786701602562],"children",[],[28],["D",1784747184691],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":58,"_197":-5,"_198":-7,"_199":-7,"_200":62,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":86,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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 · v62