forwarder.py

#!/usr/bin/env python3
"""
Telegram Topic Video Forwarder
ویدئوهای یک تاپیک خاص رو به گروه دیگه‌ای فوروارد می‌کنه.

نصب: pip install telethon
اجرا: python forwarder.py
"""

import asyncio
import json
import logging
from pathlib import Path

from telethon import TelegramClient
from telethon.errors import FloodWaitError, ChatForwardsRestrictedError

# ══════════════════════════════════════════════
#  CONFIGURATION  ←  اینجا رو ویرایش کن
# ══════════════════════════════════════════════
API_ID   = 471259               # از https://my.telegram.org
API_HASH = 'f54d7c6a0ae42ca8a837f51813ee9d8c'     # از https://my.telegram.org

SOURCE_GROUP = -1003224348777   # آیدی گروه منبع (که Topic داره)
TOPIC_ID     = 4            # آیدی تاپیک داخل گروه منبع
DEST_GROUP   = -1004395873978   # آیدی گروه مقصد

# تأخیر بین هر فوروارد (ثانیه) - زیر 2 نذار!
DELAY_SECONDS = 3

# فایل‌های کمکی
PROGRESS_FILE = 'progress.json'
LOG_FILE      = 'forwarder.log'
# ══════════════════════════════════════════════


# ─── Logging ──────────────────────────────────
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s │ %(levelname)-8s │ %(message)s',
    datefmt='%H:%M:%S',
    handlers=[
        logging.FileHandler(LOG_FILE, encoding='utf-8'),
        logging.StreamHandler()
    ]
)
log = logging.getLogger(__name__)


# ─── Helpers ──────────────────────────────────

def is_video(msg) -> bool:
    """چک می‌کنه پیام ویدئو هست یا نه (هم native video هم document video)"""
    if msg.video:
        return True
    if msg.document:
        mime = getattr(msg.document, 'mime_type', '') or ''
        return mime.startswith('video/')
    return False


def session_key() -> str:
    return f"{SOURCE_GROUP}:{TOPIC_ID}→{DEST_GROUP}"


def load_progress() -> set:
    """پیشرفت قبلی رو بارگذاری می‌کنه (اگه قبلاً متوقف شده باشه)"""
    if not Path(PROGRESS_FILE).exists():
        return set()
    with open(PROGRESS_FILE, 'r') as f:
        data = json.load(f)
    done = set(data.get(session_key(), []))
    if done:
        log.info(f"ادامه از قبل: {len(done)} پیام قبلاً فوروارد شده")
    return done


def save_progress(done: set):
    """پیشرفت رو ذخیره می‌کنه"""
    data = {}
    if Path(PROGRESS_FILE).exists():
        with open(PROGRESS_FILE, 'r') as f:
            data = json.load(f)
    data[session_key()] = list(done)
    with open(PROGRESS_FILE, 'w') as f:
        json.dump(data, f, indent=2)


# ─── Core Logic ───────────────────────────────

async def collect_videos(client, source_chat) -> list:
    """تمام ویدئوهای تاپیک رو جمع می‌کنه"""
    log.info(f"اسکن تاپیک {TOPIC_ID} برای پیدا کردن ویدئوها...")
    videos = []

    async for msg in client.iter_messages(
        source_chat,
        reply_to=TOPIC_ID,   # فقط پیام‌های این تاپیک
        limit=None,
        wait_time=1,
    ):
        if is_video(msg):
            videos.append(msg)
            if len(videos) % 50 == 0:
                log.info(f"  تا اینجا {len(videos)} ویدئو پیدا شد...")

    # قدیمی‌ترین اول فوروارد بشه
    videos.sort(key=lambda m: m.id)

    log.info(f"جمع کل ویدئوها: {len(videos)}")
    return videos


async def forward_all(client, src, dst, videos: list, done: set):
    """ویدئوها رو یکی یکی فوروارد می‌کنه"""
    remaining = [v for v in videos if v.id not in done]
    total     = len(videos)
    already   = total - len(remaining)

    log.info(f"باقی‌مانده: {len(remaining)}  │  قبلاً انجام شده: {already}")

    if not remaining:
        log.info("همه ویدئوها قبلاً فوروارد شده‌اند!")
        return

    failed = 0

    for i, msg in enumerate(remaining, already + 1):
        success = False

        for attempt in range(1, 4):  # حداکثر 3 بار تلاش
            try:
                await client.forward_messages(dst, msg, src)
                done.add(msg.id)
                log.info(f"[{i:3}/{total}] ✓  msg_id={msg.id}")

                # هر 20 تا یه بار progress ذخیره کن
                if len(done) % 20 == 0:
                    save_progress(done)

                await asyncio.sleep(DELAY_SECONDS)
                success = True
                break

            except FloodWaitError as e:
                wait = e.seconds + 10
                log.warning(f"FloodWait → صبر می‌کنم {wait} ثانیه (تلاش {attempt}/3)")
                await asyncio.sleep(wait)

            except ChatForwardsRestrictedError:
                log.error("فوروارد در گروه منبع محدود شده! عملیات متوقف شد.")
                save_progress(done)
                return

            except Exception as e:
                log.error(f"خطا در msg_id={msg.id} (تلاش {attempt}/3): {e}")
                await asyncio.sleep(5)

        if not success:
            log.error(f"✗ msg_id={msg.id} بعد از 3 تلاش رد شد")
            failed += 1

    save_progress(done)

    print("\n" + "═" * 50)
    log.info(f"تموم شد!  ✓ موفق: {total - failed}  │  ✗ ناموفق: {failed}  │  کل: {total}")


# ─── Entry Point ──────────────────────────────

async def main():
    client = TelegramClient('finder_session', API_ID, API_HASH)
    await client.start()

    try:
        me = await client.get_me()
        log.info(f"وارد شدی به عنوان: {me.first_name} (@{me.username})")

        src = await client.get_entity(SOURCE_GROUP)
        dst = await client.get_entity(DEST_GROUP)

        log.info(f"منبع  : {src.title}  (تاپیک {TOPIC_ID})")
        log.info(f"مقصد  : {dst.title}")

        done   = load_progress()
        videos = await collect_videos(client, src)

        if not videos:
            log.warning("هیچ ویدئویی پیدا نشد. TOPIC_ID رو چک کن.")
            return

        print(f"\n آماده‌ام {len(videos) - len(done)} ویدئو از {len(videos)} رو فوروارد کنم.")
        input(" Enter بزن تا شروع کنم...\n")

        await forward_all(client, src, dst, videos, done)

    finally:
        await client.disconnect()


if __name__ == '__main__':
    asyncio.run(main())