Websocket Account Data Streaming

import asyncio
import websockets

async def connect_and_consume():
  uri = "wss://ws.tradier.com/v1/accounts/events"
  async with websockets.connect(uri) as websocket:
    payload = '{"events": ["order"], "sessionid": "SESSION_ID", "excludeAccounts": []}'

    await websocket.send(payload)
    print(f"> {payload}")

    while True:
      response = await websocket.recv()
      print(f"< {response}")

asyncio.get_event_loop().run_until_complete(connect_and_consume())

const WebSocket = require('ws');
const ws = new WebSocket('wss://ws.tradier.com/v1/accounts/events');

ws.on('open', function open() {
  console.log('Connected, sending subscription commands...');
  ws.send('{"events": ["order"], "sessionid": "SESSION_ID", "excludeAccounts": []}');
});
ws.on('message', function incoming(data) {
  console.log(data);
});
ws.on('error', function error(data) {
  console.log(data);
});

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.net.URISyntaxException;

/**
* This example uses org.java-websocket.Java-WebSocket version 1.4.1
*
* For more details, please access https://github.com/TooTallNate/Java-WebSocket
* */
public class Main {
  public static void main(String[] args) throws URISyntaxException {
    final ClientExample client = new ClientExample(new URI("wss://ws.tradier.com/v1/accounts/events"));
    client.connect();
  }
}

class ClientExample extends WebSocketClient {

  public ClientExample(URI serverURI) {
    super(serverURI);
  }

  @Override
  public void onOpen(ServerHandshake handshakedata) {
  System.out.println("opened connection");
  send("{" +
        "\"events\": [\"order\"], " +
        "\"sessionid\": \"SESSION_ID\", " +
        "\"excludeAccounts\": []" +
      "}");
  }

  @Override
  public void onMessage(String message) {
    System.out.println("Received: " + message);
  }

  @Override
  public void onClose(int code, String reason, boolean remote) {
    System.out.println("Connection closed by " + (remote ? "remote peer" : "us") + " Code: " + code + " Reason: " + reason);
  }

  @Override
  public void onError(Exception e) {
    System.err.println("Exception: " + e.getMessage());
  }
}

require 'faye/websocket'
require 'eventmachine'
    
EM.run do
  ws = Faye::WebSocket::Client.new('wss://ws.tradier.com/v1/accounts/events')
    
  ws.on :open do |event|
    puts :open
    ws.send('{"events": ["order"], "sessionid": "SESSION_ID", "excludeAccounts": []}')
  end
  
  ws.on :message do |event|
    puts event.data 
  end
    
  ws.on :close do |event|
    puts :close, event.code, event.reason
    ws = nil
  end
end