${safeContent}

`;\n\n await editMessageText(\n message.chat.id,\n message.message_id,\n confirmationMessage,\n { parse_mode: \"HTML\" },\n );\n } else {\n // 🔴 گزارش دقیق علت خطا\n const errorDetail = smsRes.errorDescription || smsRes.body;\n await answerCallbackQuery(\n id,\n `❌ خطا: ${errorDetail}`,\n true, // نمایش در قالب آلرت پاپ‌آپ\n );\n\n await editMessageText(\n message.chat.id,\n message.message_id,\n `❌ ارسال پیامک با خطا مواجه شد:\\n\\n` +\n `⚠️ علت: ${escapeHtml(errorDetail)}\\n` +\n `📌 پاسخ سرور همایس: ${\n escapeHtml(smsRes.body || \"نامشخص\")\n }\\n` +\n `📱 شماره مقصد: ${targetUser.phone}`,\n { parse_mode: \"HTML\" },\n );\n }\n return;\n }\n\n // ۱-۲. کلیک روی انصراف\n if (action === \"dismiss\") {\n await query(\n \"DELETE FROM pending_prompts WHERE chat_id = ? AND message_id = ?\",\n [message.chat.id, message.message_id],\n );\n await deleteMessage(message.chat.id, message.message_id);\n await answerCallbackQuery(id, \"لغو شد.\");\n return;\n }\n\n return;\n }\n\n // ۲. مدیریت پیام‌های دریافتی و ویرایش‌شده\n const msg = update.message || update.edited_message;\n if (!msg) return;\n\n const chatId = msg.chat.id;\n\n // ۲-۱. پیام خصوصی (ثبت شماره)\n if (msg.chat.type === \"private\") {\n if (msg.text === \"/start\") {\n const userRes = await query(\n \"SELECT phone FROM users WHERE tg_id = ? LIMIT 1\",\n [msg.from.id],\n );\n if (userRes.rows[0]?.phone) {\n return sendMessage(\n chatId,\n `سلام ${msg.from.first_name}!\\nشماره شما (${\n userRes.rows[0].phone\n }) در سیستم ثبت است.`,\n );\n }\n return sendMessage(\n chatId,\n `سلام ${msg.from.first_name}!\\nبرای ثبت شماره خود، دکمه زیر را لمس کنید:`,\n {\n reply_markup: {\n keyboard: [[{\n text: \"📱 اشتراک‌گذاری شماره تماس\",\n request_contact: true,\n }]],\n resize_keyboard: true,\n one_time_keyboard: true,\n },\n },\n );\n }\n\n if (msg.contact) {\n if (msg.contact.user_id !== msg.from.id) {\n return sendMessage(\n chatId,\n \"❌ لطفاً شماره متعلق به اکانت خودتان را ارسال کنید.\",\n );\n }\n await query(\n `INSERT INTO users (tg_id, first_name, username, phone) \n VALUES (?, ?, ?, ?)\n ON CONFLICT(tg_id) DO UPDATE SET phone = excluded.phone, first_name = excluded.first_name, username = excluded.username;`,\n [\n msg.from.id,\n msg.from.first_name,\n msg.from.username || \"\",\n msg.contact.phone_number,\n ],\n );\n return sendMessage(\n chatId,\n \"✅ شماره شما در سامانه ثبت گردید.\",\n { reply_markup: { remove_keyboard: true } },\n );\n }\n return;\n }\n\n // ۲-۲. پیام داخل گروه\n if ([\"group\", \"supergroup\"].includes(msg.chat.type)) {\n if (msg.new_chat_members || msg.left_chat_member || msg.pinned_message) {\n return;\n }\n\n const groupTitle = msg.chat.title || \"گروه\";\n const hasMedia = Boolean(msg.photo || msg.video || msg.document);\n let trimmed = (msg.text || msg.caption || \"\").trim();\n\n if (hasMedia && !trimmed) {\n trimmed = `یک رسانه در گروه ${groupTitle} بارگذاری شد.`;\n }\n\n const threadId = msg.message_thread_id || 0;\n const userId = msg.from.id;\n\n await query(\n `INSERT INTO topic_members (chat_id, thread_id, tg_id) VALUES (?, ?, ?)\n ON CONFLICT(chat_id, thread_id, tg_id) DO UPDATE SET last_active = CURRENT_TIMESTAMP;`,\n [chatId, threadId, userId],\n );\n\n let targetRecordId: number;\n const existingMsg = await query(\n \"SELECT id FROM messages_index WHERE chat_id = ? AND message_id = ? LIMIT 1\",\n [chatId, msg.message_id],\n );\n\n if (existingMsg.rows[0]?.id) {\n targetRecordId = existingMsg.rows[0].id;\n await query(\n \"UPDATE messages_index SET text = ?, has_media = ? WHERE id = ?\",\n [trimmed, hasMedia ? 1 : 0, targetRecordId],\n );\n } else {\n const insRes = await query(\n `INSERT INTO messages_index (chat_id, chat_title, message_thread_id, message_id, sender_id, sender_name, text, has_media)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?) RETURNING id;`,\n [\n chatId,\n groupTitle,\n threadId,\n msg.message_id,\n userId,\n `${msg.from.first_name || \"\"} ${msg.from.last_name || \"\"}`.trim(),\n trimmed,\n hasMedia ? 1 : 0,\n ],\n );\n targetRecordId = insRes.rows[0]?.id || insRes.lastInsertRowid;\n }\n\n let isPPP = trimmed.includes(\"پپپ\");\n\n if (!isPPP && msg.reply_to_message) {\n const repText = msg.reply_to_message.text ||\n msg.reply_to_message.caption || \"\";\n if (repText.includes(\"پپپ\") || trimmed === \"پپپ\") {\n isPPP = true;\n const repRes = await query(\n \"SELECT id FROM messages_index WHERE chat_id = ? AND message_id = ? LIMIT 1\",\n [chatId, msg.reply_to_message.message_id],\n );\n if (repRes.rows[0]?.id) {\n targetRecordId = repRes.rows[0].id;\n }\n }\n }\n\n // اگر پپپ نداشت، کاری انجام نمی‌شود\n if (!isPPP) {\n return;\n }\n\n const usersRes = await query(\n \"SELECT tg_id, first_name, phone FROM users WHERE phone IS NOT NULL AND phone != '' ORDER BY id DESC\",\n );\n\n if (usersRes.rows.length === 0) {\n return sendMessage(\n chatId,\n \"⚠️ کلمه «پپپ» دریافت شد، اما شماره‌ای در سیستم ثبت نیست.\",\n {\n reply_to_message_id: msg.message_id,\n message_thread_id: threadId || undefined,\n },\n );\n }\n\n const phoneButtons = usersRes.rows.map((u: any) => [\n {\n text: `📱 ${u.first_name || \"کاربر\"} (${u.phone})`,\n callback_data: `send_to_user:${targetRecordId}:${u.tg_id}`,\n },\n ]);\n\n phoneButtons.push([\n { text: \"❌ انصراف\", callback_data: `dismiss:${targetRecordId}` },\n ]);\n\n const sent = await sendMessage(\n chatId,\n \"📋 پیامک به کدام شماره ارسال شود؟ (در صورت عدم انتخاب، پس از ۳۰ دقیقه حذف می‌شود):\",\n {\n reply_to_message_id: msg.message_id,\n message_thread_id: threadId || undefined,\n reply_markup: { inline_keyboard: phoneButtons },\n },\n );\n\n // ⏱ تنظیم تایمر ۳۰ دقیقه برای پاک شدن خودکار\n if (sent?.result?.message_id) {\n const promptMsgId = sent.result.message_id;\n\n // ذخیره در جدول انقضا\n await query(\n \"INSERT INTO pending_prompts (chat_id, message_id, expires_at) VALUES (?, ?, datetime('now', '+30 minutes'))\",\n [chatId, promptMsgId],\n );\n\n // تایمر در حافظه (برای حذف آنی سر ۳۰ دقیقه در صورت فعال بودن پروسس)\n setTimeout(async () => {\n await deleteMessage(chatId, promptMsgId).catch(() => {});\n await query(\n \"DELETE FROM pending_prompts WHERE chat_id = ? AND message_id = ?\",\n [chatId, promptMsgId],\n );\n }, 30 * 60 * 1000);\n }\n }\n}\n\n// ==========================================\n// ۶. مدیریت API پنل\n// ==========================================\nasync function handleApiRequests(req: Request, url: URL): Promise {\n if (url.pathname === \"/api/users\") {\n if (req.method === \"GET\") {\n const usersList = await query(\"SELECT * FROM users ORDER BY id DESC\");\n return Response.json(usersList.rows);\n }\n if (req.method === \"POST\") {\n const { tg_id, first_name, username, phone } = await req.json();\n if (!tg_id || !phone) {\n return Response.json({ error: \"آیدی و شماره الزامی است\" }, {\n status: 400,\n });\n }\n\n await query(\n `INSERT INTO users (tg_id, first_name, username, phone)\n VALUES (?, ?, ?, ?)\n ON CONFLICT(tg_id) DO UPDATE SET\n phone = excluded.phone,\n first_name = COALESCE(NULLIF(excluded.first_name, ''), users.first_name),\n username = COALESCE(NULLIF(excluded.username, ''), users.username);`,\n [Number(tg_id), first_name || \"ثبت دستی\", username || \"\", phone],\n );\n\n return Response.json({ success: true });\n }\n if (req.method === \"DELETE\") {\n const tgId = Number(url.searchParams.get(\"tg_id\"));\n await query(\"DELETE FROM users WHERE tg_id = ?\", [tgId]);\n return Response.json({ success: true });\n }\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// ==========================================\n// ۷. وب‌اپ پنل ادمین\n// ==========================================\nfunction getMiniAppHtml(): string {\n return `\n\n\n \n \n مدیریت پیامک همایس\n \n \n \n\n\n

پنل مدیریت شماره‌ها

\n \n \n \n \n

\n \n\n`;\n}\n\n// ==========================================\n// ۸. ورودی سرورلس اصلی\n// ==========================================\nexport default async function (req: Request): Promise {\n await initDatabase();\n const url = new URL(req.url);\n\n if (url.pathname.startsWith(\"/api/\")) {\n return handleApiRequests(req, url);\n }\n\n if (url.pathname === \"/admin\" || url.pathname === \"/miniapp\") {\n return new Response(getMiniAppHtml(), {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n if (req.method === \"POST\") {\n try {\n const update = await req.json();\n await handleTelegramUpdate(update);\n return new Response(\"OK\", { status: 200 });\n } catch (e: any) {\n console.error(\"Update Error:\", e);\n return new Response(\"Error\", { status: 500 });\n }\n }\n\n return new Response(\"ربات فعال است.\", {\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n}",[138],"pulls","branches","forks","envVars",{"_153":155,"_156":61},"connections",{"_153":61,"_154":61},"count","unfilledCount",6,"emptyCount",{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":57,"_38":163,"_13":142,"_34":143,"_36":144,"_24":25,"_135":-5,"_160":164,"_27":165},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":159,"_13":134,"_34":35,"_36":37,"_24":25,"_135":-5,"_160":161,"_27":162},["D",1788876452681],"children",[],[28],["D",1788872982278],[],[138],["D",1788866198021],["D",1789485645684],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":204,"_205":206,"_207":208,"_209":25,"_210":25,"_211":25,"_212":57,"_213":-5,"_214":-7,"_215":-7,"_216":61,"_217":25,"_218":25,"_219":-5,"_220":25,"_221":25,"_222":25,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":88,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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 · v17