From 68ebecf98ab9f2effaf7b097257d5a7c0175cfa2 Mon Sep 17 00:00:00 2001
From: "Aamir.Muhammad" <aamir.muhammad@cloudsolutions.com.sa>
Date: Tue, 22 Nov 2022 12:49:42 +0300
Subject: [PATCH] Chat Updates & Stability

---
 lib/provider/dashboard_provider_model.dart | 14 ++++++++++++
 lib/ui/landing/dashboard_screen.dart       | 26 +++++-----------------
 2 files changed, 19 insertions(+), 21 deletions(-)

diff --git a/lib/provider/dashboard_provider_model.dart b/lib/provider/dashboard_provider_model.dart
index e0c90c9..b785293 100644
--- a/lib/provider/dashboard_provider_model.dart
+++ b/lib/provider/dashboard_provider_model.dart
@@ -5,6 +5,7 @@ import 'package:mohem_flutter_app/api/chat/chat_api_client.dart';
 import 'package:mohem_flutter_app/api/dashboard_api_client.dart';
 import 'package:mohem_flutter_app/api/offers_and_discounts_api_client.dart';
 import 'package:mohem_flutter_app/app_state/app_state.dart';
+import 'package:mohem_flutter_app/classes/consts.dart';
 import 'package:mohem_flutter_app/classes/utils.dart';
 import 'package:mohem_flutter_app/config/routes.dart';
 import 'package:mohem_flutter_app/generated/locale_keys.g.dart';
@@ -24,6 +25,7 @@ import 'package:mohem_flutter_app/models/generic_response_model.dart';
 import 'package:mohem_flutter_app/models/itg/itg_response_model.dart';
 import 'package:mohem_flutter_app/models/offers_and_discounts/get_offers_list.dart';
 import 'package:mohem_flutter_app/widgets/dialogs/confirm_dialog.dart';
+import 'package:signalr_netcore/signalr_client.dart';
 
 /// Mix-in [DiagnosticableTreeMixin] to have access to [debugFillProperties] for the devtool
 // ignore: prefer_mixin
@@ -40,6 +42,7 @@ class DashboardProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
 
   //Chat
   bool isChatCounterLoding = true;
+  bool isChatHubLoding = true;
   int chatUConvCounter = 0;
 
   //Misssing Swipe
@@ -100,6 +103,7 @@ class DashboardProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
     leaveBalanceAccrual = null;
 
     isChatCounterLoding = true;
+    isChatHubLoding = true;
     chatUConvCounter = 0;
 
     ticketBalance = 0;
@@ -302,6 +306,16 @@ class DashboardProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
     }
   }
 
+  Future<HubConnection> getHubConnection() async {
+    HubConnection hub;
+    HttpConnectionOptions httpOp = HttpConnectionOptions(skipNegotiation: false, logMessageContent: true);
+    hub = HubConnectionBuilder()
+        .withUrl(ApiConsts.chatHubConnectionUrl + "?UserId=${AppState().chatDetails!.response!.id}&source=Web&access_token=${AppState().chatDetails!.response!.token}", options: httpOp)
+        .withAutomaticReconnect(retryDelays: <int>[2000, 5000, 10000, 20000]).build();
+    isChatHubLoding = false;
+    return hub;
+  }
+
   void notify() {
     notifyListeners();
   }
diff --git a/lib/ui/landing/dashboard_screen.dart b/lib/ui/landing/dashboard_screen.dart
index 52b5ade..2de3310 100644
--- a/lib/ui/landing/dashboard_screen.dart
+++ b/lib/ui/landing/dashboard_screen.dart
@@ -56,31 +56,15 @@ class _DashboardScreenState extends State<DashboardScreen> {
       data.getUserAutoLoginToken().whenComplete(() {
         buildHubConnection();
       });
-
       _onRefresh();
     });
   }
 
-  Future<void> buildHubConnection() async {
-    logger.d("Connnnnn Statred");
-    HttpConnectionOptions httpOp = HttpConnectionOptions(
-      skipNegotiation: false,
-      logMessageContent: true,
-    );
-    hubConnection = HubConnectionBuilder()
-        .withUrl(ApiConsts.chatHubConnectionUrl + "?UserId=${AppState().chatDetails!.response!.id}&source=Web&access_token=${AppState().chatDetails!.response!.token}", options: httpOp)
-        .withAutomaticReconnect(retryDelays: <int>[2000, 5000, 10000, 20000]).build();
-    hubConnection.onclose(({Exception? error}) {
-      logger.d("Con Closedddddd");
-    });
-    hubConnection.onreconnecting(({Exception? error}) {});
-    hubConnection.onreconnected(({String? connectionId}) {});
-
-    if (hubConnection.state != HubConnectionState.Connected) {
-      await hubConnection.start();
-    }
-
-
+  void buildHubConnection() async {
+    logger.d("Connection In Progresssss");
+    hubConnection = await data.getHubConnection();
+    await hubConnection.start();
+    logger.d("Connection  Done");
   }
 
   @override