Function sendMessage

ui/src/composables/useChatV2.ts:215–325

(content: string)

  // ==================

  const sendMessage = async (content: string) => {
    if (!content.trim()) return;

    // 创建用户消息
    const userMessage: TextMessage = {
      id: generateId("msg"),
      type: "text",
      role: "user",
      content: { text: content },
      createdAt: Date.now(),
      status: "pending",
    };
    chatStore.addMessage(userMessage);

    // 创建助手消息占位符（使用 reactive 确保响应式）
    const assistantMessage: TextMessage = reactive({
      id: generateId("msg"),
      type: "text",
      role: "assistant",
      content: { text: "" },
      createdAt: Date.now(),
    }) as TextMessage;
    chatStore.addMessage(assistantMessage);

    chatStore.setTyping(true);
    chatStore.updateAgentStatus("thinking");
    userMessage.status = "sent";
    chatStore.setCurrentInput("");

    try {
      if (isDemoMode) {
        // Demo 模式
        await new Promise((resolve) => setTimeout(resolve, config.demoDelay ?? 800));
        (assistantMessage.content as { text: string }).text = pickDemoResponse(content);
        assistantMessage.status = "sent";
        chatStore.setTyping(false);
        chatStore.updateAgentStatus("idle");
      } else {
        // WebSocket 流式模式
        const ws = getInstance();

        if (ws && wsConnected.value) {
          // 监听 WebSocket 消息
          const unsubscribe = ws.onMessage((message: any) => {
            if (message.type === "text_delta" && message.payload?.text) {
              // 使用批量更新优化性能
              chatStore.handleTextChunk(assistantMessage.id, message.payload.text);
            } else if (message.type === "chat_complete") {
              assistantMessage.status = "sent";
              chatStore.setTyping(false);
              chatStore.updateAgentStatus("idle");
              unsubscribe();

              // 触发回调
              if (config.onReceive) {
                config.onReceive(assistantMessage);
              }
            } else if (message.type === "error") {