Method runPostprocess

packages/memos-core/src/viewer/server.ts:4804–4963

(
    send: (event: string, data: unknown) => void,
    enableTasks: boolean,
    enableSkills: boolean,
    concurrency: number = 1,
  )

  }

  private async runPostprocess(
    send: (event: string, data: unknown) => void,
    enableTasks: boolean,
    enableSkills: boolean,
    concurrency: number = 1,
  ): Promise<void> {
    const ctx = this.ctx!;

    const importSessions = this.store.getDistinctSessionKeys()
      .filter((sk: string) => sk.startsWith("openclaw-import-") || sk.startsWith("openclaw-session-") || /^agent:[^:]+:(import|session:)/.test(sk));

    type PendingItem = { sessionKey: string; action: "full" | "skill-only"; owner: string };
    const pendingItems: PendingItem[] = [];
    let skippedCount = 0;

    const ownerMap = this.store.getSessionOwnerMap(importSessions);

    for (const sk of importSessions) {
      const hasTask = this.store.hasTaskForSession(sk);
      const hasSkill = this.store.hasSkillForSessionTask(sk);
      const owner = ownerMap.get(sk) ?? "agent:main";

      if (enableTasks && !hasTask) {
        pendingItems.push({ sessionKey: sk, action: "full", owner });
      } else if (enableSkills && hasTask && !hasSkill) {
        pendingItems.push({ sessionKey: sk, action: "skill-only", owner });
      } else {
        skippedCount++;
      }
    }

    // Group pending items by agent (owner)
    const agentGroups = new Map<string, PendingItem[]>();
    for (const item of pendingItems) {
      const group = agentGroups.get(item.owner) ?? [];
      group.push(item);
      agentGroups.set(item.owner, group);
    }

    this.ppState.total = pendingItems.length;
    this.ppState.skippedSessions = skippedCount;
    this.ppState.totalSessions = importSessions.length;
    const existingTaskCount = (this.store as any).db.prepare("SELECT COUNT(*) as c FROM tasks WHERE session_key IN (" + importSessions.map(() => "?").join(",") + ")").get(...importSessions)?.c ?? 0;
    const existingSkillCount = this.store.countSkills("active");
    send("info", {
      totalSessions: importSessions.length,
      alreadyProcessed: skippedCount,
      pending: pendingItems.length,
      agents: Array.from(agentGroups.keys()),
      concurrency,
      existingTasks: existingTaskCount,
      existingSkills: existingSkillCount,
    });
    send("progress", { processed: 0, total: pendingItems.length });

    let globalIdx = 0;
    const incIdx = () => ++globalIdx;