import WebSocket from 'ws';

const ws = new WebSocket('wss://api.e-bon.ro/ws');

ws.on('open', () => {
  ws.send(JSON.stringify({
    type: 'hello',
    protocolVersion: 1,
    role: 'subscriber',
    auth: { token: jwt },
  }));
});
ws.on('message', (raw) => {
  const event = JSON.parse(raw.toString());
  if (event.type === 'welcome') return console.log('connected');
  console.log(event.type, event.data);
});
ws.on('close', (code, reason) => {
  console.log('closed', code, reason.toString());
});

import asyncio, json, websockets

async def run(jwt: str):
    async with websockets.connect("wss://api.e-bon.ro/ws") as ws:
        await ws.send(json.dumps({
            "type": "hello",
            "protocolVersion": 1,
            "role": "subscriber",
            "auth": {"token": jwt},
        }))
        async for raw in ws:
            event = json.loads(raw)
            if event["type"] == "welcome":
                continue
            print(event["type"], event["data"])

asyncio.run(run("<jwt>"))

package main

import (
    "fmt"
    "github.com/gorilla/websocket"
)

func main() {
    ws, _, err := websocket.DefaultDialer.Dial("wss://api.e-bon.ro/ws", nil)
    if err != nil {
        panic(err)
    }
    defer ws.Close()

    hello := fmt.Sprintf(
        `{"type":"hello","protocolVersion":1,"role":"subscriber","auth":{"token":%q}}`, jwt)
    if err := ws.WriteMessage(websocket.TextMessage, []byte(hello)); err != nil {
        panic(err)
    }

    for {
        _, msg, err := ws.ReadMessage()
        if err != nil {
            return
        }
        fmt.Println(string(msg))
    }
}

wscat -c "wss://api.e-bon.ro/ws"
# then paste the hello frame as the first message:
# {"type":"hello","protocolVersion":1,"role":"subscriber","auth":{"token":"<jwt>"}}

import WebSocket from 'ws';

const ws = new WebSocket('wss://api.e-bon.ro/ws');

ws.on('open', () => {
  ws.send(JSON.stringify({
    type: 'hello',
    protocolVersion: 1,
    role: 'subscriber',
    auth: { apiKey },
  }));
});
ws.on('message', (raw) => {
  const event = JSON.parse(raw.toString());
  if (event.type === 'welcome') return;
  console.log(event.type, event.data);
});

import asyncio, json, websockets

async def run(api_key: str):
    async with websockets.connect("wss://api.e-bon.ro/ws") as ws:
        await ws.send(json.dumps({
            "type": "hello",
            "protocolVersion": 1,
            "role": "subscriber",
            "auth": {"apiKey": api_key},
        }))
        async for raw in ws:
            event = json.loads(raw)
            if event["type"] == "welcome":
                continue
            print(event["type"], event["data"])

asyncio.run(run("ebon_live_..."))

<?php
require 'vendor/autoload.php';

use WebSocket\Client;

$client = new Client("wss://api.e-bon.ro/ws");
$client->send(json_encode([
    'type' => 'hello',
    'protocolVersion' => 1,
    'role' => 'subscriber',
    'auth' => ['apiKey' => $apiKey],
]));

while (true) {
    $raw = $client->receive();
    $event = json_decode($raw, true);
    if ($event['type'] === 'welcome') {
        continue;
    }
    echo $event['type'] . PHP_EOL;
}

wscat -c "wss://api.e-bon.ro/ws"
# then paste the hello frame as the first message:
# {"type":"hello","protocolVersion":1,"role":"subscriber","auth":{"apiKey":"ebon_live_<key>"}}

import WebSocket from 'ws';

let delay = 1000;
const max = 30_000;

function connect() {
  const ws = new WebSocket('wss://api.e-bon.ro/ws');

  ws.on('open', () => {
    ws.send(JSON.stringify({
      type: 'hello',
      protocolVersion: 1,
      role: 'subscriber',
      auth: { apiKey },
    }));
  });
  ws.on('message', (raw) => {
    const event = JSON.parse(raw.toString());
    if (event.type === 'welcome') { delay = 1000; return; }
    handle(event);
  });
  ws.on('close', (code) => {
    if (code === 4001) return; // rotate credential before retrying
    setTimeout(connect, delay);
    delay = Math.min(delay * 2, max);
  });
}

connect();

import asyncio, json, websockets

async def run(api_key: str):
    delay = 1
    while True:
        try:
            async with websockets.connect("wss://api.e-bon.ro/ws") as ws:
                await ws.send(json.dumps({
                    "type": "hello",
                    "protocolVersion": 1,
                    "role": "subscriber",
                    "auth": {"apiKey": api_key},
                }))
                async for raw in ws:
                    event = json.loads(raw)
                    if event["type"] == "welcome":
                        delay = 1
                        continue
                    handle(event)
        except websockets.ConnectionClosed as exc:
            if exc.code == 4001:
                return  # rotate credential before retrying
            await asyncio.sleep(delay)
            delay = min(delay * 2, 30)