✨ Websocket hearbeat
This commit is contained in:
@@ -46,6 +46,10 @@ class WebSocketService {
|
|||||||
final StreamController<WebSocketState> _statusStreamController =
|
final StreamController<WebSocketState> _statusStreamController =
|
||||||
StreamController<WebSocketState>.broadcast();
|
StreamController<WebSocketState>.broadcast();
|
||||||
Timer? _reconnectTimer;
|
Timer? _reconnectTimer;
|
||||||
|
Timer? _heartbeatTimer;
|
||||||
|
|
||||||
|
DateTime? _heartbeatAt;
|
||||||
|
Duration? _heartbeatDelay;
|
||||||
|
|
||||||
Stream<WebSocketPacket> get dataStream => _streamController.stream;
|
Stream<WebSocketPacket> get dataStream => _streamController.stream;
|
||||||
Stream<WebSocketState> get statusStream => _statusStreamController.stream;
|
Stream<WebSocketState> get statusStream => _statusStreamController.stream;
|
||||||
@@ -71,6 +75,7 @@ class WebSocketService {
|
|||||||
}
|
}
|
||||||
await _channel!.ready;
|
await _channel!.ready;
|
||||||
_statusStreamController.sink.add(WebSocketState.connected());
|
_statusStreamController.sink.add(WebSocketState.connected());
|
||||||
|
_scheduleHeartbeat();
|
||||||
_channel!.stream.listen(
|
_channel!.stream.listen(
|
||||||
(data) {
|
(data) {
|
||||||
final dataStr =
|
final dataStr =
|
||||||
@@ -80,6 +85,13 @@ class WebSocketService {
|
|||||||
log(
|
log(
|
||||||
"[WebSocket] Received packet: ${packet.type} ${packet.errorMessage}",
|
"[WebSocket] Received packet: ${packet.type} ${packet.errorMessage}",
|
||||||
);
|
);
|
||||||
|
if (packet.type == 'pong' && _heartbeatAt != null) {
|
||||||
|
var now = DateTime.now();
|
||||||
|
_heartbeatDelay = now.difference(_heartbeatAt!);
|
||||||
|
log(
|
||||||
|
"[WebSocket] Server respond last heartbeat for ${_heartbeatDelay!.inMilliseconds} ms",
|
||||||
|
);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
onDone: () {
|
onDone: () {
|
||||||
log('[WebSocket] Connection closed, attempting to reconnect...');
|
log('[WebSocket] Connection closed, attempting to reconnect...');
|
||||||
@@ -108,6 +120,19 @@ class WebSocketService {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void _scheduleHeartbeat() {
|
||||||
|
_heartbeatTimer?.cancel();
|
||||||
|
_heartbeatTimer = Timer.periodic(const Duration(seconds: 3), (_) {
|
||||||
|
_beatTheHeart();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
void _beatTheHeart() {
|
||||||
|
_heartbeatAt = DateTime.now();
|
||||||
|
log('[WebSocket] We\'re beating the heart! $_heartbeatAt');
|
||||||
|
sendMessage(jsonEncode(WebSocketPacket(type: 'ping', data: null)));
|
||||||
|
}
|
||||||
|
|
||||||
WebSocketChannel? get ws => _channel;
|
WebSocketChannel? get ws => _channel;
|
||||||
|
|
||||||
void sendMessage(String message) {
|
void sendMessage(String message) {
|
||||||
|
Reference in New Issue
Block a user