From 2ffb73d053ca2c3f338fa0e91022003ac892e75e Mon Sep 17 00:00:00 2001 From: laurenspriem Date: Thu, 8 May 2025 15:07:50 +0530 Subject: [PATCH] Consistent method parameters --- mobile/lib/db/ml/clip_vector_db.dart | 48 +++++++++++++++------------- 1 file changed, 25 insertions(+), 23 deletions(-) diff --git a/mobile/lib/db/ml/clip_vector_db.dart b/mobile/lib/db/ml/clip_vector_db.dart index ae9b7be348..760fe38627 100644 --- a/mobile/lib/db/ml/clip_vector_db.dart +++ b/mobile/lib/db/ml/clip_vector_db.dart @@ -42,41 +42,42 @@ class ClipVectorDB { return vectorDB; } - Future bulkInsertEmbeddings({ - required Uint64List keys, - required List embeddings, - }) async { - final db = await _vectorDB; - try { - await db.bulkAddVectors(keys: keys, vectors: embeddings); - } catch (e, s) { - _logger.severe("Error bulk inserting embeddings", e, s); - rethrow; - } - } - - Future insertEmbeddings({ - required BigInt key, + Future insertEmbedding({ + required int fileID, required List embedding, }) async { final db = await _vectorDB; try { - await db.addVector(key: key, vector: embedding); + await db.addVector(key: BigInt.from(fileID), vector: embedding); } catch (e, s) { _logger.severe("Error inserting embedding", e, s); rethrow; } } - Future> getVectors(List fileIds) async { + Future bulkInsertEmbeddings({ + required List fileIDs, + required List embeddings, + }) async { + final db = await _vectorDB; + final bigKeys = Uint64List.fromList(fileIDs); + try { + await db.bulkAddVectors(keys: bigKeys, vectors: embeddings); + } catch (e, s) { + _logger.severe("Error bulk inserting embeddings", e, s); + rethrow; + } + } + + Future> getEmbeddings(List fileIDs) async { final db = await _vectorDB; try { - final keys = Uint64List.fromList(fileIds); + final keys = Uint64List.fromList(fileIDs); final vectors = await db.bulkGetVectors(keys: keys); return List.generate( vectors.length, (index) => EmbeddingVector( - fileID: fileIds[index], + fileID: fileIDs[index], embedding: vectors[index], ), ); @@ -86,13 +87,14 @@ class ClipVectorDB { } } - Future deleteEmbeddings(List keys) async { + Future deleteEmbeddings(List fileIDs) async { final db = await _vectorDB; try { final deletedCount = - await db.bulkRemoveVectors(keys: Uint64List.fromList(keys)); - _logger - .info("Deleted $deletedCount embeddings, from ${keys.length} keys"); + await db.bulkRemoveVectors(keys: Uint64List.fromList(fileIDs)); + _logger.info( + "Deleted $deletedCount embeddings, from ${fileIDs.length} keys", + ); } catch (e, s) { _logger.severe("Error bulk deleting specific embeddings", e, s); rethrow;