eduvia/workavia-mail-front
11
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Store and get fcm cache by AccountId

Browse Source 
(cherry picked from commit e327dff45a4fc67d0c5a2d2afe64fc4673e2eac1)
This commit is contained in:
dab246
2023-04-25 18:15:02 +07:00
committed by Dat Vu
parent eb27022a08
commit 550752a2a4
23 changed files with 130 additions and 107 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/push_notification/domain/repository/fcm_repository.dart
+3 -3
View File
@@ -21,11 +21,11 @@ abstract class FCMRepository {
}
);
Future<bool> storeStateToRefresh(TypeName typeName, jmap.State newState);
Future<void> storeStateToRefresh(AccountId accountId, TypeName typeName, jmap.State newState);
Future<jmap.State> getStateToRefresh(TypeName typeName);
Future<jmap.State> getStateToRefresh(AccountId accountId, TypeName typeName);
Future<bool> deleteStateToRefresh(TypeName typeName);
Future<void> deleteStateToRefresh(AccountId accountId, TypeName typeName);
Future<void> storeSubscription(FCMSubscription fcmSubscription);
lib/features/push_notification/domain/state/get_email_changes_to_push_notification_state.dart
+4 -2
View File
@@ -1,6 +1,7 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:model/email/presentation_email.dart';
class GetEmailChangesToPushNotificationLoading extends UIState {}
@@ -8,11 +9,12 @@ class GetEmailChangesToPushNotificationLoading extends UIState {}
class GetEmailChangesToPushNotificationSuccess extends UIState {
final List<PresentationEmail> emailList;
final AccountId accountId;
GetEmailChangesToPushNotificationSuccess(this.emailList);
GetEmailChangesToPushNotificationSuccess(this.accountId, this.emailList);
@override
List<Object> get props => [emailList];
List<Object> get props => [accountId, emailList];
}
class GetEmailChangesToPushNotificationFailure extends FeatureFailure {
lib/features/push_notification/domain/usecases/delete_email_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
import 'package:tmail_ui_user/features/push_notification/domain/state/delete_email_state_to_refresh_state.dart';
@@ -10,10 +11,10 @@ class DeleteEmailStateToRefreshInteractor {
DeleteEmailStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute() async* {
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right<Failure, Success>(DeleteEmailStateToRefreshLoading());
await _fcmRepository.deleteStateToRefresh(TypeName.emailType);
await _fcmRepository.deleteStateToRefresh(accountId, TypeName.emailType);
yield Right<Failure, Success>(DeleteEmailStateToRefreshSuccess());
} catch (e) {
yield Left<Failure, Success>(DeleteEmailStateToRefreshFailure(e));
lib/features/push_notification/domain/usecases/delete_mailbox_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
import 'package:tmail_ui_user/features/push_notification/domain/state/delete_mailbox_state_to_refresh_state.dart';
@@ -10,10 +11,10 @@ class DeleteMailboxStateToRefreshInteractor {
DeleteMailboxStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute() async* {
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right<Failure, Success>(DeleteMailboxStateToRefreshLoading());
await _fcmRepository.deleteStateToRefresh(TypeName.mailboxType);
await _fcmRepository.deleteStateToRefresh(accountId, TypeName.mailboxType);
yield Right<Failure, Success>(DeleteMailboxStateToRefreshSuccess());
} catch (e) {
yield Left<Failure, Success>(DeleteMailboxStateToRefreshFailure(e));
lib/features/push_notification/domain/usecases/get_email_changes_to_push_notification_interactor.dart
+1 -1
View File
@@ -37,7 +37,7 @@ class GetEmailChangesToPushNotificationInteractor {
?.map((email) => email.toPresentationEmail())
.toList() ?? List.empty();
yield Right<Failure, Success>(GetEmailChangesToPushNotificationSuccess(presentationEmailList));
yield Right<Failure, Success>(GetEmailChangesToPushNotificationSuccess(accountId, presentationEmailList));
} catch (e) {
yield Left<Failure, Success>(GetEmailChangesToPushNotificationFailure(e));
}
lib/features/push_notification/domain/usecases/get_email_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.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_email_state_to_refresh_state.dart';
@@ -10,10 +11,10 @@ class GetEmailStateToRefreshInteractor {
GetEmailStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute() async* {
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right<Failure, Success>(GetEmailStateToRefreshLoading());
final storedState = await _fcmRepository.getStateToRefresh(TypeName.emailType);
final storedState = await _fcmRepository.getStateToRefresh(accountId, TypeName.emailType);
yield Right<Failure, Success>(GetEmailStateToRefreshSuccess(storedState));
} catch (e) {
yield Left<Failure, Success>(GetEmailStateToRefreshFailure(e));
lib/features/push_notification/domain/usecases/get_mailbox_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.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_mailbox_state_to_refresh_state.dart';
@@ -10,10 +11,10 @@ class GetMailboxStateToRefreshInteractor {
GetMailboxStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute() async* {
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right<Failure, Success>(GetMailboxStateToRefreshLoading());
final storedState = await _fcmRepository.getStateToRefresh(TypeName.mailboxType);
final storedState = await _fcmRepository.getStateToRefresh(accountId, TypeName.mailboxType);
yield Right<Failure, Success>(GetMailboxStateToRefreshSuccess(storedState));
} catch (e) {
yield Left<Failure, Success>(GetMailboxStateToRefreshFailure(e));
lib/features/push_notification/domain/usecases/get_stored_email_delivery_state_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.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_stored_email_delivery_state.dart';
@@ -10,10 +11,10 @@ class GetStoredEmailDeliveryStateInteractor {
GetStoredEmailDeliveryStateInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute() async* {
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right<Failure, Success>(GetStoredEmailDeliveryStateLoading());
final storedState = await _fcmRepository.getStateToRefresh(TypeName.emailDelivery);
final storedState = await _fcmRepository.getStateToRefresh(accountId, TypeName.emailDelivery);
yield Right<Failure, Success>(GetStoredEmailDeliveryStateSuccess(storedState));
} catch (e) {
yield Left<Failure, Success>(GetStoredEmailDeliveryStateFailure(e));
lib/features/push_notification/domain/usecases/store_email_delivery_state_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
import 'package:tmail_ui_user/features/push_notification/domain/state/store_email_delivery_state.dart';
@@ -11,10 +12,10 @@ class StoreEmailDeliveryStateInteractor {
StoreEmailDeliveryStateInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute(jmap.State newState) async* {
Stream<Either<Failure, Success>> execute(AccountId accountId, jmap.State newState) async* {
try {
yield Right<Failure, Success>(StoreEmailDeliveryStateLoading());
await _fcmRepository.storeStateToRefresh(TypeName.emailDelivery, newState);
await _fcmRepository.storeStateToRefresh(accountId, TypeName.emailDelivery, newState);
yield Right<Failure, Success>(StoreEmailDeliveryStateSuccess());
} catch (e) {
yield Left<Failure, Success>(StoreEmailDeliveryStateFailure(e));
lib/features/push_notification/domain/usecases/store_email_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
import 'package:tmail_ui_user/features/push_notification/domain/state/store_email_state_to_refresh_state.dart';
@@ -11,10 +12,10 @@ class StoreEmailStateToRefreshInteractor {
StoreEmailStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute(jmap.State newState) async* {
Stream<Either<Failure, Success>> execute(AccountId accountId, jmap.State newState) async* {
try {
yield Right<Failure, Success>(StoreEmailStateToRefreshLoading());
await _fcmRepository.storeStateToRefresh(TypeName.emailType, newState);
await _fcmRepository.storeStateToRefresh(accountId, TypeName.emailType, newState);
yield Right<Failure, Success>(StoreEmailStateToRefreshSuccess());
} catch (e) {
yield Left<Failure, Success>(StoreEmailStateToRefreshFailure(e));
lib/features/push_notification/domain/usecases/store_mailbox_state_to_refresh_interactor.dart
+3 -2
View File
@@ -2,6 +2,7 @@ import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
import 'package:fcm/model/type_name.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
import 'package:tmail_ui_user/features/push_notification/domain/repository/fcm_repository.dart';
import 'package:tmail_ui_user/features/push_notification/domain/state/store_mailbox_state_to_refresh_state.dart';
@@ -11,10 +12,10 @@ class StoreMailboxStateToRefreshInteractor {
StoreMailboxStateToRefreshInteractor(this._fcmRepository);
Stream<Either<Failure, Success>> execute(jmap.State newState) async* {
Stream<Either<Failure, Success>> execute(AccountId accountId, jmap.State newState) async* {
try {
yield Right<Failure, Success>(StoreMailboxStateToRefreshLoading());
await _fcmRepository.storeStateToRefresh(TypeName.mailboxType, newState);
await _fcmRepository.storeStateToRefresh(accountId, TypeName.mailboxType, newState);
yield Right<Failure, Success>(StoreMailboxStateToRefreshSuccess());
} catch (e) {
yield Left<Failure, Success>(StoreMailboxStateToRefreshFailure(e));