TF-2271 Implement dns lookup to get jmap url
Signed-off-by: dab246 <tdvu@linagora.com> (cherry picked from commit 7b0c0015a15a243b6b4aef3d78e7653d556ad109)
This commit is contained in:
@@ -1,13 +1,11 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
import 'package:core/utils/app_logger.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/user_name.dart';
|
||||
import 'package:model/account/authentication_type.dart';
|
||||
import 'package:model/account/password.dart';
|
||||
import 'package:model/account/personal_account.dart';
|
||||
import 'package:tmail_ui_user/features/login/data/model/authentication_info_cache.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/exceptions/authentication_exception.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/repository/account_repository.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/repository/authentication_repository.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/repository/credential_repository.dart';
|
||||
@@ -24,33 +22,25 @@ class AuthenticationInteractor {
|
||||
this._accountRepository
|
||||
);
|
||||
|
||||
Stream<Either<Failure, Success>> execute({Uri? baseUrl, UserName? userName, Password? password}) async* {
|
||||
Stream<Either<Failure, Success>> execute({
|
||||
required Uri baseUrl,
|
||||
required UserName userName,
|
||||
required Password password
|
||||
}) async* {
|
||||
try {
|
||||
yield Right(AuthenticationUserLoading());
|
||||
|
||||
if (baseUrl != null && userName != null && password != null) {
|
||||
final user = await authenticationRepository.authenticationUser(baseUrl, userName, password);
|
||||
await Future.wait([
|
||||
credentialRepository.saveBaseUrl(baseUrl),
|
||||
credentialRepository.storeAuthenticationInfo(AuthenticationInfoCache(userName.value, password.value)),
|
||||
_accountRepository.setCurrentAccount(PersonalAccount(
|
||||
userName.value,
|
||||
AuthenticationType.basic,
|
||||
isSelected: true
|
||||
))
|
||||
]);
|
||||
yield Right(AuthenticationUserSuccess(user));
|
||||
} else if (baseUrl == null) {
|
||||
yield Left(AuthenticationUserFailure(CanNotFoundBaseUrl()));
|
||||
} else if (userName == null) {
|
||||
yield Left(AuthenticationUserFailure(CanNotFoundUserName()));
|
||||
} else if (password == null) {
|
||||
yield Left(AuthenticationUserFailure(CanNotFoundPassword()));
|
||||
} else {
|
||||
yield Left(AuthenticationUserFailure(null));
|
||||
}
|
||||
final user = await authenticationRepository.authenticationUser(baseUrl, userName, password);
|
||||
await Future.wait([
|
||||
credentialRepository.saveBaseUrl(baseUrl),
|
||||
credentialRepository.storeAuthenticationInfo(AuthenticationInfoCache(userName.value, password.value)),
|
||||
_accountRepository.setCurrentAccount(PersonalAccount(
|
||||
userName.value,
|
||||
AuthenticationType.basic,
|
||||
isSelected: true
|
||||
))
|
||||
]);
|
||||
yield Right(AuthenticationUserSuccess(user));
|
||||
} catch (e) {
|
||||
logError('AuthenticationInteractor::execute(): $e');
|
||||
yield Left(AuthenticationUserFailure(e));
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user