Algo signals API

curl "https://api.tick-stream.xyz/v1/algos/cot-pulse/signal" \
  -H "Authorization: Bearer sk_live_…"

import requests

r = requests.get(
    "https://api.tick-stream.xyz/v1/algos/cot-pulse/signal",
    headers={"Authorization": "Bearer sk_live_…"},
    timeout=10,
)
r.raise_for_status()
sig = r.json()
print(sig["bias"])   # long | short | flat

const r = await fetch("https://api.tick-stream.xyz/v1/algos/cot-pulse/signal", {
  headers: { Authorization: "Bearer sk_live_…" },
});
const sig = await r.json();
console.log(sig.bias); // long | short | flat

{
  "algo": "cot-pulse",
  "date": "2026-10-29",
  "bias": "long",
  "delta_k": 4.47,
  "estimate_k": 46.86,
  "last_cot_anchor": "2026-10-20",
  "execution": {
    "market": "NQ", "contracts": 1,
    "entry_window_et": "09:30–10:30", "session_close_et": "16:00",
    "sl_pts": 25, "tp_pts": 25, "scale_out_half_at_pts": 12.5,
    "reentry_after_stop": false
  },
  "position": null,
  "protect": null
}

{
  "algo": "backdraft",
  "asof": "2026-10-29",
  "regime": "short-gamma (armed)",
  "side": "flat",
  "in_position": false,
  "contracts": 0,
  "point_value": 20,
  "protect": null
}

{
  "algo": "cot-pulse",
  "events": [
    { "type": "bias", "ts": 1793232627, "date": "2026-10-29", "bias": "long", "delta_k": 4.47 },
    { "type": "exit", "ts": 1793194209, "reason": "BE", "price": 29905.5, "pnl_pts": 0 },
    { "type": "scale_out", "ts": 1793194205, "price": 29918, "pnl_pts": 12.5, "sl_moved_to": 29905.5 },
    { "type": "entry", "ts": 1793194202, "side": "long", "price": 29905.5, "sl": 29880.5, "tp": 29930.5 }
  ]
}

# Poll a signal once a minute and act only when it changes.
import os, time, requests

KEY  = os.environ["TICKSTREAM_KEY"]
ALGO = "cot-pulse"
URL  = f"https://api.tick-stream.xyz/v1/algos/{ALGO}"
H    = {"Authorization": f"Bearer {KEY}"}

def state(sig):
    # Bellwether publishes a daily bias, the others a side
    return sig.get("bias") or sig.get("side") or "flat"

last, seen = None, 0
while True:
    try:
        sig = requests.get(f"{URL}/signal", headers=H, timeout=10).json()
        if state(sig) != last:
            last = state(sig)
            print("signal:", last, sig.get("protect"))   # → your alert / order code
        ev = requests.get(f"{URL}/events?limit=20", headers=H, timeout=10).json()
        for e in reversed(ev["events"]):        # newest first → oldest first
            if e["ts"] > seen:
                seen = e["ts"]
                print(e["type"], e)
    except requests.RequestException as err:
        print("retrying:", err)
    time.sleep(60)

// Node 18+ — poll once a minute, act only on change.
const KEY = process.env.TICKSTREAM_KEY, ALGO = "cot-pulse";
const URL = `https://api.tick-stream.xyz/v1/algos/${ALGO}`;
const H = { Authorization: `Bearer ${KEY}` };
const state = (s) => s.bias ?? s.side ?? "flat";

let last = null, seen = 0;
async function tick() {
  try {
    const sig = await (await fetch(`${URL}/signal`, { headers: H })).json();
    if (state(sig) !== last) { last = state(sig); console.log("signal:", last, sig.protect); }
    const { events } = await (await fetch(`${URL}/events?limit=20`, { headers: H })).json();
    for (const e of events.reverse()) if (e.ts > seen) { seen = e.ts; console.log(e.type, e); }
  } catch (err) { console.log("retrying:", err.message); }
}
tick(); setInterval(tick, 60_000);