import asyncio
import logging
from pyrogram import Client, filters
from pyrogram.errors import FloodWait

# Configure logging
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
logger = logging.getLogger(name)

# Define FROM and TO channel IDs
FROM_CHANNEL_IDS = [-1001234567890, -1009876543210]  # Replace with your source channel IDs
TO_CHANNEL_IDS = [-1001122334455, -1005566778899]    # Replace with your destination channel IDs

@Client.on_message(filters.chat(FROM_CHANNEL_IDS) & (filters.document | filters.video | filters.photo | filters.audio))
async def copy_message(client, message):
    """Handles copying messages from the source chats to destination chats."""
    try:
        if message.media and not (message.video_note or message.sticker):
            caption = message.caption if message.caption else None
            for destination in TO_CHANNEL_IDS:
                await message.copy(destination, caption=caption)
                logger.info(f"Message copied from {message.chat.id} to {destination}")
        else:
            for destination in TO_CHANNEL_IDS:
                await message.copy(destination)
                logger.info(f"Non-media message copied from {message.chat.id} to {destination}")
    except FloodWait as e:
        logger.warning(f"FloodWait encountered. Sleeping for {e.x} seconds.")
        await asyncio.sleep(e.x)
        await copy_message(client, message)  # Retry the operation
    except Exception as e:
        logger.error(f"Error while copying message: {e}")