TF-1115 Add RemoteExceptionThrower

This commit is contained in:
dab246
2022-10-27 16:59:31 +07:00
committed by Dat H. Pham
parent 1e855c26bc
commit fb177fb33d
14 changed files with 108 additions and 74 deletions
-2
View File
@@ -15,8 +15,6 @@ export 'domain/extensions/media_type_extension.dart';
// Exceptions
export 'domain/exceptions/download_file_exception.dart';
export 'data/extensions/options_extensions.dart';
export 'domain/exceptions/remote_exception.dart';
export 'data/network/remote_exception_thrower.dart';
export 'domain/exceptions/web_session_exception.dart';
// Utils
@@ -1,24 +0,0 @@
import 'package:core/domain/exceptions/remote_exception.dart';
import 'package:dio/dio.dart';
class RemoteExceptionThrower {
void throwRemoteException(dynamic exception, {Function(DioError)? handler}) {
if (exception is DioError) {
switch (exception.type) {
case DioErrorType.connectTimeout:
throw ConnectError();
default:
if (handler != null) {
throw handler(exception);
} else {
throw UnknownError(
code: exception.response?.statusCode,
message: exception.message);
}
}
} else {
throw UnknownError(message: exception.toString());
}
}
}
@@ -1,25 +0,0 @@
import 'package:equatable/equatable.dart';
abstract class RemoteException extends Equatable implements Exception {
static const connectError = 'Connect error';
final String? message;
final int? code;
const RemoteException({this.code, this.message});
}
class UnknownError extends RemoteException {
const UnknownError({int? code, String? message}) : super(code: code, message: message);
@override
List<Object> get props => [];
}
class ConnectError extends RemoteException {
const ConnectError() : super(message: RemoteException.connectError);
@override
List<Object> get props => [];
}
@@ -26,6 +26,7 @@ import 'package:tmail_ui_user/features/thread/data/datasource/thread_datasource.
import 'package:tmail_ui_user/features/thread/data/datasource_impl/thread_datasource_impl.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_isolate_worker.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
class DestinationPickerBindings extends BaseBindings {
@@ -65,7 +66,10 @@ class DestinationPickerBindings extends BaseBindings {
Get.lazyPut(() => MailboxCacheDataSourceImpl(Get.find<MailboxCacheManager>()));
Get.lazyPut(() => StateDataSourceImpl(Get.find<StateCacheClient>()));
Get.lazyPut(() => EmailDataSourceImpl(Get.find<EmailAPI>()));
Get.lazyPut(() => ThreadDataSourceImpl(Get.find<ThreadAPI>(), Get.find<ThreadIsolateWorker>()));
Get.lazyPut(() => ThreadDataSourceImpl(
Get.find<ThreadAPI>(),
Get.find<ThreadIsolateWorker>(),
Get.find<RemoteExceptionThrower>()));
}
@override
@@ -1,5 +1,5 @@
import 'package:core/domain/exceptions/remote_exception.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception.dart';
abstract class AuthenticationException extends RemoteException {
static const wrongCredential = 'Credential is wrong';
@@ -29,6 +29,7 @@ import 'package:tmail_ui_user/features/thread/data/datasource/thread_datasource.
import 'package:tmail_ui_user/features/thread/data/datasource_impl/thread_datasource_impl.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_isolate_worker.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
class MailboxBindings extends BaseBindings {
@@ -71,7 +72,10 @@ class MailboxBindings extends BaseBindings {
Get.lazyPut(() => MailboxCacheDataSourceImpl(Get.find<MailboxCacheManager>()));
Get.lazyPut(() => StateDataSourceImpl(Get.find<StateCacheClient>()));
Get.lazyPut(() => EmailDataSourceImpl(Get.find<EmailAPI>()));
Get.lazyPut(() => ThreadDataSourceImpl(Get.find<ThreadAPI>(), Get.find<ThreadIsolateWorker>()));
Get.lazyPut(() => ThreadDataSourceImpl(
Get.find<ThreadAPI>(),
Get.find<ThreadIsolateWorker>(),
Get.find<RemoteExceptionThrower>()));
}
@override
@@ -88,6 +88,7 @@ import 'package:tmail_ui_user/features/thread/domain/usecases/move_multiple_emai
import 'package:tmail_ui_user/features/thread/domain/usecases/search_email_interactor.dart';
import 'package:tmail_ui_user/features/thread/domain/usecases/search_more_email_interactor.dart';
import 'package:tmail_ui_user/features/thread/presentation/thread_bindings.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
class MailboxDashBoardBindings extends BaseBindings {
@@ -149,7 +150,10 @@ class MailboxDashBoardBindings extends BaseBindings {
Get.find<DioClient>()
));
Get.lazyPut(() => SearchDataSourceImpl(Get.find<RecentSearchCacheClient>()));
Get.lazyPut(() => ThreadDataSourceImpl(Get.find<ThreadAPI>(), Get.find<ThreadIsolateWorker>()));
Get.lazyPut(() => ThreadDataSourceImpl(
Get.find<ThreadAPI>(),
Get.find<ThreadIsolateWorker>(),
Get.find<RemoteExceptionThrower>()));
Get.lazyPut(() => LocalThreadDataSourceImpl(Get.find<EmailCacheManager>()));
Get.lazyPut(() => StateDataSourceImpl(Get.find<StateCacheClient>()));
Get.lazyPut(() => MailboxDataSourceImpl(Get.find<MailboxAPI>(), Get.find<MailboxIsolateWorker>()));
@@ -1,34 +1,21 @@
import 'package:core/data/network/remote_exception_thrower.dart';
import 'package:core/domain/exceptions/remote_exception.dart';
import 'package:core/utils/app_logger.dart';
import 'package:dio/dio.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:tmail_ui_user/features/login/domain/exceptions/authentication_exception.dart';
import 'package:tmail_ui_user/features/session/data/datasource/session_datasource.dart';
import 'package:tmail_ui_user/features/session/data/network/session_api.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
class SessionDataSourceImpl extends SessionDataSource {
final SessionAPI _sessionAPI;
final RemoteExceptionThrower _remoteExceptionThrower;
final ExceptionThrower _exceptionThrower;
SessionDataSourceImpl(this._sessionAPI, this._remoteExceptionThrower);
SessionDataSourceImpl(this._sessionAPI, this._exceptionThrower);
@override
Future<Session> getSession() {
return Future.sync(() async {
return await _sessionAPI.getSession();
}).catchError((error) {
_remoteExceptionThrower.throwRemoteException(error, handler: (DioError error) {
if (error.response?.statusCode == 502) {
throw BadGateway();
} else {
log('SessionDataSourceImpl::getSession(): statusMessage: ${error.response?.statusMessage}');
throw UnknownError(
code: error.response?.statusCode,
message: error.response?.statusMessage);
}
});
_exceptionThrower.throwException(error);
});
}
}
@@ -1,7 +1,6 @@
import 'package:core/data/network/config/dynamic_url_interceptors.dart';
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/utils/app_toast.dart';
import 'package:core/domain/exceptions/remote_exception.dart';
import 'package:get/get.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:tmail_ui_user/features/base/reloadable/reloadable_controller.dart';
@@ -14,6 +13,7 @@ import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_a
import 'package:tmail_ui_user/features/manage_account/domain/usecases/log_out_oidc_interactor.dart';
import 'package:tmail_ui_user/features/session/domain/state/get_session_state.dart';
import 'package:tmail_ui_user/features/session/domain/usecases/get_session_interactor.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception.dart';
import 'package:tmail_ui_user/main/localizations/app_localizations.dart';
import 'package:tmail_ui_user/main/routes/app_routes.dart';
import 'package:tmail_ui_user/main/routes/route_navigation.dart';
@@ -22,6 +22,7 @@ import 'package:tmail_ui_user/features/manage_account/data/network/manage_accoun
import 'package:tmail_ui_user/features/manage_account/data/network/vacation_api.dart';
import 'package:tmail_ui_user/features/session/data/network/session_api.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
class NetworkBindings extends Bindings {
@@ -1,4 +1,3 @@
import 'package:core/core.dart';
import 'package:get/get.dart';
import 'package:tmail_ui_user/features/base/base_bindings.dart';
import 'package:tmail_ui_user/features/session/data/datasource/session_datasource.dart';
@@ -7,6 +6,7 @@ import 'package:tmail_ui_user/features/session/data/network/session_api.dart';
import 'package:tmail_ui_user/features/session/data/repository/session_repository_impl.dart';
import 'package:tmail_ui_user/features/session/domain/repository/session_repository.dart';
import 'package:tmail_ui_user/features/session/domain/usecases/get_session_interactor.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
class SessionBindings extends BaseBindings {
@@ -0,0 +1,4 @@
abstract class ExceptionThrower {
void throwException(dynamic exception);
}
+43
View File
@@ -0,0 +1,43 @@
import 'package:equatable/equatable.dart';
import 'package:jmap_dart_client/jmap/core/error/error_type.dart';
import 'package:jmap_dart_client/jmap/core/error/method/error_method_response.dart';
abstract class RemoteException with EquatableMixin implements Exception {
static const connectError = 'Connect error';
final String? message;
final int? code;
const RemoteException({this.code, this.message});
}
class UnknownError extends RemoteException {
const UnknownError({int? code, String? message}) : super(code: code, message: message);
@override
List<Object> get props => [];
}
class ConnectError extends RemoteException {
const ConnectError() : super(message: RemoteException.connectError);
@override
List<Object> get props => [];
}
class MethodLevelErrors extends RemoteException {
final ErrorType type;
const MethodLevelErrors(
this.type,
{String? message}
) : super(message: message);
@override
List<Object?> get props => [type, message];
}
class CannotCalculateChangesMethodResponseException extends MethodLevelErrors {
CannotCalculateChangesMethodResponseException({String? message}) : super(ErrorMethodResponse.cannotCalculateChanges, message: message);
}
@@ -0,0 +1,38 @@
import 'package:dio/dio.dart';
import 'package:jmap_dart_client/jmap/core/error/method/error_method_response.dart';
import 'package:jmap_dart_client/jmap/core/error/method/exception/error_method_response_exception.dart';
import 'package:tmail_ui_user/features/login/domain/exceptions/authentication_exception.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
import 'package:tmail_ui_user/main/exceptions/remote_exception.dart';
class RemoteExceptionThrower extends ExceptionThrower {
@override
void throwException(dynamic exception) {
if (exception is DioError) {
switch (exception.type) {
case DioErrorType.connectTimeout:
throw const ConnectError();
default:
if (exception.response?.statusCode == 502) {
throw BadGateway();
} else {
throw UnknownError(
code: exception.response?.statusCode,
message: exception.response?.statusMessage);
}
}
} else if (exception is ErrorMethodResponseException) {
final errorResponse = exception.errorResponse as ErrorMethodResponse;
if (errorResponse is CannotCalculateChangesMethodResponse) {
throw CannotCalculateChangesMethodResponseException();
} else {
throw MethodLevelErrors(
errorResponse.type,
message: errorResponse.description);
}
} else {
throw UnknownError(message: exception.toString());
}
}
}