Agentic Usage.

import { WebSocket } from 'ws'

const ws = new WebSocket('wss://data.simplefunctions.dev/v1/ws')

ws.on('open', () => {
  ws.send(JSON.stringify({
    action: 'subscribe',
    topics: ['featured', 'ticker:KXFEDDECISION-26DEC-CUT100'],
  }))
})

ws.on('message', (raw) => {
  const frame = JSON.parse(raw.toString())
  if (frame.type === 'featured') {
    // Top-N rank update — drop into LLM context
    console.log(frame.markets.slice(0, 5).map(m => m.ticker))
  }
  if (frame.type === 'ticker') {
    // Position-level: route to your policy
    decide(frame)
  }
})

function decide(f: { ticker: string; last: number; bid: number; ask: number }) {
  if (f.ask < 0.30 && f.bid > 0.20) {
    // Liquid + contested — call agent.placeOrder via your venue connection
  }
}

{
  "tools": [
    {
      "type": "function",
      "function": {
        "name": "list_featured",
        "description": "Top-N hottest prediction markets right now, by heat score.",
        "parameters": { "type": "object", "properties": { "n": { "type": "integer" } } }
      }
    },
    {
      "type": "function",
      "function": {
        "name": "inspect_market",
        "description": "Full snapshot of a single market by ticker.",
        "parameters": { "type": "object", "properties": { "ticker": { "type": "string" } }, "required": ["ticker"] }
      }
    },
    {
      "type": "function",
      "function": {
        "name": "subscribe_ticker",
        "description": "Open a live WebSocket subscription for a ticker; subsequent calls return latest frames.",
        "parameters": { "type": "object", "properties": { "ticker": { "type": "string" } }, "required": ["ticker"] }
      }
    }
  ]
}