TF-1289: [Domain] Add GetSubscription in reposiroty

lib/features/push_notification/domain/exceptions/fcm_exception.dart

@@ -8,4 +8,4 @@ class NotFoundEmailDeliveryStateException implements Exception {}
 
 class NotFoundFirebaseSubscriptionException implements Exception {}
 
-class NotFoundDeviceIdException implements Exception {}
+class NotFoundSubscriptionException implements Exception {}

lib/features/push_notification/domain/repository/fcm_repository.dart

@@ -28,4 +28,6 @@ abstract class FCMRepository {
   Future<FirebaseSubscription> getFirebaseSubscriptionByDeviceId(String deviceId);
 
   Future<FirebaseSubscription> registerNewToken(RegisterNewTokenRequest newTokenRequest);
+
+  Future<FCMSubscription> getSubscription();
 }

lib/features/push_notification/domain/state/get_fcm_subscription_local.dart

@@ -0,0 +1,25 @@
+
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:tmail_ui_user/features/push_notification/domain/model/fcm_subscription.dart';
+
+class GetFCMSubscriptionLocalLoading extends UIState {}
+
+class GetFCMSubscriptionLocalSuccess extends UIState {
+
+  final FCMSubscription fcmSubscription;
+
+  GetFCMSubscriptionLocalSuccess(this.fcmSubscription);
+
+  @override
+  List<Object> get props => [fcmSubscription];
+}
+
+class GetFCMSubscriptionLocalFailure extends FeatureFailure {
+  final dynamic exception;
+
+  GetFCMSubscriptionLocalFailure(this.exception);
+
+  @override
+  List<Object> get props => [exception];
+}

lib/features/push_notification/domain/usecases/get_fcm_subscription_local_interactor.dart

@@ -0,0 +1,21 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:dartz/dartz.dart';
+import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
+import 'package:tmail_ui_user/features/push_notification/domain/state/get_fcm_subscription_local.dart';
+
+class GetFCMSubscriptionLocalInteractor {
+  final FCMRepository _fcmRepository;
+
+  GetFCMSubscriptionLocalInteractor(this._fcmRepository);
+
+  Stream<Either<Failure, Success>> execute() async* {
+    try {
+      yield Right<Failure, Success>(GetFCMSubscriptionLocalLoading());
+      final _subscription = await _fcmRepository.getSubscription();
+      yield Right<Failure, Success>(GetFCMSubscriptionLocalSuccess(_subscription));
+    } catch (e) {
+      yield Left<Failure, Success>(GetFCMSubscriptionLocalFailure(e));
+    }
+  }
+}