feat: file/photo sending to Telegram (PR moazbuilds#23)

- Add [file:/path] directive extraction from Claude responses
- Send images via sendPhoto, other files via sendDocument
- Export sendLocalFile, sendPhotoFile, sendFileDocument

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Fenrur

src/commands/telegram.ts

@@ -3,8 +3,8 @@ import { getSettings, loadSettings } from "../config";
 import { resetSession } from "../sessions";
 import { transcribeAudioToText } from "../whisper";
 import { resolveSkillPrompt, listSkills } from "../skills";
-import { mkdir } from "node:fs/promises";
-import { extname, join } from "node:path";
+import { mkdir, stat } from "node:fs/promises";
+import { extname, basename, join } from "node:path";
 
 // --- Markdown → Telegram HTML conversion (ported from nanobot) ---
 
@@ -445,6 +445,95 @@ async function sendReaction(token: string, chatId: number, messageId: number, em
   });
 }
 
+const IMAGE_EXTENSIONS = new Set([".png", ".jpg", ".jpeg", ".gif", ".webp"]);
+
+function isImageExtension(filePath: string): boolean {
+  return IMAGE_EXTENSIONS.has(extname(filePath).toLowerCase());
+}
+
+async function sendFileDocument(
+  token: string,
+  chatId: number,
+  filePath: string,
+  caption?: string,
+  threadId?: number
+): Promise<void> {
+  const fileData = await Bun.file(filePath).arrayBuffer();
+  const fileName = basename(filePath);
+  const blob = new Blob([fileData]);
+  const form = new FormData();
+  form.append("chat_id", String(chatId));
+  form.append("document", blob, fileName);
+  if (caption) form.append("caption", caption);
+  if (threadId) form.append("message_thread_id", String(threadId));
+
+  const res = await fetch(`${API_BASE}${token}/sendDocument`, {
+    method: "POST",
+    body: form,
+  });
+  if (!res.ok) {
+    const body = await res.text().catch(() => "");
+    throw new Error(`Telegram sendDocument: ${res.status} ${res.statusText} ${body}`);
+  }
+}
+
+async function sendPhotoFile(
+  token: string,
+  chatId: number,
+  filePath: string,
+  caption?: string,
+  threadId?: number
+): Promise<void> {
+  const fileData = await Bun.file(filePath).arrayBuffer();
+  const fileName = basename(filePath);
+  const blob = new Blob([fileData]);
+  const form = new FormData();
+  form.append("chat_id", String(chatId));
+  form.append("photo", blob, fileName);
+  if (caption) form.append("caption", caption);
+  if (threadId) form.append("message_thread_id", String(threadId));
+
+  const res = await fetch(`${API_BASE}${token}/sendPhoto`, {
+    method: "POST",
+    body: form,
+  });
+  if (!res.ok) {
+    const body = await res.text().catch(() => "");
+    throw new Error(`Telegram sendPhoto: ${res.status} ${res.statusText} ${body}`);
+  }
+}
+
+async function sendLocalFile(
+  token: string,
+  chatId: number,
+  filePath: string,
+  caption?: string,
+  threadId?: number
+): Promise<void> {
+  if (isImageExtension(filePath)) {
+    await sendPhotoFile(token, chatId, filePath, caption, threadId);
+  } else {
+    await sendFileDocument(token, chatId, filePath, caption, threadId);
+  }
+}
+
+interface FileDirective {
+  path: string;
+}
+
+function extractFileDirectives(text: string): { cleanedText: string; files: FileDirective[] } {
+  const files: FileDirective[] = [];
+  const cleanedText = text
+    .replace(/\[file:(\/[^\]\r\n]+)\]/g, (_match, filePath) => {
+      files.push({ path: filePath.trim() });
+      return "";
+    })
+    .replace(/[ \t]+\n/g, "\n")
+    .replace(/\n{3,}/g, "\n\n")
+    .trim();
+  return { cleanedText, files };
+}
+
 let botUsername: string | null = null;
 let botId: number | null = null;
 
@@ -808,19 +897,30 @@ async function handleMessage(message: TelegramMessage): Promise<void> {
         await sendMessage(config.token, chatId, errText, threadId);
       }
     } else {
-      const { cleanedText, reactionEmoji } = extractReactionDirective(result.stdout || "");
+      const { cleanedText: afterReaction, reactionEmoji } = extractReactionDirective(result.stdout || "");
       if (reactionEmoji) {
         await sendReaction(config.token, chatId, message.message_id, reactionEmoji).catch((err) => {
           console.error(`[Telegram] Failed to send reaction for ${label}: ${err instanceof Error ? err.message : err}`);
         });
       }
+
+      // Extract [file:/path/to/file] directives from response
+      const { cleanedText, files } = extractFileDirectives(afterReaction);
+
+      // Send files
+      for (const file of files) {
+        try {
+          await stat(file.path);
+          await sendLocalFile(config.token, chatId, file.path, undefined, threadId);
+        } catch (err) {
+          const errMsg = err instanceof Error ? err.message : String(err);
+          console.error(`[Telegram] Failed to send file ${file.path} for ${label}: ${errMsg}`);
+          await sendMessage(config.token, chatId, `Could not send file ${file.path}: ${errMsg}`, threadId);
+        }
+      }
+
       const finalText = cleanedText || "(empty response)";
       if (streamMsgId) {
-        // Edit the streaming message with final formatted HTML.
-        // editStream() already set the message to the correct plain text content,
-        // so if all edits fail (e.g. "message is not modified"), do NOT send a new
-        // message — the user already sees the correct content and a sendMessage
-        // would create a duplicate.
         const html = markdownToTelegramHtml(normalizeTelegramText(finalText));
         await callApi(config.token, "editMessageText", {
           chat_id: chatId, message_id: streamMsgId,
@@ -829,10 +929,6 @@ async function handleMessage(message: TelegramMessage): Promise<void> {
           chat_id: chatId, message_id: streamMsgId,
           text: finalText.slice(0, 4096),
         }).catch(() => {
-          // If all edits fail and the stream message has tool output (verbose),
-          // send the final response as a new message. But if there were no tool
-          // lines, the stream message already shows the correct text — "not
-          // modified" just means it's already right, so don't send a duplicate.
           if (verbose && hadToolLines) {
             return sendMessage(config.token, chatId, finalText, threadId);
           }
@@ -1070,7 +1166,7 @@ async function poll(): Promise<void> {
 // --- Exports ---
 
 /** Send a message to a specific chat (used by heartbeat forwarding) */
-export { sendMessage };
+export { sendMessage, sendLocalFile, sendPhotoFile, sendFileDocument };
 
 process.on("SIGTERM", () => { running = false; });
 process.on("SIGINT", () => { running = false; });