Function useChat

ui/src/composables/useChatV2.ts:16–451

(config: ChatConfig)

import { useChatStore, useThinkingStore, useToolsStore, useTodosStore, useApprovalStore } from "@/stores";

export function useChat(config: ChatConfig) {
  // ==================
  // Stores
  // ==================

  const chatStore = useChatStore();
  const thinkingStore = useThinkingStore();
  const toolsStore = useToolsStore();
  const todosStore = useTodosStore();
  const approvalStore = useApprovalStore();

  // ==================
  // 配置
  // ==================

  const isDemoMode = config.demoMode ?? true;
  const apiUrl = config.apiUrl || import.meta.env.VITE_API_URL || "http://localhost:8080";
  const wsUrlOverride = config.wsUrl || import.meta.env.VITE_WS_URL;

  // ==================
  // 客户端初始化
  // ==================

  const { client } = useAsterClient({
    baseUrl: apiUrl,
    apiKey: config.apiKey,
    wsUrl: wsUrlOverride,
  });

  const { connect, getInstance, isConnected: wsConnected } = useWebSocket();

  // 连接状态
  const connectionState = computed(() => (isDemoMode ? true : wsConnected.value));

  // ==================
  // Demo 模式相关
  // ==================

  let demoCursor = 0;

  const fallbackResponses = [
    "我已经为你生成了一个新的多 Agent 工作流，包含大纲、评价器和部署策略。",
    "Aster 的沙箱已准备好，所有写入都被限制在 /workspace 目录，你可以放心执行指令。",
    "我为这个会话自动挂载了上下文记忆，后续可以直接引用历史工单。",
    "Streaming 模式已打开，等待后端返回 token，平均延迟 220ms。",
  ];

  const pickDemoResponse = (content: string) => {
    const list = config.demoResponses?.length ? config.demoResponses : fallbackResponses;
    const index = demoCursor % list.length;
    demoCursor += 1;
    const template = list[index] ?? "";
    return template.includes("{question}") ? template.split("{question}").join(content) : template;
  };

  // ==================
  // 事件处理器
  // ==================