Function createAskUserTool

src/app/service/agent/core/tools/ask_user.ts:32–67

(
  sendEvent: (event: ChatStreamEvent) => void,
  resolvers: Map<string, (answer: string) => void>
)

const ASK_USER_TIMEOUT_MS = 5 * 60 * 1000;

export function createAskUserTool(
  sendEvent: (event: ChatStreamEvent) => void,
  resolvers: Map<string, (answer: string) => void>
): { definition: ToolDefinition; executor: ToolExecutor } {
  let askCounter = 0;

  const executor: ToolExecutor = {
    execute: async (args: Record<string, unknown>) => {
      const question = requireString(args, "question");

      const options = args.options as string[] | undefined;
      const multiple = args.multiple as boolean | undefined;

      const askId = `ask_${Date.now()}_${++askCounter}`;

      // 通知 UI 显示提问
      sendEvent({ type: "ask_user", id: askId, question, options, multiple });

      // 等待用户回复
      return new Promise<string>((resolve) => {
        const timer = setTimeout(() => {
          resolvers.delete(askId);
          resolve(JSON.stringify({ answer: null, reason: "timeout" }));
        }, ASK_USER_TIMEOUT_MS);

        resolvers.set(askId, (answer: string) => {
          clearTimeout(timer);
          resolvers.delete(askId);
          resolve(JSON.stringify({ answer }));
        });
      });
    },
  };

  return { definition: ASK_USER_DEFINITION, executor };
}