feat: auto-reindex on empty Typesense backend startup

When the fulltext pod starts and the Typesense collection has 0
documents (e.g. after pod restart with emptyDir), automatically
enumerate all active workspaces and queue a fullReindex event for
each. This makes Typesense self-healing without requiring a PVC.

- Add optional getDocCount() to FullTextAdapter interface
- Implement getDocCount() in TypesenseAdapter via collections().retrieve()
- Add checkAndTriggerReindex() to WorkspaceManager.startIndexer()
- Elastic/OpenSearch backends skip the check (no getDocCount method)

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Signed-off-by: Don Kendall <kendall@donkendall.com>

Author: dnplkndll

foundations/server/packages/core/src/types.ts

@@ -409,6 +409,12 @@ export interface FullTextAdapter {
 
   // If no field is provided, will return existing mapping of all dimms.
   initMapping: (ctx: MeasureContext, field?: { key: string, dims: number }) => Promise<boolean>
+
+  // Optional: return the total document count in the index/collection.
+  // Used by non-persistent backends (e.g. Typesense with emptyDir) to detect
+  // empty state on startup and trigger automatic reindex.
+  // Returns -1 if the count cannot be determined (e.g. connection error).
+  getDocCount?: (ctx: MeasureContext) => Promise<number>
 }
 
 /**

foundations/server/packages/typesense/src/adapter.ts

@@ -207,6 +207,21 @@ class TypesenseAdapter implements FullTextAdapter {
     // Typesense client does not require explicit close
   }
 
+  async getDocCount (ctx: MeasureContext): Promise<number> {
+    try {
+      const col = await this.client.collections(this.collectionName).retrieve()
+      return (col as any).num_documents ?? 0
+    } catch (err: any) {
+      if (isConnectionError(err)) {
+        ctx.warn('Typesense DB is not available for doc count check')
+        return -1
+      }
+      Analytics.handleError(err)
+      ctx.error('Typesense getDocCount error', { error: err })
+      return -1
+    }
+  }
+
   async searchString (
     ctx: MeasureContext,
     workspaceId: WorkspaceUuid,

pods/fulltext/src/manager.ts

@@ -105,6 +105,8 @@ export class WorkspaceManager {
       }
     }
 
+    await this.checkAndTriggerReindex()
+
     this.shutdownInterval = setInterval(() => {
       for (const [k, v] of [...this.indexers.entries()]) {
         if (v instanceof Promise) {
@@ -159,6 +161,36 @@ export class WorkspaceManager {
     )
   }
 
+  private async checkAndTriggerReindex (): Promise<void> {
+    if (this.fulltextAdapter.getDocCount === undefined) {
+      return
+    }
+
+    const docCount = await this.fulltextAdapter.getDocCount(this.ctx)
+    if (docCount < 0) {
+      this.ctx.warn('Could not determine backend doc count, skipping auto-reindex check')
+      return
+    }
+    if (docCount > 0) {
+      this.ctx.info('Fulltext backend has documents, skipping auto-reindex', { docCount })
+      return
+    }
+
+    this.ctx.warn('Fulltext backend is empty (0 documents), triggering auto-reindex for all workspaces')
+    try {
+      const token = generateToken(systemAccountUuid, undefined, { service: 'tool' })
+      const accountClient = getAccountClient(token)
+      const workspaces = await accountClient.listWorkspaces(null, 'active')
+      this.ctx.info('Auto-reindex: found workspaces', { count: workspaces.length })
+      for (const ws of workspaces) {
+        await this.fulltextProducer.send(this.ctx, ws.uuid, [workspaceEvents.fullReindex()])
+        this.ctx.info('Queued full reindex', { workspace: ws.uuid })
+      }
+    } catch (err: any) {
+      this.ctx.error('Failed to trigger auto-reindex', { error: err })
+    }
+  }
+
   private async processTransactions (
     m: ConsumerMessage<TxCUD<Doc<Space>> | TxDomainEvent<QueueSourced<Event>>>,
     control: ConsumerControl