Function createTaskTools

src/app/service/agent/core/tools/task_tools.ts:68–148

(options?: TaskToolsOptions)

};

export function createTaskTools(options?: TaskToolsOptions): {
  tools: Array<{ definition: ToolDefinition; executor: ToolExecutor }>;
  tasks: Map<string, Task>;
} {
  const tasks = new Map<string, Task>();
  let nextId = 1;

  // 从持久化数据恢复
  if (options?.initialTasks) {
    for (const task of options.initialTasks) {
      tasks.set(task.id, task);
      const numId = parseInt(task.id, 10);
      if (!isNaN(numId) && numId >= nextId) {
        nextId = numId + 1;
      }
    }
  }

  // 持久化并推送事件
  const emitUpdate = async () => {
    const taskList = Array.from(tasks.values());
    if (options?.onSave) {
      await options.onSave(taskList);
    }
    if (options?.sendEvent) {
      options.sendEvent({
        type: "task_update",
        tasks: taskList.map((t) => ({
          id: t.id,
          subject: t.subject,
          status: t.status,
          description: t.description,
        })),
      });
    }
  };

  const createExecutor: ToolExecutor = {
    execute: async (args: Record<string, unknown>) => {
      const task: Task = {
        id: String(nextId++),
        subject: requireString(args, "subject"),
        description: optionalString(args, "description"),
        status: "pending",
      };
      tasks.set(task.id, task);
      await emitUpdate();
      return JSON.stringify(task);
    },
  };

  const updateExecutor: ToolExecutor = {
    execute: async (args: Record<string, unknown>) => {
      const taskId = requireString(args, "task_id");
      const task = tasks.get(taskId);
      if (!task) {
        throw new Error(`Task "${taskId}" not found`);
      }