Method backfillMemoryEmbeddings

packages/memos-core/src/hub/server.ts:231–256

()

  }

  private backfillMemoryEmbeddings(): void {
    if (!this.opts.embedder) return;
    try {
      const all = this.opts.store.listHubMemories({ limit: 500 });
      const missing = all.filter(m => {
        try { return !this.opts.store.getHubMemoryEmbedding(m.id); } catch { return true; }
      });
      if (missing.length === 0) return;
      this.opts.log.info(`hub: backfilling embeddings for ${missing.length} hub memories`);
      const texts = missing.map(m => (m.summary || m.content || "").slice(0, 500));
      this.opts.embedder.embed(texts).then((vectors) => {
        let count = 0;
        for (let i = 0; i < vectors.length; i++) {
          if (vectors[i]) {
            this.opts.store.upsertHubMemoryEmbedding(missing[i].id, new Float32Array(vectors[i]));
            count++;
          }
        }
        this.opts.log.info(`hub: backfilled ${count}/${missing.length} memory embeddings`);
      }).catch((err) => {
        this.opts.log.warn(`hub: backfill memory embeddings failed: ${err}`);
      });
    } catch (err) {
      this.opts.log.warn(`hub: backfill memory embeddings error: ${err}`);
    }
  }

  private embedMemoryAsync(memoryId: string, summary: string, content: string): void {
    const embedder = this.opts.embedder;