diff --git a/clients/client-dart/CHANGELOG.md b/clients/client-dart/CHANGELOG.md index 4dcd5cb..d894181 100644 --- 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 index 6adc1a0..ef021d1 100644 --- 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 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 deleted file mode 100644 index 099b700..0000000 --- a/clients/client-dart/lib/src/status_codes.dart +++ /dev/null @@ -1,3 +0,0 @@ -class StatusCodes { - static const int ok = 1000; -} diff --git a/clients/client-dart/lib/src/transport.dart b/clients/client-dart/lib/src/transport.dart index 0a39da0..8986df9 100644 --- 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 index f740f14..0980c38 100644 --- 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