Two-thread spammer in anonymous chats

Приветствую, это мой первый юзер бот, написанный на pyrogram. Хотел бы отдать его вам на растерзание и на критику.

Необходимое для работы скрипта:
1. Python 3.11 + https://www.python.org/downloads/
2. Библиотека pyrogram (вводим в консоли pip install pyrogram)

Принцип работы:
1. При запуске скрипта нам дается выбор:
1.1. Ввести 1 в консоль - бот будет сначала спрашивать м/д у собеседника, а потом уже спамить. Можно настроить в самом скрипте, чтобы в зависимости от ответа "м" или "д" бот отправлял разный текст ну или вовсе скипал.
1.2. Ввести 2 в консоль - бот будет просто спамить ваш текст и команду /next
2. С каждым сообщением текста для спама будет отображаться количество отправленных сообщений в консоль
3. Юзер бот спамит в два бота: AnonRuBot и anonimnyychatbot (НЕ реклама). При вашем желании или просьбам могу дописать больше ботов, чтобы флудить в еще большее количество (это несложно).

Начало работы (для тех кому нужно):
1. Заходим на сайт https://my.telegram.org/auth и авторизовываемся, получаем свой АПИ введя рандомные данные.
2. Копируем api_id и api_hash и вставляем их в скрипт.
3. Редактируем сообщение для спама на свое.
4. Запускаем скрипт и заканчиваем авторизацию(придет код).

from pyrogram import Client, filters
from asyncio import sleep
from datetime import datetime

api_id = 777 # Ставим свое
api_hash = "777" # Ставим свое
app = Client("my_account", api_id, api_hash)
now = datetime.now()

current_time = now.strftime("%H:%M:%S")
print("Запущен, текущее время:", current_time)

spam_text = """Жрать хочу пиздец""" # Свой спам текст сюда
spam_count = 0

print('''Спамим спрашивая м/д или сразу спам текст?
1 = Спрашивая
2 = Агрессивный спам''')
a = int(input())
with app:
app.send_message("@AnonRuBot", '/start')
app.send_message("@anonimnyychatbot", '/start')

@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^Собеседник найден "))
async def message_start_spam(client, message):
if a == 1:
await sleep(3)
await app.send_message("@AnonRuBot", "привет мд?")
else:
await sleep(3) # Ставите свою задержку если хотите
await app.send_message("@AnonRuBot", f'{spam_text}')
global spam_count
spam_count += 1
print(f'Отправлено {spam_count} сообщений')
await sleep(2)
await app.send_message("@AnonRuBot", '/next')

@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^м$|^М$"))
async def spam1(client, message):
await sleep(2)
await app.send_message("@AnonRuBot", f'{spam_text}')
global spam_count
spam_count += 1
print(f'Отправлено {spam_count} сообщений')
await sleep(2)
await app.send_message("@AnonRuBot", '/next')

@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^д$|^Д$"))
async def rabotaem(client, message):
await sleep(2)
await app.send_message("@AnonRuBot", f'{spam_text}')
global spam_count
spam_count += 1
print(f'Отправлено {spam_count} сообщений')
await sleep(2)
await app.send_message("@AnonRuBot", '/next')



@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^Собеседник закончил с вами связь "))
async def rabotaem2(client, message):
await sleep(2)
await app.send_message("@AnonRuBot", '/next')


@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^У вас ограничение на количество чатов в сутки."))
async def pizdec(client, message):
print('Нас заблокировали в анонимном чате.')


@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@anonimnyychatbot") & filters.regex(r"^Нашёл кое-кого для тебя!"))
async def message_start_spam2(client, message):
if a == 1:
await sleep(3)
await app.send_message("@anonimnyychatbot", "привет мд?")
else:
await sleep(3) # Ставите свою задержку если хотите
await app.send_message("@anonimnyychatbot", f'{spam_text}')
global spam_count
spam_count += 1
print(f'Отправлено {spam_count} сообщений')
await sleep(2)
await app.send_message("@anonimnyychatbot", '/next')
@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@anonimnyychatbot") & filters.regex(r"^Диалог остановлен "))
async def rabotaem3(client, message):
await sleep(2)
await app.send_message("@anonimnyychatbot", '/next')
app.run()

Code

from pyrogram import Client, filters

from asyncio import sleep

from datetime import datetime



api_id = 777   # Ставим свое

api_hash = "777"   # Ставим свое

app = Client("my_account", api_id, api_hash)

now = datetime.now()



current_time = now.strftime("%H:%M:%S")

print("Запущен, текущее время:", current_time)



spam_text = """Жрать хочу пиздец"""   # Свой спам текст сюда

spam_count = 0



print('''Спамим спрашивая м/д или сразу спам текст?

1 = Спрашивая

2 = Агрессивный спам''')

a = int(input())

with app:

    app.send_message("@AnonRuBot", '/start')

    app.send_message("@anonimnyychatbot", '/start')



@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^Собеседник найден "))

async def message_start_spam(client, message):

    if a == 1:

        await sleep(3)

        await app.send_message("@AnonRuBot", "привет мд?")

    else:

        await sleep(3)  # Ставите свою задержку если хотите

        await app.send_message("@AnonRuBot", f'{spam_text}')

        global spam_count

        spam_count += 1

        print(f'Отправлено {spam_count} сообщений')

        await sleep(2)

        await app.send_message("@AnonRuBot", '/next')



@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot")  & filters.regex(r"^м$|^М$"))

async def spam1(client, message):

    await sleep(2)

    await app.send_message("@AnonRuBot", f'{spam_text}')

    global spam_count

    spam_count += 1

    print(f'Отправлено {spam_count} сообщений')

    await sleep(2)

    await app.send_message("@AnonRuBot", '/next')



@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot")  & filters.regex(r"^д$|^Д$"))

async def rabotaem(client, message):

    await sleep(2)

    await app.send_message("@AnonRuBot", f'{spam_text}')

    global spam_count

    spam_count += 1

    print(f'Отправлено {spam_count} сообщений')

    await sleep(2)

    await app.send_message("@AnonRuBot", '/next')







@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot") & filters.regex(r"^Собеседник закончил с вами связь "))

async def rabotaem2(client, message):

    await sleep(2)

    await app.send_message("@AnonRuBot", '/next')





@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@AnonRuBot")  & filters.regex(r"^У вас ограничение на количество чатов в сутки."))

async def pizdec(client, message):

    print('Нас заблокировали в анонимном чате.')





@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@anonimnyychatbot") & filters.regex(r"^Нашёл кое-кого для тебя!"))

async def message_start_spam2(client, message):

    if a == 1:

        await sleep(3)

        await app.send_message("@anonimnyychatbot", "привет мд?")

    else:

        await sleep(3)  # Ставите свою задержку если хотите

        await app.send_message("@anonimnyychatbot", f'{spam_text}')

        global spam_count

        spam_count += 1

        print(f'Отправлено {spam_count} сообщений')

        await sleep(2)

        await app.send_message("@anonimnyychatbot", '/next')

@app.on_message(filters.text & filters.private & filters.incoming & filters.user("@anonimnyychatbot") & filters.regex(r"^Диалог остановлен "))

async def rabotaem3(client, message):

    await sleep(2)

    await app.send_message("@anonimnyychatbot", '/next')

app.run()