✨ Chat messaging

lib/providers/account.dart

@@ -144,7 +144,7 @@ class AccountProvider extends GetxController {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) return;
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['passport'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);
 

lib/providers/auth.dart

@@ -6,6 +6,7 @@ import 'package:flutter_secure_storage/flutter_secure_storage.dart';
 import 'package:get/get.dart';
 import 'package:get/get_connect/http/src/request/request.dart';
 import 'package:solian/providers/account.dart';
+import 'package:solian/providers/chat.dart';
 import 'package:solian/services.dart';
 import 'package:oauth2/oauth2.dart' as oauth2;
 
@@ -98,6 +99,7 @@ class AuthProvider extends GetConnect {
 
     Get.find<AccountProvider>().connect();
     Get.find<AccountProvider>().notifyPrefetch();
+    Get.find<ChatProvider>().connect();
 
     return credentials!;
   }
@@ -105,6 +107,7 @@ class AuthProvider extends GetConnect {
   void signout() {
     _cacheUserProfileResponse = null;
 
+    Get.find<ChatProvider>().disconnect();
     Get.find<AccountProvider>().disconnect();
     Get.find<AccountProvider>().notifications.clear();
     Get.find<AccountProvider>().notificationUnread.value = 0;
@@ -121,7 +124,7 @@ class AuthProvider extends GetConnect {
       return _cacheUserProfileResponse!;
     }
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['passport'];
     client.httpClient.addAuthenticator(requestAuthenticator);
 

lib/providers/chat.dart

@@ -0,0 +1,67 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:get/get.dart';
+import 'package:solian/models/packet.dart';
+import 'package:solian/providers/auth.dart';
+import 'package:solian/services.dart';
+import 'package:web_socket_channel/io.dart';
+
+class ChatProvider extends GetxController {
+  RxBool isConnected = false.obs;
+  RxBool isConnecting = false.obs;
+
+  IOWebSocketChannel? websocket;
+
+  StreamController<NetworkPackage> stream = StreamController.broadcast();
+
+  void connect({noRetry = false}) async {
+    final AuthProvider auth = Get.find();
+    if (!await auth.isAuthorized) throw Exception('unauthorized');
+
+    if (auth.credentials == null) await auth.loadCredentials();
+
+    final uri = Uri.parse(
+      '${ServiceFinder.services['messaging']}/api/ws?tk=${auth.credentials!.accessToken}'
+          .replaceFirst('http', 'ws'),
+    );
+
+    isConnecting.value = true;
+
+    try {
+      websocket = IOWebSocketChannel.connect(uri);
+      await websocket?.ready;
+    } catch (e) {
+      if (!noRetry) {
+        await auth.refreshCredentials();
+        return connect(noRetry: true);
+      }
+    }
+
+    listen();
+
+    isConnected.value = true;
+    isConnecting.value = false;
+  }
+
+  void disconnect() {
+    websocket?.sink.close(WebSocketStatus.normalClosure);
+    isConnected.value = false;
+  }
+
+  void listen() {
+    websocket?.stream.listen(
+      (event) {
+        final packet = NetworkPackage.fromJson(jsonDecode(event));
+        stream.sink.add(packet);
+      },
+      onDone: () {
+        isConnected.value = false;
+      },
+      onError: (err) {
+        isConnected.value = false;
+      },
+    );
+  }
+}

lib/providers/content/attachment.dart

@@ -37,7 +37,7 @@ class AttachmentProvider extends GetConnect {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['paperclip'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);
 
@@ -76,7 +76,7 @@ class AttachmentProvider extends GetConnect {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['paperclip'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);
 
@@ -100,7 +100,7 @@ class AttachmentProvider extends GetConnect {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['paperclip'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);
 

lib/providers/content/channel.dart

@@ -7,7 +7,7 @@ class ChannelProvider extends GetxController {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['messaging'];
 
     final resp = await client.get('/api/channels/$realm/$alias');
@@ -22,7 +22,7 @@ class ChannelProvider extends GetxController {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['messaging'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);
 

lib/providers/content/realm.dart

@@ -7,7 +7,7 @@ class RealmProvider extends GetxController {
     final AuthProvider auth = Get.find();
     if (!await auth.isAuthorized) throw Exception('unauthorized');
 
-    final client = GetConnect();
+    final client = GetConnect(maxAuthRetries: 3);
     client.httpClient.baseUrl = ServiceFinder.services['passport'];
     client.httpClient.addAuthenticator(auth.requestAuthenticator);