Function useAgentLoop

ui/src/composables/useAgentLoop.ts:79–469

(config: AgentLoopConfig = {})

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

export function useAgentLoop(config: AgentLoopConfig = {}) {
  const approvalStore = useApprovalStore();
  const thinkingStore = useThinkingStore();
  const toolsStore = useToolsStore();
  const { connect, getInstance, isConnected } = useWebSocket();

  // 状态
  const isRunning = ref(false);
  const isPaused = ref(false);
  const currentOutput = ref("");
  const history = ref<any[]>([]);
  const pendingApproval = ref<ApprovalRequest | null>(null);

  // 配置
  const sensitiveTools = config.sensitiveTools || ["Edit", "Write", "bash", "fs_write"];
  const maxRetries = config.maxRetries || 3;
  const maxLoops = config.maxLoops || 10;

  // WebSocket URL
  const apiUrl = config.apiUrl || import.meta.env.VITE_API_URL || "http://localhost:8080";
  const wsUrl = config.wsUrl || apiUrl.replace(/^http/, "ws") + "/v1/ws";

  /**
   * 初始化 WebSocket 连接
   */
  const initConnection = async () => {
    if (!isConnected.value) {
      await connect(wsUrl);
    }
    return getInstance();
  };

  /**
   * 发送思考事件
   */
  const emitThink = (event: Partial<ThinkAloudEvent>) => {
    const fullEvent: ThinkAloudEvent = {
      id: generateId("think"),
      stage: event.stage || "Thinking",
      reasoning: event.reasoning || "",
      decision: event.decision || "",
      timestamp: new Date().toISOString(),
      ...event,
    };

    config.onThink?.(fullEvent);
    return fullEvent;
  };

  /**
   * 执行 Agent Loop
   *
   * @param input 用户输入
   * @param contextData 上下文数据
   * @param resumeState 恢复状态 (用于 HITL 恢复)
   */
  const execute = async (input: string, contextData: string = "", resumeState?: { history: any[]; approvedTool?: ApprovalRequest }): Promise<AgentExecutionResult> => {
    isRunning.value = true;