From b7dacc655ad0cc3e265eeb3a3cbfc96b0466baad Mon Sep 17 00:00:00 2001 From: HuyNguyen Date: Thu, 29 Dec 2022 17:05:49 +0700 Subject: [PATCH] TF-1289: [Data] Implement GetSubscription in fcm datasource --- .../data/datasource/fcm_datasource.dart | 2 ++ .../data/datasource_impl/cache_fcm_datasource_impl.dart | 9 +++++++++ .../data/datasource_impl/fcm_datasource_impl.dart | 5 +++++ 3 files changed, 16 insertions(+) diff --git a/lib/features/push_notification/data/datasource/fcm_datasource.dart b/lib/features/push_notification/data/datasource/fcm_datasource.dart index 5ef1c5f5c..1b0238363 100644 --- a/lib/features/push_notification/data/datasource/fcm_datasource.dart +++ b/lib/features/push_notification/data/datasource/fcm_datasource.dart @@ -17,4 +17,6 @@ abstract class FCMDatasource { Future getFirebaseSubscriptionByDeviceId(String deviceId); Future registerNewToken(RegisterNewTokenRequest newTokenRequest); + + Future geSubscription(); } \ No newline at end of file diff --git a/lib/features/push_notification/data/datasource_impl/cache_fcm_datasource_impl.dart b/lib/features/push_notification/data/datasource_impl/cache_fcm_datasource_impl.dart index 4ae4b5c79..0cf843f2b 100644 --- a/lib/features/push_notification/data/datasource_impl/cache_fcm_datasource_impl.dart +++ b/lib/features/push_notification/data/datasource_impl/cache_fcm_datasource_impl.dart @@ -59,4 +59,13 @@ class CacheFCMDatasourceImpl extends FCMDatasource { _exceptionThrower.throwException(error); }); } + + @override + Future geSubscription() { + return Future.sync(() async { + return await _firebaseCacheManager.getSubscription(); + }).catchError((error) { + _exceptionThrower.throwException(error); + }); + } } \ No newline at end of file diff --git a/lib/features/push_notification/data/datasource_impl/fcm_datasource_impl.dart b/lib/features/push_notification/data/datasource_impl/fcm_datasource_impl.dart index 555540f77..aa10ba78c 100644 --- a/lib/features/push_notification/data/datasource_impl/fcm_datasource_impl.dart +++ b/lib/features/push_notification/data/datasource_impl/fcm_datasource_impl.dart @@ -53,4 +53,9 @@ class FcmDatasourceImpl extends FCMDatasource { Future storeSubscription(FCMSubscriptionCache fcmSubscriptionCache) { throw UnimplementedError(); } + + @override + Future geSubscription() { + throw UnimplementedError(); + } } \ No newline at end of file