سورس ربات عضویت اجباری در کانال تلگرام

# -*- coding: utf-8 -*-
# ------------------------------------------------------------
#  ربات عضویت اجباری در کانال تلگرام
#  طراحی و کدنویسی: سروش مقدمی — فیلتور (filtori.com)
# ------------------------------------------------------------
#  قبل از اینکه کاربر به محتوای ربات (فایل، لینک، کد تخفیف و...)
#  دسترسی بگیره، ربات بررسی می‌کنه عضو کانال شما هست یا نه:
#   - اگر عضو نیست: دکمهٔ «عضویت در کانال» و دکمهٔ «عضو شدم ✅»
#   - بعد از عضویت: محتوای موردنظر براش ارسال می‌شه
#
#  ⚠️ خیلی مهم: ربات باید «ادمین» همون کانال باشه؛
#     وگرنه تلگرام اجازهٔ بررسی عضویت رو نمی‌ده.
#  ⚠️ ربات تلگرام باید روی سروری اجرا بشه که به api.telegram.org دسترسی داره.
#
#  آموزش کامل:
#     https://filtori.com/telegram-bot-source/join-check-bot/
#  سوال یا راهنمایی:  https://filtori.com/contact/
# ------------------------------------------------------------

import time

import requests

TOKEN = "توکن_ربات_خودت_را_اینجا_بگذار"
BASE = f"https://api.telegram.org/bot{TOKEN}"

# آیدی کانال با @ (کانال عمومی)
CHANNEL = "@your_channel"
CHANNEL_LINK = "https://t.me/your_channel"

# محتوایی که بعد از تایید عضویت ارسال می‌شه
REWARD_TEXT = (
    "ممنون که عضو کانال شدی 🌟\n\n"
    "کد تخفیف ویژه‌ات: FILTORI20\n"
    "لینک دانلود فایل: https://example.com/file.zip"
)

MEMBER_STATUSES = {"creator", "administrator", "member"}


def api(method, data):
    """فراخوانی یک متد Bot API و برگرداندن پاسخ JSON."""
    try:
        return requests.post(f"{BASE}/{method}", json=data, timeout=15).json()
    except (requests.RequestException, ValueError) as error:
        print(f"خطا در {method}:", error)
        return {"ok": False}


def get_updates(offset):
    params = {"offset": offset, "timeout": 30}
    try:
        return requests.get(f"{BASE}/getUpdates", params=params, timeout=40).json()
    except (requests.RequestException, ValueError) as error:
        print("خطا در دریافت پیام‌ها:", error)
        return {"ok": False, "result": []}


def is_member(user_id):
    """True اگر کاربر عضو کانال باشد."""
    result = api("getChatMember", {"chat_id": CHANNEL, "user_id": user_id})
    if not result.get("ok"):
        # معمولاً یعنی ربات ادمین کانال نیست یا آیدی کانال اشتباه است
        print("بررسی عضویت ناموفق:", result.get("description"))
        return False
    member = result["result"]
    if member.get("status") in MEMBER_STATUSES:
        return True
    # کاربر «محدودشده» ولی همچنان عضو
    return member.get("status") == "restricted" and member.get("is_member", False)


def ask_to_join(chat_id):
    keyboard = {
        "inline_keyboard": [
            [{"text": "📢 عضویت در کانال", "url": CHANNEL_LINK}],
            [{"text": "عضو شدم ✅", "callback_data": "check_join"}],
        ]
    }
    api(
        "sendMessage",
        {
            "chat_id": chat_id,
            "text": "برای استفاده از ربات، اول عضو کانال ما شو 👇\nبعد از عضویت، دکمهٔ «عضو شدم» رو بزن.",
            "reply_markup": keyboard,
        },
    )


def give_reward(chat_id):
    api("sendMessage", {"chat_id": chat_id, "text": REWARD_TEXT})


def handle_message(message):
    chat_id = message["chat"]["id"]
    user_id = message["from"]["id"]
    if is_member(user_id):
        give_reward(chat_id)
    else:
        ask_to_join(chat_id)


def handle_callback(callback):
    user_id = callback["from"]["id"]
    chat_id = callback["message"]["chat"]["id"]
    if callback.get("data") != "check_join":
        api("answerCallbackQuery", {"callback_query_id": callback["id"]})
        return

    if is_member(user_id):
        api("answerCallbackQuery", {"callback_query_id": callback["id"], "text": "عضویتت تایید شد ✅"})
        give_reward(chat_id)
    else:
        api(
            "answerCallbackQuery",
            {
                "callback_query_id": callback["id"],
                "text": "هنوز عضو کانال نشدی! اول عضو شو، بعد دکمه رو بزن.",
                "show_alert": True,
            },
        )


def main():
    print("ربات عضویت اجباری فیلتور روشن شد... (Ctrl+C برای خاموش‌کردن)")
    offset = 0
    while True:
        updates = get_updates(offset)
        if not updates.get("ok"):
            time.sleep(2)
            continue

        for update in updates.get("result", []):
            offset = update["update_id"] + 1
            if "callback_query" in update:
                handle_callback(update["callback_query"])
            elif "message" in update and "from" in update["message"]:
                handle_message(update["message"])

        time.sleep(0.5)


if __name__ == "__main__":
    main()