mirror of
https://github.com/immich-app/immich.git
synced 2024-11-15 18:08:48 -07:00
39 lines
1.1 KiB
Dart
39 lines
1.1 KiB
Dart
|
import 'package:hooks_riverpod/hooks_riverpod.dart';
|
||
|
import 'package:logging/logging.dart';
|
||
|
|
||
|
typedef AsyncFuture<T> = Future<AsyncValue<T>>;
|
||
|
|
||
|
mixin ErrorLoggerMixin {
|
||
|
abstract final Logger logger;
|
||
|
|
||
|
/// Returns an AsyncValue<T> if the future is successfully executed
|
||
|
/// Else, logs the error to the overrided logger and returns an AsyncError<>
|
||
|
AsyncFuture<T> guardError<T>(
|
||
|
Future<T> Function() fn, {
|
||
|
Level logLevel = Level.SEVERE,
|
||
|
}) async {
|
||
|
try {
|
||
|
final result = await fn();
|
||
|
return AsyncData(result);
|
||
|
} catch (error, stackTrace) {
|
||
|
logger.log(logLevel, "$error", error, stackTrace);
|
||
|
return AsyncError(error, stackTrace);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
/// Returns the result of the future if success
|
||
|
/// Else, logs the error and returns the default value
|
||
|
Future<T> logError<T>(
|
||
|
Future<T> Function() fn, {
|
||
|
required T defaultValue,
|
||
|
Level logLevel = Level.SEVERE,
|
||
|
}) async {
|
||
|
try {
|
||
|
return await fn();
|
||
|
} catch (error, stackTrace) {
|
||
|
logger.log(logLevel, "$error", error, stackTrace);
|
||
|
}
|
||
|
return defaultValue;
|
||
|
}
|
||
|
}
|