48 lines
1.6 KiB
Dart
48 lines
1.6 KiB
Dart
import 'dart:async';
|
||
import 'dart:convert';
|
||
import 'package:chepuhagram/domain/services/api_service.dart';
|
||
import 'package:web_socket_channel/web_socket_channel.dart';
|
||
import 'package:web_socket_channel/status.dart' as status;
|
||
import 'package:chepuhagram/core/constants.dart';
|
||
|
||
class SocketService {
|
||
WebSocketChannel? _channel;
|
||
final StreamController<Map<String, dynamic>> _messageController =
|
||
StreamController<Map<String, dynamic>>.broadcast();
|
||
|
||
// Поток, который будут слушать провайдеры
|
||
Stream<Map<String, dynamic>> get messages => _messageController.stream;
|
||
|
||
Future<void> connect(ApiService apiService) async {
|
||
final token = await apiService.getAccessToken();
|
||
if (_channel != null) return; // Уже подключены
|
||
|
||
// В FastAPI эндпоинт обычно ожидает токен в URL или подзаголовке
|
||
final uri = Uri.parse("ws://${AppConstants.baseUrl}/ws?token=$token");
|
||
|
||
_channel = WebSocketChannel.connect(uri);
|
||
|
||
_channel!.stream.listen(
|
||
(data) {
|
||
final decoded = jsonDecode(data);
|
||
_messageController.add(decoded);
|
||
},
|
||
onError: (error) => _reconnect(apiService),
|
||
onDone: () => _reconnect(apiService),
|
||
);
|
||
}
|
||
|
||
Future<void> _reconnect(ApiService apiService) async {
|
||
_channel = null;
|
||
Future.delayed(const Duration(seconds: 5), () => connect(apiService));
|
||
}
|
||
|
||
void sendMessage(Map<String, dynamic> data) {
|
||
_channel?.sink.add(jsonEncode(data));
|
||
}
|
||
|
||
void disconnect() {
|
||
_channel?.sink.close(status.goingAway);
|
||
_channel = null;
|
||
}
|
||
} |