TF-1289: [Data] Implement GetSubscription in fcm repository
This commit is contained in:
@@ -49,4 +49,13 @@ class FCMCacheManager {
|
|||||||
return _fcmSubscriptionCacheClient.insertItem(
|
return _fcmSubscriptionCacheClient.insertItem(
|
||||||
FCMSubscriptionCache.keyCacheValue, fcmSubscriptionCache);
|
FCMSubscriptionCache.keyCacheValue, fcmSubscriptionCache);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Future<FCMSubscriptionCache> getSubscription() async {
|
||||||
|
final _fcmSubscription = await _fcmSubscriptionCacheClient.getItem(FCMSubscriptionCache.keyCacheValue);
|
||||||
|
if (_fcmSubscription == null) {
|
||||||
|
throw NotFoundSubscriptionException();
|
||||||
|
} else {
|
||||||
|
return _fcmSubscription;
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -86,6 +86,12 @@ class FCMRepositoryImpl extends FCMRepository {
|
|||||||
return _fcmDatasource[DataSourceType.network]!.registerNewToken(newTokenRequest);
|
return _fcmDatasource[DataSourceType.network]!.registerNewToken(newTokenRequest);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
Future<FCMSubscription> getSubscription() async {
|
||||||
|
final _fcmSubScription = await _fcmDatasource[DataSourceType.local]!.geSubscription();
|
||||||
|
return FCMSubscription(_fcmSubScription.deviceId, _fcmSubScription.subscriptionId);
|
||||||
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Future<void> storeSubscription(FCMSubscription fcmSubscription) {
|
Future<void> storeSubscription(FCMSubscription fcmSubscription) {
|
||||||
return _fcmDatasource[DataSourceType.local]!.storeSubscription(fcmSubscription.toFCMSubscriptionCache());
|
return _fcmDatasource[DataSourceType.local]!.storeSubscription(fcmSubscription.toFCMSubscriptionCache());
|
||||||
|
|||||||
Reference in New Issue
Block a user