Add crashlytics as app module dependacies

lib/data/Repo/employee_repo.dart

@@ -11,18 +11,19 @@ import '../services/employee_service.dart';
 class EmployeeRepo {
   final EmployeeService _employeeService;
   final UserStateNotifier _userStateNotifier;
+  final FirebaseCrashlytics _crashlytics;
   late BehaviorSubject<List<Employee>> _employeeController;
   StreamSubscription<List<Employee>>? _employeeStreamSubscription;
 
-  EmployeeRepo(this._employeeService, this._userStateNotifier) {
+  EmployeeRepo(this._employeeService, this._userStateNotifier, this._crashlytics) {
     _employeeController = BehaviorSubject<List<Employee>>();
     _employeeStreamSubscription = _employeeService
         .employees(_userStateNotifier.currentSpaceId!)
         .listen((value) {
       _employeeController.add(value);
     }, onError: (e, s) async {
       _employeeController.addError(e);
-      await FirebaseCrashlytics.instance.recordError(e, s);
+      await _crashlytics.recordError(e, s);
     });
   }
 
@@ -40,12 +41,14 @@ class EmployeeRepo {
   Future<void> reset() async {
     _employeeController = BehaviorSubject<List<Employee>>();
     await _employeeStreamSubscription?.cancel();
-    _employeeStreamSubscription =
-        _employeeService.employees(_userStateNotifier.currentSpaceId!).listen(
-      (value) {
-        _employeeController.add(value);
-      },
-    );
+    _employeeStreamSubscription = _employeeService
+        .employees(_userStateNotifier.currentSpaceId!)
+        .listen((value) {
+      _employeeController.add(value);
+    }, onError: (e, s) async {
+      _employeeController.addError(e);
+      await _crashlytics.recordError(e, s);
+    });
   }
 
   @disposeMethod

lib/data/Repo/leave_repo.dart

@@ -8,16 +8,17 @@ import 'package:rxdart/rxdart.dart';
 @LazySingleton()
 class LeaveRepo {
   final LeaveService _leaveService;
+  final FirebaseCrashlytics _crashlytics;
   late BehaviorSubject<List<Leave>> _leavesController;
   StreamSubscription<List<Leave>>? _leavesStreamSubscription;
 
-  LeaveRepo(this._leaveService) {
+  LeaveRepo(this._leaveService, this._crashlytics) {
     _leavesController = BehaviorSubject<List<Leave>>();
     _leavesStreamSubscription = _leaveService.leaves.listen((value) {
       _leavesController.add(value);
     }, onError: (e, s) async {
       _leavesController.addError(e);
-      await FirebaseCrashlytics.instance.recordError(e, s);
+      await _crashlytics.recordError(e, s);
     });
   }
 
@@ -40,11 +41,12 @@ class LeaveRepo {
   Future<void> reset() async {
     _leavesController = BehaviorSubject<List<Leave>>();
     await _leavesStreamSubscription?.cancel();
-    _leavesStreamSubscription = _leaveService.leaves.listen(
-      (value) {
-        _leavesController.add(value);
-      },
-    );
+    _leavesStreamSubscription = _leaveService.leaves.listen((value) {
+      _leavesController.add(value);
+    }, onError: (e, s) async {
+      _leavesController.addError(e);
+      await _crashlytics.recordError(e, s);
+    });
   }
 
   Stream<List<Leave>> userLeaveRequest(String uid) =>

lib/data/di/app_module.dart

@@ -2,6 +2,7 @@ import 'package:cloud_firestore/cloud_firestore.dart';
 import 'package:connectivity_plus/connectivity_plus.dart';
 import 'package:device_info_plus/device_info_plus.dart';
 import 'package:firebase_auth/firebase_auth.dart';
+import 'package:firebase_crashlytics/firebase_crashlytics.dart';
 import 'package:firebase_storage/firebase_storage.dart';
 import 'package:image_picker/image_picker.dart';
 import 'package:injectable/injectable.dart';
@@ -17,6 +18,8 @@ abstract class AppModule {
 
   ImagePicker get imagePicker => ImagePicker();
 
+  FirebaseCrashlytics get firebaseCrashlytics => FirebaseCrashlytics.instance;
+
   FirebaseStorage get firebaseStorage => FirebaseStorage.instance;
 
   FirebaseFirestore get firebaseFireStore => FirebaseFirestore.instance;