add new fields in home screen and sse bloc file

Author: amitamrutiya

lib/Blocs/home_screen_bloc/home_screen_bloc.dart

@@ -1,3 +1,5 @@
+import 'dart:async';
+
 import 'package:bloc/bloc.dart';
 import 'package:equatable/equatable.dart';
 import 'package:flood_mobile/Model/feeds_content_model.dart';
@@ -20,6 +22,7 @@ class HomeScreenBloc extends Bloc<HomeScreenEvent, HomeScreenState> {
     on<SetTorrentListJsonEvent>(_setTorrentListJson);
     on<SetFeedsAndRulesListJsonEvent>(_setFeedsAndRulesListJson);
     on<UpdateTorrentListEvent>(_updateTorrentList);
+    on<UpdateNotificationCancelEvent>(_updateNotificationCancel);
   }
 
   // Handle the SetUnreadNotifications event
@@ -81,4 +84,10 @@ class HomeScreenBloc extends Bloc<HomeScreenEvent, HomeScreenState> {
       UpdateTorrentListEvent event, Emitter<HomeScreenState> emit) {
     emit(state.copyWith(torrentListJson: event.newTorrentListJson));
   }
+
+  // Handle the UpdateNotificationCancel event
+  FutureOr<void> _updateNotificationCancel(
+      UpdateNotificationCancelEvent event, Emitter<HomeScreenState> emit) {
+    emit(state.copyWith(notificationCancel: event.newNotificationCancel));
+  }
 }

lib/Blocs/home_screen_bloc/home_screen_event.dart

@@ -90,3 +90,12 @@ class UpdateTorrentListEvent extends HomeScreenEvent {
   @override
   List<Object> get props => [newTorrentListJson];
 }
+
+class UpdateNotificationCancelEvent extends HomeScreenEvent {
+  final Map<String, bool> newNotificationCancel;
+
+  UpdateNotificationCancelEvent({required this.newNotificationCancel});
+
+  @override
+  List<Object> get props => [newNotificationCancel];
+}

lib/Blocs/home_screen_bloc/home_screen_state.dart

@@ -13,6 +13,7 @@ class HomeScreenState extends Equatable {
   final List<FeedsContentsModel> rssFeedsContentsList;
   String upSpeed;
   String downSpeed;
+  final Map<String, bool> notificationCancel;
 
   HomeScreenState({
     required this.torrentList,
@@ -25,6 +26,7 @@ class HomeScreenState extends Equatable {
     required this.rssFeedsContentsList,
     required this.upSpeed,
     required this.downSpeed,
+    required this.notificationCancel,
   });
 
   HomeScreenState copyWith({
@@ -38,19 +40,20 @@ class HomeScreenState extends Equatable {
     List<FeedsContentsModel>? rssFeedsContentsList,
     String? upSpeed,
     String? downSpeed,
+    Map<String, bool>? notificationCancel,
   }) {
     return HomeScreenState(
-      torrentList: torrentList ?? this.torrentList,
-      torrentListJson: torrentListJson ?? this.torrentListJson,
-      unreadNotifications: unreadNotifications ?? this.unreadNotifications,
-      notificationModel: notificationModel ?? this.notificationModel,
-      rssFeedsListJson: rssFeedsListJson ?? this.rssFeedsListJson,
-      rssFeedsList: rssFeedsList ?? this.rssFeedsList,
-      rssRulesList: rssRulesList ?? this.rssRulesList,
-      rssFeedsContentsList: rssFeedsContentsList ?? this.rssFeedsContentsList,
-      upSpeed: upSpeed ?? this.upSpeed,
-      downSpeed: downSpeed ?? this.downSpeed,
-    );
+        torrentList: torrentList ?? this.torrentList,
+        torrentListJson: torrentListJson ?? this.torrentListJson,
+        unreadNotifications: unreadNotifications ?? this.unreadNotifications,
+        notificationModel: notificationModel ?? this.notificationModel,
+        rssFeedsListJson: rssFeedsListJson ?? this.rssFeedsListJson,
+        rssFeedsList: rssFeedsList ?? this.rssFeedsList,
+        rssRulesList: rssRulesList ?? this.rssRulesList,
+        rssFeedsContentsList: rssFeedsContentsList ?? this.rssFeedsContentsList,
+        upSpeed: upSpeed ?? this.upSpeed,
+        downSpeed: downSpeed ?? this.downSpeed,
+        notificationCancel: notificationCancel ?? this.notificationCancel);
   }
 
   @override
@@ -65,6 +68,7 @@ class HomeScreenState extends Equatable {
         rssFeedsContentsList,
         upSpeed,
         downSpeed,
+        notificationCancel,
       ];
 }
 
@@ -82,6 +86,7 @@ class HomeScreenInitial extends HomeScreenState {
           rssFeedsContentsList: [],
           upSpeed: '0 KB/s',
           downSpeed: '0 KB/s',
+          notificationCancel: {},
         );
 
   @override

lib/Blocs/sse_bloc/sse_bloc.dart

@@ -56,22 +56,20 @@ class SSEBloc extends Bloc<SSEEvent, SSEState> {
                           .torrentList
                           .length;
                   i++) {
-                EventHandlerApi.showNotification(i, event.context);
+                createTorrentDownloadNotification(i, event.context);
               }
               break;
             case Events.TORRENT_LIST_DIFF_CHANGE:
+              var homeScreenBloc =
+                  BlocProvider.of<HomeScreenBloc>(event.context, listen: false)
+                      .state;
               EventHandlerApi.updateFullTorrentList(
                   model: listenEvent, context: event.context);
               await Future.delayed(Duration.zero);
-              for (int i = 0;
-                  i <
-                      BlocProvider.of<HomeScreenBloc>(event.context,
-                              listen: false)
-                          .state
-                          .torrentList
-                          .length;
-                  i++) {
-                EventHandlerApi.showNotification(i, event.context);
+              for (int i = 0; i < homeScreenBloc.torrentList.length; i++) {
+                if (!homeScreenBloc.notificationCancel
+                    .containsKey(homeScreenBloc.torrentList[i].hash))
+                  await createTorrentDownloadNotification(i, event.context);
               }
               break;
             case Events.NOTIFICATION_COUNT_CHANGE:
@@ -91,7 +89,14 @@ class SSEBloc extends Bloc<SSEEvent, SSEState> {
                     .torrentList[j]
                     .status
                     .contains('complete')) {
-                  EventHandlerApi.showEventNotification(j, event.context);
+                  createDownloadFinishedNotification(j, event.context);
+                } else if (BlocProvider.of<HomeScreenBloc>(event.context,
+                        listen: false)
+                    .state
+                    .torrentList[j]
+                    .status
+                    .contains('error')) {
+                  createDownloadErrorNotification(j, event.context);
                 }
               }
               break;