Igen, bocsánat, nem vagyok olyan jó hekker :(

Ez most már működni látszik, csak az a gond hogy nagyon sok email cim blokkolva van. Igy jobb megadni egy magas számot és akkor talán 10% áttör.

Futtatás:

pip install disposable_email_domains

python szatyor.py -n 1000000

import requests
import time
import random
import string
import argparse
from concurrent.futures import ThreadPoolExecutor, as_completed
import json
import traceback
from disposable_email_domains import blocklist

URL = "https://api.citizengo.org/api/sign_petition"

HEADERS = {
    "Content-Type": "application/json",
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36",
    "Accept": "application/json, text/plain, */*",
    "Accept-Language": "en",
    "Origin": "https://citizengo.org",
    "Referer": "https://citizengo.org",
    "Sec-Fetch-Dest": "empty",
    "Sec-Fetch-Mode": "cors",
    "Sec-Fetch-Site": "same-site"
}

def _log_response(resp):
    print("---- HTTP ERROR ----")
    print(f"Status: {resp.status_code}")
    print(f"Headers: {resp.headers}")

    try:
        print("JSON:", json.dumps(resp.json(), indent=2))
    except ValueError:
        print("Text:", resp.text[:1000])  # truncate to avoid huge dumps

    print("--------------------")

def get_payload(email, first_name, last_name, pid):
    return {
        "email": email,
        "personalInfo": True,
        "personal_data": {
            "first_name": first_name,
            "last_name": last_name,
            "zip_code": "1000",
            "country": "VN",
            "purl": "https://citizengo.org/en/el/17908"
        },
        "pid": pid,
        "personal_message": None,
        "trk_medium": None,
        "trk_campaign": None,
        "trk_content": None,
        "trk_recruiter": None,
        "trk_source": None,
        "feedback_questions": [],
        "allow_data_checked": True,
        "cgo_verification": "skryubhinsvyub09#"
    }
def backoff_delay(attempt, base=0.5):
    delay = base * (2 ** attempt)
    jitter = random.uniform(0, delay * 0.1)
    return delay + jitter

def is_retriable_logical_error(data: dict) -> bool:
    """
    Detect the specific response pattern that should trigger a retry.
    """
    if not isinstance(data, dict):
        return False

    return (
        data.get("error_code") == 0 and
        data.get("m") == 6 and
        isinstance(data.get("debug"), dict) and
        data["debug"].get("existing_signature") is False
    )

def submit(email, first_name, last_name, pid, max_retries=5):
    session = requests.Session()

    for attempt in range(max_retries):
        try:
            #print(json.dumps(get_payload(email, first_name, last_name, pid)))
            resp = session.post(
                URL,
                headers=HEADERS,
                data=json.dumps(get_payload(email, first_name, last_name, pid)),
                timeout=10
            )

            # Retry on server errors
            if resp.status_code >= 500:
                _log_response(resp)
                raise requests.exceptions.HTTPError(f"{resp.status_code}")

            resp.raise_for_status()

            # Try to parse JSON response (optional)
            try:
                data = resp.json()
            except ValueError:
                return resp.text

            if is_retriable_logical_error(data):
                raise RuntimeError("Logical retry condition triggered")

            return data


        except (requests.exceptions.RequestException, RuntimeError) as e:
            if attempt == max_retries - 1:
                print(f"Final failure: {e}")
                break

            delay = backoff_delay(attempt)
            print(f"Retry {attempt+1} failed, retrying in {delay:.2f}s...")
            time.sleep(delay)

    return None


def register_test_email(max_retries=5):
    domain_list = list(blocklist)

    # Pick and return a random domain
    chosen_domain = random.choice(domain_list)
    username = f"testuser{random.randint(1000, 9999)}"

    return f"{username}@{chosen_domain}"


if __name__ == "__main__":
    parser = argparse.ArgumentParser(
        description="Vedjuk meg a szatyor fingot"
    )
    parser.add_argument(
        "-n", "--count",
        type=int,
        default=1,
        help="Number of email accounts to create"
    )

    args = parser.parse_args()
    count = max(1, args.count)

    results = []
    pid = 17908

    for _ in range(count):
        email = register_test_email()
        if email:
            print(email)
            first_name = "Anh"
            last_name = "Vang"
            result = submit(email, first_name, last_name, pid)
            print("Response:", result)

Igen, bocsánat, nem vagyok olyan jó hekker :(

Ez most már működni látszik, csak az a gond hogy nagyon sok email cim blokkolva van. Igy jobb megadni egy magas számot és akkor talán 10% áttör.

Futtatás:

pip install disposable_email_domains

python szatyor.py -n 1000000

import requests
import time
import random
import string
import argparse
from concurrent.futures import ThreadPoolExecutor, as_completed
import json
import traceback
from disposable_email_domains import blocklist

URL = "https://api.citizengo.org/api/sign_petition"

HEADERS = {
    "Content-Type": "application/json",
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36",
    "Accept": "application/json, text/plain, */*",
    "Accept-Language": "en",
    "Origin": "https://citizengo.org",
    "Referer": "https://citizengo.org",
    "Sec-Fetch-Dest": "empty",
    "Sec-Fetch-Mode": "cors",
    "Sec-Fetch-Site": "same-site"
}

def _log_response(resp):
    print("---- HTTP ERROR ----")
    print(f"Status: {resp.status_code}")
    print(f"Headers: {resp.headers}")

    try:
        print("JSON:", json.dumps(resp.json(), indent=2))
    except ValueError:
        print("Text:", resp.text[:1000])  # truncate to avoid huge dumps

    print("--------------------")

def get_payload(email, first_name, last_name, pid):
    return {
        "email": email,
        "personalInfo": True,
        "personal_data": {
            "first_name": first_name,
            "last_name": last_name,
            "zip_code": "1000",
            "country": "VN",
            "purl": "https://citizengo.org/en/el/17908"
        },
        "pid": pid,
        "personal_message": None,
        "trk_medium": None,
        "trk_campaign": None,
        "trk_content": None,
        "trk_recruiter": None,
        "trk_source": None,
        "feedback_questions": [],
        "allow_data_checked": True,
        "cgo_verification": "skryubhinsvyub09#"
    }
def backoff_delay(attempt, base=0.5):
    delay = base * (2 ** attempt)
    jitter = random.uniform(0, delay * 0.1)
    return delay + jitter

def is_retriable_logical_error(data: dict) -> bool:
    """
    Detect the specific response pattern that should trigger a retry.
    """
    if not isinstance(data, dict):
        return False

    return (
        data.get("error_code") == 0 and
        data.get("m") == 6 and
        isinstance(data.get("debug"), dict) and
        data["debug"].get("existing_signature") is False
    )

def submit(email, first_name, last_name, pid, max_retries=5):
    session = requests.Session()

    for attempt in range(max_retries):
        try:
            #print(json.dumps(get_payload(email, first_name, last_name, pid)))
            resp = session.post(
                URL,
                headers=HEADERS,
                data=json.dumps(get_payload(email, first_name, last_name, pid)),
                timeout=10
            )

            # Retry on server errors
            if resp.status_code >= 500:
                _log_response(resp)
                raise requests.exceptions.HTTPError(f"{resp.status_code}")

            resp.raise_for_status()

            # Try to parse JSON response (optional)
            try:
                data = resp.json()
            except ValueError:
                return resp.text

            if is_retriable_logical_error(data):
                raise RuntimeError("Logical retry condition triggered")

            return data

except (requests.exceptions.RequestException, RuntimeError) as e:

if attempt == max_retries - 1:

print(f"Final failure: {e}")

break

delay = backoff_delay(attempt)

print(f"Retry {attempt+1} failed, retrying in {delay:.2f}s...")

time.sleep(delay)

return None

def register_test_email(max_retries=5):

domain_list = list(blocklist)

# Pick and return a random domain

chosen_domain = random.choice(domain_list)

username = f"testuser{random.randint(1000, 9999)}"

return f"{username}@{chosen_domain}"

if __name__ == "__main__":

parser = argparse.ArgumentParser(

description="Vedjuk meg a szatyor fingot"

)

parser.add_argument(

"-n", "--count",

type=int,

default=1,

help="Number of email accounts to create"

)

args = parser.parse_args()

count = max(1, args.count)

results = []

pid = 17908

for _ in range(count):

email = register_test_email()

if email:

print(email)

first_name = "Anh"

last_name = "Vang"

result = submit(email, first_name, last_name, pid)

print("Response:", result)