TF-2311 Remove session page view
(cherry picked from commit 557d67b816c91076d8cafc9aa680e62d5b012f5b)
This commit is contained in:
@@ -0,0 +1,9 @@
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
|
||||
abstract class SessionDataSource {
|
||||
Future<Session> getSession();
|
||||
|
||||
Future<void> storeSession(Session session);
|
||||
|
||||
Future<Session> getStoredSession();
|
||||
}
|
||||
@@ -0,0 +1,40 @@
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/caching/clients/session_hive_cache_client.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/datasource/session_datasource.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/exceptions/session_exceptions.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/extensions/session_hive_obj_extension.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/model/session_hive_obj.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/extensions/session_extensions.dart';
|
||||
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
|
||||
|
||||
class HiveSessionDataSourceImpl extends SessionDataSource {
|
||||
|
||||
final SessionHiveCacheClient _sessionHiveCacheClient;
|
||||
final ExceptionThrower _exceptionThrower;
|
||||
|
||||
HiveSessionDataSourceImpl(this._sessionHiveCacheClient, this._exceptionThrower);
|
||||
|
||||
@override
|
||||
Future<Session> getSession() {
|
||||
throw UnimplementedError();
|
||||
}
|
||||
|
||||
@override
|
||||
Future<void> storeSession(Session session) {
|
||||
return Future.sync(() async {
|
||||
return _sessionHiveCacheClient.insertItem(SessionHiveObj.keyValue, session.toHiveObj());
|
||||
}).catchError(_exceptionThrower.throwException);
|
||||
}
|
||||
|
||||
@override
|
||||
Future<Session> getStoredSession() {
|
||||
return Future.sync(() async {
|
||||
final sessionHiveObj = await _sessionHiveCacheClient.getItem(SessionHiveObj.keyValue);
|
||||
if (sessionHiveObj != null) {
|
||||
return sessionHiveObj.toSession();
|
||||
} else {
|
||||
throw NotFoundSessionException();
|
||||
}
|
||||
}).catchError(_exceptionThrower.throwException);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/datasource/session_datasource.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/network/session_api.dart';
|
||||
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
|
||||
|
||||
class SessionDataSourceImpl extends SessionDataSource {
|
||||
|
||||
final SessionAPI _sessionAPI;
|
||||
final ExceptionThrower _exceptionThrower;
|
||||
|
||||
SessionDataSourceImpl(this._sessionAPI, this._exceptionThrower);
|
||||
|
||||
@override
|
||||
Future<Session> getSession() {
|
||||
return Future.sync(() async {
|
||||
return await _sessionAPI.getSession();
|
||||
}).catchError(_exceptionThrower.throwException);
|
||||
}
|
||||
|
||||
@override
|
||||
Future<void> storeSession(Session session) {
|
||||
throw UnimplementedError();
|
||||
}
|
||||
|
||||
@override
|
||||
Future<Session> getStoredSession() {
|
||||
throw UnimplementedError();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,2 @@
|
||||
|
||||
class NotFoundSessionException implements Exception {}
|
||||
@@ -0,0 +1,9 @@
|
||||
|
||||
import 'dart:convert';
|
||||
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/model/session_hive_obj.dart';
|
||||
|
||||
extension SessionHiveObjExtension on SessionHiveObj {
|
||||
Session toSession() => Session.fromJson(jsonDecode(value));
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
import 'package:equatable/equatable.dart';
|
||||
import 'package:hive/hive.dart';
|
||||
import 'package:tmail_ui_user/features/caching/utils/caching_constants.dart';
|
||||
|
||||
part 'session_hive_obj.g.dart';
|
||||
|
||||
@HiveType(typeId: CachingConstants.SESSION_HIVE_CACHE_ID)
|
||||
class SessionHiveObj extends HiveObject with EquatableMixin {
|
||||
|
||||
static const String keyValue = 'session';
|
||||
|
||||
@HiveField(0)
|
||||
final String value;
|
||||
|
||||
SessionHiveObj({
|
||||
required this.value
|
||||
});
|
||||
|
||||
@override
|
||||
List<Object?> get props => [value];
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
import 'dart:async';
|
||||
|
||||
import 'package:jmap_dart_client/http/http_client.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_identifier.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_properties.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/get_session.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
|
||||
class SessionAPI {
|
||||
|
||||
final HttpClient httpClient;
|
||||
|
||||
SessionAPI(this.httpClient);
|
||||
|
||||
Future<Session> getSession({Map<CapabilityIdentifier, CapabilityProperties Function(Map<String, dynamic>)>? converters}) async {
|
||||
final getSessionBuilder = GetSessionBuilder(httpClient);
|
||||
|
||||
final result = await getSessionBuilder.build().execute();
|
||||
|
||||
return result;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
import 'package:core/data/model/source_type/data_source_type.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/datasource/session_datasource.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/repository/session_repository.dart';
|
||||
|
||||
class SessionRepositoryImpl extends SessionRepository {
|
||||
|
||||
final Map<DataSourceType, SessionDataSource> sessionDataSource;
|
||||
|
||||
SessionRepositoryImpl(this.sessionDataSource);
|
||||
|
||||
@override
|
||||
Future<Session> getSession() {
|
||||
return sessionDataSource[DataSourceType.network]!.getSession();
|
||||
}
|
||||
|
||||
@override
|
||||
Future<void> storeSession(Session session) {
|
||||
return sessionDataSource[DataSourceType.hiveCache]!.storeSession(session);
|
||||
}
|
||||
|
||||
@override
|
||||
Future<Session> getStoredSession() {
|
||||
return sessionDataSource[DataSourceType.hiveCache]!.getStoredSession();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_properties.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/core_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/default_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/empty_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/mail_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/mdn_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/submission_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/vacation_capability.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/websocket_capability.dart';
|
||||
|
||||
class CapabilityPropertiesConverter {
|
||||
|
||||
Map<String, dynamic>? toJson(CapabilityProperties properties) {
|
||||
if (properties is CoreCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is MailCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is SubmissionCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is VacationCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is WebSocketCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is MdnCapability) {
|
||||
return properties.toJson();
|
||||
} else if (properties is DefaultCapability) {
|
||||
return properties.properties;
|
||||
} else if (properties is EmptyCapability) {
|
||||
return properties.toJson();
|
||||
} else {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
import 'package:jmap_dart_client/http/converter/account_id_converter.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/account/account.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/extensions/session_account_extension.dart';
|
||||
|
||||
class SessionAccountConverter {
|
||||
|
||||
MapEntry<String, dynamic> convertToMapEntry(AccountId accountId, Account account) {
|
||||
return MapEntry(
|
||||
const AccountIdConverter().toJson(accountId),
|
||||
account.toJson()
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
import 'package:jmap_dart_client/http/converter/capability_identifier_converter.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_identifier.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_properties.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/converter/capability_properties_converter.dart';
|
||||
|
||||
class SessionCapabilitiesConverter {
|
||||
|
||||
MapEntry<String, dynamic> convertToMapEntry(CapabilityIdentifier identifier, CapabilityProperties properties) {
|
||||
return MapEntry(
|
||||
const CapabilityIdentifierConverter().toJson(identifier),
|
||||
CapabilityPropertiesConverter().toJson(properties)
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
import 'package:jmap_dart_client/http/converter/account_id_converter.dart';
|
||||
import 'package:jmap_dart_client/http/converter/capability_identifier_converter.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/capability/capability_identifier.dart';
|
||||
|
||||
class SessionPrimaryAccountConverter {
|
||||
|
||||
MapEntry<String, dynamic> convertToMapEntry(CapabilityIdentifier identifier, AccountId accountId) {
|
||||
return MapEntry(
|
||||
const CapabilityIdentifierConverter().toJson(identifier),
|
||||
const AccountIdConverter().toJson(accountId)
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,24 @@
|
||||
|
||||
import 'package:jmap_dart_client/http/converter/account_name_converter.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/account/account.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/converter/session_capabilities_converter.dart';
|
||||
|
||||
extension SessionAccountExtension on Account {
|
||||
|
||||
Map<String, dynamic> toJson() {
|
||||
final val = <String, dynamic>{};
|
||||
|
||||
void writeNotNull(String key, dynamic value) {
|
||||
if (value != null) {
|
||||
val[key] = value;
|
||||
}
|
||||
}
|
||||
|
||||
writeNotNull('name', const AccountNameConverter().toJson(name));
|
||||
writeNotNull('isPersonal', isPersonal);
|
||||
writeNotNull('isReadOnly', isReadOnly);
|
||||
writeNotNull('accountCapabilities', accountCapabilities.map((key, value) => SessionCapabilitiesConverter().convertToMapEntry(key, value)));
|
||||
|
||||
return val;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,46 @@
|
||||
|
||||
import 'dart:convert';
|
||||
|
||||
import 'package:core/presentation/extensions/uri_extension.dart';
|
||||
import 'package:jmap_dart_client/http/converter/state_converter.dart';
|
||||
import 'package:jmap_dart_client/http/converter/user_name_converter.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/home/data/model/session_hive_obj.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/converter/session_account_converter.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/converter/session_capabilities_converter.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/converter/session_primary_account_converter.dart';
|
||||
|
||||
extension SessionExtensions on Session {
|
||||
|
||||
Map<String, dynamic> toJson() {
|
||||
final val = <String, dynamic>{};
|
||||
|
||||
void writeNotNull(String key, dynamic value) {
|
||||
if (value != null) {
|
||||
val[key] = value;
|
||||
}
|
||||
}
|
||||
|
||||
writeNotNull('capabilities', capabilities.map((key, value) => SessionCapabilitiesConverter().convertToMapEntry(key, value)));
|
||||
writeNotNull('accounts', accounts.map((key, value) => SessionAccountConverter().convertToMapEntry(key, value)));
|
||||
writeNotNull('primaryAccounts', primaryAccounts.map((key, value) => SessionPrimaryAccountConverter().convertToMapEntry(key, value)));
|
||||
writeNotNull('username', const UserNameConverter().toJson(username));
|
||||
writeNotNull('apiUrl', apiUrl.toString());
|
||||
writeNotNull('downloadUrl', downloadUrl.toString());
|
||||
writeNotNull('uploadUrl', uploadUrl.toString());
|
||||
writeNotNull('eventSourceUrl', eventSourceUrl.toString());
|
||||
writeNotNull('state', const StateConverter().toJson(state));
|
||||
|
||||
return val;
|
||||
}
|
||||
|
||||
SessionHiveObj toHiveObj() => SessionHiveObj(value: jsonEncode(toJson()));
|
||||
|
||||
String getQualifiedApiUrl({String? baseUrl}) {
|
||||
if (baseUrl != null) {
|
||||
return apiUrl.toQualifiedUrl(baseUrl: Uri.parse(baseUrl)).toString();
|
||||
} else {
|
||||
return apiUrl.toString();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
|
||||
abstract class SessionRepository {
|
||||
Future<Session> getSession();
|
||||
|
||||
Future<void> storeSession(Session session);
|
||||
|
||||
Future<Session> getStoredSession();
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
|
||||
class GetSessionLoading extends LoadingState {}
|
||||
|
||||
class GetSessionSuccess extends UIState {
|
||||
final Session session;
|
||||
|
||||
GetSessionSuccess(this.session);
|
||||
|
||||
@override
|
||||
List<Object> get props => [session];
|
||||
}
|
||||
|
||||
class GetSessionFailure extends FeatureFailure {
|
||||
final dynamic remoteException;
|
||||
|
||||
GetSessionFailure({dynamic exception, this.remoteException}) : super(exception: exception);
|
||||
}
|
||||
@@ -0,0 +1,11 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
|
||||
class StoreSessionLoading extends LoadingState {}
|
||||
|
||||
class StoreSessionSuccess extends UIState {}
|
||||
|
||||
class StoreSessionFailure extends FeatureFailure {
|
||||
|
||||
StoreSessionFailure(dynamic exception) : super(exception: exception);
|
||||
}
|
||||
@@ -0,0 +1,41 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
import 'package:core/utils/app_logger.dart';
|
||||
import 'package:core/utils/platform_info.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/repository/session_repository.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/state/get_session_state.dart';
|
||||
|
||||
class GetSessionInteractor {
|
||||
final SessionRepository sessionRepository;
|
||||
|
||||
GetSessionInteractor(this.sessionRepository);
|
||||
|
||||
Stream<Either<Failure, Success>> execute() async* {
|
||||
try {
|
||||
yield Right<Failure, Success>(GetSessionLoading());
|
||||
final session = await sessionRepository.getSession();
|
||||
yield Right<Failure, Success>(GetSessionSuccess(session));
|
||||
} catch (e) {
|
||||
if (PlatformInfo.isMobile) {
|
||||
yield* _getStoredSessionFromCache(remoteException: e);
|
||||
} else {
|
||||
yield Left<Failure, Success>(GetSessionFailure(exception: e));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Stream<Either<Failure, Success>> _getStoredSessionFromCache({dynamic remoteException}) async* {
|
||||
try {
|
||||
log('GetSessionInteractor::_getStoredSessionFromCache:');
|
||||
yield Right<Failure, Success>(GetSessionLoading());
|
||||
final session = await sessionRepository.getStoredSession();
|
||||
yield Right<Failure, Success>(GetSessionSuccess(session));
|
||||
} catch (e) {
|
||||
yield Left<Failure, Success>(GetSessionFailure(
|
||||
exception: e,
|
||||
remoteException: remoteException
|
||||
));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,22 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/repository/session_repository.dart';
|
||||
import 'package:tmail_ui_user/features/home/domain/state/store_session_state.dart';
|
||||
|
||||
class StoreSessionInteractor {
|
||||
final SessionRepository sessionRepository;
|
||||
|
||||
StoreSessionInteractor(this.sessionRepository);
|
||||
|
||||
Stream<Either<Failure, Success>> execute(Session session) async* {
|
||||
try {
|
||||
yield Right<Failure, Success>(StoreSessionLoading());
|
||||
await sessionRepository.storeSession(session);
|
||||
yield Right<Failure, Success>(StoreSessionSuccess());
|
||||
} catch (e) {
|
||||
yield Left<Failure, Success>(StoreSessionFailure(e));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -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/cleanup/data/datasource/cleanup_datasource.dart';
|
||||
@@ -15,7 +14,6 @@ import 'package:tmail_ui_user/features/cleanup/domain/usecases/cleanup_recent_se
|
||||
import 'package:tmail_ui_user/features/home/presentation/home_controller.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/repository/authentication_oidc_repository.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/usecases/check_oidc_is_available_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_account_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/thread/data/local/email_cache_manager.dart';
|
||||
import 'package:tmail_ui_user/main/exceptions/cache_exception_thrower.dart';
|
||||
import 'package:tmail_ui_user/main/utils/email_receive_manager.dart';
|
||||
@@ -25,13 +23,11 @@ class HomeBindings extends BaseBindings {
|
||||
@override
|
||||
void bindingsController() {
|
||||
Get.lazyPut(() => HomeController(
|
||||
Get.find<GetAuthenticatedAccountInteractor>(),
|
||||
Get.find<DynamicUrlInterceptors>(),
|
||||
Get.find<CleanupEmailCacheInteractor>(),
|
||||
Get.find<EmailReceiveManager>(),
|
||||
Get.find<CleanupRecentSearchCacheInteractor>(),
|
||||
Get.find<CleanupRecentLoginUrlCacheInteractor>(),
|
||||
Get.find<CleanupRecentLoginUsernameCacheInteractor>(),
|
||||
Get.find<CleanupEmailCacheInteractor>(),
|
||||
Get.find<EmailReceiveManager>(),
|
||||
Get.find<CleanupRecentSearchCacheInteractor>(),
|
||||
Get.find<CleanupRecentLoginUrlCacheInteractor>(),
|
||||
Get.find<CleanupRecentLoginUsernameCacheInteractor>(),
|
||||
));
|
||||
}
|
||||
|
||||
|
||||
@@ -1,17 +1,14 @@
|
||||
import 'package:core/data/network/config/dynamic_url_interceptors.dart';
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
import 'package:core/utils/app_logger.dart';
|
||||
import 'package:core/utils/platform_info.dart';
|
||||
import 'package:flutter/foundation.dart';
|
||||
import 'package:flutter_downloader/flutter_downloader.dart';
|
||||
import 'package:get/get.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/session/session.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
|
||||
import 'package:model/account/personal_account.dart';
|
||||
import 'package:model/email/email_content.dart';
|
||||
import 'package:model/email/email_content_type.dart';
|
||||
import 'package:model/oidc/token_oidc.dart';
|
||||
import 'package:receive_sharing_intent/receive_sharing_intent.dart';
|
||||
import 'package:tmail_ui_user/features/base/base_controller.dart';
|
||||
import 'package:tmail_ui_user/features/base/reloadable/reloadable_controller.dart';
|
||||
import 'package:tmail_ui_user/features/caching/config/hive_cache_config.dart';
|
||||
import 'package:tmail_ui_user/features/cleanup/domain/model/cleanup_rule.dart';
|
||||
import 'package:tmail_ui_user/features/cleanup/domain/model/email_cleanup_rule.dart';
|
||||
@@ -22,19 +19,13 @@ import 'package:tmail_ui_user/features/cleanup/domain/usecases/cleanup_email_cac
|
||||
import 'package:tmail_ui_user/features/cleanup/domain/usecases/cleanup_recent_login_url_cache_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/cleanup/domain/usecases/cleanup_recent_login_username_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/cleanup/domain/usecases/cleanup_recent_search_cache_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/state/get_authenticated_account_state.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/state/get_credential_state.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/state/get_stored_token_oidc_state.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/usecases/get_authenticated_account_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/login/presentation/login_form_type.dart';
|
||||
import 'package:tmail_ui_user/features/login/presentation/model/login_arguments.dart';
|
||||
import 'package:tmail_ui_user/main/routes/app_routes.dart';
|
||||
import 'package:tmail_ui_user/main/routes/navigation_router.dart';
|
||||
import 'package:tmail_ui_user/main/routes/route_navigation.dart';
|
||||
import 'package:tmail_ui_user/main/routes/route_utils.dart';
|
||||
import 'package:tmail_ui_user/main/utils/email_receive_manager.dart';
|
||||
|
||||
class HomeController extends BaseController {
|
||||
final GetAuthenticatedAccountInteractor _getAuthenticatedAccountInteractor;
|
||||
final DynamicUrlInterceptors _dynamicUrlInterceptors;
|
||||
class HomeController extends ReloadableController {
|
||||
final CleanupEmailCacheInteractor _cleanupEmailCacheInteractor;
|
||||
final EmailReceiveManager _emailReceiveManager;
|
||||
final CleanupRecentSearchCacheInteractor _cleanupRecentSearchCacheInteractor;
|
||||
@@ -42,8 +33,6 @@ class HomeController extends BaseController {
|
||||
final CleanupRecentLoginUsernameCacheInteractor _cleanupRecentLoginUsernameCacheInteractor;
|
||||
|
||||
HomeController(
|
||||
this._getAuthenticatedAccountInteractor,
|
||||
this._dynamicUrlInterceptors,
|
||||
this._cleanupEmailCacheInteractor,
|
||||
this._emailReceiveManager,
|
||||
this._cleanupRecentSearchCacheInteractor,
|
||||
@@ -55,7 +44,7 @@ class HomeController extends BaseController {
|
||||
|
||||
@override
|
||||
void onInit() {
|
||||
if (!kIsWeb) {
|
||||
if (PlatformInfo.isMobile) {
|
||||
_initFlutterDownloader();
|
||||
_registerReceivingSharingIntent();
|
||||
}
|
||||
@@ -68,6 +57,17 @@ class HomeController extends BaseController {
|
||||
super.onReady();
|
||||
}
|
||||
|
||||
@override
|
||||
void handleReloaded(Session session) {
|
||||
popAndPush(
|
||||
RouteUtils.generateNavigationRoute(
|
||||
AppRoutes.dashboard,
|
||||
NavigationRouter()
|
||||
),
|
||||
arguments: session
|
||||
);
|
||||
}
|
||||
|
||||
void _initFlutterDownloader() {
|
||||
FlutterDownloader
|
||||
.initialize(debug: kDebugMode)
|
||||
@@ -84,84 +84,22 @@ class HomeController extends BaseController {
|
||||
_cleanupRecentSearchCacheInteractor.execute(RecentSearchCleanupRule()),
|
||||
_cleanupRecentLoginUrlCacheInteractor.execute(RecentLoginUrlCleanupRule()),
|
||||
_cleanupRecentLoginUsernameCacheInteractor.execute(RecentLoginUsernameCleanupRule()),
|
||||
]).then((value) => _getAuthenticatedAccount());
|
||||
}
|
||||
|
||||
void _getAuthenticatedAccount() async {
|
||||
log('HomeController::_getAuthenticatedAccount()');
|
||||
consumeState(_getAuthenticatedAccountInteractor.execute());
|
||||
]).then((value) => getAuthenticatedAccountAction());
|
||||
}
|
||||
|
||||
void _registerReceivingSharingIntent() {
|
||||
_emailReceiveManager.receivingSharingStream.listen((uri) {
|
||||
log('HomeController::onReady(): Received Email: ${uri.toString()}');
|
||||
if (uri != null) {
|
||||
if (GetUtils.isEmail(uri.path)) {
|
||||
log('HomeController::onReady(): Address: ${uri.path}');
|
||||
_emailReceiveManager.setPendingEmailAddress(EmailAddress(null, uri.path));
|
||||
} else if (uri.scheme == "file") {
|
||||
log('HomeController::onReady(): SharedMediaFilePath: ${uri.path}');
|
||||
_emailReceiveManager.setPendingFileInfo([SharedMediaFile(uri.path, null, null, SharedMediaType.FILE)]);
|
||||
} else {
|
||||
log('HomeController::onReady(): EmailContent: ${uri.path}');
|
||||
_emailReceiveManager.setPendingEmailContent(EmailContent(EmailContentType.textPlain, Uri.decodeComponent(uri.path)));
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
_emailReceiveManager.receivingFileSharingStream.listen((listFile) {
|
||||
log('HomeController::onInit(): SharedMediaFile: ${listFile.toString()}');
|
||||
_emailReceiveManager.setPendingFileInfo(listFile);
|
||||
});
|
||||
}
|
||||
|
||||
void _goToLogin({LoginArguments? arguments}) {
|
||||
popAndPush(AppRoutes.login, arguments: arguments);
|
||||
}
|
||||
|
||||
@override
|
||||
void handleFailureViewState(Failure failure) async {
|
||||
super.handleFailureViewState(failure);
|
||||
if (failure is GetAuthenticatedAccountFailure ||
|
||||
failure is GetStoredTokenOidcFailure ||
|
||||
failure is GetCredentialFailure) {
|
||||
_goToLogin(arguments: LoginArguments(LoginFormType.baseUrlForm));
|
||||
}
|
||||
}
|
||||
|
||||
@override
|
||||
void handleSuccessViewState(Success success) {
|
||||
super.handleSuccessViewState(success);
|
||||
if (success is GetStoredTokenOidcSuccess) {
|
||||
_goToSessionWithTokenOidc(success);
|
||||
} else if (success is GetCredentialViewState) {
|
||||
_goToSessionWithBasicAuth(success);
|
||||
}
|
||||
}
|
||||
|
||||
void _goToSessionWithTokenOidc(GetStoredTokenOidcSuccess storedTokenOidcSuccess) {
|
||||
_dynamicUrlInterceptors.setJmapUrl(storedTokenOidcSuccess.baseUrl.toString());
|
||||
_dynamicUrlInterceptors.changeBaseUrl(storedTokenOidcSuccess.baseUrl.toString());
|
||||
authorizationInterceptors.setTokenAndAuthorityOidc(
|
||||
newToken: storedTokenOidcSuccess.tokenOidc.toToken(),
|
||||
newConfig: storedTokenOidcSuccess.oidcConfiguration);
|
||||
authorizationIsolateInterceptors.setTokenAndAuthorityOidc(
|
||||
newToken: storedTokenOidcSuccess.tokenOidc.toToken(),
|
||||
newConfig: storedTokenOidcSuccess.oidcConfiguration);
|
||||
popAndPush(AppRoutes.session, arguments: _dynamicUrlInterceptors.baseUrl);
|
||||
}
|
||||
|
||||
void _goToSessionWithBasicAuth(GetCredentialViewState credentialViewState) {
|
||||
_dynamicUrlInterceptors.setJmapUrl(credentialViewState.baseUrl.origin);
|
||||
_dynamicUrlInterceptors.changeBaseUrl(credentialViewState.baseUrl.origin);
|
||||
authorizationInterceptors.setBasicAuthorization(
|
||||
credentialViewState.userName.value,
|
||||
credentialViewState.password.value,
|
||||
);
|
||||
authorizationIsolateInterceptors.setBasicAuthorization(
|
||||
credentialViewState.userName.value,
|
||||
credentialViewState.password.value,
|
||||
);
|
||||
popAndPush(AppRoutes.session, arguments: _dynamicUrlInterceptors.baseUrl);
|
||||
_emailReceiveManager.receivingFileSharingStream.listen(_emailReceiveManager.setPendingFileInfo);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user