Python PN1 Orderbook

import asyncio
import os
from polynode import OrderbookEngine

async def main() -> None:
    token_id = os.environ["POLYMARKET_TOKEN_ID"]
    engine = OrderbookEngine(
        os.environ["POLYNODE_API_KEY"],
        integrity=True,
        allow_stale_reads=False,
    )

    engine.on("integrity_error", lambda error: print(
        error.code, error.token, error
    ))
    engine.on("ready", lambda: print({
        "best_bid": engine.best_bid(token_id),
        "best_ask": engine.best_ask(token_id),
        "midpoint": engine.midpoint(token_id),
        "spread": engine.spread(token_id),
    }))

    try:
        await engine.subscribe([token_id])
        await asyncio.Event().wait()
    finally:
        engine.close()

asyncio.run(main())