From e94a8d9a5e86e291132df140d09c40be9d5c702b Mon Sep 17 00:00:00 2001
From: "Aamir.Muhammad" <aamir.muhammad@cloudsolutions.com.sa>
Date: Tue, 6 Dec 2022 10:57:56 +0300
Subject: [PATCH] Hub Connection Fix

---
 lib/provider/chat_provider_model.dart | 26 ++++++++++++--------------
 lib/ui/chat/chat_home.dart            |  2 +-
 lib/ui/landing/dashboard_screen.dart  |  4 ++--
 3 files changed, 15 insertions(+), 17 deletions(-)

diff --git a/lib/provider/chat_provider_model.dart b/lib/provider/chat_provider_model.dart
index b045bbb..0b522db 100644
--- a/lib/provider/chat_provider_model.dart
+++ b/lib/provider/chat_provider_model.dart
@@ -51,10 +51,8 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
   }
 
   Future<void> buildHubConnection() async {
-    hubConnection = await getHubConnection();
-    await hubConnection.start()!.then((value) {
-      print('-----------------------Hub Started For Chat------------------');
-    });
+    chatHubConnection = await getHubConnection();
+    await chatHubConnection.start();
   }
 
   Future<HubConnection> getHubConnection() async {
@@ -75,18 +73,18 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
   }
 
   void registerEvents() {
-    hubConnection.on("OnUpdateUserStatusAsync", changeStatus);
-    hubConnection.on("OnDeliveredChatUserAsync", onMsgReceived);
+    chatHubConnection.on("OnUpdateUserStatusAsync", changeStatus);
+    chatHubConnection.on("OnDeliveredChatUserAsync", onMsgReceived);
     // hubConnection.on("OnSeenChatUserAsync", onChatSeen);
     //hubConnection.on("OnUserTypingAsync", onUserTyping);
-    hubConnection.on("OnUserCountAsync", userCountAsync);
+    chatHubConnection.on("OnUserCountAsync", userCountAsync);
     //  hubConnection.on("OnUpdateUserChatHistoryWindowsAsync", updateChatHistoryWindow);
-    hubConnection.on("OnGetUserChatHistoryNotDeliveredAsync", chatNotDelivered);
-    hubConnection.on("OnUpdateUserChatHistoryStatusAsync", updateUserChatStatus);
+    chatHubConnection.on("OnGetUserChatHistoryNotDeliveredAsync", chatNotDelivered);
+    chatHubConnection.on("OnUpdateUserChatHistoryStatusAsync", updateUserChatStatus);
   }
 
   void getUserRecentChats() async {
-    if (hubConnection.state != HubConnectionState.Connected) {
+    if (chatHubConnection.state != HubConnectionState.Connected) {
       getUserAutoLoginToken().whenComplete(() async {
         await buildHubConnection();
         getUserRecentChats();
@@ -127,7 +125,7 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
   }
 
   Future invokeUserChatHistoryNotDeliveredAsync({required int userId}) async {
-    await hubConnection.invoke("GetUserChatHistoryNotDeliveredAsync", args: [userId]);
+    await chatHubConnection.invoke("GetUserChatHistoryNotDeliveredAsync", args: [userId]);
     return "";
   }
 
@@ -194,7 +192,7 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
 
   void updateUserChatHistoryStatusAsync(List data) {
     try {
-      hubConnection.invoke("UpdateUserChatHistoryStatusAsync", args: [data]);
+      chatHubConnection.invoke("UpdateUserChatHistoryStatusAsync", args: [data]);
     } catch (e) {
       throw e;
     }
@@ -202,7 +200,7 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
 
   void updateUserChatHistoryOnMsg(List data) {
     try {
-      hubConnection.invoke("UpdateUserChatHistoryStatusAsync", args: [data]);
+      chatHubConnection.invoke("UpdateUserChatHistoryStatusAsync", args: [data]);
     } catch (e) {
       throw e;
     }
@@ -486,7 +484,7 @@ class ChatProviderModel with ChangeNotifier, DiagnosticableTreeMixin {
 
     String chatData =
         '{"contant":"$msg","contantNo":"$contentNo","chatEventId":$chatEventId,"fileTypeId": $fileTypeId,"currentUserId":${AppState().chatDetails!.response!.id},"chatSource":1,"userChatHistoryLineRequestList":[{"isSeen":false,"isDelivered":false,"targetUserId":$targetUserId,"targetUserStatus":1}],"chatReplyId":$chatReplyId,"conversationId":"$chatCID"}';
-    await hubConnection.invoke("AddChatUserAsync", args: <Object>[json.decode(chatData)]);
+    await chatHubConnection.invoke("AddChatUserAsync", args: <Object>[json.decode(chatData)]);
   }
 
   void sendChatMessage(int targetUserId, String targetUserName, BuildContext context) async {
diff --git a/lib/ui/chat/chat_home.dart b/lib/ui/chat/chat_home.dart
index df03ba7..4e218e3 100644
--- a/lib/ui/chat/chat_home.dart
+++ b/lib/ui/chat/chat_home.dart
@@ -30,7 +30,7 @@ class _ChatHomeState extends State<ChatHome> {
     super.initState();
     data = Provider.of<ChatProviderModel>(context, listen: false);
     data.registerEvents();
-    if (hubConnection.state != HubConnectionState.Connected) {
+    if (chatHubConnection.state != HubConnectionState.Connected) {
       data.getUserAutoLoginToken().whenComplete(() async {
         await data.buildHubConnection();
         data.getUserRecentChats();
diff --git a/lib/ui/landing/dashboard_screen.dart b/lib/ui/landing/dashboard_screen.dart
index 8c1291a..f06a405 100644
--- a/lib/ui/landing/dashboard_screen.dart
+++ b/lib/ui/landing/dashboard_screen.dart
@@ -31,7 +31,7 @@ import 'package:provider/provider.dart';
 import 'package:pull_to_refresh/pull_to_refresh.dart';
 import 'package:signalr_netcore/signalr_client.dart';
 
-late HubConnection hubConnection;
+late HubConnection chatHubConnection;
 
 class DashboardScreen extends StatefulWidget {
   DashboardScreen({Key? key}) : super(key: key);
@@ -67,7 +67,7 @@ class _DashboardScreenState extends State<DashboardScreen> {
   @override
   void dispose() {
     super.dispose();
-    hubConnection.stop();
+    chatHubConnection.stop();
   }
 
   void _bHubCon() {