pip install telethon

from telethon import TelegramClient, events
import asyncio
import os
from datetime import datetime

Данные из my.telegram.org

API_ID = 12345678  # Замените на ваш api_id
API_HASH = 'your_api_hash_here'  # Замените на ваш api_hash

ID группы для модерации (можно получить через @userinfobot)

MODERATION_GROUP_ID = -1001234567890  # Замените на ID вашей группы
ADMIN_ID = 123456789  # Ваш Telegram ID

Создаем клиент

client = TelegramClient('moderation_bot_session', API_ID, API_HASH)

Функция логирования

def log_action(action, details):
    log_file = 'moderation_log.txt'
    timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    with open(log_file, 'a', encoding='utf-8') as f:
        f.write(f"[{timestamp}] {action}: {details}\n")
    print(f"[{timestamp}] {action}: {details}")

Обработчик новых сообщений в группе

@client.on(events.NewMessage(chats=MODERATION_GROUP_ID))
async def handle_group_message(event):
    message = event.message
    sender = await event.get_sender()
    
    # Проверка на спам (много ссылок в сообщении)
    if message.text and message.text.count('http') > 3:
        await event.delete()
        await event.respond('⚠️ Сообщение удалено: подозрение на спам')
        log_action('SPAM_DELETED', f'От {sender.first_name if sender else "Неизвестно"}: {message.text[:50]}')
        
        # Уведомление администратору
        await client.send_message(
            ADMIN_ID,
            f'🚨 Удалено спам-сообщение в группе от {sender.first_name if sender else "Неизвестно"}'
        )
        return
    
    # Автоматический ответ на часто задаваемые вопросы
    faq_responses = {
        'как начать': 'Для начала работы ознакомьтесь с правилами группы в закрепленном сообщении.',
        'правила': 'Правила группы находятся в описании и закрепленном сообщении.',
        'помощь': 'По вопросам обращайтесь к администраторам группы.'
    }
    
    if message.text:
        message_lower = message.text.lower()
        for keyword, response in faq_responses.items():
            if keyword in message_lower:
                await event.reply(response)
                log_action('FAQ_ANSWERED', f'Вопрос: {keyword}')
                break

Обработчик всех сообщений для мониторинга

@client.on(events.NewMessage)
async def monitor_messages(event):
    # Логируем все сообщения (опционально)
    if event.message.text:
        log_action('MESSAGE', f'От {event.chat.title if hasattr(event.chat, "title") else "Личное"}: {event.message.text[:100]}')

Запуск бота

async def main():
    await client.start()
    print("🤖 Бот модерации запущен!")
    print(f"Модерация группы: {MODERATION_GROUP_ID}")
    log_action('BOT_STARTED', 'Бот успешно запущен')
    await client.run_until_disconnected()

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

python user_bot.py

@client.on(events.NewMessage(chats='source_channel'))
async def forward_messages(event):
    # Пересылаем сообщения в другой канал
    await client.send_message('target_channel', event.message)

import schedule
import time

async def scheduled_post():
    await client.send_message(
        'your_channel',
        'Автоматическое сообщение по расписанию!'
    )

Запуск по расписанию (каждый день в 10:00)

schedule.every().day.at("10:00").do(lambda: asyncio.run(scheduled_post()))

KEYWORDS = ['важное', 'срочно', 'новости']

@client.on(events.NewMessage)
async def keyword_monitor(event):
    message_text = event.message.text.lower() if event.message.text else ''
    
    for keyword in KEYWORDS:
        if keyword in message_text:
            # Отправляем уведомление
            await client.send_message(
                'me',  # Себе в "Избранное"
                f'Найдено ключевое слово "{keyword}" в сообщении!'
            )

@client.on(events.NewMessage)
async def safe_handler(event):
    try:
        # Ваш код
        pass
    except Exception as e:
        print(f"Ошибка: {e}")
        # Логирование ошибки

import asyncio

async def send_with_delay(message, delay=1):
    await asyncio.sleep(delay)  # Задержка между запросами
    await client.send_message('target', message)

@client.on(events.NewMessage)
async def auto_moderation(event):
    message = event.message
    
    # Проверка на спам (много ссылок)
    if message.text and message.text.count('http') > 3:
        await event.delete()
        await event.respond('Сообщение удалено: подозрение на спам')
    
    # Проверка на мат
    bad_words = ['плохое_слово1', 'плохое_слово2']
    if message.text:
        for word in bad_words:
            if word in message.text.lower():
                await event.delete()
                break

from datetime import datetime

stats = {
    'messages_count': 0,
    'users': set(),
    'start_time': datetime.now()
}

@client.on(events.NewMessage)
async def collect_stats(event):
    stats['messages_count'] += 1
    sender = await event.get_sender()
    if hasattr(sender, 'id'):
        stats['users'].add(sender.id)
    
    # Вывод статистики каждый час
    if stats['messages_count'] % 100 == 0:
        print(f"Обработано сообщений: {stats['messages_count']}")
        print(f"Уникальных пользователей: {len(stats['users'])}")

TARGET_CHANNELS = ['@channel1', '@channel2', '@channel3']

@client.on(events.NewMessage(chats='@source_channel'))
async def cross_post(event):
    for channel in TARGET_CHANNELS:
        try:
            await client.send_message(channel, event.message)
            await asyncio.sleep(0.5)  # Задержка между отправками
        except Exception as e:
            print(f"Ошибка отправки в {channel}: {e}")