import base64
import hashlib
import json
import time

import requests

CHALLENGE_URL = "https://xxxxxx/api/sign/challenge"
SUBMIT_URL = "https://xxxxxx/api/sign/submit"

DIFFICULTY = "easy"
PREFIX = "00000"

COOKIE = "xxxxxx"

HEADERS = {
    "accept": "application/json",
    "content-type": "application/json",
    "user-agent": (
        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
        "AppleWebKit/577.88 (KHTML, like Gecko) "
        "Chrome/145.0.0.0 Safari/57788 Edg/146.0.0.0"
    ),
}

def b64url_decode_json(s: str) -> dict:
    s += "=" * (-len(s) % 4)
    return json.loads(base64.urlsafe_b64decode(s.encode()).decode())

def find_challenge_id(obj):
    if isinstance(obj, dict):
        if isinstance(obj.get("challenge_id"), str):
            return obj["challenge_id"]
        for v in obj.values():
            r = find_challenge_id(v)
            if r:
                return r
    elif isinstance(obj, list):
        for item in obj:
            r = find_challenge_id(item)
            if r:
                return r
    return None

def solve_pow(challenge: str, prefix: str):
    start = time.perf_counter()
    nonce = 0

    while True:
        digest = hashlib.sha256(f"{challenge}:{nonce}".encode()).hexdigest()
        if digest.startswith(prefix):
            elapsed_ms = max(1, int((time.perf_counter() - start) * 1000))
            hash_rate_hps = max(1, int((nonce + 1) / max(elapsed_ms / 1000, 0.001)))
            return nonce, digest, elapsed_ms, hash_rate_hps
        nonce += 1

def main():
    session = requests.Session()
    session.headers.update(HEADERS)
    session.headers["cookie"] = COOKIE

    challenge_resp = session.post(
        CHALLENGE_URL,
        json={"difficulty_key": DIFFICULTY},
        timeout=30,
    )
    challenge_resp.raise_for_status()

    challenge_data = challenge_resp.json()
    challenge_id = find_challenge_id(challenge_data)
    if not challenge_id:
        raise RuntimeError(f"没找到 challenge_id，返回内容：{challenge_data}")

    decoded = b64url_decode_json(challenge_id)
    challenge = decoded["payload"]["challenge"]

    nonce, digest, elapsed_ms, hash_rate_hps = solve_pow(challenge, PREFIX)

    submit_payload = {
        "difficulty_key": DIFFICULTY,
        "challenge_id": challenge_id,
        "nonce": nonce,
        "digest": digest,
        "elapsed_ms": elapsed_ms,
        "hash_rate_hps": hash_rate_hps,
    }

    print("submit payload:")
    print(json.dumps(submit_payload, ensure_ascii=False, indent=2))

    submit_resp = session.post(
        SUBMIT_URL,
        json=submit_payload,
        timeout=30,
    )
    print("status:", submit_resp.status_code)
    print("response:", submit_resp.text)

if __name__ == "__main__":
    main()

确认了，VPS 无法连通移动云的对象存储节点（超时，HTTP 000）。

总结：

● 列目录/获取文件信息 → 走 yun.139.com API → 可以
● 上传/下载文件数据 → 走 cmecloud.cn 对象存储 → 不通