feat(deriv_auth): [DERG-1396] akhil/1396/multi_user_level_authentication_poc_master

packages/deriv_auth/lib/features/auth/cubit/deriv_auth_cubit.dart

@@ -86,11 +86,23 @@ class DerivAuthCubit extends Cubit<DerivAuthState> implements DerivAuthIO {
   }
 
   @override
-  Future<void> tokenLogin(String token) async {
+  Future<void> tokenLogin(String token, {List<String>? tokenList}) async {
     emit(DerivAuthLoadingState());
-
+    List<String> accountTokens = <String>[];
+    if (tokenList == null) {
+      final List<AccountModel> accountList =
+          await authService.getLatestAccounts();
+      accountTokens = accountList
+          .where((AccountModel account) =>
+              account.token != null && token != account.token)
+          .map((AccountModel account) => account.token!)
+          .toList();
+    } else {
+      accountTokens = tokenList;
+    }
     await _tokenLoginRequest(
       token,
+      tokenList: accountTokens,
       accounts: await authService.getLatestAccounts(),
     );
   }
@@ -105,6 +117,8 @@ class DerivAuthCubit extends Cubit<DerivAuthState> implements DerivAuthIO {
         request: request,
         userAgent: userAgent,
       );
+
+      ///TODO (John): Check if this has to be reset for every account change
       final LandingCompanyEntity landingCompanyEntity =
           await authService.getLandingCompany(authorizeEntity.country);
       _isUserMigrated = _checkUserMigrated(authorizeEntity);
@@ -126,10 +140,11 @@ class DerivAuthCubit extends Cubit<DerivAuthState> implements DerivAuthIO {
   Future<void> _tokenLoginRequest(
     String token, {
     required List<AccountModel> accounts,
+    List<String>? tokenList,
   }) async {
     try {
-      final AuthorizeEntity authorizeEntity =
-          await authService.login(token, accounts: accounts);
+      final AuthorizeEntity authorizeEntity = await authService.login(token,
+          accounts: accounts, tokenList: tokenList);
       final LandingCompanyEntity landingCompanyEntity =
           await authService.getLandingCompany(authorizeEntity.country);
       _isUserMigrated = _checkUserMigrated(authorizeEntity);
@@ -152,18 +167,28 @@ class DerivAuthCubit extends Cubit<DerivAuthState> implements DerivAuthIO {
   Future<void> authorizeDefaultAccount() async {
     emit(DerivAuthLoadingState());
 
+    List<String> tokenList = <String>[];
+    final List<AccountModel> accountList =
+        await authService.getLatestAccounts();
     final String? defaultAccountToken =
         (await authService.getDefaultAccount())?.token;
 
     if (defaultAccountToken == null) {
       emit(DerivAuthLoggedOutState());
 
       return;
+    } else {
+      tokenList = accountList
+          .where((AccountModel account) =>
+              account.token != null && defaultAccountToken != account.token)
+          .map((AccountModel account) => account.token!)
+          .toList();
     }
 
     await _tokenLoginRequest(
       defaultAccountToken,
-      accounts: await authService.getLatestAccounts(),
+      accounts: accountList,
+      tokenList: tokenList,
     );
   }
 

packages/deriv_auth/lib/features/auth/deriv_auth_io.dart

@@ -27,7 +27,7 @@ abstract class DerivAuthIO {
   });
 
   /// Log user in with [token] after reset password or sign up.
-  Future<void> tokenLogin(String token);
+  Future<void> tokenLogin(String token, {List<String>? tokenList});
 
   /// Log user out.
   Future<void> logout();

packages/deriv_auth/lib/features/auth/repository/base_auth_repository.dart

@@ -5,7 +5,10 @@ import 'package:deriv_auth/core/models/landig_comany_model.dart';
 /// Interface of all authentication functions required from client.
 abstract class BaseAuthRepository {
   /// Authorize user with [token].
-  Future<AuthorizeResponseEntity> authorize(String? token);
+  Future<AuthorizeResponseEntity> authorize(
+    String? token, {
+    List<String>? tokenList,
+  });
 
   /// Client functionality after user logs in.
   Future<void> onLogin(AuthorizeEntity authorizeEntity);

packages/deriv_auth/lib/features/auth/services/base_auth_service.dart

@@ -15,6 +15,7 @@ abstract class BaseAuthService {
   Future<AuthorizeEntity> login(
     String token, {
     required List<AccountModel> accounts,
+    List<String>? tokenList,
     String? signupProvider,
     String? refreshToken,
   });

packages/deriv_auth/lib/features/auth/services/deriv_auth_service.dart

@@ -46,6 +46,7 @@ class DerivAuthService extends BaseAuthService {
     Function? onInvalidJwtToken,
   }) async {
     try {
+      List<String> _tokenList = <String>[];
       final String jwtToken = await jwtService.getJwtToken();
 
       final GetTokensResponseModel _response = await tokenService.getUserTokens(
@@ -59,10 +60,17 @@ class DerivAuthService extends BaseAuthService {
           _filterSupportedAccounts(_response.accounts);
 
       final String? _defaultAccountToken = _supportedAccounts.first.token;
-
+      if (_supportedAccounts.isNotEmpty && _defaultAccountToken != null) {
+        _tokenList = _supportedAccounts
+            .sublist(1)
+            .where((AccountModel account) => account.token != null)
+            .map((AccountModel account) => account.token!)
+            .toList();
+      }
       if (_defaultAccountToken != null) {
         return login(
           _defaultAccountToken,
+          tokenList: _tokenList.isEmpty ? null : _tokenList,
           accounts: _supportedAccounts,
           signupProvider: request.signupProvider,
           refreshToken: _response.refreshToken,
@@ -90,12 +98,14 @@ class DerivAuthService extends BaseAuthService {
   Future<AuthorizeEntity> login(
     String token, {
     required List<AccountModel> accounts,
+    List<String>? tokenList,
     String? signupProvider,
     String? refreshToken,
   }) async {
     try {
       final AuthorizeEntity? responseAuthorizeEntity =
-          (await authRepository.authorize(token)).authorize;
+          (await authRepository.authorize(token, tokenList: tokenList))
+              .authorize;
 
       _checkAuthorizeValidity(responseAuthorizeEntity);
 

packages/deriv_auth/test/features/auth/cubit/deriv_auth_cubit_test.dart

@@ -1,3 +1,4 @@
+import 'dart:async';
 import 'package:bloc_test/bloc_test.dart';
 import 'package:deriv_auth/core/exceptions/deriv_auth_exception.dart';
 import 'package:deriv_auth/core/models/account_model.dart';
@@ -32,7 +33,10 @@ void main() {
         expect(authCubit.output, isA<Stream<DerivAuthState>>());
       });
 
-      test('should emit [AuthLoggedOutState] for the first app start.', () {
+      test('should emit [AuthLoggedOutState] for the first app start.',
+          () async {
+        when(() => service.getLatestAccounts()).thenAnswer(
+            (_) => Future<List<AccountModel>>.value(<AccountModel>[]));
         when(() => service.getDefaultAccount())
             .thenAnswer((_) => Future<AccountModel?>.value());
 
@@ -42,20 +46,22 @@ void main() {
           isA<DerivAuthLoggedOutState>(),
         ];
 
-        expectLater(
+        unawaited(expectLater(
           authCubit.stream,
           emitsInOrder(expectedResponse),
-        );
+        ));
 
-        authCubit.authorizeDefaultAccount();
+        await authCubit.authorizeDefaultAccount();
 
+        verify(() => service.getLatestAccounts()).called(1);
         verify(() => service.getDefaultAccount()).called(1);
         verifyNever(
           () => service.login(any(), accounts: any(named: 'accounts')),
         );
       });
 
-      test('should emit [AuthLoggedInState] if there is default account.', () {
+      test('should emit [AuthLoggedInState] if there is default account.',
+          () async {
         when(() => service.getDefaultAccount())
             .thenAnswer((_) => Future<AccountModel?>.value(mockedAccountModel));
 
@@ -66,22 +72,24 @@ void main() {
         when(() => service.getLandingCompany(any())).thenAnswer((_) =>
             Future<LandingCompanyEntity>.value(const LandingCompanyEntity()));
 
-        when(() => service.login(any(), accounts: any(named: 'accounts')))
-            .thenAnswer((_) =>
-                Future<AuthorizeEntity>.value(mockedValidAuthorizeEntity));
+        when(() => service
+            .login(any(),
+                accounts: any(named: 'accounts'),
+                tokenList: <String>[])).thenAnswer(
+            (_) => Future<AuthorizeEntity>.value(mockedValidAuthorizeEntity));
 
         final List<TypeMatcher<DerivAuthState>> expectedResponse =
             <TypeMatcher<DerivAuthState>>[
           isA<DerivAuthLoadingState>(),
           isA<DerivAuthLoggedInState>(),
         ];
 
-        expectLater(
+        unawaited(expectLater(
           authCubit.stream,
           emitsInOrder(expectedResponse),
-        );
+        ));
 
-        authCubit.authorizeDefaultAccount();
+        await authCubit.authorizeDefaultAccount();
 
         verify(() => service.getDefaultAccount()).called(1);
       });
@@ -242,9 +250,11 @@ void main() {
             Future<List<AccountModel>>.value(
                 <AccountModel>[mockedAccountModel]));
 
-        when(() => service.login(any(), accounts: any(named: 'accounts')))
-            .thenAnswer((_) =>
-                Future<AuthorizeEntity>.value(mockedValidAuthorizeEntity));
+        when(() => service
+            .login(any(),
+                accounts: any(named: 'accounts'),
+                tokenList: <String>[])).thenAnswer(
+            (_) => Future<AuthorizeEntity>.value(mockedValidAuthorizeEntity));
 
         final List<TypeMatcher<DerivAuthState>> expectedResponse =
             <TypeMatcher<DerivAuthState>>[
@@ -260,10 +270,11 @@ void main() {
           emitsInOrder(expectedResponse),
         );
 
-        authCubit.tokenLogin(_token);
+        authCubit.tokenLogin(_token, tokenList: <String>[]);
 
         verify(
-          () => service.login(any(), accounts: any(named: 'accounts')),
+          () => service.login(any(),
+              accounts: any(named: 'accounts'), tokenList: <String>[]),
         ).called(1);
       });
 
@@ -296,7 +307,8 @@ void main() {
         authCubit.tokenLogin(_token);
 
         verify(
-          () => service.login(any(), accounts: any(named: 'accounts')),
+          () => service.login(any(),
+              accounts: any(named: 'accounts'), tokenList: <String>[]),
         ).called(1);
       });