fix: implement pings for websocket on browser

kuzzleio · Dec 22, 2023 · 642afaf · 642afaf
1 parent 056a310
commit 642afaf
Show file tree

Hide file tree

Showing 5 changed files with 133 additions and 65 deletions.
diff --git a/lib/src/protocols/websocket.dart b/lib/src/protocols/websocket.dart
@@ -7,7 +7,7 @@ class WebSocketProtocol extends KuzzleWebSocket {
  bool autoReconnect = true,
  Duration reconnectionDelay = const Duration(seconds: 1),
  int reconnectionAttempts = 10,
- Duration? pingInterval,
+ Duration pingInterval = const Duration(seconds: 2),
  }) : super(
  uri,
  autoReconnect: autoReconnect,

diff --git a/lib/src/protocols/websocket_browser.dart b/lib/src/protocols/websocket_browser.dart
@@ -16,15 +16,16 @@ class KuzzleWebSocket extends KuzzleProtocol {
  bool autoReconnect = true,
  Duration reconnectionDelay = const Duration(seconds: 1),
  int reconnectionAttempts = 10,
- this.pingInterval,
+ required this.pingInterval,
  }) : super(uri,
  autoReconnect: autoReconnect,
  reconnectionDelay: reconnectionDelay,
  reconnectionAttempts: reconnectionAttempts);
 
  WebSocket? _webSocket;
  StreamSubscription? _subscription;
- Duration? pingInterval;
+ Duration pingInterval;
+ Timer? pingTimer;
 
  @override
  Future<void> protocolConnect() async {
@@ -42,6 +43,15 @@ class KuzzleWebSocket extends KuzzleProtocol {
 
  _subscription = _webSocket!.onMessage.listen(_handlePayload);
 
+ pingTimer?.cancel();
+ pingTimer = Timer.periodic(pingInterval, (timer) {
+ if (_webSocket != null && _webSocket!.readyState == WebSocket.OPEN) {
+ _webSocket!.sendString('{"p":1}');
+ } else {
+ timer.cancel();
+ }
+ });
+
  final onErrorSubscription =
  _webSocket!.onError.listen(_connected.completeError);
 

diff --git a/lib/src/protocols/websocket_io.dart b/lib/src/protocols/websocket_io.dart
@@ -15,15 +15,15 @@ class KuzzleWebSocket extends KuzzleProtocol {
  bool autoReconnect = true,
  Duration reconnectionDelay = const Duration(seconds: 1),
  int reconnectionAttempts = 10,
- this.pingInterval,
+ required this.pingInterval,
  }) : super(uri,
  autoReconnect: autoReconnect,
  reconnectionDelay: reconnectionDelay,
  reconnectionAttempts: reconnectionAttempts);
 
  WebSocket? _webSocket;
  StreamSubscription? _subscription;
- Duration? pingInterval;
+ Duration pingInterval;
 
  @override
  Future<void> protocolConnect() async {