Connection Lifecycle

​

Connection Steps

​

1. Open WebSocket

wss://stream.lasersell.io/v1/ws

​

2. Receive hello_ok

{
  "type": "hello_ok",
  "session_id": 42,
  "server_time_ms": 1706000000000,
  "limits": {
    "hi_capacity": 1024,
    "pnl_flush_ms": 1000,
    "max_positions_per_session": 100,
    "max_wallets_per_session": 10,
    "max_positions_per_wallet": 20,
    "max_sessions_per_api_key": 5
  }
}

​

3. Send configure

{
  "type": "configure",
  "wallet_pubkeys": ["WALLET_PUBKEY_1", "WALLET_PUBKEY_2"],
  "strategy": {
    "target_profit_pct": 5.0,
    "stop_loss_pct": 1.5,
    "trailing_stop_pct": 3.0
  },
  "send_mode": "helius_sender",
  "tip_lamports": 1000
}

​

4. Receive Acknowledgement

​

The limits Object

​

Reconnection

1. The client waits with exponential backoff starting at 100 ms.
2. Backoff doubles on each attempt up to a maximum of 2,000 ms.
3. On successful reconnect, the client re sends the configure message.
4. The server will re emit balance_update and position_opened events for existing holdings.

​

Ping and Pong

​

Client Ping

{
  "type": "ping",
  "client_time_ms": 1706000000000
}

{
  "type": "pong",
  "server_time_ms": 1706000000001
}

​

Server Ping

​

StreamClient vs StreamSession

​

StreamClient

• Handles connect, reconnect, and message framing.
• Returns raw ServerMessage objects from recv().
• Provides a StreamSender for sending client messages.
• Supports lane splitting via connectLanes() which separates high priority messages (exit signals, position events) from low priority messages (pnl_update).

​

StreamSession

• Position tracking: Automatically maintains a map of open positions by ID and token account.
• Typed events: Returns StreamEvent objects with a PositionHandle attached.
• Deadline timers: Automatically requests exit signals after deadline_timeout_sec.
• Strategy updates: updateStrategy() and updateStrategyOptional() methods.

​

Lanes

• High priority lane: hello_ok, error, balance_update, position_opened, position_closed, exit_signal_with_tx
• Low priority lane: pnl_update

const client = new StreamClient("YOUR_API_KEY");
const connection = await client.connectLanes(configure, {
  lowPriorityCapacity: 512,
});

const [sender, highRx, lowRx] = connection.split();

// Process high priority in main loop
for await (const msg of highRx) {
  // exit signals, position events...
}

// Process low priority in background
for await (const msg of lowRx) {
  // pnl_update...
}