[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_160":161,"_162":163},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":53,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":25,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","c25f9f7e-ab76-11f1-b36a-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ==========================================\n// ۱. تنظیمات امن (خواندن منحصراً از متغیرهای محیطی)\n// ==========================================\nconst getEnv = (key: string, fallback = \"\") => \n Deno.env.get(key) || (typeof process !== \"undefined\" ? process.env[key] : undefined) || fallback;\n\n// تمام اطلاعات حساس از کد حذف شده و فقط از Env خوانده می‌شوند\nconst ADMIN_ID = Number(getEnv(\"ADMIN_ID\", \"0\"));\n\nconst HOMAIS_CONFIG = {\n username: getEnv(\"HOMAIS_USERNAME\", \"fr41160\"),\n password: getEnv(\"HOMAIS_PASSWORD\"),\n portalCode: getEnv(\"HOMAIS_PORTAL_CODE\", \"10003692\"),\n serverType: getEnv(\"HOMAIS_SERVER_TYPE\", \"100\"),\n \n};\n\nconst TELEGRAM_TOKEN = getEnv(\"TELEGRAM_TOKEN\");\n\nconst TG_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\nconst SINGLE_EMOJI_REGEX = /^(\\p{Extended_Pictographic}|\\p{Emoji_Presentation})$/u;\n\n// هشدار کنسول در صورت ست نشدن متغیرها\nif (!TELEGRAM_TOKEN) {\n console.warn(\"⚠️ متغیر TELEGRAM_TOKEN ست نشده است. لطفاً آن را در Environment Variables اضافه کنید.\");\n}\n\n// ==========================================\n// ۲. دیتابیس SQLite\n// ==========================================\nasync function query(sql: string, args: any[] = []) {\n const res = await sqlite.execute({ sql, args });\n const rows = (res.rows || []).map((row: any) => {\n if (!Array.isArray(row)) return row;\n const obj: Record = {};\n (res.columns || []).forEach((col: string, idx: number) => {\n obj[col] = row[idx];\n });\n return obj;\n });\n return {\n rows,\n lastInsertRowid: res.lastInsertRowid,\n rowsAffected: res.rowsAffected\n };\n}\n\nasync function initDatabase() {\n await query(`\n CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n tg_id INTEGER UNIQUE,\n first_name TEXT,\n username TEXT,\n phone TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS topic_members (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n thread_id INTEGER DEFAULT 0,\n tg_id INTEGER,\n last_active DATETIME DEFAULT CURRENT_TIMESTAMP,\n UNIQUE(chat_id, thread_id, tg_id)\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS messages_index (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n chat_title TEXT,\n message_thread_id INTEGER DEFAULT 0,\n message_id INTEGER,\n sender_id INTEGER,\n sender_name TEXT,\n text TEXT,\n has_media INTEGER DEFAULT 0,\n tag TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS predefined_tags (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT UNIQUE\n );\n `);\n}\n\n// ==========================================\n// ۳. درایور پیامک همایس\n// ==========================================\nfunction normalizeIranianPhone(rawPhone: string): string {\n let cleaned = rawPhone.replace(/[^0-9]/g, '');\n if (cleaned.startsWith('98')) {\n cleaned = '0' + cleaned.substring(2);\n } else if (cleaned.startsWith('9') && cleaned.length === 10) {\n cleaned = '0' + cleaned;\n }\n return cleaned;\n}\n\nasync function sendHomaisSms(mobile: string, text: string) {\n if (!HOMAIS_CONFIG.username || !HOMAIS_CONFIG.password) {\n return { status: 500, ok: false, body: \"اطلاعات پنل همایس در متغیرهای محیطی تعریف نشده است.\" };\n }\n\n const targetMobile = normalizeIranianPhone(mobile);\n const params = new URLSearchParams({\n username: HOMAIS_CONFIG.username,\n password: HOMAIS_CONFIG.password,\n PortalCode: HOMAIS_CONFIG.portalCode,\n mobile: targetMobile,\n message: text,\n ServerType: HOMAIS_CONFIG.serverType,\n });\n\n const url = `http://api.homais.com/services/messaging/sms/api/sendMessage/direct/?${params.toString()}`;\n\n try {\n const res = await fetch(url, { method: \"GET\" });\n const rawText = await res.text();\n return {\n status: res.status,\n ok: res.ok && !rawText.toLowerCase().includes('error'),\n body: rawText.trim()\n };\n } catch (err: any) {\n return { status: 0, ok: false, body: `خطا در اتصال: ${err.message}` };\n }\n}\n\n// ==========================================\n// ۴. توابع ارتباط با تلگرام\n// ==========================================\nasync function callTelegram(method: string, payload: any) {\n if (!TELEGRAM_TOKEN) return null;\n try {\n const res = await fetch(`${TG_API}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n return await res.json();\n } catch (err) {\n console.error(`Telegram API Error [${method}]:`, err);\n return null;\n }\n}\n\nasync function sendMessage(chatId: number, text: string, extra: any = {}) {\n return callTelegram(\"sendMessage\", { chat_id: chatId, text, ...extra });\n}\n\nasync function answerCallbackQuery(callbackQueryId: string, text = \"\", showAlert = false) {\n return callTelegram(\"answerCallbackQuery\", { callback_query_id: callbackQueryId, text, show_alert: showAlert });\n}\n\nasync function editMessageText(chatId: number, messageId: number, text: string, replyMarkup: any = null) {\n return callTelegram(\"editMessageText\", {\n chat_id: chatId,\n message_id: messageId,\n text,\n reply_markup: replyMarkup || undefined\n });\n}\n\nasync function deleteMessage(chatId: number, messageId: number) {\n return callTelegram(\"deleteMessage\", { chat_id: chatId, message_id: messageId });\n}\n\nasync function getChatMember(chatId: number, userId: number) {\n const res = await callTelegram(\"getChatMember\", { chat_id: chatId, user_id: userId });\n return res?.result;\n}\n\n// ==========================================\n// ۵. هندلر آپدیت‌های تلگرام\n// ==========================================\nasync function handleTelegramUpdate(update: any) {\n // ۱. دکمه‌های شیشه‌ای\n if (update.callback_query) {\n const { id, data, from, message } = update.callback_query;\n if (!data) return;\n\n const [action, targetId, extra] = data.split(':');\n const recordId = Number(targetId);\n\n // دکمه حذف پیام و انصراف از پیامک\n if (action === 'dismiss') {\n const res = await query(\"SELECT * FROM messages_index WHERE id = ? LIMIT 1\", [recordId]);\n const msgRecord = res.rows[0];\n\n if (msgRecord) {\n let canDismiss = from.id === msgRecord.sender_id || from.id === ADMIN_ID;\n if (!canDismiss) {\n const member = await getChatMember(msgRecord.chat_id, from.id);\n canDismiss = ['creator', 'administrator'].includes(member?.status);\n }\n if (!canDismiss) {\n return answerCallbackQuery(id, \"⛔️ تنها فرستنده پیام یا مدیران گروه مجاز به حذف هستند.\", true);\n }\n }\n\n await deleteMessage(message.chat.id, message.message_id);\n await answerCallbackQuery(id, \"پیام حذف شد.\");\n return;\n }\n\n // ارسال پیامک گروهی با همایس\n if (action === 'sms') {\n const res = await query(\"SELECT * FROM messages_index WHERE id = ? LIMIT 1\", [recordId]);\n const msgRecord = res.rows[0];\n\n if (!msgRecord) {\n return answerCallbackQuery(id, \"پیام یافت نشد.\", true);\n }\n\n let canDispatch = from.id === msgRecord.sender_id || from.id === ADMIN_ID;\n if (!canDispatch) {\n const member = await getChatMember(msgRecord.chat_id, from.id);\n canDispatch = ['creator', 'administrator'].includes(member?.status);\n }\n\n if (!canDispatch) {\n return answerCallbackQuery(id, \"⛔️ فقط نویسنده پیام یا مدیر گروه مجاز به ارسال پیامک هستند.\", true);\n }\n\n const membersRes = await query(`\n SELECT DISTINCT u.phone \n FROM topic_members tm\n INNER JOIN users u ON tm.tg_id = u.tg_id\n WHERE tm.chat_id = ? AND tm.thread_id = ? AND tm.tg_id != ? AND u.phone IS NOT NULL AND u.phone != ''\n `, [msgRecord.chat_id, msgRecord.message_thread_id, from.id]);\n\n const phones = membersRes.rows.map(r => r.phone).filter(Boolean);\n\n if (phones.length === 0) {\n return answerCallbackQuery(id, \"⚠️ هیچ مخاطبی با شماره در این تاپیک ثبت نشده است.\", true);\n }\n\n await answerCallbackQuery(id, `در حال ارسال پیامک به ${phones.length} مخاطب...`);\n\n let smsText = \"\";\n if (msgRecord.has_media && msgRecord.text.includes(\"بارگذاری شده\")) {\n smsText = `یک عکس در گروه [${msgRecord.chat_title}] بارگذاری شده که جالب توجه شما می باشد. (ارسال‌کننده: ${msgRecord.sender_name})`;\n } else {\n const excerpt = msgRecord.text.length > 70 ? msgRecord.text.substring(0, 67) + \"...\" : msgRecord.text;\n smsText = `پیام جدید از ${msgRecord.sender_name} در گروه [${msgRecord.chat_title}]:\\n${excerpt}`;\n }\n\n await Promise.allSettled(phones.map(phone => sendHomaisSms(phone, smsText)));\n\n await editMessageText(\n message.chat.id,\n message.message_id,\n `✅ پیامک این پیام با موفقیت به سرور همایس تحویل و برای ${phones.length} نفر ارسال شد.`\n );\n return;\n }\n\n // برچسب‌ها\n if (action === 'tag_menu') {\n const tagsRes = await query(\"SELECT * FROM predefined_tags ORDER BY id DESC LIMIT 10\");\n if (tagsRes.rows.length === 0) {\n return answerCallbackQuery(id, \"هنوز برچسبی ثبت نشده است.\", true);\n }\n\n const keyboard = tagsRes.rows.map(t => [\n { text: `#${t.name}`, callback_data: `set_tag:${recordId}:${t.name}` }\n ]);\n keyboard.push([{ text: \"🔙 بازگشت\", callback_data: `back_main:${recordId}` }]);\n\n await editMessageText(message.chat.id, message.message_id, \"یک برچسب برای این پیام انتخاب کنید:\", {\n inline_keyboard: keyboard\n });\n return;\n }\n\n if (action === 'back_main') {\n await editMessageText(message.chat.id, message.message_id, \"عملیات اطلاع‌رسانی پیامک:\", {\n inline_keyboard: [\n [\n { text: \"📩 بله، پیامک هم بشود\", callback_data: `sms:${recordId}` },\n { text: \"🏷 برچسب‌گذاری\", callback_data: `tag_menu:${recordId}` }\n ],\n [\n { text: \"❌ خیر، پیامک نشود (حذف)\", callback_data: `dismiss:${recordId}` }\n ]\n ]\n });\n return;\n }\n\n if (action === 'set_tag') {\n const tagName = extra;\n await query(\"UPDATE messages_index SET tag = ? WHERE id = ?\", [tagName, recordId]);\n await answerCallbackQuery(id, `برچسب #${tagName} اعمال شد.`);\n await editMessageText(message.chat.id, message.message_id, `برچسب #${tagName} ثبت گردید ✅`);\n return;\n }\n\n return;\n }\n\n // ۲. پیام‌های ورودی\n const msg = update.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(\"SELECT phone FROM users WHERE tg_id = ? LIMIT 1\", [msg.from.id]);\n\n if (userRes.rows[0]?.phone) {\n return sendMessage(chatId, `سلام ${msg.from.first_name}! شماره شما (${userRes.rows[0].phone}) در سامانه ثبت است.`);\n }\n\n return sendMessage(chatId, `سلام ${msg.from.first_name}!\\nجهت دریافت پیامک‌ها، دکمه زیر را لمس کرده و شماره خود را به اشتراک بگذارید:`, {\n reply_markup: {\n keyboard: [[{ text: '📱 اشتراک‌گذاری شماره برای دریافت پیامک‌ها', request_contact: true }]],\n resize_keyboard: true,\n one_time_keyboard: true\n }\n });\n }\n\n if (msg.contact) {\n if (msg.contact.user_id !== msg.from.id) {\n return sendMessage(chatId, \"❌ لطفاً شماره مربوط به اکانت خودتان را بفرستید.\");\n }\n const rawPhone = msg.contact.phone_number;\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 `, [msg.from.id, msg.from.first_name, msg.from.username || \"\", rawPhone]);\n\n return sendMessage(chatId, \"✅ شماره شما با موفقیت در سامانه همایس ثبت گردید.\", {\n reply_markup: { remove_keyboard: true }\n });\n }\n\n if (msg.text?.startsWith('/testsms') && msg.from.id === ADMIN_ID) {\n const parts = msg.text.replace('/testsms', '').trim().split(' ');\n const mobile = parts[0];\n const smsText = parts.slice(1).join(' ');\n\n if (!mobile || !smsText) {\n return sendMessage(chatId, \"❌ فرمت:\\n`/testsms 09121111111 متن پیامک`\", { parse_mode: 'Markdown' });\n }\n\n await sendMessage(chatId, \"⏳ در حال ارسال پیامک به همایس...\");\n const res = await sendHomaisSms(mobile, smsText);\n return sendMessage(chatId, `📡 وضعیت: ${res.ok ? '✅ موفق' : '❌ خطا'}\\nپاسخ: \\`${res.body}\\``, { parse_mode: 'Markdown' });\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) return;\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 if (!hasMedia && (!trimmed || trimmed.length < 4 || SINGLE_EMOJI_REGEX.test(trimmed))) {\n return;\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 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 const recordId = insRes.rows[0]?.id || insRes.lastInsertRowid;\n\n await sendMessage(chatId, \"عملیات اطلاع‌رسانی پیامک:\", {\n reply_to_message_id: msg.message_id,\n message_thread_id: threadId || undefined,\n reply_markup: {\n inline_keyboard: [\n [\n { text: \"📩 بله، پیامک هم بشود\", callback_data: `sms:${recordId}` },\n { text: \"🏷 برچسب‌گذاری\", callback_data: `tag_menu:${recordId}` }\n ],\n [\n { text: \"❌ خیر، پیامک نشود (حذف)\", callback_data: `dismiss:${recordId}` }\n ]\n ]\n }\n });\n }\n}\n\n// ==========================================\n// ۶. مدیریت APIهای پنل مینی‌اپ\n// ==========================================\nasync function handleApiRequests(req: Request, url: URL): Promise {\n if (url.pathname === '/api/stats') {\n const msgCount = await query(\"SELECT COUNT(*) as count FROM messages_index\");\n const userCount = await query(\"SELECT COUNT(*) as count FROM users WHERE phone IS NOT NULL AND phone != ''\");\n const groupCount = await query(\"SELECT COUNT(DISTINCT chat_id) as count FROM messages_index\");\n\n return Response.json({\n totalMessages: msgCount.rows[0]?.count || 0,\n usersWithPhone: userCount.rows[0]?.count || 0,\n connectedGroups: groupCount.rows[0]?.count || 0\n });\n }\n\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: \"آیدی عددی و شماره الزامی است\" }, { status: 400 });\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 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 if (url.pathname === '/api/groups') {\n const groups = await query(\"SELECT DISTINCT chat_id, chat_title FROM messages_index\");\n return Response.json(groups.rows);\n }\n\n if (url.pathname === '/api/tags') {\n if (req.method === 'GET') {\n const tags = await query(\"SELECT * FROM predefined_tags ORDER BY id DESC\");\n return Response.json(tags.rows);\n }\n if (req.method === 'POST') {\n const { name } = await req.json();\n if (!name) return Response.json({ error: \"نام الزامی است\" }, { status: 400 });\n const clean = name.replace(/^#/, '').trim();\n await query(\"INSERT OR IGNORE INTO predefined_tags (name) VALUES (?)\", [clean]);\n return Response.json({ success: true, name: clean });\n }\n if (req.method === 'DELETE') {\n const id = Number(url.searchParams.get('id'));\n await query(\"DELETE FROM predefined_tags WHERE id = ?\", [id]);\n return Response.json({ success: true });\n }\n }\n\n if (url.pathname === '/api/search') {\n const q = url.searchParams.get('q') || '';\n const chatId = url.searchParams.get('chat_id');\n const tag = url.searchParams.get('tag');\n\n let sqlQuery = \"SELECT * FROM messages_index WHERE 1=1\";\n const args: any[] = [];\n\n if (q) {\n sqlQuery += \" AND text LIKE ?\";\n args.push(`%${q}%`);\n }\n if (chatId) {\n sqlQuery += \" AND chat_id = ?\";\n args.push(Number(chatId));\n }\n if (tag) {\n sqlQuery += \" AND tag = ?\";\n args.push(tag);\n }\n\n sqlQuery += \" ORDER BY id DESC LIMIT 50\";\n const results = await query(sqlQuery, args);\n return Response.json(results.rows);\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

\n پیام‌های ذخیره\n 0\n

\n مخاطبان پیامک\n 0\n

\n گروه‌های فعال\n 0\n

\n\n \n

➕ ثبت یا ویرایش دستی شماره عضو

\n \n \n \n

\n \n

\n\n

لیست شماره‌های ثبت‌شده

\n \n

در حال دریافت لیست مخاطبان...

\n\n \n

\n \n

\n \n \n

\n \n

پیامی مطابق جستجو یافت نشد.

\n\n \n

افزودن برچسب جدید

\n \n \n

\n در حال بارگذاری...\n

\n\n \n\n`;\n}\n\n// ==========================================\n// ۸. ورودی اصلی سرورلس (Entrypoint)\n// ==========================================\nexport default async function(req: Request): Promise {\n await initDatabase();\n\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(\"Error processing Telegram Update:\", 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}","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ==========================================\n// ۱. تنظیمات امن (خواندن منحصراً از متغیرهای محیطی)\n// ==========================================\nconst getEnv = (key: string, fallback = \"\") => \n Deno.env.get(key) || (typeof process !== \"undefined\" ? process.env[key] : undefined) || fallback;\n\n// تمام اطلاعات حساس از کد حذف شده و فقط از Env خوانده می‌شوند\nconst ADMIN_ID = Number(getEnv(\"ADMIN_ID\"));\n\nconst HOMAIS_CONFIG = {\n username: getEnv(\"HOMAIS_USERNAME\", \"fr41160\"),\n password: getEnv(\"HOMAIS_PASSWORD\"),\n portalCode: getEnv(\"HOMAIS_PORTAL_CODE\", \"10003692\"),\n serverType: getEnv(\"HOMAIS_SERVER_TYPE\", \"100\"),\n \n};\n\nconst TELEGRAM_TOKEN = getEnv(\"TELEGRAM_TOKEN\");\n\nconst TG_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\nconst SINGLE_EMOJI_REGEX = /^(\\p{Extended_Pictographic}|\\p{Emoji_Presentation})$/u;\n\n// هشدار کنسول در صورت ست نشدن متغیرها\nif (!TELEGRAM_TOKEN) {\n console.warn(\"⚠️ متغیر TELEGRAM_TOKEN ست نشده است. لطفاً آن را در Environment Variables اضافه کنید.\");\n}\n\n// ==========================================\n// ۲. دیتابیس SQLite\n// ==========================================\nasync function query(sql: string, args: any[] = []) {\n const res = await sqlite.execute({ sql, args });\n const rows = (res.rows || []).map((row: any) => {\n if (!Array.isArray(row)) return row;\n const obj: Record = {};\n (res.columns || []).forEach((col: string, idx: number) => {\n obj[col] = row[idx];\n });\n return obj;\n });\n return {\n rows,\n lastInsertRowid: res.lastInsertRowid,\n rowsAffected: res.rowsAffected\n };\n}\n\nasync function initDatabase() {\n await query(`\n CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n tg_id INTEGER UNIQUE,\n first_name TEXT,\n username TEXT,\n phone TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS topic_members (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n thread_id INTEGER DEFAULT 0,\n tg_id INTEGER,\n last_active DATETIME DEFAULT CURRENT_TIMESTAMP,\n UNIQUE(chat_id, thread_id, tg_id)\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS messages_index (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n chat_title TEXT,\n message_thread_id INTEGER DEFAULT 0,\n message_id INTEGER,\n sender_id INTEGER,\n sender_name TEXT,\n text TEXT,\n has_media INTEGER DEFAULT 0,\n tag TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n );\n `);\n await query(`\n CREATE TABLE IF NOT EXISTS predefined_tags (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT UNIQUE\n );\n `);\n}\n\n// ==========================================\n// ۳. درایور پیامک همایس\n// ==========================================\nfunction normalizeIranianPhone(rawPhone: string): string {\n let cleaned = rawPhone.replace(/[^0-9]/g, '');\n if (cleaned.startsWith('98')) {\n cleaned = '0' + cleaned.substring(2);\n } else if (cleaned.startsWith('9') && cleaned.length === 10) {\n cleaned = '0' + cleaned;\n }\n return cleaned;\n}\n\nasync function sendHomaisSms(mobile: string, text: string) {\n if (!HOMAIS_CONFIG.username || !HOMAIS_CONFIG.password) {\n return { status: 500, ok: false, body: \"اطلاعات پنل همایس در متغیرهای محیطی تعریف نشده است.\" };\n }\n\n const targetMobile = normalizeIranianPhone(mobile);\n const params = new URLSearchParams({\n username: HOMAIS_CONFIG.username,\n password: HOMAIS_CONFIG.password,\n PortalCode: HOMAIS_CONFIG.portalCode,\n mobile: targetMobile,\n message: text,\n ServerType: HOMAIS_CONFIG.serverType,\n });\n\n const url = `http://api.homais.com/services/messaging/sms/api/sendMessage/direct/?${params.toString()}`;\n\n try {\n const res = await fetch(url, { method: \"GET\" });\n const rawText = await res.text();\n return {\n status: res.status,\n ok: res.ok && !rawText.toLowerCase().includes('error'),\n body: rawText.trim()\n };\n } catch (err: any) {\n return { status: 0, ok: false, body: `خطا در اتصال: ${err.message}` };\n }\n}\n\n// ==========================================\n// ۴. توابع ارتباط با تلگرام\n// ==========================================\nasync function callTelegram(method: string, payload: any) {\n if (!TELEGRAM_TOKEN) return null;\n try {\n const res = await fetch(`${TG_API}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n return await res.json();\n } catch (err) {\n console.error(`Telegram API Error [${method}]:`, err);\n return null;\n }\n}\n\nasync function sendMessage(chatId: number, text: string, extra: any = {}) {\n return callTelegram(\"sendMessage\", { chat_id: chatId, text, ...extra });\n}\n\nasync function answerCallbackQuery(callbackQueryId: string, text = \"\", showAlert = false) {\n return callTelegram(\"answerCallbackQuery\", { callback_query_id: callbackQueryId, text, show_alert: showAlert });\n}\n\nasync function editMessageText(chatId: number, messageId: number, text: string, replyMarkup: any = null) {\n return callTelegram(\"editMessageText\", {\n chat_id: chatId,\n message_id: messageId,\n text,\n reply_markup: replyMarkup || undefined\n });\n}\n\nasync function deleteMessage(chatId: number, messageId: number) {\n return callTelegram(\"deleteMessage\", { chat_id: chatId, message_id: messageId });\n}\n\nasync function getChatMember(chatId: number, userId: number) {\n const res = await callTelegram(\"getChatMember\", { chat_id: chatId, user_id: userId });\n return res?.result;\n}\n\n// ==========================================\n// ۵. هندلر آپدیت‌های تلگرام\n// ==========================================\nasync function handleTelegramUpdate(update: any) {\n // ۱. دکمه‌های شیشه‌ای\n if (update.callback_query) {\n const { id, data, from, message } = update.callback_query;\n if (!data) return;\n\n const [action, targetId, extra] = data.split(':');\n const recordId = Number(targetId);\n\n // دکمه حذف پیام و انصراف از پیامک\n if (action === 'dismiss') {\n const res = await query(\"SELECT * FROM messages_index WHERE id = ? LIMIT 1\", [recordId]);\n const msgRecord = res.rows[0];\n\n if (msgRecord) {\n let canDismiss = from.id === msgRecord.sender_id || from.id === ADMIN_ID;\n if (!canDismiss) {\n const member = await getChatMember(msgRecord.chat_id, from.id);\n canDismiss = ['creator', 'administrator'].includes(member?.status);\n }\n if (!canDismiss) {\n return answerCallbackQuery(id, \"⛔️ تنها فرستنده پیام یا مدیران گروه مجاز به حذف هستند.\", true);\n }\n }\n\n await deleteMessage(message.chat.id, message.message_id);\n await answerCallbackQuery(id, \"پیام حذف شد.\");\n return;\n }\n\n // ارسال پیامک گروهی با همایس\n if (action === 'sms') {\n const res = await query(\"SELECT * FROM messages_index WHERE id = ? LIMIT 1\", [recordId]);\n const msgRecord = res.rows[0];\n\n if (!msgRecord) {\n return answerCallbackQuery(id, \"پیام یافت نشد.\", true);\n }\n\n let canDispatch = from.id === msgRecord.sender_id || from.id === ADMIN_ID;\n if (!canDispatch) {\n const member = await getChatMember(msgRecord.chat_id, from.id);\n canDispatch = ['creator', 'administrator'].includes(member?.status);\n }\n\n if (!canDispatch) {\n return answerCallbackQuery(id, \"⛔️ فقط نویسنده پیام یا مدیر گروه مجاز به ارسال پیامک هستند.\", true);\n }\n\n const membersRes = await query(`\n SELECT DISTINCT u.phone \n FROM topic_members tm\n INNER JOIN users u ON tm.tg_id = u.tg_id\n WHERE tm.chat_id = ? AND tm.thread_id = ? AND tm.tg_id != ? AND u.phone IS NOT NULL AND u.phone != ''\n `, [msgRecord.chat_id, msgRecord.message_thread_id, from.id]);\n\n const phones = membersRes.rows.map(r => r.phone).filter(Boolean);\n\n if (phones.length === 0) {\n return answerCallbackQuery(id, \"⚠️ هیچ مخاطبی با شماره در این تاپیک ثبت نشده است.\", true);\n }\n\n await answerCallbackQuery(id, `در حال ارسال پیامک به ${phones.length} مخاطب...`);\n\n let smsText = \"\";\n if (msgRecord.has_media && msgRecord.text.includes(\"بارگذاری شده\")) {\n smsText = `یک عکس در گروه [${msgRecord.chat_title}] بارگذاری شده که جالب توجه شما می باشد. (ارسال‌کننده: ${msgRecord.sender_name})`;\n } else {\n const excerpt = msgRecord.text.length > 70 ? msgRecord.text.substring(0, 67) + \"...\" : msgRecord.text;\n smsText = `پیام جدید از ${msgRecord.sender_name} در گروه [${msgRecord.chat_title}]:\\n${excerpt}`;\n }\n\n await Promise.allSettled(phones.map(phone => sendHomaisSms(phone, smsText)));\n\n await editMessageText(\n message.chat.id,\n message.message_id,\n `✅ پیامک این پیام با موفقیت به سرور همایس تحویل و برای ${phones.length} نفر ارسال شد.`\n );\n return;\n }\n\n // برچسب‌ها\n if (action === 'tag_menu') {\n const tagsRes = await query(\"SELECT * FROM predefined_tags ORDER BY id DESC LIMIT 10\");\n if (tagsRes.rows.length === 0) {\n return answerCallbackQuery(id, \"هنوز برچسبی ثبت نشده است.\", true);\n }\n\n const keyboard = tagsRes.rows.map(t => [\n { text: `#${t.name}`, callback_data: `set_tag:${recordId}:${t.name}` }\n ]);\n keyboard.push([{ text: \"🔙 بازگشت\", callback_data: `back_main:${recordId}` }]);\n\n await editMessageText(message.chat.id, message.message_id, \"یک برچسب برای این پیام انتخاب کنید:\", {\n inline_keyboard: keyboard\n });\n return;\n }\n\n if (action === 'back_main') {\n await editMessageText(message.chat.id, message.message_id, \"عملیات اطلاع‌رسانی پیامک:\", {\n inline_keyboard: [\n [\n { text: \"📩 بله، پیامک هم بشود\", callback_data: `sms:${recordId}` },\n { text: \"🏷 برچسب‌گذاری\", callback_data: `tag_menu:${recordId}` }\n ],\n [\n { text: \"❌ خیر، پیامک نشود (حذف)\", callback_data: `dismiss:${recordId}` }\n ]\n ]\n });\n return;\n }\n\n if (action === 'set_tag') {\n const tagName = extra;\n await query(\"UPDATE messages_index SET tag = ? WHERE id = ?\", [tagName, recordId]);\n await answerCallbackQuery(id, `برچسب #${tagName} اعمال شد.`);\n await editMessageText(message.chat.id, message.message_id, `برچسب #${tagName} ثبت گردید ✅`);\n return;\n }\n\n return;\n }\n\n // ۲. پیام‌های ورودی\n const msg = update.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(\"SELECT phone FROM users WHERE tg_id = ? LIMIT 1\", [msg.from.id]);\n\n if (userRes.rows[0]?.phone) {\n return sendMessage(chatId, `سلام ${msg.from.first_name}! شماره شما (${userRes.rows[0].phone}) در سامانه ثبت است.`);\n }\n\n return sendMessage(chatId, `سلام ${msg.from.first_name}!\\nجهت دریافت پیامک‌ها، دکمه زیر را لمس کرده و شماره خود را به اشتراک بگذارید:`, {\n reply_markup: {\n keyboard: [[{ text: '📱 اشتراک‌گذاری شماره برای دریافت پیامک‌ها', request_contact: true }]],\n resize_keyboard: true,\n one_time_keyboard: true\n }\n });\n }\n\n if (msg.contact) {\n if (msg.contact.user_id !== msg.from.id) {\n return sendMessage(chatId, \"❌ لطفاً شماره مربوط به اکانت خودتان را بفرستید.\");\n }\n const rawPhone = msg.contact.phone_number;\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 `, [msg.from.id, msg.from.first_name, msg.from.username || \"\", rawPhone]);\n\n return sendMessage(chatId, \"✅ شماره شما با موفقیت در سامانه همایس ثبت گردید.\", {\n reply_markup: { remove_keyboard: true }\n });\n }\n\n if (msg.text?.startsWith('/testsms') && msg.from.id === ADMIN_ID) {\n const parts = msg.text.replace('/testsms', '').trim().split(' ');\n const mobile = parts[0];\n const smsText = parts.slice(1).join(' ');\n\n if (!mobile || !smsText) {\n return sendMessage(chatId, \"❌ فرمت:\\n`/testsms 09121111111 متن پیامک`\", { parse_mode: 'Markdown' });\n }\n\n await sendMessage(chatId, \"⏳ در حال ارسال پیامک به همایس...\");\n const res = await sendHomaisSms(mobile, smsText);\n return sendMessage(chatId, `📡 وضعیت: ${res.ok ? '✅ موفق' : '❌ خطا'}\\nپاسخ: \\`${res.body}\\``, { parse_mode: 'Markdown' });\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) return;\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 if (!hasMedia && (!trimmed || trimmed.length < 4 || SINGLE_EMOJI_REGEX.test(trimmed))) {\n return;\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 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 const recordId = insRes.rows[0]?.id || insRes.lastInsertRowid;\n\n await sendMessage(chatId, \"عملیات اطلاع‌رسانی پیامک:\", {\n reply_to_message_id: msg.message_id,\n message_thread_id: threadId || undefined,\n reply_markup: {\n inline_keyboard: [\n [\n { text: \"📩 بله، پیامک هم بشود\", callback_data: `sms:${recordId}` },\n { text: \"🏷 برچسب‌گذاری\", callback_data: `tag_menu:${recordId}` }\n ],\n [\n { text: \"❌ خیر، پیامک نشود (حذف)\", callback_data: `dismiss:${recordId}` }\n ]\n ]\n }\n });\n }\n}\n\n// ==========================================\n// ۶. مدیریت APIهای پنل مینی‌اپ\n// ==========================================\nasync function handleApiRequests(req: Request, url: URL): Promise {\n if (url.pathname === '/api/stats') {\n const msgCount = await query(\"SELECT COUNT(*) as count FROM messages_index\");\n const userCount = await query(\"SELECT COUNT(*) as count FROM users WHERE phone IS NOT NULL AND phone != ''\");\n const groupCount = await query(\"SELECT COUNT(DISTINCT chat_id) as count FROM messages_index\");\n\n return Response.json({\n totalMessages: msgCount.rows[0]?.count || 0,\n usersWithPhone: userCount.rows[0]?.count || 0,\n connectedGroups: groupCount.rows[0]?.count || 0\n });\n }\n\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: \"آیدی عددی و شماره الزامی است\" }, { status: 400 });\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 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 if (url.pathname === '/api/groups') {\n const groups = await query(\"SELECT DISTINCT chat_id, chat_title FROM messages_index\");\n return Response.json(groups.rows);\n }\n\n if (url.pathname === '/api/tags') {\n if (req.method === 'GET') {\n const tags = await query(\"SELECT * FROM predefined_tags ORDER BY id DESC\");\n return Response.json(tags.rows);\n }\n if (req.method === 'POST') {\n const { name } = await req.json();\n if (!name) return Response.json({ error: \"نام الزامی است\" }, { status: 400 });\n const clean = name.replace(/^#/, '').trim();\n await query(\"INSERT OR IGNORE INTO predefined_tags (name) VALUES (?)\", [clean]);\n return Response.json({ success: true, name: clean });\n }\n if (req.method === 'DELETE') {\n const id = Number(url.searchParams.get('id'));\n await query(\"DELETE FROM predefined_tags WHERE id = ?\", [id]);\n return Response.json({ success: true });\n }\n }\n\n if (url.pathname === '/api/search') {\n const q = url.searchParams.get('q') || '';\n const chatId = url.searchParams.get('chat_id');\n const tag = url.searchParams.get('tag');\n\n let sqlQuery = \"SELECT * FROM messages_index WHERE 1=1\";\n const args: any[] = [];\n\n if (q) {\n sqlQuery += \" AND text LIKE ?\";\n args.push(`%${q}%`);\n }\n if (chatId) {\n sqlQuery += \" AND chat_id = ?\";\n args.push(Number(chatId));\n }\n if (tag) {\n sqlQuery += \" AND tag = ?\";\n args.push(tag);\n }\n\n sqlQuery += \" ORDER BY id DESC LIMIT 50\";\n const results = await query(sqlQuery, args);\n return Response.json(results.rows);\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

\n پیام‌های ذخیره\n 0\n

\n مخاطبان پیامک\n 0\n

\n گروه‌های فعال\n 0\n

\n\n \n

➕ ثبت یا ویرایش دستی شماره عضو

\n \n \n \n

\n \n

\n\n

لیست شماره‌های ثبت‌شده

\n \n

در حال دریافت لیست مخاطبان...

\n\n \n

\n \n

\n \n \n

\n \n

پیامی مطابق جستجو یافت نشد.

\n\n \n

افزودن برچسب جدید

\n \n \n

\n در حال بارگذاری...\n

Diff · v4