stream

packages/user_repository/lib/src/firebase_user_repository.dart

@@ -1,3 +1,4 @@
+import 'dart:async';
 import 'dart:developer';
 import 'dart:io';
 
@@ -9,21 +10,46 @@ import 'entities/entities.dart';
 import 'user_repo.dart';
 
 class FirebaseUserRepository implements UserRepository {
-  FirebaseUserRepository({
-    FirebaseAuth? firebaseAuth,
-  }) : _firebaseAuth = firebaseAuth ?? FirebaseAuth.instance;
-
   final FirebaseAuth _firebaseAuth;
   final usersCollection = FirebaseFirestore.instance.collection('users');
+  final StreamController<MyUser?> _userStreamController =
+      StreamController<MyUser?>.broadcast();
 
-  @override
-  Stream<User?> get user {
-    return _firebaseAuth.authStateChanges().map((firebaseUser) {
-      final user = firebaseUser;
-      return user;
+  FirebaseUserRepository(this._firebaseAuth) {
+    _firebaseAuth.userChanges().listen((user) async {
+      if (user != null) {
+        try {
+          final myUser = await getMyUser(user.uid);
+          _userStreamController.add(myUser);
+        } catch (e) {
+          log('Error en FirebaseUserRepository ${e.toString()}');
+          _userStreamController.add(null);
+        }
+      } else {
+        _userStreamController.add(null);
+      }
+    });
+
+    this.streamUser().listen((event) {
+      log('xd - : ${event}');
     });
   }
 
+  // Stream<MyUser?> get user => _userStreamController.stream;
+
+  @override
+  Stream<MyUser?> streamUser() {
+    return _userStreamController.stream;
+  }
+
+  // @override
+  // Stream<User?> get user {
+  //   return _firebaseAuth.authStateChanges().map((firebaseUser) {
+  //     final user = firebaseUser;
+  //     return user;
+  //   });
+  // }
+
   // Sign up
   @override
   Future<MyUser> signUp(MyUser myUser, String password) async {

packages/user_repository/lib/src/user_repo.dart

@@ -3,7 +3,8 @@ import 'package:firebase_auth/firebase_auth.dart';
 import '../user_repository.dart';
 
 abstract class UserRepository {
-  Stream<User?> get user;
+  // Stream<User?> get user;
+  Stream<MyUser?> streamUser();
 
   Future<void> signIn(String email, String password);