Settlement

import os
from datetime import datetime
from decimal import Decimal

import requests

REST_BASE = "https://api.preprod.polymarketexchange.com"
SYMBOL    = "aec-cfb-clmsn-lsu-2026-09-05"  # from the position change that triggered this check
ACCESS_TOKEN = os.environ["PMX_ACCESS_TOKEN"]  # mint per /connect#authentication; expires_in is 180s

# Gate on event series and symbol prefix. automaticResolution controls nothing.
# VERIFY: `aec-atp` is the only symbol prefix we have evidence for. The authoritative
# list of auto-resolving series and prefixes must come from us — never guess one.
AUTO_RESOLVING_PREFIXES = ("aec-atp",)

# VERIFY: which InstrumentState values are terminal for resolution is not published,
# and these two spellings are unconfirmed. See the warning above.
TERMINAL_STATES = {"INSTRUMENT_STATE_CLOSED", "INSTRUMENT_STATE_TERMINATED"}


def instant(value):
    """Parses an RFC 3339 timestamp. Returns None when the field is absent or empty.

    Never compare these as strings: an absent field is an empty string, which
    compares LOW against every real timestamp and silently passes the gate.
    """
    if not value:
        return None
    return datetime.fromisoformat(str(value).replace("Z", "+00:00"))


def settlement_view(symbol: str) -> dict:
    # /v1/orderbook/* needs no x-participant-id.
    response = requests.get(
        f"{REST_BASE}/v1/orderbook/{symbol}",
        headers={"authorization": f"Bearer {ACCESS_TOKEN}"},
        timeout=10,  # the edge 504s past 30 seconds; fail fast instead
    )
    response.raise_for_status()  # never swallow: 401 means a stale token, 504 means >30s at the edge
    return response.json()


def resolution_state(view: dict) -> str:
    """Returns "resolved", "mark" or "review". Never returns "resolved" on a fractional price."""
    px_raw = view.get("settlementPx")          # int64 arrives as a string
    price_scale = view.get("priceScale")       # 100 and 1000 are both live in production
    if px_raw is None or not price_scale:
        return "mark"                          # absent and zero are indistinguishable in proto3

    px = Decimal(str(px_raw)) / Decimal(str(price_scale))   # de-scale with priceScale, not settlementPriceScale

    if view.get("settlementPreliminary") is not False:
        return "mark"                          # false alone is NOT proof of resolution, but true rules it out

    set_time = instant(view.get("settlementSetTime"))
    expiration = instant(view.get("expirationDate"))
    if set_time is None or expiration is None:
        return "review"                        # a missing field FAILS the condition; it never passes it
    if set_time < expiration:
        return "review"                        # settlementSetTime can precede expirationDate by ~13h on a mark

    if view.get("instrumentState") not in TERMINAL_STATES:
        return "review"
    if px not in (Decimal("0.00"), Decimal("1.00")):
        return "review"                        # binary markets have been seen settling non-binary — hold, do not pay
    return "resolved"


if __name__ == "__main__":
    state = resolution_state(settlement_view(SYMBOL))
    series = "auto-resolving" if SYMBOL.startswith(AUTO_RESOLVING_PREFIXES) else "manual"
    print(SYMBOL, state, series)
    # "resolved" → mirror our credit. We credit the participant account; you must not credit again.
    # "review"   → queue for a human. Do not auto-pay and do not auto-void.

const REST_BASE = "https://api.preprod.polymarketexchange.com";
const SYMBOL = "aec-cfb-clmsn-lsu-2026-09-05"; // from the position change that triggered this check
const ACCESS_TOKEN = process.env.PMX_ACCESS_TOKEN!; // mint per /connect#authentication; expires_in is 180s

// Gate on event series and symbol prefix. automaticResolution controls nothing.
// VERIFY: `aec-atp` is the only symbol prefix we have evidence for. The authoritative
// list of auto-resolving series and prefixes must come from us — never guess one.
const AUTO_RESOLVING_PREFIXES = ["aec-atp"];

// VERIFY: which InstrumentState values are terminal for resolution is not published,
// and these two spellings are unconfirmed. See the warning above.
const TERMINAL_STATES = new Set(["INSTRUMENT_STATE_CLOSED", "INSTRUMENT_STATE_TERMINATED"]);

/**
 * Parses an RFC 3339 timestamp, or null when the field is absent or unparseable.
 * Never compare these as strings: an absent field is an empty string, which
 * compares LOW against every real timestamp and silently passes the gate.
 */
function instant(value: unknown): number | null {
  if (typeof value !== "string" || value === "") return null;
  const ms = Date.parse(value);
  return Number.isNaN(ms) ? null : ms;
}

type ResolutionState = "resolved" | "mark" | "review";

async function settlementView(symbol: string): Promise<any> {
  // /v1/orderbook/* needs no x-participant-id.
  const response = await fetch(`${REST_BASE}/v1/orderbook/${symbol}`, {
    headers: { authorization: `Bearer ${ACCESS_TOKEN}` },
    signal: AbortSignal.timeout(10_000), // the edge 504s past 30 seconds; fail fast instead
  });
  if (!response.ok) {
    // Never swallow: 401 means a stale token, 504 means >30s at the edge.
    throw new Error(`orderbook read failed: ${response.status} ${await response.text()}`);
  }
  return response.json();
}

function resolutionState(view: any): ResolutionState {
  const pxRaw = view.settlementPx; // int64 arrives as a string
  const priceScale = Number(view.priceScale); // 100 and 1000 are both live in production
  if (pxRaw === undefined || pxRaw === null || !priceScale) return "mark";

  const px = Number(pxRaw) / priceScale; // de-scale with priceScale, not settlementPriceScale

  if (view.settlementPreliminary !== false) return "mark"; // false alone is NOT proof of resolution

  const setTime = instant(view.settlementSetTime);
  const expiration = instant(view.expirationDate);
  // A missing field FAILS the condition; it never passes it.
  if (setTime === null || expiration === null) return "review";
  // settlementSetTime can precede expirationDate by ~13h on a mark.
  if (setTime < expiration) return "review";

  if (!TERMINAL_STATES.has(view.instrumentState)) return "review";
  if (px !== 0 && px !== 1) return "review"; // binary markets have settled non-binary — hold, do not pay
  return "resolved";
}

const series = AUTO_RESOLVING_PREFIXES.some((p) => SYMBOL.startsWith(p)) ? "auto-resolving" : "manual";

settlementView(SYMBOL)
  .then((view) => console.log(SYMBOL, resolutionState(view), series))
  .catch((err) => {
    console.error(err);
    process.exit(1);
  });

# /v1/orderbook/* needs no x-participant-id. --fail-with-body so a 401 or 504 is not silently parsed.
curl --fail-with-body --max-time 10 \
  -H "authorization: Bearer $PMX_ACCESS_TOKEN" \
  "https://api.preprod.polymarketexchange.com/v1/orderbook/aec-cfb-clmsn-lsu-2026-09-05"