kenmirrors/ente
1
0
Fork 0
mirror of https://github.com/ente-io/ente.git synced 2025-08-07 23:18:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

[mob] Cache magic result in memory

Browse Source
This commit is contained in:
Neeraj Gupta 2024-09-17 15:47:26 +05:30
parent 98e0aeee8a
commit 66c3870518
1 changed files with 25 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
mobile/lib/services/magic_cache_service.dart
View File

@ -49,7 +49,7 @@ class MagicCache {
}
extension MagicCacheServiceExtension on MagicCache {
Future<GenericSearchResult> toGenericSearchResult() async {
Future<GenericSearchResult?> toGenericSearchResult() async {
final enteFilesInMagicCache = <EnteFile>[];
await FilesDB.instance
.getFilesFromIDs(fileUploadedIDs)
@ -60,6 +60,9 @@ extension MagicCacheServiceExtension on MagicCache {
}
}
});
if (enteFilesInMagicCache.isEmpty) {
return null;
}
return GenericSearchResult(
ResultType.magic,
title,
@ -94,6 +97,8 @@ class MagicCacheService {
final Logger _logger = Logger((MagicCacheService).toString());
MagicCacheService._privateConstructor();
Future<List<MagicCache>>? _magicCacheFuture;
static final MagicCacheService instance =
MagicCacheService._privateConstructor();
@ -172,6 +177,7 @@ class MagicCacheService {
if (!file.existsSync()) {
file.createSync(recursive: true);
}
_magicCacheFuture = Future.value(magicCaches);
await file
.writeAsBytes(MagicCache.encodeListToJson(magicCaches).codeUnits);
w?.log("cacheWritten");
@ -182,11 +188,20 @@ class MagicCacheService {
}
}
Future<List<MagicCache>?> _getMagicCache() async {
Future<List<MagicCache>> _getMagicCache() async {
if (_magicCacheFuture != null) {
return _magicCacheFuture!;
}
_magicCacheFuture = _readResultFromDisk();
return _magicCacheFuture!;
}
Future<List<MagicCache>> _readResultFromDisk() async {
_logger.info("Reading magic cache result from disk");
final file = File(await _getCachePath());
if (!file.existsSync()) {
_logger.info("No magic cache found");
return null;
return [];
}
final jsonString = file.readAsStringSync();
return MagicCache.decodeJsonToList(jsonString);
@ -202,15 +217,20 @@ class MagicCacheService {
kDebugMode ? EnteWatch("magicGenericSearchResult") : null;
w?.start();
final magicCaches = await _getMagicCache();
if (magicCaches == null) {
if (magicCaches.isEmpty) {
w?.log("noCacheFound");
_logger.info("No magic cache found");
return [];
} else {
w?.log("cacheFound");
}
final List<GenericSearchResult> genericSearchResults = [];
for (MagicCache magicCache in magicCaches) {
final genericSearchResult = await magicCache.toGenericSearchResult();
genericSearchResults.add(genericSearchResult);
if (genericSearchResult != null) {
genericSearchResults.add(genericSearchResult);
}
}
w?.logAndReset("done");
return genericSearchResults;