diff --git a/lib/data/data_sources/token_local_data_source.dart b/lib/data/data_sources/token_local_data_source.dart index 4f5c0c8e..ddeba948 100644 --- a/lib/data/data_sources/token_local_data_source.dart +++ b/lib/data/data_sources/token_local_data_source.dart @@ -1,7 +1,6 @@ import 'package:flutter_secure_storage/flutter_secure_storage.dart'; import 'package:injectable/injectable.dart'; import 'package:on_time_front/domain/entities/token_entity.dart'; -import 'package:rxdart/subjects.dart'; abstract class TokenLocalDataSource { Future storeTokens(TokenEntity token); @@ -11,22 +10,12 @@ abstract class TokenLocalDataSource { Future getToken(); Future deleteToken(); - - Stream get authenticationStream; } @Injectable(as: TokenLocalDataSource) class TokenLocalDataSourceImpl implements TokenLocalDataSource { final storage = FlutterSecureStorage(); - late final _authenticationStreamController = BehaviorSubject.seeded( - false, - ); - - @override - Stream get authenticationStream => - _authenticationStreamController.asBroadcastStream(); - final accessTokenKey = 'accessToken'; final refreshTokenKey = 'refreshToken'; @@ -52,12 +41,10 @@ class TokenLocalDataSourceImpl implements TokenLocalDataSource { Future deleteToken() async { await storage.delete(key: accessTokenKey); await storage.delete(key: refreshTokenKey); - //_authenticationStreamController.add(false); } @override Future storeAuthToken(String token) async { await storage.write(key: accessTokenKey, value: token); - //_authenticationStreamController.add(true); } } diff --git a/lib/data/repositories/user_repository_impl.dart b/lib/data/repositories/user_repository_impl.dart index 9dddf5f9..b41571e7 100644 --- a/lib/data/repositories/user_repository_impl.dart +++ b/lib/data/repositories/user_repository_impl.dart @@ -25,13 +25,7 @@ class UserRepositoryImpl implements UserRepository { GoogleSignIn get googleSignIn => _googleSignIn; UserRepositoryImpl( - this._authenticationRemoteDataSource, this._tokenLocalDataSource) { - _tokenLocalDataSource.authenticationStream.listen((state) { - if (state) { - _userStreamController.add(const UserEntity.empty()); - } - }); - } + this._authenticationRemoteDataSource, this._tokenLocalDataSource); @override Future getUser() async {