feat: improve client

bancolombia · Feb 6, 2025 · ea9d8ed · ea9d8ed
1 parent 50bc599
commit ea9d8ed
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 9 deletions.
diff --git a/clients/client-dart/CHANGELOG.md b/clients/client-dart/CHANGELOG.md
@@ -1,4 +1,6 @@
 # CHANGELOG
+## [2.0.4] 
+- Fix reconnection with heartbeats issue
 ## [2.0.3] 
 - Improve logs
 - Refactor

diff --git a/clients/client-dart/lib/src/async_client.dart b/clients/client-dart/lib/src/async_client.dart
@@ -8,7 +8,6 @@ import 'package:web_socket_channel/io.dart';
 import 'async_config.dart';
 import 'channel_message.dart';
 import 'retry_timer.dart';
-import 'status_codes.dart';
 import 'transport.dart';
 
 /// Async Data Flow Low Level Client
@@ -217,7 +216,7 @@ class AsyncClient {
   Future<bool> disconnect() async {
     _log.finer('async-client. disconnect() called');
 
-    await _transport?.close(StatusCodes.ok, 'Client disconnect');
+    await _transport?.close(1000, 'Client disconnect');
     _connectRetryTimer.reset();
     _log.finer('async-client. async-client. disconnect() called end');
 

diff --git a/clients/client-dart/lib/src/status_codes.dart b/clients/client-dart/lib/src/status_codes.dart
diff --git a/clients/client-dart/lib/src/transport.dart b/clients/client-dart/lib/src/transport.dart
@@ -8,7 +8,6 @@ import 'binary_decoder.dart';
 import 'channel_message.dart';
 import 'json_decoder.dart';
 import 'message_decoder.dart';
-import 'status_codes.dart';
 
 class Transport {
   MessageDecoder msgDecoder = JsonDecoder();
@@ -116,7 +115,7 @@ class Transport {
     }
 
     _signalSocketClose(
-      _webSocketCh.closeCode ?? StatusCodes.ok,
+      _webSocketCh.closeCode ?? 1000,
       _webSocketCh.closeReason ?? '',
     );
   }
@@ -152,7 +151,8 @@ class Transport {
   void _abnormalClose(reason) {
     _log.warning('async-client. Abnormal Close');
     _closeWasClean = false;
-    _webSocketCh.sink.close(StatusCodes.ok, reason);
+    const heartbeatCode = 3051;
+    _webSocketCh.sink.close(heartbeatCode, reason);
   }
 
   String _makeRef() {

diff --git a/clients/client-dart/pubspec.yaml b/clients/client-dart/pubspec.yaml
@@ -1,6 +1,6 @@
 name: channel_sender_client
 description: Client for Async DataFlow Channel Sender
-version: 2.0.3
+version: 2.0.4
 homepage: https://github.com/bancolombia/async-dataflow
 repository: https://github.com/bancolombia/async-dataflow.git