Бот для связи между админом и юзером на Aiogram

import logging
import asyncio
from aiogram import Bot, Dispatcher, executor, types
 
# Вставьте ваш токен, полученный от BotFather
TOKEN = ""
 
# ID администратора (ваш ID)
ADMIN_ID = ""
 
# Настройка логгирования
logging.basicConfig(level=logging.INFO)
 
# Инициализация бота и диспетчера
bot = Bot(token=TOKEN)
dp = Dispatcher(bot)
 
# Список заблокированных пользователей
banned_users = []
 
# Словарь для отслеживания времени отправки последнего сообщения от каждого пользователя
last_message_times = {}
 
# Ограничение скорости: одно сообщение в 10 минут
MESSAGE_RATE_LIMIT = 0  # 600 секунд = 10 минут
 
 
# Обработка команды /start
@dp.message_handler(commands=['start'])
async def start(message: types.Message):
    await message.reply(
        "Отправь мне сообщение, и я перешлю его в личные сообщения администратору. Сообщения можно отправлять раз в 5 минут")
 
 
# Обработка команды /ban
@dp.message_handler(commands=['ban'])
async def ban_user(message: types.Message):
    try:
        # Проверяем, является ли пользователь администратором
        is_admin = str(message.from_user.id) == ADMIN_ID
        if is_admin:
            # Проверяем, отправлено ли сообщение в ответ на другое сообщение
            if message.reply_to_message:
                # Получаем ID пользователя, которого нужно заблокировать
                user_id = message.reply_to_message.from_user.id
                # Добавляем пользователя в список заблокированных
                banned_users.append(user_id)
                await message.reply(f"Пользователь {user_id} заблокирован.")
        else:
            await message.reply("Только посмей, дырявая псина")
    except Exception as e:
        await message.reply(f"Ошибка при блокировке пользователя: {e}")
 
# Обработка сообщений от администратора к боту
@dp.message_handler(lambda message: message.from_user.id == int(ADMIN_ID))
async def handle_admin_message(message: types.Message):
    if message.reply_to_message and message.reply_to_message.forward_sender_name:
        # Если сообщение администратора является ответом на сообщение пользователя
        user_id = message.reply_to_message.forward_sender_name.id
    elif message.reply_to_message and message.reply_to_message.forward_from:
        # Если сообщение администратора является ответом на сообщение пользователя
        user_id = message.reply_to_message.forward_from.id
    else:
        await message.reply("Чтобы ответить пользователю, перешлите мне его сообщение.")
        return
 
    if message.text:
        await bot.send_message(chat_id=user_id, text=message.text)
        await message.reply("Ваш ответ отправлен пользователю.")
 
 
 
 
# Обработка текстовых сообщений
@dp.message_handler(content_types=types.ContentType.TEXT)
async def echo(message: types.Message):
    user_id = message.from_user.id
 
    # Проверяем, является ли пользователь администратором
    is_admin = str(user_id) == ADMIN_ID
 
    current_time = last_message_times.get(user_id, 0)
 
    # Если пользователь администратор, ничего не делаем
    if is_admin:
        return
 
    # Проверяем, является ли сообщение ответом на предыдущее сообщение администратора
    if message.reply_to_message and message.reply_to_message.from_user.id == int(ADMIN_ID):
        # Пересылаем сообщение администратору
        await bot.forward_message(chat_id=ADMIN_ID, from_chat_id=message.chat.id, message_id=message.message_id)
        await message.reply("Ваше сообщение отправлено! Администратор скоро свяжется с вами")
        return
 
    # Проверяем, прошло ли достаточно времени с предыдущего сообщения
    if current_time == 0 or message.date.timestamp() - current_time > MESSAGE_RATE_LIMIT:
        # Пересылаем сообщение админу
        await bot.forward_message(chat_id=ADMIN_ID, from_chat_id=message.chat.id, message_id=message.message_id)
        await message.reply("Ваше сообщение отправлено администратору.")
        # Обновляем время последнего сообщения от пользователя
        last_message_times[user_id] = message.date.timestamp()
    else:
        # Уведомляем пользователя о том, что нужно подождать
        await message.reply("Пожалуйста, подождите 5 минут перед отправкой нового сообщения.")
 
@dp.message_handler(content_types=[
    types.ContentType.PHOTO,
    types.ContentType.AUDIO,
    types.ContentType.DOCUMENT,
    types.ContentType.VIDEO,
    types.ContentType.VOICE,
])
async def handle_media(message: types.Message):
    user_id = message.from_user.id
 
    # Проверяем, является ли отправитель администратором
    if str(user_id) == ADMIN_ID:
        # Проверяем, отправлено ли сообщение в ответ на сообщение пользователя
        if message.reply_to_message and message.reply_to_message.from_user.id != int(ADMIN_ID):
            # Если сообщение администратора является ответом на сообщение пользователя,
            # пересылаем медиа-сообщение обратно пользователю
            user_id = message.reply_to_message.from_user.id
 
            # Пересылаем сообщение администратора пользователю
            await bot.forward_message(chat_id=user_id, from_chat_id=message.chat.id, message_id=message.message_id)
 
            # Отправляем уведомление об успешной отправке медиа-контента
            await message.reply("Медиа-контент отправлен пользователю.")
        else:
            # Если сообщение администратора не является ответом на сообщение пользователя,
            # пересылаем медиа-контент администратору, но не отправляем сообщение самому себе
            if user_id != ADMIN_ID:
                await bot.forward_message(chat_id=ADMIN_ID, from_chat_id=message.chat.id, message_id=message.message_id)
                await bot.send_message(chat_id=user_id, text="Ваше медиа-сообщение было отправлено администратору.")
    else:
        # Пересылаем медиа-контент администратору
        await bot.forward_message(chat_id=ADMIN_ID, from_chat_id=message.chat.id, message_id=message.message_id)
        await bot.send_message(chat_id=user_id, text="Ваше медиа-сообщение было отправлено администратору.")
 
 
 
 
 
if __name__ == '__main__':
    executor.start_polling(dp, skip_updates=True)