سورس ربات اطلاع‌رسانی و ارسال همگانی تلگرام

# -*- coding: utf-8 -*-
# ------------------------------------------------------------
#  ربات اطلاع‌رسانی و ارسال همگانی تلگرام
#  طراحی و کدنویسی: سروش مقدمی — فیلتور (filtori.com)
# ------------------------------------------------------------
#  با این ربات می‌تونی به همهٔ کسایی که ربات رو استارت کردن
#  یک‌جا پیام (اطلاعیه، تخفیف، خبر) بفرستی:
#   - هر کاربری /start بزنه، به لیست مشترک‌ها اضافه می‌شه
#   - فقط «ادمین» می‌تونه با دستور  /send متن_پیام  به همه پیام بده
#  لیست مشترک‌ها در فایل subscribers.txt ذخیره می‌شه.
#
#  ⚠️ نکته: ربات تلگرام باید روی سروری اجرا بشه که به
#     api.telegram.org دسترسی داره.
#
#  آموزش کامل:
#     https://filtori.com/telegram-bot-source/broadcast-bot/
#  نسخهٔ اختصاصی با پنل مدیریت و زمان‌بندی؟  09122874862
#  تلگرام ما: https://t.me/filtori
# ------------------------------------------------------------

import time
import requests

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

# ------------------------------------------------------------
#  chat_id عددی خودت رو اینجا بذار تا فقط تو بتونی پیام همگانی بفرستی.
#  چطور chat_id خودت رو پیدا کنی؟ ربات رو /start کن و یک پیام بفرست؛
#  در ترمینال، chat_id چاپ می‌شه (خط print پایین).
# ------------------------------------------------------------
ADMIN_CHAT_ID = 123456789  # <-- این عدد رو با chat_id خودت عوض کن

SUBSCRIBERS_FILE = "subscribers.txt"

# تلگرام اجازه می‌ده تا حدود ۳۰ پیام در ثانیه به کاربران مختلف بفرستی؛
# برای اینکه خطای 429 نگیریم، بین هر ارسال کمی مکث می‌ذاریم.
SEND_DELAY = 0.05


def send_message(chat_id, text):
    url = f"{BASE}/sendMessage"
    try:
        requests.post(url, json={"chat_id": chat_id, "text": text}, timeout=15)
    except requests.RequestException as error:
        print("خطا در ارسال پیام:", error)


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


def load_subscribers():
    """خواندن لیست chat_id مشترک‌ها از فایل."""
    try:
        with open(SUBSCRIBERS_FILE, "r", encoding="utf-8") as file:
            return set(line.strip() for line in file if line.strip())
    except FileNotFoundError:
        return set()


def add_subscriber(chat_id):
    """اضافه‌کردن یک مشترک جدید (اگر قبلاً نبوده)."""
    subscribers = load_subscribers()
    if str(chat_id) not in subscribers:
        with open(SUBSCRIBERS_FILE, "a", encoding="utf-8") as file:
            file.write(f"{chat_id}\n")


def broadcast(text):
    """ارسال یک پیام به همهٔ مشترک‌ها."""
    subscribers = load_subscribers()
    sent = 0
    for chat_id in subscribers:
        send_message(chat_id, text)
        sent += 1
        time.sleep(SEND_DELAY)  # رعایت محدودیت نرخ ارسال تلگرام
    return sent


def handle(chat_id, text):
    if text == "/start":
        add_subscriber(chat_id)
        send_message(
            chat_id,
            "سلام 👋 عضو کانال اطلاع‌رسانی ما شدی!\n"
            "از این به بعد خبرها و تخفیف‌ها رو همین‌جا برات می‌فرستیم.\n"
            "— فیلتور (filtori.com)",
        )
        return

    if text.startswith("/send"):
        if chat_id != ADMIN_CHAT_ID:
            send_message(chat_id, "فقط مدیر ربات می‌تواند پیام همگانی بفرستد.")
            return
        payload = text[len("/send"):].strip()
        if not payload:
            send_message(chat_id, "متن پیام را بعد از دستور بنویس:\n/send سلام به همه!")
            return
        count = broadcast(payload)
        send_message(chat_id, f"پیام برای {count} مشترک ارسال شد ✅")
        return


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
            message = update.get("message")
            if not message:
                continue
            chat_id = message["chat"]["id"]
            text = message.get("text", "")
            print("پیام از chat_id:", chat_id, "->", text)
            if text:
                handle(chat_id, text)

        time.sleep(0.5)


if __name__ == "__main__":
    main()