boot the reflection worker (embedder optional)

ReflectionWorkerOpts.embedder is now optional. reflectionTick
returns zeroed counts when no embedder is wired so the cadence
exists from boot — once a tenant adds Voyage / OpenAI keys, the
next tick picks up the backlog.

Wired into server/src/index.ts boot next to the MemoryService
init: starts the 30s interval, .unref()'d so it doesn't pin the
event loop on shutdown.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: p4w4n

server/src/index.ts

@@ -621,6 +621,15 @@ export async function startServer(): Promise<StartedServer> {
     createPgvectorMemoryBackend(db as any),
     createPgvectorWikiBackend(db as any),
   );
+
+  // Reflection worker — backfills embeddings for memory_entries +
+  // memory_pages where embedding IS NULL. Booted even without an
+  // embedder configured (the tick no-ops); once a tenant adds an
+  // embedder, the next tick picks up the backlog. Interval is 30s.
+  const { startReflectionWorker } = await import(
+    "./services/memory/reflection-worker.js"
+  );
+  startReflectionWorker({ db: db as any });
   const app = await createApp(db as any, {
     uiMode,
     serverPort: listenPort,

server/src/services/memory/reflection-worker.ts

@@ -26,7 +26,10 @@ import type { EmbeddingProvider } from "./embedding.js";
 
 export interface ReflectionWorkerOpts {
   db: Db;
-  embedder: EmbeddingProvider;
+  // Optional. When absent, the embed stages are skipped (no-op tick).
+  // Boot can wire the worker before any embedder is configured —
+  // the worker quietly idles until createEmbeddingProvider lands.
+  embedder?: EmbeddingProvider;
   // How many rows per tick. Default 32; embedding APIs are happiest
   // with batches up to ~100 (see embedding.ts MAX_BATCH).
   batchSize?: number;
@@ -116,6 +119,13 @@ export async function reflectionTick(
   let factsEmbedded = 0;
   let pagesEmbedded = 0;
   let errors = 0;
+  // No-op when no embedder is wired. Boot installs the worker even
+  // before an embedder is configured so the cadence exists; once a
+  // tenant adds Voyage / OpenAI keys, the next tick picks up the
+  // pending backlog.
+  if (!opts.embedder) {
+    return { factsEmbedded: 0, pagesEmbedded: 0, errors: 0 };
+  }
   try {
     const facts = await embedPendingFacts(opts.db, opts.embedder, batchSize);
     factsEmbedded = facts.embedded;