Method getAllEmbeddings

packages/memos-core/src/storage/sqlite.ts:1348–1366

(ownerFilter?: string[])

  // ─── Vector Search ───

  getAllEmbeddings(ownerFilter?: string[]): Array<{ chunkId: string; vector: number[] }> {
    let sql = `SELECT e.chunk_id, e.vector, e.dimensions FROM embeddings e
       JOIN chunks c ON c.id = e.chunk_id
       WHERE c.dedup_status = 'active'`;
    const params: any[] = [];

    if (ownerFilter && ownerFilter.length > 0) {
      const placeholders = ownerFilter.map(() => "?").join(",");
      sql += ` AND c.owner IN (${placeholders})`;
      params.push(...ownerFilter);
    }

    const rows = this.db.prepare(sql).all(...params) as Array<{ chunk_id: string; vector: Buffer; dimensions: number }>;

    return rows.map((r) => ({
      chunkId: r.chunk_id,
      vector: Array.from(new Float32Array(r.vector.buffer, r.vector.byteOffset, r.dimensions)),
    }));
  }

  getRecentEmbeddings(limit: number, ownerFilter?: string[]): Array<{ chunkId: string; vector: number[] }> {
    if (limit <= 0) return this.getAllEmbeddings(ownerFilter);