beenull/ente
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Minor fixes

Browse source
This commit is contained in:
vishnukvmd 2023-10-13 17:55:27 +05:30
parent 30139f1b97
commit eb0bd4516b
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lib/services/semantic_search/semantic_search_service.dart
View file

@ -39,6 +39,8 @@ class SemanticSearchService {
Future<void> init(SharedPreferences preferences) async { Future<void> init(SharedPreferences preferences) async {
await _loadModel(); await _loadModel();
await EmbeddingStore.instance.init(preferences); await EmbeddingStore.instance.init(preferences);
_startBackFill();
await EmbeddingStore.instance.pushEmbeddings(); await EmbeddingStore.instance.pushEmbeddings();
Bus.instance.on<SyncStatusUpdate>().listen((event) async { Bus.instance.on<SyncStatusUpdate>().listen((event) async {
if (event.status == SyncStatus.diffSynced) { if (event.status == SyncStatus.diffSynced) {
@ -46,9 +48,8 @@ class SemanticSearchService {
} }
}); });
Bus.instance.on<FileUploadedEvent>().listen((event) async { Bus.instance.on<FileUploadedEvent>().listen((event) async {
_addToQueue(event.file); addToQueue(event.file);
}); });
_startBackFill();
} }
Future<List<EnteFile>> search(String query) async { Future<List<EnteFile>> search(String query) async {
@ -144,7 +145,7 @@ class SemanticSearchService {
return results; return results;
} }
void _addToQueue(EnteFile file) { void addToQueue(EnteFile file) {
_logger.info("Adding " + file.toString() + " to the queue"); _logger.info("Adding " + file.toString() + " to the queue");
_queue.add(file); _queue.add(file);
_pollQueue(); _pollQueue();