Bump drizzle-orm from 1.0.0-beta.9-e89174b to 1.0.0-beta.12-5845444

Bumps [drizzle-orm](https://github.com/drizzle-team/drizzle-orm) from 1.0.0-beta.9-e89174b to 1.0.0-beta.12-5845444.
- [Release notes](https://github.com/drizzle-team/drizzle-orm/releases)
- [Commits](https://github.com/drizzle-team/drizzle-orm/commits)

---
updated-dependencies:
- dependency-name: drizzle-orm
  dependency-version: 1.0.0-beta.12-5845444
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

package.json

@@ -17,14 +17,18 @@
     "drizzle-orm": "^1.0.0-beta.12-5845444",
     "emoji-regex": "^10.6.0",
     "ollama": "^0.6.3",
+    "puppeteer": "^24.36.1",
+    "puppeteer-extra": "^3.3.6",
+    "puppeteer-extra-plugin-stealth": "^2.11.2",
     "qrcode": "^1.5.4",
     "sharp": "^0.34.5",
     "systeminformation": "^5.30.6",
     "twemoji": "^14.0.2",
-    "typescript-telegram-bot-api": "^0.11.0"
+    "typescript-telegram-bot-api": "^0.11.0",
+    "youtubei.js": "^16.0.1"
   },
   "devDependencies": {
-    "@types/bun": "^1.3.7",
+    "@types/bun": "^1.3.8",
     "@types/node": "^25.1.0",
     "@types/qrcode": "^1.5.6",
     "@typescript-eslint/eslint-plugin": "^8.54.0",

src/commands/gemini-chat.ts

@@ -13,7 +13,6 @@ import {
     oldReplyToMessage,
     startIntervalEditor
 } from "../util/utils";
-import fs from "node:fs";
 
 export class GeminiChat extends ChatCommand {
     command = "gemini";
@@ -66,10 +65,9 @@ export class GeminiChat extends ChatCommand {
             const images = messageParts[0].images;
 
             images.forEach(image => {
-                const base64Image = Buffer.from(fs.readFileSync(image)).toString("base64");
                 input.push({
                     type: "image",
-                    data: base64Image,
+                    data: image,
                     mime_type: "image/png"
                 });
             });

src/commands/mistral-chat.ts

@@ -7,13 +7,11 @@ import {
     escapeMarkdownV2Text,
     logError,
     oldReplyToMessage,
-    photoPathByUniqueId,
     startIntervalEditor
 } from "../util/utils";
 import {Environment} from "../common/environment";
 import {bot, mistralAi} from "../index";
 import {MessageStore} from "../common/message-store";
-import fs from "node:fs";
 
 export class MistralChat extends ChatCommand {
     command = "mistral";
@@ -46,10 +44,9 @@ export class MistralChat extends ChatCommand {
             });
 
             for (const image of part.images) {
-                const base64Image = Buffer.from(fs.readFileSync(photoPathByUniqueId(image))).toString("base64");
                 content.push({
                     type: "image_url",
-                    imageUrl: "data:image/jpeg;base64," + base64Image
+                    imageUrl: "data:image/jpeg;base64," + image
                 });
             }
 
@@ -84,6 +81,7 @@ export class MistralChat extends ChatCommand {
 
             const stream = await mistralAi.chat.stream({
                 model: Environment.MISTRAL_MODEL,
+                // eslint-disable-next-line @typescript-eslint/no-explicit-any
                 messages: chatMessages as any
             });
 

src/commands/ollama-chat.ts

@@ -16,7 +16,7 @@ import {OllamaCancel} from "../callback_commands/ollama-cancel";
 import {OllamaGetModel} from "./ollama-get-model";
 
 export class OllamaChat extends ChatCommand {
-    command = "ollama";
+    command = ["ollama", "ollamathink"];
     argsMode = "required" as const;
 
     title = "/ollama";
@@ -24,10 +24,10 @@ export class OllamaChat extends ChatCommand {
 
     async execute(msg: Message, match?: RegExpExecArray | null): Promise<void> {
         console.log("match", match);
-        return this.executeOllama(msg, match?.[3]);
+        return this.executeOllama(msg, match?.[3], match?.[1]?.toLowerCase()?.startsWith("ollamathink"));
     }
 
-    async executeOllama(msg: Message, text: string): Promise<void> {
+    async executeOllama(msg: Message, text: string, think: boolean = false): Promise<void> {
         if (!text || text.trim().length === 0) return;
 
         const chatId = msg.chat.id;
@@ -55,9 +55,9 @@ export class OllamaChat extends ChatCommand {
                 return total + (curr.images?.length ?? 0);
             }, 0);
 
-            if (imagesCount) {
+            if (!think && imagesCount) {
                 try {
-                    const modelInfo = await chatCommands.find(c => c instanceof OllamaGetModel).loadModelInfo();
+                    const modelInfo = await chatCommands.find(c => c instanceof OllamaGetModel).loadImageModelInfo();
                     if (modelInfo) {
                         const caps = modelInfo.capabilities || [];
                         if (!caps.includes("vision")) {
@@ -73,20 +73,38 @@ export class OllamaChat extends ChatCommand {
                 }
             }
 
+            if (think) {
+                try {
+                    const modelInfo = await chatCommands.find(c => c instanceof OllamaGetModel).loadThinkModelInfo();
+                    if (modelInfo) {
+                        const caps = modelInfo.capabilities || [];
+                        if (!caps.includes("thinking")) {
+                            await replyToMessage({
+                                message: msg,
+                                text: "Моя текущая модель не умеет размышлять 🥹"
+                            });
+                            return;
+                        }
+                    }
+                } catch (e) {
+                    logError(e);
+                }
+            }
+
             const uuid = crypto.randomUUID();
             const cancelMarkup = {inline_keyboard: [[Cancel.withData(new OllamaCancel().data + " " + uuid).asButton()]]};
 
             waitMessage = await replyToMessage({
                 message: msg,
-                text: imagesCount ?
+                text: (!think && imagesCount) ?
                     imagesCount > 1 ? Environment.analyzingPicturesText : Environment.analyzingPictureText
                     : Environment.waitText
             });
 
             const stream = await ollama.chat({
-                model: Environment.OLLAMA_MODEL,
+                model: think ? Environment.OLLAMA_THINK_MODEL : imagesCount ? Environment.OLLAMA_IMAGE_MODEL : Environment.OLLAMA_MODEL,
                 stream: true,
-                think: false,
+                think: think,
                 messages: chatMessages,
             });
 
@@ -153,6 +171,7 @@ export class OllamaChat extends ChatCommand {
                                 message_id: waitMessage.message_id,
                                 text: "🤔 Размышляю...",
                                 parse_mode: "Markdown",
+                                reply_markup: cancelMarkup
                             }).catch(logError);
                         }
 

src/commands/ollama-get-model.ts

@@ -11,25 +11,75 @@ export class OllamaGetModel extends ChatCommand {
 
     async execute(msg: Message): Promise<void> {
         try {
-            const showResponse = await this.loadModelInfo();
+            const model = Environment.OLLAMA_MODEL;
+            const imageModel = Environment.OLLAMA_IMAGE_MODEL;
+            const thinkModel = Environment.OLLAMA_THINK_MODEL;
 
-            const caps = showResponse.capabilities;
+            const promises: (Promise<ShowResponse | null> | null)[] = [this.loadModelInfo()];
 
-            const text = "```Ollama\n" +
-                `model: ${Environment.OLLAMA_MODEL}\n\n` +
-                `vision: ${boolToEmoji(caps.includes("vision"))}\n` +
-                `thinking: ${boolToEmoji(caps.includes("thinking"))}\n` +
-                `tools: ${boolToEmoji(caps.includes("tools"))}`
-                + "```";
+            if (imageModel && imageModel !== model) {
+                promises.push(this.loadImageModelInfo());
+            } else {
+                promises.push(null);
+            }
+
+            if (thinkModel && thinkModel !== model) {
+                promises.push(this.loadThinkModelInfo());
+            } else {
+                promises.push(null);
+            }
+
+            const infos = await Promise.all(promises);
+
+            let modelInfo = infos[0];
+            const modelText = "```Text\n" + this.getModelText(model, modelInfo) + "```";
+
+            modelInfo = infos[1];
+            const imageModelText = modelInfo ?
+                "```Image\n" + this.getModelText(imageModel, modelInfo) + "```" : null;
+
+            modelInfo = infos[2];
+            const thinkModelText = modelInfo ?
+                "```Think\n" + this.getModelText(thinkModel, modelInfo) + "```" : null;
+
+            const modelInfos = [modelText];
+            if (imageModelText) {
+                modelInfos.push(imageModelText);
+            }
+            if (thinkModelText) {
+                modelInfos.push(thinkModelText);
+            }
+
+            await replyToMessage({
+                message: msg,
+                text: modelInfos.join("\n\n"),
+                parse_mode: "Markdown"
+            }).catch(logError);
 
-            await replyToMessage({message: msg, text: text, parse_mode: "Markdown"}).catch(logError);
         } catch (e) {
             logError(e);
             await replyToMessage({message: msg, text: e.toString()}).catch(logError);
         }
     }
 
+    private getModelText(model: string, info: ShowResponse): string {
+        const caps = info.capabilities;
+
+        return `model: ${model}\n\n` +
+            `vision: ${boolToEmoji(caps.includes("vision"))}\n` +
+            `thinking: ${boolToEmoji(caps.includes("thinking"))}\n` +
+            `tools: ${boolToEmoji(caps.includes("tools"))}`;
+    }
+
     async loadModelInfo(): Promise<ShowResponse | null> {
         return ollama.show({model: Environment.OLLAMA_MODEL});
     }
+
+    async loadImageModelInfo(): Promise<ShowResponse | null> {
+        return ollama.show({model: Environment.OLLAMA_IMAGE_MODEL});
+    }
+
+    async loadThinkModelInfo(): Promise<ShowResponse | null> {
+        return ollama.show({model: Environment.OLLAMA_THINK_MODEL});
+    }
 }

src/commands/youtube-download.ts

@@ -0,0 +1,54 @@
+import {ChatCommand} from "../base/chat-command";
+import {Message} from "typescript-telegram-bot-api";
+import {logError, replyToMessage} from "../util/utils";
+import {bot} from "../index";
+import {downloadVideoFromYouTube} from "../util/ytdl";
+
+export class YouTubeDownload extends ChatCommand {
+    command = ["ytdl", "youtube"];
+    argsMode = "required" as const;
+
+    async execute(msg: Message, match?: RegExpExecArray): Promise<void> {
+        const url = match?.[3];
+        return this.downloadYouTubeVideo(msg, url);
+    }
+
+    async downloadYouTubeVideo(msg: Message, url: string): Promise<void> {
+        let waitMessage: Message | null = null;
+
+        try {
+            waitMessage = await replyToMessage({message: msg, text: "⏳ Секунду..."});
+
+            const {time, exists, buffer} = await downloadVideoFromYouTube(url);
+            if (buffer) {
+                const start = Date.now();
+                waitMessage = await bot.editMessageMedia({
+                    chat_id: msg.chat.id,
+                    message_id: waitMessage.message_id,
+                    media: {
+                        type: "video",
+                        media: buffer
+                    }
+                }) as Message;
+
+                const diff = Date.now() - start;
+                waitMessage = await bot.editMessageCaption({
+                    chat_id: msg.chat.id,
+                    message_id: waitMessage.message_id,
+                    caption: `✅ [Видео](${url})` + (exists ? " загружено из кэша" : " успешно скачано") + " за " + (time + diff) + "мс",
+                    parse_mode: "MarkdownV2"
+                }) as Message;
+            }
+        } catch (e) {
+            logError(e);
+
+            if (waitMessage && "text" in waitMessage) {
+                await bot.editMessageText({
+                    chat_id: msg.chat.id,
+                    message_id: waitMessage.message_id,
+                    text: `⚠️ Произошла ошибка.\n${e}`,
+                });
+            }
+        }
+    }
+}

src/common/environment.ts

@@ -1,6 +1,7 @@
 import path from "node:path";
 import {saveData} from "../db/database";
 import {Answers} from "../model/answers";
+import {ifTrue} from "../util/utils";
 
 export class Environment {
     static BOT_TOKEN: string;
@@ -27,6 +28,8 @@ export class Environment {
 
     static OLLAMA_ADDRESS?: string;
     static OLLAMA_MODEL?: string;
+    static OLLAMA_IMAGE_MODEL?: string;
+    static OLLAMA_THINK_MODEL?: string;
     static OLLAMA_API_KEY?: string;
 
     static GEMINI_API_KEY?: string;
@@ -44,24 +47,26 @@ export class Environment {
 
     static load() {
         Environment.BOT_TOKEN = process.env.BOT_TOKEN;
-        Environment.TEST_ENVIRONMENT = process.env.TEST_ENVIRONMENT === "true";
+        Environment.TEST_ENVIRONMENT = ifTrue(process.env.TEST_ENVIRONMENT);
         Environment.CHAT_IDS_WHITELIST = new Set(process.env.CHAT_IDS_WHITELIST?.split(",")?.map(e => parseInt(e.trim(), 10)) || []);
         Environment.BOT_PREFIX = process.env.BOT_PREFIX || "";
         Environment.CREATOR_ID = parseInt(process.env.CREATOR_ID || "");
-        Environment.IS_DOCKER = process.env.IS_DOCKER == "true";
+        Environment.IS_DOCKER = ifTrue(process.env.IS_DOCKER);
         Environment.DATA_PATH = Environment.IS_DOCKER ? "/" + path.join("config", "data") : "data";
         Environment.DB_PATH = "file:" + path.join(Environment.DATA_PATH, Environment.DB_FILE_NAME);
 
-        Environment.ONLY_FOR_CREATOR_MODE = process.env.ONLY_FOR_CREATOR_MODE == "true";
+        Environment.ONLY_FOR_CREATOR_MODE = ifTrue(process.env.ONLY_FOR_CREATOR_MODE);
 
-        Environment.USE_NAMES_IN_PROMPT = process.env.USE_NAMES_IN_PROMPT == "true";
+        Environment.USE_NAMES_IN_PROMPT = ifTrue(process.env.USE_NAMES_IN_PROMPT);
 
         Environment.MAX_PHOTO_SIZE = Number(process.env.MAX_PHOTO_SIZE || "1280");
 
         Environment.SYSTEM_PROMPT = process.env.SYSTEM_PROMPT?.trim();
 
         Environment.OLLAMA_ADDRESS = process.env.OLLAMA_ADDRESS;
-        Environment.OLLAMA_MODEL = process.env.OLLAMA_MODEL;
+        Environment.OLLAMA_MODEL = process.env.OLLAMA_MODEL || "gemma3:4b";
+        Environment.OLLAMA_IMAGE_MODEL = process.env.OLLAMA_IMAGE_MODEL || Environment.OLLAMA_MODEL;
+        Environment.OLLAMA_THINK_MODEL = process.env.OLLAMA_THINK_MODEL || Environment.OLLAMA_MODEL;
         Environment.OLLAMA_API_KEY = process.env.OLLAMA_API_KEY;
 
         Environment.GEMINI_API_KEY = process.env.GEMINI_API_KEY;

src/common/message-store.ts

@@ -1,6 +1,6 @@
 import {StoredMessage} from "../model/stored-message";
 import {Message} from "typescript-telegram-bot-api";
-import {extractTextMessage, isStoredMessage} from "../util/utils";
+import {extractTextMessage, getPhotoMaxSize, isStoredMessage} from "../util/utils";
 import {messageDao} from "../index";
 
 export class MessageStore {
@@ -22,6 +22,7 @@ export class MessageStore {
             fromId: m.from.id,
             text: extractTextMessage(m),
             date: m.date ?? 0,
+            photoMaxSizeFilePath: m.photo ? [getPhotoMaxSize(m.photo).file_unique_id] : null
         };
 
         this.map.set(this.key(msg.chatId, msg.id), msg);

src/common/user-store.ts

@@ -9,7 +9,7 @@ export class UserStore {
         return this.map;
     }
 
-    static async put(u: User) {
+    static async put(u: User): Promise<StoredUser> {
         const user: StoredUser = {
             id: u.id,
             isBot: u.is_bot,
@@ -22,6 +22,7 @@ export class UserStore {
         this.map.set(u.id, user);
 
         await userDao.insert(userDao.mapTo([u]));
+        return user;
     }
 
     static async get(id: number): Promise<StoredUser | null> {

src/index.ts

@@ -3,8 +3,10 @@ import {Environment} from "./common/environment";
 import {InlineQueryResult, TelegramBot, User} from "typescript-telegram-bot-api";
 import {ChatCommand} from "./base/chat-command";
 import {
+    delay,
     extractTextMessage,
     findAndExecuteCallbackCommand,
+    ignore,
     initSystemSpecs,
     logError,
     processNewMessage
@@ -66,6 +68,11 @@ import {GeminiGetModel} from "./commands/gemini-get-model";
 import {GeminiSetModel} from "./commands/gemini-set-model";
 import {Debug} from "./commands/debug";
 import {GeminiGenerateImage} from "./commands/gemini-generate-image";
+import {YouTubeDownload} from "./commands/youtube-download";
+import fs from "node:fs";
+import path from "node:path";
+import {setInterval} from "node:timers";
+import {clearUpVideoFolder} from "./util/files";
 
 process.setUncaughtExceptionCaptureCallback(logError);
 
@@ -148,6 +155,8 @@ export const chatCommands: ChatCommand[] = [
 
     new Shutdown(),
     new Leave(),
+
+    new YouTubeDownload()
 ];
 
 export const callbackCommands: CallbackCommand[] = [
@@ -187,7 +196,12 @@ if (Environment.MISTRAL_API_KEY) {
     );
 }
 
+export const photoDir = path.join(Environment.DATA_PATH, "photo");
+export const videoDir = path.join(Environment.DATA_PATH, "video");
+
 async function main() {
+    const start = Date.now();
+
     console.log(
         `TEST_ENVIRONMENT: ${Environment.TEST_ENVIRONMENT}\n` +
         `DATA_PATH: ${Environment.DATA_PATH}\n` +
@@ -195,6 +209,25 @@ async function main() {
         `ONLY_FOR_CREATOR: ${Environment.ONLY_FOR_CREATOR_MODE}`
     );
 
+    fs.mkdir(photoDir, ignore);
+    fs.mkdir(videoDir, ignore);
+
+    const now = new Date();
+
+    const midnight = new Date();
+    midnight.setHours(0, 0, 0, 0);
+    midnight.setDate(now.getDate() + 1);
+
+    const diff = midnight.getTime() - now.getTime();
+    console.log("Clearing up videos will be started in " + diff + "ms");
+
+    delay(diff).then(() => {
+        setInterval(() => {
+            console.log("Started clearing up videos");
+            clearUpVideoFolder();
+        }, 1000 * 60 * 60 * 24);
+    });
+
     const commands = chatCommands.filter(cmd => {
         return cmd.title && cmd.title.startsWith("/") && cmd.title.split(" ").length === 1 && cmd.description;
     }).map(cmd => {
@@ -216,7 +249,9 @@ async function main() {
         await UserStore.put(botUser);
         await bot.startPolling();
 
-        console.log("Bot started!");
+        const end = Date.now();
+        const diff = Math.abs(end - start);
+        console.log(`Bot started in ${diff}ms!`);
     } catch (error) {
         logError(error);
     }

src/model/ollama-request.ts

@@ -1,5 +1,6 @@
 export type OllamaRequest = {
     uuid: string;
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     stream: any;
     done: boolean;
     fromId: number;

src/util/files.ts

@@ -0,0 +1,41 @@
+import {logError} from "./utils";
+import fs from "node:fs";
+import {videoDir} from "../index";
+import path from "node:path";
+
+export function clearUpVideoFolder() {
+    fs.readdir(videoDir, (err, files) => {
+        if (err) {
+            logError(err);
+            return;
+        }
+
+        const filenamesToDelete: string[] = [];
+
+        files.forEach((filename, index) => {
+            fs.stat(path.join(videoDir, filename), (err, stats) => {
+                if (err) {
+                    logError(err);
+                } else {
+                    const then = stats.mtime.getTime() / 1000;
+                    const now = Date.now() / 1000;
+                    const diff = Math.abs(now - then);
+                    const moreThanOneDay = diff >= 60 * 60 * 24;
+                    if (moreThanOneDay) {
+                        filenamesToDelete.push(filename);
+                    }
+
+                    if (index === files.length - 1) {
+                        console.log("filenamesToDelete", filenamesToDelete);
+                        if (filenamesToDelete.length) {
+                            filenamesToDelete.forEach((filename) => {
+                                const fullPath = path.join(videoDir, filename);
+                                fs.rm(fullPath, logError);
+                            });
+                        }
+                    }
+                }
+            });
+        });
+    });
+}

src/util/utils.ts

@@ -27,6 +27,8 @@ import {MessageStore} from "../common/message-store";
 import {SystemInfo} from "../commands/system-info";
 import {PrefixResponse} from "../commands/prefix-response";
 import {OllamaChat} from "../commands/ollama-chat";
+import {getYouTubeVideoId} from "./ytdl";
+import {YouTubeDownload} from "../commands/youtube-download";
 
 export const ignore = () => {
 };
@@ -469,10 +471,14 @@ export function extractTextMessage(msg: Message | StoredMessage | string): strin
 export function cutPrefixes(msg: Message | StoredMessage | string): string {
     const prefixes = [
         Environment.BOT_PREFIX,
+        `/ollamathink@${botUser.username}`,
+        "/ollamathink",
+        `/ollama@${botUser.username}`,
+        "/ollama",
         `/gemini@${botUser.username}`,
         "/gemini",
         `/mistral@${botUser.username}`,
-        "/mistral"
+        "/mistral",
     ];
 
     const text = extractTextMessage(msg);
@@ -497,11 +503,20 @@ export async function loadImagesIfExists(msg: Message | StoredMessage): Promise<
         return msg.photoMaxSizeFilePath;
     }
 
+    if (!msg.photo?.length) return;
+
     const imageFilePaths: string[] = [];
 
-    const maxSize = await getPhotoMaxSize(msg.photo);
+    for (const size of msg.photo) {
+        const exists = fs.existsSync(photoPathByUniqueId(size.file_unique_id));
+        if (exists) {
+            return [size.file_unique_id];
+        }
+    }
+
+    const maxSize = await mapPhotoSizeToMax(getPhotoMaxSize(msg.photo));
     if (maxSize) {
-        const imagePath = path.join(Environment.DATA_PATH, "temp");
+        const imagePath = path.join(Environment.DATA_PATH, "photo");
         if (!fs.existsSync(imagePath)) {
             fs.mkdirSync(imagePath);
         }
@@ -527,14 +542,23 @@ export async function loadImagesIfExists(msg: Message | StoredMessage): Promise<
     return imageFilePaths;
 }
 
-export async function loadImagesFromFileIds(maxSizes: PhotoMaxSize[]): Promise<string[] | null> {
-    if (!maxSizes?.length) return null;
+export async function loadImagesFromFileIds(sizes: PhotoSize[]): Promise<string[] | null> {
+    if (!sizes?.length) return null;
 
-    const dataPath = path.join(Environment.DATA_PATH, "temp");
+    const dataPath = path.join(Environment.DATA_PATH, "photo");
     if (!fs.existsSync(dataPath)) {
         fs.mkdirSync(dataPath);
     }
 
+    const existing =
+        sizes.filter(s => fs.existsSync(photoPathByUniqueId(s.file_unique_id)))
+            .map(s => s.file_unique_id);
+
+    const promises = sizes.filter(s => !fs.existsSync(photoPathByUniqueId(s.file_unique_id)))
+        .map(s => mapPhotoSizeToMax(s));
+
+    const maxSizes = await Promise.all(promises);
+
     const imagePromises = maxSizes.map((size) => {
         return axios.get<ArrayBuffer>(size.url, {responseType: "arraybuffer"});
     });
@@ -542,17 +566,19 @@ export async function loadImagesFromFileIds(maxSizes: PhotoMaxSize[]): Promise<s
     const responses = await Promise.all(imagePromises);
     const paths = responses.map((res, index) => {
         try {
-            const imageFilePath = path.join(dataPath, maxSizes[index].unique_file_id + ".jpg");
+            const uniqueFileId = maxSizes[index].unique_file_id;
+            const imageFilePath = path.join(dataPath, uniqueFileId + ".jpg");
             const src = Buffer.from(res.data);
             fs.writeFileSync(imageFilePath, src);
-            return imageFilePath;
+            return uniqueFileId;
         } catch (e) {
             logError(e);
             return null;
         }
     });
-
-    return paths.filter(p => p);
+    const finalPaths = paths.filter(p => p);
+    finalPaths.unshift(...existing);
+    return finalPaths;
 }
 
 export async function collectReplyChainText(triggerMsg: Message | StoredMessage, limit: number = 40, includeTrigger = true, cutPrefix: boolean = true): Promise<MessagePart[]> {
@@ -561,15 +587,20 @@ export async function collectReplyChainText(triggerMsg: Message | StoredMessage,
     const pushPart = async (msg: Message | StoredMessage, textRequired: boolean = false) => {
         const rawText = extractTextMessage(msg);
         const cleanText = cutPrefix ? cutPrefixes(rawText) : rawText;
-        const images = await loadImagesIfExists(msg);
+        const imageNames = await loadImagesIfExists(msg);
 
         if (!cleanText && textRequired) return;
-        if (!cleanText && !images?.length) return;
+        if (!cleanText && !imageNames?.length) return;
 
         const fromId = isStoredMessage(msg) ? msg.fromId : msg.from.id;
         const firstName = isStoredMessage(msg) ?
             (await UserStore.get(msg.fromId))?.firstName : msg.from.first_name;
 
+        const images = imageNames ? imageNames.map(n => {
+            const filePath = photoPathByUniqueId(n);
+            return Buffer.from(fs.readFileSync(filePath)).toString("base64");
+        }) : null;
+
         parts.push({
             bot: fromId === botUser.id,
             content: cleanText ? cleanText : "",
@@ -932,7 +963,7 @@ export function getRuntimeInfo(): RuntimeInfo {
 
 export type PhotoMaxSize = { width: number, height: number, url: string; file_id: string; unique_file_id: string; };
 
-export async function getPhotoMaxSize(photos: PhotoSize[], target: number = Environment.MAX_PHOTO_SIZE): Promise<PhotoMaxSize | null> {
+export function getPhotoMaxSize(photos: PhotoSize[], target: number = Environment.MAX_PHOTO_SIZE): PhotoSize | null {
     if (!photos) return null;
 
     photos = photos.filter(p => Math.max(p.width, p.height) <= target);
@@ -940,7 +971,7 @@ export async function getPhotoMaxSize(photos: PhotoSize[], target: number = Envi
     if (photos.length === 0) return null;
 
     if (photos.length === 1) {
-        return mapPhotoSizeToMax(photos[0]);
+        return photos[0];
     }
 
     const max = photos.reduce((prev, cur) => {
@@ -949,8 +980,7 @@ export async function getPhotoMaxSize(photos: PhotoSize[], target: number = Envi
         return cur.width * cur.height > prev.width * prev.height ? cur : prev;
     }, null);
 
-    if (!max) return null;
-    return mapPhotoSizeToMax(max);
+    return max;
 }
 
 export async function mapPhotoSizeToMax(size: PhotoSize): Promise<PhotoMaxSize | null> {
@@ -964,20 +994,25 @@ export async function mapPhotoSizeToMax(size: PhotoSize): Promise<PhotoMaxSize |
     };
 }
 
-export async function imageToBase64(filePath: string): Promise<string> {
-    return new Promise((resolve, reject) => {
-        fs.readFile(filePath, (err, data) => {
-            if (err) {
-                return reject(err);
-            }
-            const base64Image = Buffer.from(data).toString("base64");
-            const dataUrl = `data:image/jpeg;base64,${base64Image}`;
-            resolve(dataUrl);
-        });
-    });
+export async function imageToBase64(filePath: string, withMimeType: boolean = false): Promise<string | null> {
+    if (!fs.existsSync(filePath)) return null;
+
+    try {
+        const file = fs.readFileSync(filePath);
+        const base64 = Buffer.from(file).toString("base64");
+        if (withMimeType) {
+            return `data:image/jpeg;base64,${base64}`;
+        }
+
+        return base64;
+    } catch (e) {
+        logError(e);
+        return null;
+    }
 }
 
-export function ifTrue(exp?: never): boolean {
+// eslint-disable-next-line @typescript-eslint/no-explicit-any
+export function ifTrue(exp?: any): boolean {
     if (!exp) return false;
 
     return ["true", "t", "y", 1, "1"].includes(exp);
@@ -993,14 +1028,21 @@ export async function processNewMessage(msg: Message) {
     console.log("message", msg);
 
     let storedMsg: StoredMessage | null = null;
-    Promise.all([
-            MessageStore.put(msg).then(r => {
-                storedMsg = r;
-                console.log("storedMsg", storedMsg);
-            }),
-            UserStore.put(msg.from)
-        ]
-    ).catch(logError);
+
+    try {
+        const results = await Promise.all([
+                MessageStore.put(msg),
+                UserStore.put(msg.from)
+            ]
+        );
+
+        storedMsg = results[0];
+        if (!msg.media_group_id && storedMsg.photoMaxSizeFilePath) {
+            await loadImagesIfExists(msg);
+        }
+    } catch (e) {
+        logError(e);
+    }
 
     if ((msg.new_chat_members?.length || 0 > 0)) {
         await bot.sendMessage({chat_id: msg.chat.id, text: randomValue(Environment.ANSWERS.invite)}).catch(logError);
@@ -1062,12 +1104,34 @@ export async function processNewMessage(msg: Message) {
         return;
     }
 
+    const textToCheck = startsWithPrefix ? messageWithoutPrefix : cmdText;
+    if (msg.entities) {
+        const urlEntities = msg.entities.filter(e => e.type === "url");
+        if (urlEntities.length) {
+            for (const e of urlEntities) {
+                const url = msg.text.substring(e.offset, e.offset + e.length);
+                // TODO: 31/01/2026, Danil Nikolaev: implement proper checking
+                try {
+                    getYouTubeVideoId(url);
+
+                    const yt = chatCommands.find(e => e instanceof YouTubeDownload);
+                    if (await checkRequirements(yt, msg)) {
+                        await yt.downloadYouTubeVideo(msg, url);
+                    }
+                    return;
+                } catch (e) {
+                    logError(e);
+                }
+            }
+        }
+    }
+
     if (!startsWithPrefix && msg.chat.type !== "private") return;
     if (msg.chat.type === "private" && !Environment.ADMIN_IDS.has(msg.chat.id)) return;
 
     const chat = chatCommands.find(e => e instanceof OllamaChat);
     if (await checkRequirements(chat, msg)) {
-        await chat.executeOllama(msg, startsWithPrefix ? messageWithoutPrefix : cmdText);
+        await chat.executeOllama(msg, textToCheck);
     }
 }
 
@@ -1080,9 +1144,7 @@ async function processAlbum(groupId: string): Promise<string[]> {
         .map(m => m.photo);
 
     const allPhotoMaxSizes = await Promise.all(allPhotos.map(photo => getPhotoMaxSize(photo)));
-    const ids = allPhotoMaxSizes.map(p => p.unique_file_id);
-
-    await loadImagesFromFileIds(allPhotoMaxSizes);
+    const ids = await loadImagesFromFileIds(allPhotoMaxSizes);
 
     console.log(`Received album ${groupId} with ${ids.length} photos.`);
     console.log("File IDs:", ids);
@@ -1092,5 +1154,5 @@ async function processAlbum(groupId: string): Promise<string[]> {
 }
 
 export function photoPathByUniqueId(uniqueId: string): string {
-    return path.join(Environment.DATA_PATH, "temp", uniqueId + ".jpg");
+    return path.join(Environment.DATA_PATH, "photo", uniqueId + ".jpg");
 }

src/util/ytdl.ts

@@ -0,0 +1,93 @@
+import Innertube, {Platform, Types, Utils} from "youtubei.js";
+import fs, {createWriteStream} from "node:fs";
+import path from "node:path";
+import {Environment} from "../common/environment";
+
+export function getYouTubeVideoId(url: string): string {
+    const regex = /(?:youtube\.com\/(?:[^\/]+\/.+\/|(?:v|e(?:mbed)?|shorts)\/|.*[?&]v=)|youtu\.be\/)([^"&?\/\s]{11})/i;
+    const match = url.match(regex);
+    if (!match || !match[1]) throw new Error("Invalid YouTube or Shorts URL");
+    return match[1];
+}
+
+export async function downloadVideoFromYouTube(url: string, targetQuality: string = "720p"): Promise<{
+    time: number,
+    exists?: boolean,
+    buffer: Buffer | null
+}> {
+    const start = Date.now();
+    let buffer: Buffer | null = null;
+
+    try {
+        const videoId = getYouTubeVideoId(url);
+        const videoFolder = path.join(Environment.DATA_PATH, "video");
+        if (!fs.existsSync(videoFolder)) {
+            fs.mkdirSync(videoFolder);
+        }
+
+        const filePath = path.join(videoFolder, `${videoId}.mp4`);
+        if (fs.existsSync(filePath)) {
+            const buffer = Buffer.from(fs.readFileSync(filePath));
+            return {
+                time: Date.now() - start,
+                exists: true,
+                buffer: buffer
+            };
+        }
+
+        Platform.shim.eval = async (data: Types.BuildScriptResult, env: Record<string, Types.VMPrimative>) => {
+            const properties = [];
+            if (env.n) properties.push(`n: exportedVars.nFunction("${env.n}")`);
+            if (env.sig) properties.push(`sig: exportedVars.sigFunction("${env.sig}")`);
+
+            const code = `${data.output}\nreturn { ${properties.join(", ")} }`;
+            return new Function(code)();
+        };
+        const yt = await Innertube.create({
+            generate_session_locally: true,
+            retrieve_player: true
+        });
+
+        const info = await yt.getInfo(videoId);
+
+        console.log(`Fetching metadata for: ${videoId}...`);
+
+        const format = info.streaming_data?.formats.find(f => f.quality_label === targetQuality)
+            || info.streaming_data?.adaptive_formats.find(f => f.quality_label === targetQuality);
+
+        if (!format) {
+            console.log(`Quality ${targetQuality} not found. Falling back to best available.`);
+        }
+
+        const stream = await yt.download(videoId, {
+            type: "video+audio",
+            quality: "best",
+            format: "mp4"
+        });
+
+        const file = createWriteStream(filePath);
+
+        console.log("Downloading...");
+
+        for await (const chunk of Utils.streamToIterable(stream)) {
+            file.write(chunk);
+        }
+
+        file.end();
+
+        buffer = fs.readFileSync(filePath);
+        console.log(`✅ Saved to ${videoId}.mp4`);
+    } catch (error) {
+        console.error("❌ Download failed:", error instanceof Error ? error.message : error);
+        throw error;
+    }
+
+    const end = Date.now();
+    const diff = end - start;
+    console.log(`Video downloaded. URL: ${url}\ntook ${diff}ms`);
+
+    return {
+        time: diff,
+        buffer: buffer,
+    };
+}

tsconfig.json

@@ -9,7 +9,9 @@
     "resolveJsonModule": true,
     "esModuleInterop": true,
     "emitDecoratorMetadata": true,
-    "experimentalDecorators": true
+    "experimentalDecorators": true,
+    "allowSyntheticDefaultImports": true,
+    "allowJs": true
   },
   "include": [
     "src"