TypeScript PN1 Orderbook

import { OrderbookEngine } from 'polynode-sdk';

const apiKey = process.env.POLYNODE_API_KEY;
const tokenId = process.env.POLYMARKET_TOKEN_ID;
if (!apiKey || !tokenId) throw new Error('Set POLYNODE_API_KEY and POLYMARKET_TOKEN_ID');

const engine = new OrderbookEngine({
  apiKey,
  integrity: true,
  allowStaleReads: false,
});

engine.on('integrity_error', (error) => {
  console.error(error.code, error.token, error.message);
});

engine.on('ready', () => {
  console.log({
    bestBid: engine.bestBid(tokenId),
    bestAsk: engine.bestAsk(tokenId),
    midpoint: engine.midpoint(tokenId),
    spread: engine.spread(tokenId),
  });
});

await engine.subscribe([tokenId]);

const view = engine.view([tokenId]);
view.on('update', (update) => console.log(update.asset_id));
view.on('trade', (trade) => console.log(trade.price, trade.size));

console.log(view.book(tokenId));
view.destroy();

import { PolyNode } from 'polynode-sdk';

const pn = new PolyNode({ apiKey });
const ob = pn.configureOrderbook({ integrity: true });
ob.on('snapshot', (snapshot) => console.log(snapshot.integrity));
ob.on('resyncing', (message) => console.warn(message.markets));
ob.on('unknown', (message) => console.log(message.raw));
await ob.subscribe([tokenId]);

engine.close();
// Or, for the raw client:
ob.disconnect();