Method handlePostprocess

packages/memos-core/src/viewer/server.ts:4705–4759

(req: http.IncomingMessage, res: http.ServerResponse)

  // ─── Post-processing: independent task/skill generation ───

  private handlePostprocess(req: http.IncomingMessage, res: http.ServerResponse): void {
    if (this.ppRunning) {
      res.writeHead(409, { "Content-Type": "application/json" });
      res.end(JSON.stringify({ error: "postprocess already running" }));
      return;
    }
    if (!this.ctx) {
      res.writeHead(500, { "Content-Type": "application/json" });
      res.end(JSON.stringify({ error: "plugin context not available — please restart the gateway" }));
      return;
    }

    this.readBody(req, (body) => {
      let opts: { enableTasks?: boolean; enableSkills?: boolean; concurrency?: number } = {};
      try { opts = JSON.parse(body); } catch { /* defaults */ }

      const concurrency = Math.max(1, Math.min(opts.concurrency ?? 1, 8));

      res.writeHead(200, {
        "Content-Type": "text/event-stream",
        "Cache-Control": "no-cache",
        "Connection": "keep-alive",
        "X-Accel-Buffering": "no",
      });

      this.ppSSEClients.push(res);
      res.on("close", () => { this.ppSSEClients = this.ppSSEClients.filter(c => c !== res); });

      this.ppAbort = false;
      this.ppState = { running: true, done: false, stopped: false, processed: 0, total: 0, tasksCreated: 0, skillsCreated: 0, errors: 0, skippedSessions: 0, totalSessions: 0 };

      const send = (event: string, data: unknown) => {
        this.broadcastPPSSE(event, data);
      };

      this.ppRunning = true;
      this.runPostprocess(send, !!opts.enableTasks, !!opts.enableSkills, concurrency).finally(() => {
        this.ppRunning = false;
        this.ppState.running = false;
        this.ppState.done = true;
        if (this.ppAbort) {
          this.ppState.stopped = true;
          this.broadcastPPSSE("stopped", { ...this.ppState });
        } else {
          this.broadcastPPSSE("done", { ...this.ppState });
        }
        this.ppAbort = false;
        const ppClientsToClose = [...this.ppSSEClients];
        this.ppSSEClients = [];
        setTimeout(() => {
          for (const c of ppClientsToClose) { try { c.end(); } catch { /* */ } }
        }, 500);
      });
    });
  }

  private handlePostprocessStream(res: http.ServerResponse): void {
    res.writeHead(200, {