Method embedMemoryAsync

packages/memos-core/src/hub/server.ts:258–271

(memoryId: string, summary: string, content: string)

  }

  private embedMemoryAsync(memoryId: string, summary: string, content: string): void {
    const embedder = this.opts.embedder;
    if (!embedder) return;
    const text = (summary || content || "").slice(0, 500);
    if (!text) return;
    embedder.embed([text]).then((vectors) => {
      if (vectors[0]) {
        this.opts.store.upsertHubMemoryEmbedding(memoryId, new Float32Array(vectors[0]));
        this.opts.log.info(`hub: embedded shared memory ${memoryId}`);
      }
    }).catch((err) => {
      this.opts.log.warn(`hub: embedding shared memory failed: ${err}`);
    });
  }

  private async handle(req: http.IncomingMessage, res: http.ServerResponse): Promise<void> {
    const url = new URL(req.url || "/", `http://127.0.0.1:${this.port}`);