Merge pull request #4 from cs-internship/feature/add-base64

feat: implement base64 image conversion and update related

Author: Ali-Sdg90

__tests__/bot/handlers/messages/groupHandler.extra.test.js

@@ -1,5 +1,15 @@
 jest.resetModules();
 
+const mockFetchSuccess = () =>
+    jest.doMock("node-fetch", () =>
+        jest.fn(async () => ({
+            ok: true,
+            buffer: async () => Buffer.from("imgdata"),
+        }))
+    );
+
+mockFetchSuccess();
+
 describe("groupHandler additional edge branches", () => {
     test("buildChunks uses formatGroupMessageChunks when available", async () => {
         jest.resetModules();
@@ -33,15 +43,15 @@ describe("groupHandler additional edge branches", () => {
         } = require("../../../../bot/services/perplexity");
         const groupHandler = require("../../../../bot/handlers/messages/groupHandler");
 
-        let editedText = null;
         const ctx = {
             message: { text: "hi", entities: [], message_id: 1 },
             chat: { id: 1, type: "group" },
             from: { username: "user" },
             telegram: {
                 sendMessage: async () => ({ message_id: 10 }),
                 editMessageText: async (c, mid, u, text) => {
-                    editedText = text;
+                    // eslint-disable-next-line no-unused-vars
+                    const editedText = text;
                 },
                 callApi: async () => {},
                 getFile: async () => ({ file_path: "p" }),
@@ -64,6 +74,7 @@ describe("groupHandler additional edge branches", () => {
 
     test("media_group setTimeout catch logs error when processMessage throws", async () => {
         jest.resetModules();
+        mockFetchSuccess();
 
         const consoleSpy = jest
             .spyOn(console, "error")

__tests__/bot/handlers/messages/groupHandler.test.js

@@ -1,5 +1,15 @@
 jest.resetModules();
 
+const mockFetchSuccess = () =>
+    jest.doMock("node-fetch", () =>
+        jest.fn(async () => ({
+            ok: true,
+            buffer: async () => Buffer.from("imgdata"),
+        }))
+    );
+
+mockFetchSuccess();
+
 // Mock deps
 jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
     groupMessageValidator: jest.fn().mockResolvedValue(true),
@@ -75,7 +85,7 @@ test("photo message gets file and included in photoUrls", async () => {
     };
     const _ctx = await runHandler(message);
     expect(sendToPerplexity).toHaveBeenCalledWith("with photo", [
-        "https://api.telegram.org/file/botTOKEN/path.jpg",
+        "data:image/jpeg;base64,aW1nZGF0YQ==",
     ]);
 });
 
@@ -197,6 +207,7 @@ test("error response from sendToPerplexity triggers editMessageText with error e
     };
     // re-require module to use overwritten sendToPerplexity
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -224,6 +235,7 @@ test("error response from sendToPerplexity triggers editMessageText with error e
 test("processing error triggers fallback reply and fallback sendMessage in processMessage", async () => {
     // simulate sendToPerplexity throwing inside processMessage to hit fallback sendMessage
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -278,6 +290,7 @@ test("processing error triggers fallback reply and fallback sendMessage in proce
 
 test("splits long response into multiple chunks and sends subsequent messages", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -364,6 +377,7 @@ test("private chat returns next() immediately", async () => {
 
 test("exact-command reaction callApi throws but does not call perplexity", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -408,6 +422,7 @@ test("exact-command reaction callApi throws but does not call perplexity", async
 
 test("photo getFile throws and processing continues without photoUrls", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -465,6 +480,7 @@ test("photo getFile throws and processing continues without photoUrls", async ()
 
 test("media_group processing logs error when processing throws inside timeout", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -540,6 +556,7 @@ test("media_group processing logs error when processing throws inside timeout",
 
 test("processMessage handles errorEntry for media_group by editing message with error text", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -619,6 +636,7 @@ test("processMessage handles errorEntry for media_group by editing message with
 
 test("processMessage splits long response into chunks for media_group and sends subsequent messages", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -699,6 +717,7 @@ test("processMessage splits long response into chunks for media_group and sends
 
 test("top-level handler fallback reply when sendToPerplexity throws", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -753,6 +772,7 @@ test("top-level handler fallback reply when sendToPerplexity throws", async () =
 
 test("top-level nested fallback logs error when ctx.reply also throws", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -811,6 +831,7 @@ test("top-level nested fallback logs error when ctx.reply also throws", async ()
 
 test("processMessage nested fallback logs error when fallback sendMessage throws", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -892,6 +913,7 @@ test("processMessage nested fallback logs error when fallback sendMessage throws
 
 test("direct call to _processMessage edits message when errorEntry returned", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));
@@ -925,6 +947,7 @@ test("direct call to _processMessage edits message when errorEntry returned", as
 
 test("direct call to _processMessage logs error when fallback sendMessage throws", async () => {
     jest.resetModules();
+    mockFetchSuccess();
     jest.doMock("../../../../bot/utils/groupMessageValidator", () => ({
         groupMessageValidator: jest.fn().mockResolvedValue(true),
     }));

__tests__/bot/utils/branchCoverage.test.js

@@ -4,17 +4,6 @@ describe("Branch coverage extra edge cases", () => {
         expect(safeChunkText("")).toEqual([]);
     });
 
-    test("createOptions with undefined message still sets system message", () => {
-        jest.resetModules();
-        jest.doMock("../../../bot/constants/systemMessage", () => ({
-            systemMessage: "SYS",
-        }));
-        const { createOptions } = require("../../../bot/utils/createOptions");
-        const opts = createOptions("K");
-        const body = JSON.parse(opts.body);
-        expect(body.messages[0].content[0].text).toBe("SYS");
-    });
-
     test("getUsernameByFullname empty rich_text returns null", async () => {
         jest.resetModules();
         jest.doMock("@notionhq/client", () => ({

__tests__/bot/utils/formatGroupMessageChunks.test.js

@@ -2,9 +2,6 @@ const {
     formatGroupMessageChunks,
 } = require("../../../bot/utils/formatGroupMessage");
 
-const explanationLink =
-    "\n\nتوضیح نحوه ساخت پیام:\n\nhttps://t.me/cs_internship/729";
-
 describe("formatGroupMessageChunks", () => {
     test("when no chart splits by lines and escapes", () => {
         const resp = "hello & world";