Fetch active, liquid markets from Polymarket's Gamma API.

Filter markets to only target categories.

Log trade to SQLite and return result dict.

Run all scrapers and return deduplicated, sorted results.

Fetch and filter markets from Gamma API.

Poll RSS feeds periodically and emit new headlines.

Infer category from question text and tags.

Quick keyword filter to reduce noise before scoring.

Find markets that a news headline is relevant to. Uses keyword overlap scoring — fast, no API call.

Score a market question against recent news using Claude.

Quarter-Kelly position sizing. Capped at MAX_BET_USD.

Check if any open trades have resolved. Update calibration table. Queries Gamma API for market resolution status.

Classify a news headline against a market question. Synchronous.

V1: Compare Claude's confidence against market price.

Execute a trade on Polymarket or log a dry-run. Synchronous.

Generate a calibration report from stored data.

Start all sources and the dedup router.

Start all pipeline components concurrently.

Run a backtest against resolved markets. Uses mock headlines derived from market questions if none provided.

Launch the live dashboard. Scans on a configurable interval.

V1: Run the full pipeline once. Returns list of trade results.

Parse a single RSS feed and return recent items.

Connect to Polymarket WebSocket for live price updates.

Deduplicate and forward events to output queue.

Place a real order via Polymarket CLOB client.

Execute trades from the signal queue.

Extract meaningful keywords from a market question.

Fallback: fetch from CLOB API directly.

Process a WebSocket price update.

Add V2 columns to trades table if they don't exist.

Poll Gamma API for price updates when WebSocket unavailable.

Print a rich backtest report.

Process each news event: match → classify → detect edge.

Print periodic status updates.

Async wrapper around classify().

Remove near-duplicate headlines by normalized prefix matching.

V2: Use classification direction + materiality instead of probability estimation. Only generates a signal when: - Direction is bullish or

Async wrapper around execute_trade.

Extract meaningful keywords from a market question.

Fetch recently resolved markets from Gamma API.

Filter to niche markets within volume bounds.

Get the token ID for a given side (YES/NO).

Start the market watcher — refresh + WebSocket + polling fallback.

Entry point for V2 event-driven pipeline.

Execute one full pipeline scan and update state.

Pull from NewsAPI.org if key is configured.

Set up filtered stream rules based on keywords.

Run backtest against resolved markets.

Show classification accuracy report.

Browse niche markets only (volume-filtered).

V1: Synchronous pipeline — RSS → score → trade.

Check all API keys and connections work.

V2: Event-driven pipeline — real-time news → classify → trade.

Find a tracked market by partial question match.

Broader matching using headline + summary text. Falls back to category matching if keyword matching returns nothing.

Connect to filtered stream and emit NewsEvents.