Method upsertHubEmbedding

packages/memos-core/src/storage/sqlite.ts:2434–2441

(chunkId: string, vector: Float32Array)

  }

  upsertHubEmbedding(chunkId: string, vector: Float32Array): void {
    const buf = Buffer.from(vector.buffer, vector.byteOffset, vector.byteLength);
    this.db.prepare(`
      INSERT INTO hub_embeddings (chunk_id, vector, dimensions, updated_at)
      VALUES (?, ?, ?, ?)
      ON CONFLICT(chunk_id) DO UPDATE SET vector = excluded.vector, dimensions = excluded.dimensions, updated_at = excluded.updated_at
    `).run(chunkId, buf, vector.length, Date.now());
  }

  getHubEmbedding(chunkId: string): Float32Array | null {
    const row = this.db.prepare('SELECT vector, dimensions FROM hub_embeddings WHERE chunk_id = ?').get(chunkId) as { vector: Buffer; dimensions: number } | undefined;