fix(server): race condition for sync

2026-07-23 21:38:44 +08:00 · 2026-04-03 02:00:02 +08:00
parent 99b07c2ee1
commit b98ab495bb
5 changed files with 121 additions and 28 deletions
@@ -29,21 +29,20 @@ export class IndexerEvent {
    );
  }

-  @OnEvent('workspace.updated')
-  async indexWorkspace({ id }: Events['workspace.updated']) {
+  @OnEvent('doc.snapshot.updated')
+  async indexWorkspace({ workspaceId, docId }: Events['doc.snapshot.updated']) {
    if (!this.config.indexer.enabled) {
      return;
    }

+    if (workspaceId !== docId) {
+      return;
+    }
+
    await this.queue.add(
      'indexer.indexWorkspace',
-      {
-        workspaceId: id,
-      },
-      {
-        jobId: `indexWorkspace/${id}`,
-        priority: 100,
-      }
+      { workspaceId },
+      { jobId: `indexWorkspace/${workspaceId}`, priority: 100 }
    );
  }