async function callProfy(path: string, init?: RequestInit) {
  const res = await fetch(`https://api.profy.cn${path}`, init);

  // Read text first — a non-JSON 2xx (proxy page, auth HTML, empty body)
  // must stay diagnosable
  const text = await res.text();
  let body: { code?: number; message?: string; data?: unknown };
  try {
    body = JSON.parse(text);
  } catch {
    throw new Error(
      `Non-JSON response: HTTP ${res.status} ${text.slice(0, 200)}`
    );
  }

  // Both dimensions matter
  if (!res.ok || body.code !== 0) {
    const err = new Error(body.message || `HTTP ${res.status}`);
    (err as Error & { code?: number }).code = body.code;
    throw err;
  }

  return body.data;
}

import httpx

class ProfyError(Exception):
    def __init__(self, code: int | None, message: str, status: int):
        super().__init__(message)
        self.code = code
        self.status = status

async def call_profy(client: httpx.AsyncClient, path: str, **kwargs):
    res = await client.request(kwargs.pop("method", "GET"),
                               f"https://api.profy.cn{path}", **kwargs)
    text = res.text
    try:
        body = res.json()
    except ValueError:
        raise ProfyError(None, f"Non-JSON response: {text[:200]}", res.status_code)

    code = body.get("code")
    if not res.is_success or code != 0:
        raise ProfyError(code, body.get("message") or f"HTTP {res.status_code}",
                         res.status_code)

    return body.get("data")