python Исходник Бесплатный спамер тг по открытым телеграм чатам

import asyncio
import shutil
import os
import time
import socks

from telethon.sync import TelegramClient
from telethon.tl.functions.channels import JoinChannelRequest
from opentele.api import UseCurrentSession


app_telegram = r'./Telegram.exe'
links_file = './links.txt'
sessions = os.listdir('./sessions')


with open('spam_text.txt', 'r', encoding='utf-8') as file:
    spam_text = str(file.readlines()[0])


with open('proxy.txt', 'r') as file:
    proxy_data = file.readline().strip()

proxy_parts = proxy_data.split('@')
host_port = proxy_parts[0]
username_password = proxy_parts[1].split(':')

proxy = {
    'host': host_port.split(':')[0],
    'port': int(host_port.split(':')[1]),
    'username': username_password[0],
    'password': username_password[1]
}

async def procces_links(links):
    for session in sessions:
        session_path = os.path.join('./sessions', session)
        print(f'Работа с сессией: {session_path}')
        for link in links:
            try:
                await send_message(link, session_path)
                print(f"Отпаврил сообщение в {link}")
            except Exception as e:
                if 'A wait of' in str(e) and "seconds is required (caused by JoinChannelRequest)" in str(e):
                    wait_time = int(
                        str(e).split('A wait of ')[1].split(" seconds is required (caused by JoinChannelRequest")[0])
                    print(f"ошибка при отправке сообщения: {e}")
                    print(f"перехожу к следующей сессии")
                    break
                elif "You're banned from sending messages in supergroups/channels" in str(e):
                    print('Вы заблокированы и не можете отправлять сообщения в этот чат')
                else:
                    print(f'ошибка при отправке сообщения: {e}')

            # удаляем обработанные ссылки из списка ссылок, если надо
            links.remove(link)

            with open(links_file, 'w') as file:
                file.write('\n'.join(links))

            # небольщая задержка между отправкой сообщений
            await asyncio.sleep(2)

async def send_message(chat_link, session_path):
    # подключаемся к текущей сессии
    client = TelegramClient(session_path, proxy=(socks.SOCKS5, proxy['host'], proxy['port'], proxy['username'], proxy['password']))
    await client.connect()

    # создаем объект TDesktop и сохраняем ему в tdata
    tdesk = await client.ToTDesktop(flag = UseCurrentSession)
    tdesk.SaveTData(f"tdatas/{os.path.basename(session_path)}/tdata")
    #создаем копию telegram.exe чтобы была возмможность зайти в наш акк тг и глянуть че с ним там такое просиходит
    new_app = f"tdatas/{os.path.basename(session_path)}"
    shutil.copy2(app_telegram, new_app)

    try:
        await client(JoinChannelRequest(chat_link))
        # дада рекурсим, а че?
        await client.send_message(chat_link, spam_text)
    except Exception as e:
        raise e
    finally:
        await client.disconnect()

async def main():
    with open(links_file, 'r') as file:
        links = file.readlines()

    links = [link.strip() for link in links]

    if not links:
        print('ссылок больше нет')
        return

    await procces_links(links)

asyncio.run(main())