From 283bf80243723335dcd5d0780721055e0bbded1a Mon Sep 17 00:00:00 2001 From: Hugo Pointcheval Date: Fri, 29 Mar 2024 21:01:19 +0100 Subject: [PATCH] fix(notification): port the new usecase syntax --- .../src/domain/usecases/init_cloud_messaging_use_case.dart | 4 ++-- .../src/domain/usecases/listen_notification_use_case.dart | 6 +++--- .../features/notifications/bloc/cloud_messaging_cubit.dart | 4 +--- 3 files changed, 6 insertions(+), 8 deletions(-) diff --git a/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/init_cloud_messaging_use_case.dart b/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/init_cloud_messaging_use_case.dart index 12632716..79f73190 100644 --- a/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/init_cloud_messaging_use_case.dart +++ b/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/init_cloud_messaging_use_case.dart @@ -17,12 +17,12 @@ import 'package:wyatt_architecture/wyatt_architecture.dart'; import 'package:wyatt_cloud_messaging_bloc_base/src/domain/repositories/cloud_messaging_repository.dart'; -class InitCloudmessagingUseCase extends AsyncUseCase { +class InitCloudmessagingUseCase extends NoParamsAsyncUseCase { InitCloudmessagingUseCase({ required CloudMessagingRepository notificationRepository, }) : _notificationRepository = notificationRepository; final CloudMessagingRepository _notificationRepository; @override - FutureOrResult execute(NoParam? params) => + FutureOrResult execute() => _notificationRepository.init(); } diff --git a/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/listen_notification_use_case.dart b/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/listen_notification_use_case.dart index 3d670f5d..14738a03 100644 --- a/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/listen_notification_use_case.dart +++ b/packages/wyatt_cloud_messaging_bloc_base/lib/src/domain/usecases/listen_notification_use_case.dart @@ -24,13 +24,13 @@ import 'package:wyatt_cloud_messaging_bloc_base/src/domain/repositories/cloud_me import 'package:wyatt_type_utils/wyatt_type_utils.dart'; class ListenNotificationUseCase - extends StreamUseCase { + extends NoParamsAsyncUseCase> { ListenNotificationUseCase({ required CloudMessagingRepository notificationRepository, }) : _notificationRepository = notificationRepository; final CloudMessagingRepository _notificationRepository; @override - FutureOrResult> execute(NoParam? params) async { + FutureOrResult> execute() async { Stream? notificationStream; final notificationStreamResponse = @@ -66,7 +66,7 @@ class ListenNotificationUseCase } if (notificationStream == null) { - return const Err(NotificationException('Cannot listen notifications')); + return Err(const NotificationException('Cannot listen notifications')); } return Ok(notificationStream); diff --git a/packages/wyatt_cloud_messaging_bloc_base/lib/src/features/notifications/bloc/cloud_messaging_cubit.dart b/packages/wyatt_cloud_messaging_bloc_base/lib/src/features/notifications/bloc/cloud_messaging_cubit.dart index ed8eb0f5..96ad6edf 100644 --- a/packages/wyatt_cloud_messaging_bloc_base/lib/src/features/notifications/bloc/cloud_messaging_cubit.dart +++ b/packages/wyatt_cloud_messaging_bloc_base/lib/src/features/notifications/bloc/cloud_messaging_cubit.dart @@ -18,11 +18,9 @@ import 'dart:async'; import 'package:equatable/equatable.dart'; import 'package:flutter_bloc/flutter_bloc.dart'; -import 'package:wyatt_architecture/wyatt_architecture.dart'; import 'package:wyatt_cloud_messaging_bloc_base/src/domain/entities/remote_notifications.dart'; import 'package:wyatt_cloud_messaging_bloc_base/src/domain/usecases/listen_notification_use_case.dart'; import 'package:wyatt_cloud_messaging_bloc_base/src/domain/usecases/subscribe_to_notification_topic_use_case.dart'; - import 'package:wyatt_cloud_messaging_bloc_base/src/domain/usecases/unsubscribe_from_notification_topic_use_case.dart'; part 'cloud_messaging_state.dart'; @@ -46,7 +44,7 @@ class CloudMessagingCubit extends Cubit { final OnNotification? handleNotification; Future listenNotification() async { - final notificaitons = await _listenNotification.execute(const NoParam()); + final notificaitons = await _listenNotification.execute(); if (notificaitons.isOk) { notificaitons.ok?.listen((notification) { emit(CloudmessagingState(notification));