Method handleTaskRetrySkill

packages/memos-core/src/viewer/server.ts:1303–1326

(_req: http.IncomingMessage, res: http.ServerResponse, urlPath: string)

  // ─── Task/Skill management ───

  private handleTaskRetrySkill(_req: http.IncomingMessage, res: http.ServerResponse, urlPath: string): void {
    const taskId = urlPath.replace("/api/task/", "").replace("/retry-skill", "");
    const task = this.store.getTask(taskId);
    if (!task) { res.writeHead(404, { "Content-Type": "application/json" }); res.end(JSON.stringify({ error: "Task not found" })); return; }
    if (task.status !== "completed") { res.writeHead(400, { "Content-Type": "application/json" }); res.end(JSON.stringify({ error: "Only completed tasks can retry skill generation" })); return; }
    if (!this.ctx) { res.writeHead(500, { "Content-Type": "application/json" }); res.end(JSON.stringify({ error: "Plugin context not available" })); return; }

    // Clean up stale task_skills references (e.g., skill was manually deleted)
    const db = (this.store as any).db;
    db.prepare("DELETE FROM task_skills WHERE task_id = ? AND skill_id NOT IN (SELECT id FROM skills)").run(taskId);

    this.store.setTaskSkillMeta(taskId, { skillStatus: "queued", skillReason: "手动重试中..." });
    this.jsonResponse(res, { ok: true, taskId, status: "queued" });

    const ctx = this.ctx;
    const recallEngine = new RecallEngine(this.store, this.embedder, ctx);
    const evolver = new SkillEvolver(this.store, recallEngine, ctx, this.embedder);
    evolver.onTaskCompleted(task).then(() => {
      this.log.info(`Retry skill generation completed for task ${taskId}`);
    }).catch((err) => {
      this.log.error(`Retry skill generation failed for task ${taskId}: ${err}`);
      this.store.setTaskSkillMeta(taskId, { skillStatus: "skipped", skillReason: `error: ${err}` });
    });
  }

  private embedTaskInBackground(taskId: string, text: string): void {
    if (!this.embedder || !text.trim()) return;