Method embedChunksAsync

packages/memos-core/src/hub/server.ts:201–215

(chunkIds: string[], chunks: Array<{ id: string; summary?: string; content?: string }>)

  }

  private embedChunksAsync(chunkIds: string[], chunks: Array<{ id: string; summary?: string; content?: string }>): void {
    const embedder = this.opts.embedder;
    if (!embedder) return;
    const texts = chunks.map(c => c.summary || (c.content ? c.content.slice(0, 500) : ""));
    embedder.embed(texts).then((vectors) => {
      for (let i = 0; i < vectors.length; i++) {
        if (vectors[i]) {
          this.opts.store.upsertHubEmbedding(chunkIds[i], new Float32Array(vectors[i]));
        }
      }
      this.opts.log.info(`hub: embedded ${vectors.filter(Boolean).length}/${chunkIds.length} shared chunks`);
    }).catch((err) => {
      this.opts.log.warn(`hub: embedding shared chunks failed: ${err}`);
    });
  }

  private embedSkillAsync(skillId: string, name: string, description: string, sourceUserId: string, sourceSkillId: string): void {
    const embedder = this.opts.embedder;