Function sendWs

lib/logger.js:80–93

(ws, msg, context = '')

}

function sendWs(ws, msg, context = '') {
  if (!ws || ws.readyState !== WebSocket.OPEN) return false;
  ws.send(JSON.stringify(msg));
  if (msg.type === 'status' || msg.type === 'transcript_ready' || msg.type === 'replay_done' || msg.type === 'turn_state') {
    const extra = [];
    if (msg.sessionId !== undefined) extra.push(`session=${msg.sessionId ?? 'null'}`);
    if (msg.lastSeq !== undefined) extra.push(`lastSeq=${msg.lastSeq}`);
    if (msg.resumed !== undefined) extra.push(`resumed=${msg.resumed}`);
    if (msg.phase !== undefined) extra.push(`phase=${msg.phase}`);
    if (msg.version !== undefined) extra.push(`version=${msg.version}`);
    log(`Send ${msg.type}${context ? ` (${context})` : ''} -> ${wsLabel(ws)}${extra.length ? ` ${extra.join(' ')}` : ''}`);
  }
  return true;
}

function broadcast(msg) {
  if (!state.wss) return;