Function sendMessage

ui/src/composables/useChat.ts:87–225

(content: string)

  // 发送消息
  const sendMessage = async (content: string) => {
    console.log("📤 sendMessage called with:", content);
    console.log("📊 isDemoMode:", isDemoMode);
    console.log("📊 wsConnected:", wsConnected.value);
    console.log("📊 ws instance:", getInstance());

    if (!content.trim()) return;

    // 添加用户消息
    const userMessage: TextMessage = {
      id: generateId("msg"),
      type: "text",
      role: "user",
      content: { text: content },
      createdAt: Date.now(),
      status: "pending",
    };
    chatStore.messages.push(userMessage);
    console.log("✅ User message added to messages array");

    // 创建 AI 响应占位（使用 reactive 确保响应式）
    const assistantMessage: TextMessage = reactive({
      id: generateId("msg"),
      type: "text",
      role: "assistant",
      content: { text: "" },
      createdAt: Date.now(),
    }) as TextMessage;
    chatStore.messages.push(assistantMessage);
    chatStore.setActiveMessage(assistantMessage.id);
    console.log("✅ Assistant message placeholder added");

    chatStore.isTyping = true;
    agent.value.status = "thinking";
    userMessage.status = "sent";
    currentInput.value = "";

    try {
      if (isDemoMode) {
        await new Promise((resolve) => setTimeout(resolve, config.demoDelay ?? 800));
        assistantMessage.content.text = pickDemoResponse(content);
        assistantMessage.status = "sent";
        chatStore.isTyping = false;
        agent.value.status = "idle";
      } else {
        const ws = getInstance();
        console.log("🔍 Checking WebSocket availability:", {
          "ws exists": !!ws,
          isConnected: wsConnected.value,
          "ws type": ws?.constructor?.name,
        });

        // 使用 WebSocket 进行流式对话
        if (ws && wsConnected.value) {
          console.log("✅ Using WebSocket for chat");

          // 监听 WebSocket 消息
          const unsubscribe = ws.onMessage((message: any) => {