TF-1289: [Data] Implement DestroySubscription in fcm repository

This commit is contained in:
HuyNguyen
2022-12-29 17:53:58 +07:00
committed by Dat Vu
parent 4acc4ce5cb
commit 37e7013dd5
2 changed files with 33 additions and 0 deletions
@@ -3,8 +3,11 @@ import 'package:fcm/method/set/firebase_subscription_set_method.dart';
import 'package:fcm/method/set/firebase_subscription_set_response.dart';
import 'package:fcm/method/get/firebase_subscription_get_method.dart';
import 'package:fcm/method/get/firebase_subscription_get_response.dart';
import 'package:fcm/model/firebase_capability.dart';
import 'package:fcm/model/firebase_subscription.dart';
import 'package:jmap_dart_client/http/http_client.dart';
import 'package:jmap_dart_client/jmap/core/capability/capability_identifier.dart';
import 'package:jmap_dart_client/jmap/core/id.dart';
import 'package:jmap_dart_client/jmap/jmap_request.dart';
import 'package:tmail_ui_user/features/push_notification/domain/exceptions/fcm_exception.dart';
import 'package:tmail_ui_user/features/push_notification/domain/model/register_new_token_request.dart';
@@ -62,4 +65,29 @@ class FcmApi {
return firebaseSubscriptionSetResponse!.created![newTokenRequest.createRequestId]!;
}
Future<bool> destroySubscription(String subscriptionId) async {
final processingInvocation = ProcessingInvocation();
final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
final firebaseSubscriptionSetMethod = FirebaseSubscriptionSetMethod();
final firebaseSubscriptionSetInvocation = requestBuilder.invocation(firebaseSubscriptionSetMethod);
final response = await (requestBuilder
..usings({
CapabilityIdentifier.jmapCore,
FirebaseCapability.fcmIdentifier,
}))
.build()
.execute();
final firebaseSubscriptionSetResponse = response.parse<FirebaseSubscriptionSetResponse>(
firebaseSubscriptionSetInvocation.methodCallId,
FirebaseSubscriptionSetResponse.deserialize);
return Future.sync(() async {
return firebaseSubscriptionSetResponse?.destroyed?.contains(Id(subscriptionId)) == true;
}).catchError((error) {
throw error;
});
}
}
@@ -96,4 +96,9 @@ class FCMRepositoryImpl extends FCMRepository {
Future<void> storeSubscription(FCMSubscription fcmSubscription) {
return _fcmDatasource[DataSourceType.local]!.storeSubscription(fcmSubscription.toFCMSubscriptionCache());
}
@override
Future<bool> destroySubscription(String subscriptionId) {
return _fcmDatasource[DataSourceType.network]!.destroySubscription(subscriptionId);
}
}