Build a Bot

# Published signals with no outcome yet. No account, no header.
curl "https://ribqa.com/api/public/signals/pending?limit=50"

# Response: {"signals":[...],"data":[...],"total":N}. signals and data are the same list.
# One signal with its plan, veto context and outcome:
curl "https://ribqa.com/api/public/signals/<id>"

# Sign in with your own credentials. This page stores none.
curl -X POST "https://ribqa.com/api/v1/auth/login" \
  -H "Content-Type: application/json" \
  -d '{"email":"<your-email>","password":"<your-password>"}'

# Response: access_token, refresh_token, expires_in (seconds), user.
# With two-factor on, the response is two_factor_required, challenge and
# expires_in instead, and the tokens come from /api/v1/auth/login/2fa.
export TOKEN="<access_token>"

# access_token lifetime: 7200s default, 43200s with remember_me,
# 86400s with keep_signed_in. Refresh before it expires.
curl -X POST "https://ribqa.com/api/v1/auth/refresh" \
  -H "Content-Type: application/json" \
  -d '{"refresh_token":"<refresh_token>"}'

# The refresh token is rotated. Store the new one from the response.

# Option A: bearer header.
curl -N "https://ribqa.com/api/v1/stream" -H "Authorization: Bearer $TOKEN"

# Option B: a single-use ticket, for clients that cannot set headers.
curl -X POST "https://ribqa.com/api/v1/stream/ticket" -H "Authorization: Bearer $TOKEN"
# Response: {"ticket":"...","expires_in_seconds":45,"stream_path":"/api/v1/stream"}
curl -N "https://ribqa.com/api/v1/stream?ticket=<ticket>"

# A ticket is valid once, for 45 seconds. Request one per connection.
# ?token=<access_token> is refused in production.

# API key: Account > API keys. Shown once; keep it out of URLs.
curl -s https://ribqa.com/api/v1/mcp \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer $SENTINEL_MCP_KEY" \
  -d '{"jsonrpc":"2.0","id":1,"method":"tools/call",
       "params":{"name":"get_open_signals","arguments":{"limit":20}}}'

stop_distance = abs(entry - sl) / entry
notional      = capital * risk_pct / 100 / (stop_distance + 0.0012)
leverage      = min(notional / capital, your_leverage_cap)

import time, requests

API = "https://ribqa.com"
RISK_PCT, CAPITAL, COST = 1.0, 1000.0, 0.0012  # 0.12% round trip + funding
MAX_DRIFT = 0.005                               # skip if price moved 0.5% against entry

def pending():
    r = requests.get(f"{API}/api/public/signals/pending", params={"limit": 100}, timeout=10)
    if r.status_code == 429:
        time.sleep(int(r.headers.get("Retry-After", "60")))
        return []
    r.raise_for_status()
    return r.json()["signals"]

def price(sig):
    host = "fapi" if sig.get("market_type") == "futures" else "api"
    path = "/fapi/v1/ticker/price" if host == "fapi" else "/api/v3/ticker/price"
    r = requests.get(f"https://{host}.binance.com{path}", params={"symbol": sig["symbol"]}, timeout=10)
    return float(r.json()["price"])

seen = {s["id"] for s in pending()}  # act only on signals published after start

while True:
    time.sleep(200)  # anonymous limit is 20 requests an hour
    for sig in pending():
        if sig["id"] in seen:
            continue
        seen.add(sig["id"])
        long = sig["direction"] == "long"
        entry, sl, tp1, now = sig["entry"], sig["sl"], sig["tp"][0], price(sig)
        drift = (now - entry) / entry * (1 if long else -1)
        crossed = (now >= tp1 or now <= sl) if long else (now <= tp1 or now >= sl)
        if drift > MAX_DRIFT or crossed:
            print("skip", sig["symbol"], f"drift {drift:+.2%}")
            continue
        stop = abs(entry - sl) / entry
        notional = CAPITAL * RISK_PCT / 100 / (stop + COST)
        print(sig["symbol"], sig["direction"], f"notional {notional:.0f} USDT", "sl", sl, "tp1", tp1)
        # place_order(...)  your exchange client, on a paper or testnet account first