市场怎么判定输赢

import gzip, json, csv

MARKETS = "BTC-5m-markets.jsonl.gz"      # one line per market, as downloaded
STREAMS = {                              # each market names the one it settles on
    60: "BTCUSD-twap60s-prices.csv.gz",
    30: "BTCUSD-twap30s-prices.csv.gz",
    0:  "BTCUSD-prices.csv.gz",          # before TWAP, the instantaneous feed
}

_loaded = {}
def stream(lookback):
    if lookback not in _loaded:
        with gzip.open(STREAMS[lookback], "rt") as f:
            _loaded[lookback] = list(csv.DictReader(f))
    return _loaded[lookback]

for line in gzip.open(MARKETS, "rt"):
    m = json.loads(line)
    # strike_value is null when it could not be established honestly
    if not m.get("resolved") or m.get("strike_value") is None:
        continue

    # Read the stream off the MARKET, never off the date: configs coexist on
    # one day. A MISSING config is a record we could not read — not evidence
    # of the pre-TWAP era — so it is skipped. Only an explicit null or 0 says
    # "this one settled on the instantaneous stream".
    raw = m.get("raw")
    cfg = raw.get("cryptoMarketConfig") if isinstance(raw, dict) else None
    if not isinstance(cfg, dict) or "twapLookbackSeconds" not in cfg:
        continue
    lookback = cfg["twapLookbackSeconds"]
    if lookback is None:
        lookback = 0
    if lookback not in STREAMS:
        continue                         # unknown config: refuse rather than guess

    open_ms, close_ms = m["start_sec"] * 1000, m["end_sec"] * 1000
    window = [t for t in stream(lookback)
              if open_ms <= int(t["feed_ts_ms"]) <= close_ms]
    if not window:
        continue

    # by timestamp, not by file order: frames are archived as received
    last = max(window, key=lambda t: int(t["feed_ts_ms"]))

    # full_accuracy_value is 1e18 fixed point ONLY when the relay published it;
    # otherwise the collector wrote str(value) and the archive cannot tell you
    fixed = last["full_accuracy_value"]
    if not fixed.isdigit():
        continue                         # a decimal fallback, not fixed point
    settled = int(fixed)
    if abs(settled / 1e18 - float(last["value"])) > 1e-6:
        continue                         # an integer, but not at the 1e18 scale

    # only a COMPLETE binary pair is an outcome; anything else is bad metadata
    prices = m.get("outcome_prices")
    if prices not in (["1", "0"], ["0", "1"]):
        continue

    # the market resolves Up when the close is >= the strike, not > it
    mine   = "UP" if settled >= int(m["strike_value"]) else "DOWN"
    theirs = "UP" if prices[0] == "1" else "DOWN"
    print(m["slug"], mine, "matches" if mine == theirs else "DIFFERS")