Idmon API — Documentation

Authorization: Bearer <your-api-key>

wss://api.idmon.io/ws?key=<your-api-key>&types=volume_surge,whale_trade&minVolume=50000

{ "type": "connected", "message": "Authenticated. Stream active." }

{
  "type": "alert",
  "data": {
    "alertType": "whale_trade",
    "conditionId": "0xabc123...",
    "question": "Will the Fed cut rates in July 2026?",
    "category": "economics",
    "currentPrices": { "Yes": 0.62, "No": 0.38 },
    "priceChangePct": 4.8,
    "volume24h": 1240000,
    "message": "Whale bought $85K YES at 0.62",
    "timestamp": "2026-06-19T10:14:22Z"
  }
}

{ "type": "ping" }

import WebSocket from 'ws';

const KEY = process.env.IDMON_API_KEY;
const url = `wss://api.idmon.io/ws?key=${KEY}&types=whale_trade,volume_surge&minVolume=50000`;

function connect() {
  const ws = new WebSocket(url);

  ws.on('open', () => {
    console.log('WebSocket open — waiting for alerts...');
  });

  ws.on('message', (raw) => {
    const msg = JSON.parse(raw.toString());

    if (msg.type === 'ping') return; // ignore keepalive

    if (msg.type === 'alert') {
      const { alertType, question, message, timestamp } = msg.data;
      console.log(`[${timestamp}] ${alertType}: ${question}`);
      console.log(`  ${message}`);
    }

    if (msg.type === 'connected') {
      console.log('Authenticated:', msg.message);
    }
  });

  ws.on('close', (code, reason) => {
    if (code === 4001) { console.error('Unauthorized — check your API key'); return; }
    if (code === 4003) { console.error('WebSocket not available on your plan'); return; }
    if (code === 4008) { console.error('Connection limit reached — reduce concurrent connections'); return; }
    // Reconnect on unexpected closure
    console.warn(`Closed (${code}): ${reason}. Reconnecting in 5s...`);
    setTimeout(connect, 5000);
  });

  ws.on('error', (err) => console.error('WS error:', err.message));
}

connect();

{
  "schema": 1,
  "event": "whale_trade",
  "id": "evt_01j9abc...",
  "ts": "2026-06-19T10:14:22Z",
  "conditionId": "0xabc123...",
  "data": {
    "question": "Will the Fed cut rates in July 2026?",
    "slug": "fed-rate-cut-july-2026",
    "category": "economics",
    "message": "Whale bought $85K YES at 0.62",
    "currentPrices": { "Yes": 0.62, "No": 0.38 },
    "previousPrices": { "Yes": 0.57, "No": 0.43 },
    "priceChangePct": 4.8,
    "volume24h": 1240000,
    "liquidity": 310000,
    "polymarketUrl": "https://polymarket.com/event/fed-rate-cut-july-2026"
  }
}

import hmac
import hashlib
from flask import Flask, request, abort

app = Flask(__name__)
WEBHOOK_SECRET = b"your_webhook_secret_here"

@app.route("/webhook", methods=["POST"])
def webhook():
    sig_header = request.headers.get("X-PMP-Signature", "")
    if not sig_header.startswith("sha256="):
        abort(400, "Missing signature")

    received_sig = sig_header[len("sha256="):]

    # Compute HMAC over the RAW body — do NOT re-serialise
    raw_body = request.get_data()
    expected_sig = hmac.new(WEBHOOK_SECRET, raw_body, hashlib.sha256).hexdigest()

    if not hmac.compare_digest(expected_sig, received_sig):
        abort(401, "Invalid signature")

    payload = request.get_json()
    event = payload["event"]
    print(f"Verified event: {event}")

    return "", 200  # respond 2xx quickly — processing can be async