Spaces:

cacode
/

register

Runtime error

App Files Files Community

cacode commited on 28 days ago

Commit

1257cc2

verified ·

1 Parent(s): bbc6b0b

Upload 7 files

Browse files

Files changed (7) hide show

Dockerfile +24 -0
app.py +45 -0
logger.py +12 -0
register.py +242 -0
requirements.txt +6 -0
scheduler.py +23 -0
uploader.py +53 -0

Dockerfile ADDED Viewed

	@@ -0,0 +1,24 @@

+FROM python:3.10-slim
+# 安装 Chromium 及依赖
+RUN apt-get update && apt-get install -y \
+    chromium \
+    chromium-driver \
+    fonts-liberation \
+    libnss3 \
+    libatk-bridge2.0-0 \
+    libgtk-3-0 \
+    libxss1 \
+    libasound2 \
+    libgbm1 \
+    && rm -rf /var/lib/apt/lists/*
+ENV CHROME_BIN=/usr/bin/chromium
+ENV CHROMEDRIVER_BIN=/usr/bin/chromedriver
+WORKDIR /app
+COPY . /app
+RUN pip install --no-cache-dir -r requirements.txt
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app.py ADDED Viewed

	@@ -0,0 +1,45 @@

+from fastapi import FastAPI
+from fastapi.responses import HTMLResponse
+import threading
+from scheduler import scheduler_loop
+app = FastAPI()
+@app.on_event("startup")
+def start_scheduler():
+    t = threading.Thread(target=scheduler_loop, daemon=True)
+    t.start()
+@app.get("/", response_class=HTMLResponse)
+def index():
+    try:
+        logs = open("runtime.log", "r", encoding="utf-8").read()[-20000:]
+    except:
+        logs = ""
+    return f"""
+    <html>
+    <head>
+        <meta http-equiv="refresh" content="5">
+        <title>Gemini Auto Register</title>
+        <style>
+            body {{
+                background:#0b0b0b;
+                color:#00ff9c;
+                font-family: monospace;
+                padding:20px;
+            }}
+            pre {{
+                white-space: pre-wrap;
+                font-size: 13px;
+            }}
+        </style>
+    </head>
+    <body>
+        <h2>Gemini Business 自动注册</h2>
+        <p>每 3 小时自动创建 5 个账号</p>
+        <pre>{logs}</pre>
+    </body>
+    </html>
+    """

logger.py ADDED Viewed

	@@ -0,0 +1,12 @@

+from datetime import datetime
+import threading
+LOG_FILE = "runtime.log"
+_lock = threading.Lock()
+def log(msg, level="INFO"):
+    line = f"[{datetime.now():%Y-%m-%d %H:%M:%S}] [{level}] {msg}"
+    with _lock:
+        with open(LOG_FILE, "a", encoding="utf-8") as f:
+            f.write(line + "\n")
+    print(line)

	@@ -0,0 +1,242 @@

+"""
+Gemini Business 自动注册模块 (Docker / HF Space 版)
+"""
+# ================= 标准库 =================
+import json
+import time
+import random
+from pathlib import Path
+from datetime import datetime
+from urllib.parse import urlparse, parse_qs
+from concurrent.futures import ThreadPoolExecutor
+# ================= 第三方 =================
+import requests
+from bs4 import BeautifulSoup
+import undetected_chromedriver as uc
+from selenium.webdriver.common.by import By
+from selenium.webdriver.common.keys import Keys
+from selenium.webdriver.support.ui import WebDriverWait
+from selenium.webdriver.support import expected_conditions as EC
+# ================= 项目内 =================
+from logger import log
+# ==================== 配置 ====================
+LOGIN_URL = "https://auth.business.gemini.google/login?continueUrl=https:%2F%2Fbusiness.gemini.google%2F"
+MAIL_API = "https://mail.chatgpt.org.uk"
+MAIL_KEY = "gpt-test"
+ACCOUNTS_FILE = "accounts.json"
+HEADLESS_MODE = True
+XPATH = {
+    "email_input": "//input[@type='email']",
+    "continue_btn": "//button",
+}
+NAMES = [
+    "James Smith", "John Johnson", "Robert Williams", "Michael Brown",
+    "William Jones", "David Garcia", "Mary Miller", "Patricia Davis",
+    "Jennifer Rodriguez", "Linda Martinez", "Elizabeth Taylor"
+]
+# ==================== 邮箱 ====================
+email_queue = []
+def create_temp_email():
+    try:
+        r = requests.get(
+            f"{MAIL_API}/api/generate-email",
+            headers={"X-API-Key": MAIL_KEY},
+            timeout=20
+        )
+        if r.status_code == 200 and r.json().get("success"):
+            return r.json()["data"]["email"]
+    except Exception as e:
+        log(f"邮箱创建失败: {e}", "ERROR")
+    return None
+def prefetch_email():
+    email = create_temp_email()
+    if email:
+        email_queue.append(email)
+def get_email():
+    if email_queue:
+        email = email_queue.pop(0)
+        log(f"使用预取邮箱: {email}")
+        return email
+    email = create_temp_email()
+    log(f"新邮箱: {email}")
+    return email
+def fetch_verification_code(email, timeout=90):
+    log("等待验证码...")
+    start = time.time()
+    while time.time() - start < timeout:
+        try:
+            r = requests.get(
+                f"{MAIL_API}/api/emails",
+                params={"email": email},
+                headers={"X-API-Key": MAIL_KEY},
+                timeout=10
+            )
+            if r.status_code == 200:
+                emails = r.json().get("data", {}).get("emails", [])
+                if emails:
+                    soup = BeautifulSoup(
+                        emails[0].get("html_content", ""),
+                        "html.parser"
+                    )
+                    span = soup.find("span", class_="verification-code")
+                    if span:
+                        code = span.text.strip()
+                        if len(code) == 6:
+                            log(f"验证码: {code}", "OK")
+                            return code
+        except:
+            pass
+        time.sleep(2)
+    log("验证码超时", "ERROR")
+    return None
+# ==================== 浏览器 ====================
+def create_driver():
+    options = uc.ChromeOptions()
+    options.add_argument("--headless=new")
+    options.add_argument("--no-sandbox")
+    options.add_argument("--disable-dev-shm-usage")
+    options.add_argument("--disable-gpu")
+    options.add_argument("--window-size=1280,800")
+    return uc.Chrome(options=options, use_subprocess=True)
+# ==================== 保存配置 ====================
+def save_account_config(email, driver):
+    cookies = driver.get_cookies()
+    url = driver.current_url
+    parsed = urlparse(url)
+    config_id = None
+    for p in url.split("/"):
+        if len(p) > 10 and p.isalnum():
+            config_id = p
+    cookie_map = {c["name"]: c["value"] for c in cookies}
+    csesidx = parse_qs(parsed.query).get("csesidx", [None])[0]
+    if not all([config_id, csesidx]):
+        log("配置提取失败", "ERROR")
+        return None
+    data = {
+        "id": email,
+        "config_id": config_id,
+        "csesidx": csesidx,
+        "cookies": cookie_map,
+        "expires_at": datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    }
+    accounts = []
+    if Path(ACCOUNTS_FILE).exists():
+        accounts = json.load(open(ACCOUNTS_FILE, "r", encoding="utf-8"))
+    accounts.append(data)
+    json.dump(accounts, open(ACCOUNTS_FILE, "w", encoding="utf-8"), indent=2)
+    log(f"账号保存成功: {email}", "OK")
+    return data
+# ==================== 注册单个 ====================
+def register_single(driver, executor):
+    email = get_email()
+    wait = WebDriverWait(driver, 30)
+    try:
+        driver.get(LOGIN_URL)
+        time.sleep(2)
+        inp = wait.until(EC.element_to_be_clickable((By.XPATH, XPATH["email_input"])))
+        inp.clear()
+        inp.send_keys(email)
+        inp.send_keys(Keys.ENTER)
+        executor.submit(prefetch_email)
+        code = fetch_verification_code(email)
+        if not code:
+            return False
+        time.sleep(1)
+        driver.switch_to.active_element.send_keys(code)
+        time.sleep(2)
+        name = random.choice(NAMES)
+        driver.switch_to.active_element.send_keys(name)
+        driver.switch_to.active_element.send_keys(Keys.ENTER)
+        time.sleep(5)
+        save_account_config(email, driver)
+        log(f"注册成功: {email}", "OK")
+        return True
+    except Exception as e:
+        log(f"注册异常: {e}", "ERROR")
+        return False
+# ==================== 批量注册 ====================
+def run_batch_registration(target=5):
+    if Path(ACCOUNTS_FILE).exists():
+        Path(ACCOUNTS_FILE).unlink()
+    driver = create_driver()
+    executor = ThreadPoolExecutor(max_workers=2)
+    success = 0
+    attempts = 0
+    executor.submit(prefetch_email)
+    while success < target:
+        attempts += 1
+        log(f"开始注册第 {attempts} 次")
+        ok = register_single(driver, executor)
+        if ok:
+            success += 1
+        time.sleep(random.randint(2, 4))
+    driver.quit()
+    executor.shutdown(wait=False)
+    return {
+        "success": success,
+        "attempts": attempts,
+        "is_ok": success > 0
+    }
+# ==================== 对外接口 ====================
+def handle_task_execution(count, uploader):
+    stats = run_batch_registration(count)
+    if stats["is_ok"]:
+        uploader.login()
+        uploader.upload_and_merge(ACCOUNTS_FILE)
+    return stats

requirements.txt ADDED Viewed

	@@ -0,0 +1,6 @@

+fastapi
+uvicorn
+requests
+beautifulsoup4
+selenium
+undetected-chromedriver

scheduler.py ADDED Viewed

	@@ -0,0 +1,23 @@

+import time
+from datetime import datetime
+from uploader import AccountUploader
+from register import handle_task_execution
+from logger import log
+API_HOST = "https://cacode-hajimi-bus-2api.hf.space/"
+ADMIN_KEY = "CodeAtlantis"
+INTERVAL = 3 * 60 * 60
+COUNT = 5
+def scheduler_loop():
+    uploader = AccountUploader(API_HOST, ADMIN_KEY)
+    while True:
+        log("==== 自动任务开始 ====")
+        try:
+            handle_task_execution(COUNT, uploader)
+        except Exception as e:
+            log(f"任务异常: {e}", "ERROR")
+        log("==== 任务结束，休眠 ====")
+        time.sleep(INTERVAL)

uploader.py ADDED Viewed

	@@ -0,0 +1,53 @@

+import json
+import requests
+from pathlib import Path
+from logger import log
+class AccountUploader:
+    def __init__(self, api_host, admin_key):
+        self.api_host = api_host.rstrip("/")
+        self.admin_key = admin_key
+        self.session = requests.Session()
+    def login(self):
+        log("连接服务器中...")
+        r = self.session.post(
+            f"{self.api_host}/login",
+            data={"admin_key": self.admin_key},
+            timeout=30
+        )
+        if self.session.cookies:
+            log("服务器登录成功", "OK")
+            return True
+        log("服务器登录失败", "ERROR")
+        return False
+    def upload_and_merge(self, file_path):
+        if not Path(file_path).exists():
+            log("账号文件不存在", "ERROR")
+            return False
+        local = json.load(open(file_path, "r", encoding="utf-8"))
+        r = self.session.get(f"{self.api_host}/admin/accounts-config", timeout=30)
+        remote = r.json().get("accounts", []) if r.status_code == 200 else []
+        ids = {a["id"] for a in remote}
+        merged = remote[:]
+        for a in local:
+            if a["id"] not in ids:
+                merged.append(a)
+        r = self.session.put(
+            f"{self.api_host}/admin/accounts-config",
+            json=merged,
+            timeout=30
+        )
+        if r.status_code == 200:
+            log(f"上传完成，共 {len(merged)} 个账号", "OK")
+            return True
+        log("上传失败", "ERROR")
+        return False