Redemption Watcher

RedemptionWatcher loads positions for selected wallets, watches oracle resolutions, and emits a RedeemableAlert for matching positions. It can also follow live position changes and periodically refresh positions. Use the direct redemptions event preset when you need the raw redemption stream. Use this helper when you want wallet-aware position matching and an estimated payout in one object.

Start

import { RedemptionWatcher } from 'polynode-sdk';

const watcher = new RedemptionWatcher({
  apiKey: process.env.POLYNODE_API_KEY!,
});

watcher.on('alert', (alert) => {
  console.log(alert.wallet, alert.marketTitle, alert.isWinner,
    alert.estimatedPayoutUsd);
});
watcher.on('error', console.error);

await watcher.start(['0xabc...']);

import asyncio
import os
from polynode import RedemptionWatcher

async def main() -> None:
    watcher = RedemptionWatcher(os.environ["POLYNODE_API_KEY"])
    watcher.on("alert", lambda alert: print(
        alert.wallet,
        alert.market_title,
        alert.is_winner,
        alert.estimated_payout_usd,
    ))

    await watcher.start(["0xabc..."])
    try:
        async for alert in watcher:
            print(alert.condition_id, alert.token_id)
    finally:
        watcher.close()

asyncio.run(main())

use polynode::{PolyNodeClient, RedemptionWatcher, RedemptionWatcherConfig};
use std::sync::Arc;

#[tokio::main]
async fn main() -> polynode::Result<()> {
    let client = Arc::new(PolyNodeClient::new(
        std::env::var("POLYNODE_API_KEY").expect("Set POLYNODE_API_KEY")
    )?);
    let mut watcher = RedemptionWatcher::new(
        client,
        RedemptionWatcherConfig::default(),
    );
    watcher.start(&["0xabc..."]).await?;

    while let Some(alert) = watcher.next_alert().await {
        println!("{} {} {}", alert.wallet, alert.market_title,
            alert.estimated_payout_usd);
    }
    watcher.close();
    Ok(())
}

Alert fields

An alert identifies the wallet, condition and token, held and winning outcomes, whether the position won, size, estimated payout, market title and slug, resolution price and payouts, block number, and timestamp. An alert is a notification to inspect a position. Your application should verify current position state before submitting a redemption transaction.

Lifecycle

Register handlers before start so early alerts are not missed. The TypeScript and Python helpers support adding and removing wallets at runtime. All languages expose the tracked wallet/position state and a close method. Close the watcher during shutdown to stop refresh work and release its subscriptions. Reconnect delivery is best effort; the periodic refresh is useful as a reconciliation layer, not a promise of exactly-once alerts. See Oracle events and Redemption events for the underlying payloads.

Getting Started

Core Guides

Optional Helpers

TypeScript

Python

Rust

Charts (Browser)

Redemption Watcher

Start

Alert fields

Lifecycle

​Start

​Alert fields

​Lifecycle

Start

Alert fields

Lifecycle