Method sendMessage

src/runtime/adapters/web.ts:455–471

(channelId: string, text: string)

  }

  async sendMessage(channelId: string, text: string): Promise<void> {
    const sockets = this.socketsByChannel.get(channelId);
    const activeSockets = [...(sockets || [])].filter(
      (socket) => socket.readyState === socket.OPEN,
    );

    if (activeSockets.length === 0) {
      throw new Error(`[Web] No active WebSocket clients for channelId: ${channelId}`);
    }

    for (const socket of activeSockets) {
      sendWsEvent(socket, { type: "message_start", role: "assistant" });
      sendWsEvent(socket, { type: "text_delta", delta: text });
      sendWsEvent(socket, { type: "message_end", role: "assistant" });
      socket.send(JSON.stringify({ done: true }));
    }
  }

  // -------------------------------------------------------------------------
  // WebSocket message handler