Streaming

import asyncio, json, os
import websockets

URL = "wss://terminal.jafx.com/trading-api/v1/stream"
KEY = os.environ["JAFX_API_KEY"]

async def run():
    last_seq, delay = None, 1
    while True:
        try:
            async with websockets.connect(URL, additional_headers={"Authorization": f"Bearer {KEY}"}) as ws:
                delay = 1
                sub = {"op": "subscribe", "channels": ["orders", "quotes:EURUSD"]}
                if last_seq is not None:
                    sub["since_seq"] = last_seq
                await ws.send(json.dumps(sub))
                async for raw in ws:
                    frame = json.loads(raw)
                    if frame.get("ch") == "orders":
                        last_seq = frame["seq"]
                        print(frame["event"], frame["data"])
                    elif frame.get("op") == "resync_required":
                        last_seq = frame["seq"]   # reload positions over REST here
        except websockets.ConnectionClosed as e:
            if e.rcvd and e.rcvd.code in (4401, 4409):
                raise SystemExit(f"stream closed with {e.rcvd.code}")
        except OSError as e:
            print("connection failed:", e)
        await asyncio.sleep(delay)
        delay = min(delay * 2, 30)

asyncio.run(run())

import WebSocket from 'ws'

const URL = 'wss://terminal.jafx.com/trading-api/v1/stream'
let lastSeq: number | null = null
let delay = 1000

function connect(): void {
  const ws = new WebSocket(URL, { headers: { Authorization: `Bearer ${process.env.JAFX_API_KEY}` } })
  ws.on('open', () => {
    delay = 1000
    const sub: Record<string, unknown> = { op: 'subscribe', channels: ['orders', 'quotes:EURUSD'] }
    if (lastSeq !== null) sub.since_seq = lastSeq
    ws.send(JSON.stringify(sub))
  })
  ws.on('message', raw => {
    const frame = JSON.parse(raw.toString())
    if (frame.ch === 'orders') {
      lastSeq = frame.seq
      console.log(frame.event, frame.data)
    } else if (frame.op === 'resync_required') {
      lastSeq = frame.seq // reload positions over REST here
    }
  })
  ws.on('error', e => console.error('stream error:', e.message))
  ws.on('close', code => {
    if (code === 4401 || code === 4409) return console.error(`stream closed with ${code}`)
    setTimeout(connect, delay)
    delay = Math.min(delay * 2, 30_000)
  })
}

connect()