feat: implement formatErrorForClubs utility for structured error reporting

Author: Ali-Sdg90

bot/handlers/messages/groupHandler.js

@@ -9,6 +9,7 @@ const { ERROR_RESPONSES } = require("../../constants/errorResponses");
 const { sendToPerplexity } = require("../../services/perplexity");
 const { convertENtoFA } = require("../../utils/convertENtoFA");
 const { escapeHtml } = require("../../utils/escapeHtml");
+const { formatErrorForClubs } = require("../../utils/formatErrorForClubs");
 const {
     formatGroupMessage,
     formatGroupMessageChunks,
@@ -180,22 +181,44 @@ const processMessage = async (
     ctx,
     options = {}
 ) => {
-    const { replyChunksTo = "original", fallbackReplyMode = "telegram" } =
-        options;
+    // console.log("IncomeData >>", {
+    //     text,
+    //     photoUrls,
+    //     chatId,
+    //     replyToMessageId,
+    //     chatType,
+    //     options,
+    // });
+    // console.log("------------------------------------");
+
+    const {
+        replyChunksTo = "original",
+        fallbackReplyMode = "telegram",
+        // - "always": always send details
+        // - "never": never send details (only generic)
+        // - "adminOnly": send details only if chatId is in adminChatIds
+        sendErrorDetails = "always",
+        adminChatIds = [],
+    } = options;
+
+    const shouldSendDetails =
+        sendErrorDetails === "always" ||
+        (sendErrorDetails === "adminOnly" &&
+            (adminChatIds.includes(chatId) ||
+                adminChatIds.includes(String(chatId))));
 
     if (await groupMessageValidator(chatType, chatId, text, ctx)) {
         try {
             const processingMessage = await telegramClient.sendMessage(
                 chatId,
                 "🕒 در حال پردازش...",
-                {
-                    reply_to_message_id: replyToMessageId,
-                }
+                { reply_to_message_id: replyToMessageId }
             );
 
             const rawResponse = await sendToPerplexity(text, photoUrls);
-            // let rawResponse = "test";
-            // const rawResponse = "<b>test</b> 📊" + "w".repeat(50);
+
+            // console.log("RawResponse >>", rawResponse);
+            // console.log("------------------------------------");
 
             const response = convertENtoFA(rawResponse);
 
@@ -218,9 +241,13 @@ const processMessage = async (
                 return;
             }
 
+            // console.log("Before Chunks >>", response);
+            // console.log("------------------------------------");
+
             const chunks = buildChunks(response, 4000);
 
-            console.log("Response Chunks >>", chunks);
+            // console.log("Response Chunks >>", chunks);
+            // console.log("------------------------------------");
 
             await telegramClient.editMessageText(
                 chatId,
@@ -233,6 +260,9 @@ const processMessage = async (
                 }
             );
 
+            // console.log("First chunk sent.", chunks[0]);
+            // console.log("------------------------------------");
+
             const replyToForExtraChunks =
                 replyChunksTo === "processing"
                     ? processingMessage.message_id
@@ -244,30 +274,93 @@ const processMessage = async (
                     disable_web_page_preview: true,
                     reply_to_message_id: replyToForExtraChunks,
                 });
+
+                // console.log(`Chunk ${i + 1} sent.`, chunks[i]);
+                // console.log("------------------------------------");
             }
         } catch (error) {
             console.error(
                 "❌ Error processing message:",
                 error && error.stack ? error.stack : error
             );
 
+            const context = {
+                chatId,
+                chatType,
+                replyToMessageId,
+                replyChunksTo,
+                fallbackReplyMode,
+                hasPhotos: Array.isArray(photoUrls) && photoUrls.length > 0,
+                photoCount: Array.isArray(photoUrls) ? photoUrls.length : 0,
+                textPreview: String(text ?? "").slice(0, 500),
+            };
+
             try {
+                if (!shouldSendDetails) {
+                    // Generic message only
+                    if (fallbackReplyMode === "ctx" && ctx?.reply) {
+                        await ctx.reply("❌ مشکلی پیش اومد.", {
+                            disable_web_page_preview: true,
+                        });
+                    } else {
+                        await telegramClient.sendMessage(
+                            chatId,
+                            "❌ مشکلی پیش اومد.",
+                            { reply_to_message_id: replyToMessageId }
+                        );
+                    }
+                    return;
+                }
+
+                const errorHtml = formatErrorForClubs(error, context);
+                const errChunks = safeChunkText(errorHtml, 4000);
+
                 if (fallbackReplyMode === "ctx" && ctx?.reply) {
-                    await ctx.reply("❌ مشکلی پیش اومد.");
+                    for (const ch of errChunks) {
+                        await ctx.reply(ch, {
+                            parse_mode: "HTML",
+                            disable_web_page_preview: true,
+                        });
+                    }
+                    // console.log("Fallback error details sent via ctx.");
+                    // console.log("------------------------------------");
                 } else {
+                    // First one replies to original message
+                    await telegramClient.sendMessage(chatId, errChunks[0], {
+                        parse_mode: "HTML",
+                        disable_web_page_preview: true,
+                        reply_to_message_id: replyToMessageId,
+                    });
+
+                    for (let i = 1; i < errChunks.length; i++) {
+                        await telegramClient.sendMessage(chatId, errChunks[i], {
+                            parse_mode: "HTML",
+                            disable_web_page_preview: true,
+                            reply_to_message_id: replyToMessageId,
+                        });
+                    }
+                }
+            } catch (e) {
+                console.error(
+                    "❌ Error sending fallback reply:",
+                    e && e.stack ? e.stack : e
+                );
+
+                // Last-resort generic message
+                try {
                     await telegramClient.sendMessage(
                         chatId,
                         "❌ مشکلی پیش اومد.",
                         {
                             reply_to_message_id: replyToMessageId,
                         }
                     );
+                } catch (_) {
+                    console.error(
+                        "❌ Final fallback message failed.",
+                        _ && _.stack ? _.stack : _
+                    );
                 }
-            } catch (e) {
-                console.error(
-                    "❌ Error sending fallback reply:",
-                    e && e.stack ? e.stack : e
-                );
             }
         }
     }

bot/utils/formatErrorForClubs.js

@@ -0,0 +1,46 @@
+const { escapeHtml } = require("./escapeHtml");
+
+const redactSecrets = (income) => {
+    if (!income) return income;
+
+    return String(income)
+        .replace(/(api[_-]?key\s*[:=]\s*)([^\s"'`]+)/gi, "$1[REDACTED]")
+        .replace(
+            /(authorization\s*[:=]\s*bearer\s+)([^\s"'`]+)/gi,
+            "$1[REDACTED]"
+        )
+        .replace(/(token\s*[:=]\s*)([^\s"'`]+)/gi, "$1[REDACTED]");
+};
+
+const safeJson = (obj) => {
+    try {
+        return JSON.stringify(
+            obj,
+            (k, v) => {
+                if (typeof v === "string") return redactSecrets(v);
+                return v;
+            },
+            2
+        );
+    } catch {
+        return String(obj);
+    }
+};
+
+const formatErrorForClubs = (err, context = {}) => {
+    const name = err?.name || "Error";
+    const message = err?.message || String(err || "");
+    const stack = err?.stack || "";
+
+    return (
+        `❌ <b>خطا رخ داد</b>\n\n` +
+        `<b>نوع:</b> ${escapeHtml(name)}\n` +
+        `<b>پیام:</b> ${escapeHtml(redactSecrets(message))}\n\n` +
+        `<b>Stack:</b>\n<pre>${escapeHtml(
+            redactSecrets(stack || "(no stack)")
+        )}</pre>\n\n` +
+        `<b>Context:</b>\n<pre>${escapeHtml(safeJson(context))}</pre>`
+    );
+};
+
+module.exports = { formatErrorForClubs };