ente/lib/services/search_service.dart

import 'package:photos/core/event_bus.dart';
import 'package:photos/db/files_db.dart';
import 'package:photos/events/local_photos_updated_event.dart';
import 'package:photos/models/file.dart';

class SearchService {
  List<File> _cachedFiles;

  SearchService._privateConstructor();
  static final SearchService instance = SearchService._privateConstructor();

  Future<void> init() async {
    // Intention of delay is to give more CPU cycles to other tasks
    Future.delayed(const Duration(seconds: 5), () async {
      FilesDB.instance
          .getAllFilesFromDB()
          .then((value) => _cachedFiles = value);
    });

    Bus.instance.on<LocalPhotosUpdatedEvent>().listen((event) {
      _cachedFiles = null;
      getAllFiles();
    });
  }

  Future<List<File>> getAllFiles() async {
    _cachedFiles ??= await FilesDB.instance.getAllFilesFromDB();
    return _cachedFiles;
  }

  void clearCachedFiles() {
    _cachedFiles.clear();
  }
}