feat: add support to latest flutter version

.github/workflows/release.yml

@@ -44,7 +44,7 @@ jobs:
           future_release: ${{ needs.auto-gen-tag.outputs.tag }}
           since_tag: ${{ steps.get_latest_release.outputs.release }}
       - name: Upload changelog
-        uses: actions/upload-artifact@v2
+        uses: actions/upload-artifact@v4
         with:
           name: changelog
           path: CHANGELOG.md
@@ -57,7 +57,7 @@ jobs:
     steps:
       - run: echo ${{needs.auto-gen-tag.outputs.tag}}
       - name: Download changelog
-        uses: actions/download-artifact@v2
+        uses: actions/download-artifact@v4
         with:
           name: changelog
       - name: Draft release with changelog
@@ -80,7 +80,7 @@ jobs:
       - uses: actions/checkout@v3
       - uses: subosito/flutter-action@v2
         with:
-          flutter-version: '3.7.8'
+          flutter-version: '3.27.0'
       - name: Install dependencies
         run: flutter pub get
       - name: Run tests
@@ -95,7 +95,7 @@ jobs:
       - name: Install Flutter
         uses: subosito/flutter-action@v2
         with:
-          flutter-version: '3.7.8'
+          flutter-version: '3.27.0'
       - name: Check Publish Warnings
         run: dart pub publish --dry-run
       - name: Publish

.github/workflows/tests.yml

@@ -17,7 +17,7 @@ jobs:
       - uses: actions/checkout@v3
       - uses: subosito/flutter-action@v2
         with:
-          flutter-version: '3.7.8'
+          flutter-version: '3.27.0'
       - name: Install dependencies
         run: flutter pub get
       - name: Run tests

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 0.0.27
+
+- Upgraded Lime version from 0.0.25 to 0.0.26 and add support to latest flutter stable version.
+
 ## 0.0.26
 
 - Upgraded Lime version from 0.0.24 to 0.0.25.

lib/blip_sdk.dart

@@ -1,6 +1,7 @@
-library blip_sdk;
+library;
 
 export 'package:lime/lime.dart';
+
 export 'src/application.dart' show Application;
 export 'src/client.dart' show Client;
 export 'src/client_builder.dart' show ClientBuilder;

lib/src/client.dart

@@ -29,7 +29,7 @@ class Client {
   final _extensions = <ExtensionType, BaseExtension>{};
 
   late StreamController<bool> onConnectionDone;
-  var onListeningChanged = StreamController<bool>();
+  var onListeningChanged = StreamController<bool>.broadcast();
 
   bool _listening = false;
   bool _closing = false;
@@ -91,7 +91,7 @@ class Client {
     );
 
     final session = await _clientChannel.establishSession(
-      application.identifier + '@' + application.domain,
+      '${application.identifier}@${application.domain}',
       application.instance,
       application.authentication,
     );
@@ -103,7 +103,7 @@ class Client {
       ],
     );
 
-    _listening = true;
+    listening = true;
     _connectionTryCount = 0;
 
     return session;
@@ -113,7 +113,7 @@ class Client {
   void _initializeClientChannel() {
     // Allows Take an action when the connection to the server is closed
     transport.onClose.stream.listen((event) async {
-      _listening = false;
+      listening = false;
       if (!_closing) {
         // Use an exponential backoff for the timeout
         num timeout = 100 * pow(2, _connectionTryCount);
@@ -283,19 +283,11 @@ class Client {
   Future<Session?> close() async {
     Session? result;
     _closing = true;
-
     if (_clientChannel.state == SessionState.established &&
         transport.socket?.closeCode == null) {
       result = await _clientChannel.sendFinishingSession();
     }
 
-    onListeningChanged.close();
-    onListeningChanged = StreamController<bool>();
-
-    _clientChannel.onConnectionDone.close();
-    _clientChannel.onConnectionDone = StreamController<bool>();
-    onConnectionDone = _clientChannel.onConnectionDone;
-
     await transport.close();
 
     return result;
@@ -475,33 +467,24 @@ class Client {
 
   /// Allows to get a extension
   T _getExtension<T extends BaseExtension>(ExtensionType type, String to) {
-    var _extension = _extensions[type];
-    if (_extension == null) {
+    var extension = _extensions[type];
+    if (extension == null) {
       switch (type) {
         case ExtensionType.media:
-          _extension = MediaExtension(this, to);
+          extension = MediaExtension(this, to);
           break;
       }
 
-      _extensions[type] = _extension;
+      _extensions[type] = extension;
     }
-    return _extension as T;
+    return extension as T;
   }
 
   /// Returns a media extension
   MediaExtension get media =>
       _getExtension<MediaExtension>(ExtensionType.media, application.domain);
 
   Future<void> _onConnect() async {
-    transport.onEnvelope?.close();
-    transport.onEnvelope = StreamController<Map<String, dynamic>>();
-
-    transport.onConnectionDone?.close();
-    transport.onConnectionDone = StreamController<bool>();
-
-    transport.onClose.close();
-    transport.onClose = StreamController<bool>();
-
     _clientChannel = ClientChannel(transport);
 
     _initializeClientChannel();

lib/src/extensions/media/media.extension.dart

@@ -1,25 +1,53 @@
 import 'package:lime/lime.dart';
 
-import '../../client.dart';
 import '../base.extension.dart';
 import 'uri_templates.dart';
 
 const postmasterName = 'postmaster';
 const postmasterDomain = 'media';
 
 class MediaExtension extends BaseExtension {
-  MediaExtension(final Client client, final String domain)
-      : super(client,
-            to: Node(
-                name: postmasterName, domain: '$postmasterDomain.$domain'));
+  MediaExtension(super.client, final String domain)
+      : super(
+          to: Node(
+            name: postmasterName,
+            domain: '$postmasterDomain.$domain',
+          ),
+        );
 
   Future<Command> getUploadToken({bool secure = false}) {
-    return processCommand(createGetCommand(
-        buildResourceQuery(UriTemplates.mediaUpload, {'secure': secure})));
+    return processCommand(
+      buildUploadTokenComand(
+        secure: secure,
+      ),
+    );
+  }
+
+  Command buildUploadTokenComand({bool secure = false}) {
+    return createGetCommand(
+      buildResourceQuery(
+        UriTemplates.mediaUpload,
+        {
+          'secure': secure,
+        },
+      ),
+    );
   }
 
   Future<Command> refreshMedia(id) {
     return processCommand(
-        createGetCommand(buildUri(UriTemplates.refreshMedia, [id])));
+      buildRefreshMediaCommand(id),
+    );
+  }
+
+  Command buildRefreshMediaCommand(id) {
+    return createGetCommand(
+      buildUri(
+        UriTemplates.refreshMedia,
+        [
+          id,
+        ],
+      ),
+    );
   }
 }