Method processAgent

packages/memos-core/src/viewer/server.ts:4863–4943

(agentOwner: string, items: PendingItem[])

    // Process one agent's sessions sequentially
    const processAgent = async (agentOwner: string, items: PendingItem[]) => {
      const taskProcessor = new TaskProcessor(this.store, ctx);
      let skillEvolver: SkillEvolver | null = null;

      if (enableSkills) {
        const recallEngine = new RecallEngine(this.store, this.embedder, ctx);
        skillEvolver = new SkillEvolver(this.store, recallEngine, ctx);
        taskProcessor.onTaskCompleted(async (task) => {
          try {
            await skillEvolver!.onTaskCompleted(task);
            this.ppState.skillsCreated++;
            send("skill", { taskId: task.id, title: task.title, agent: agentOwner });
          } catch (err) {
            this.log.warn(`Postprocess skill evolution error (${agentOwner}): ${err}`);
          }
        });
      }

      for (const { sessionKey, action } of items) {
        if (this.ppAbort) break;
        const idx = incIdx();
        this.ppState.processed = globalIdx;

        send("item", {
          index: idx,
          total: pendingItems.length,
          session: sessionKey,
          agent: agentOwner,
          step: "processing",
          action,
        });

        try {
          if (action === "full") {
            await taskProcessor.onChunksIngested(sessionKey, Date.now());
            const activeTask = this.store.getActiveTask(sessionKey);
            if (activeTask) {
              await taskProcessor.finalizeTask(activeTask);
              const finalized = this.store.getTask(activeTask.id);
              this.ppState.tasksCreated++;
              send("item", {
                index: idx, total: pendingItems.length, session: sessionKey, agent: agentOwner,
                step: "done", taskTitle: finalized?.title || "", taskStatus: finalized?.status || "",
              });
            } else {
              send("item", {
                index: idx, total: pendingItems.length, session: sessionKey, agent: agentOwner,
                step: "done", taskTitle: "(no chunks)",
              });
            }
          } else if (action === "skill-only" && skillEvolver) {
            const completedTasks = this.store.getCompletedTasksForSession(sessionKey);
            let skillGenerated = false;
            for (const task of completedTasks) {
              if (this.ppAbort) break;
              try {
                await skillEvolver.onTaskCompleted(task);
                this.ppState.skillsCreated++;