GET /v1/social/oauth-status/:state

curl "https://api.layers.com/v1/social/oauth-status/st_01HXZ8K2M4P5QRS6TUV7WXYZ9A" \
  -H "Authorization: Bearer lp_..."

const POLL_INTERVAL_MS = 5_000;
const MAX_POLL_MS = 10 * 60 * 1_000; // state row TTL.

async function waitForOAuth(state: string) {
  const deadline = Date.now() + MAX_POLL_MS;
  let backoffMs = POLL_INTERVAL_MS;

  while (Date.now() < deadline) {
    let status;
    try {
      status = await layers.social.getOAuthStatus({ state });
    } catch (err: any) {
      // 429 — honor Retry-After, then exponential backoff on subsequent 429s.
      if (err?.status === 429) {
        const retryAfterMs = Number(err.headers?.["retry-after"] ?? "5") * 1_000;
        await new Promise(r => setTimeout(r, Math.max(retryAfterMs, backoffMs)));
        backoffMs = Math.min(backoffMs * 2, 30_000);
        continue;
      }
      throw err;
    }

    if (status.status === "completed") return status.socialAccountId;
    if (status.status === "failed") {
      // status.error.code is one of the snake_case codes below (e.g.
      // "platform_denied", "exchange_failed"). Map to your own copy.
      throw new Error(status.error?.message ?? "OAuth failed");
    }

    // 5s floor — oauth-status is rate-limited and poll-budget-tight; under 5s
    // wastes budget without changing user-visible latency.
    await new Promise(r => setTimeout(r, POLL_INTERVAL_MS));
  }

  throw new Error("oauth state expired before user completed consent");
}

import time

POLL_INTERVAL_S = 5  # 5s floor.
MAX_POLL_S = 10 * 60  # state row TTL.

def wait_for_oauth(state: str) -> str:
    deadline = time.monotonic() + MAX_POLL_S
    backoff_s = POLL_INTERVAL_S

    while time.monotonic() < deadline:
        try:
            status = layers.social.get_oauth_status(state=state)
        except RateLimitedError as e:  # SDK-shaped 429
            retry_after = int(e.headers.get("Retry-After", "5"))
            time.sleep(max(retry_after, backoff_s))
            backoff_s = min(backoff_s * 2, 30)
            continue

        if status["status"] == "completed":
            return status["socialAccountId"]
        if status["status"] == "failed":
            err = status.get("error", {})
            raise RuntimeError(f"oauth failed: {err.get('code')} — {err.get('message')}")

        time.sleep(POLL_INTERVAL_S)

    raise RuntimeError("oauth state expired before user completed consent")