feat(trash): AiWorker.processJob deletedAt guard (#4 v0.2.3)

src/main/ai/AiWorker.ts

@@ -121,7 +121,7 @@ export class AiWorker {
       const startMs = this.now().getTime();
       try {
         const note = this.repo.findById(job.noteId);
-        if (!note || note.aiStatus !== 'pending') return;
+        if (!note || note.deletedAt !== null || note.aiStatus !== 'pending') return;
         const nowDate = this.now();
         const todayDate = todayKstAsDate(nowDate);
         const todayIso = todayKstAsIso(nowDate);

tests/unit/AiWorker.test.ts

@@ -278,3 +278,29 @@ describe('AiWorker telemetry emit', () => {
     expect(failed!.payload.reason).toBe('other');
   });
 });
+
+describe('AiWorker — deletedAt guard (v0.2.3 #4)', () => {
+  let db: Database.Database;
+  let repo: NoteRepository;
+
+  beforeEach(() => {
+    db = new Database(':memory:');
+    runMigrations(db);
+    repo = new NoteRepository(db);
+  });
+
+  it('skips notes with deleted_at IS NOT NULL — provider.generate not called', async () => {
+    const { id } = repo.create({ rawText: 'x' });
+    // 먼저 trash — pending_jobs cleanup 됨
+    repo.trash(id, '2026-05-01T12:00:00.000Z');
+    // 강제로 pending_jobs row 다시 삽입 (race 시뮬레이션 — AiWorker 가 이미 dequeue 한 상태 흉내)
+    db.prepare(`INSERT INTO pending_jobs (note_id, attempts, next_run_at) VALUES (?, 0, ?)`).run(id, '2026-05-01T12:00:00.000Z');
+    const generate = vi.fn();
+    const provider = makeProvider({ generate: generate as any });
+    const w = new AiWorker(repo, provider, { backoffsMs: [0, 0, 0] });
+    await w.loadFromDb();
+    await w.drain();
+    expect(generate).not.toHaveBeenCalled();
+    expect(repo.findById(id)!.aiStatus).toBe('pending');
+  });
+});