add web socket

Author: br-programmer

lib/core/shared/data/config/dev_config.dart

@@ -5,7 +5,7 @@ import 'package:injectable/injectable.dart';
 @Injectable(as: Config)
 class DevConfig implements Config {
   @override
-  String get baseUrl => '';
+  String get baseUrl => 'api.ourglass.cc';
 
   @override
   bool get enableLogging => true;
@@ -14,6 +14,9 @@ class DevConfig implements Config {
   String get flavorName => dev.name;
 
   @override
-  // String get turnUrl => 'stun.dev.ourglass.cc';
   String get turnUrl => 'stun:stun.dev.ourglass.cc:3479';
+
+  @override
+  String get accesToken =>
+      'eyJhbGciOiJSUzI1NiIsImtpZCI6IkNEOENENEFCMUMzREY3MjgyM0UwM0M3ODMyRTlENTQ1MTYzQjU5QkRSUzI1NiIsIng1dCI6InpZelVxeHc5OXlnajREeDRNdW5WUlJZN1diMCIsInR5cCI6ImF0K2p3dCJ9.eyJpc3MiOiJodHRwczovL2FwaS5vdXJnbGFzcy5jYyIsIm5iZiI6MTY3MzU1NTc1NSwiaWF0IjoxNjczNTU1NzU1LCJleHAiOjE2NzM1NTkzNTUsImF1ZCI6WyJhdWRpb21hbmFnZXIiLCJjaGFubmVsIiwiY2hhdCIsImNvbW1lbnRzIiwiZmlsZW1hbmFnZXIiLCJmb2xsb3ciLCJmcmllbmRzIiwiaWRlbnRpdHkiLCJpbWFnZXNtYW5hZ2VyIiwibGFuZ3VhZ2VtYW5hZ2VyIiwibGl2ZWNvbmNlcnQiLCJsaXZlZXZlbnRtYW5hZ2VyIiwibm90aWZpY2F0aW9ubWFuYWdlciIsInBvc3R2aWRlbyIsInJlYWN0aW9ucyIsInNjaGVkdWxpbmciLCJ0ZXh0cG9zdCIsInRpZXIiLCJ1c2VycHJvZmlsZWRhdGFhZ2dyZWdhdGUiLCJ2aWRlb21hbmFnZXIiLCJ3YWxsYWdncmVnYXRlIl0sInNjb3BlIjpbImF1ZGlvbWFuYWdlci5mdWxsIiwiY2hhbm5lbC5mdWxsIiwiY2hhdC5mdWxsIiwiY29tbWVudHMuZnVsbCIsImZpbGVtYW5hZ2VyLmZ1bGwiLCJmb2xsb3cuZnVsbCIsImZyaWVuZHMuZnVsbCIsImlkZW50aXR5LmZ1bGwiLCJpbWFnZXNtYW5hZ2VyLmZ1bGwiLCJsYW5ndWFnZW1hbmFnZXIuZnVsbCIsImxpdmVjb25jZXJ0LmZ1bGwiLCJsaXZlZXZlbnRtYW5hZ2VyLmZ1bGwiLCJub3RpZmljYXRpb25tYW5hZ2VyLmZ1bGwiLCJvcGVuaWQiLCJwb3N0dmlkZW8uZnVsbCIsInByb2ZpbGUiLCJyZWFjdGlvbnMuZnVsbCIsInNjaGVkdWxpbmcuZnVsbCIsInN0YXRpc3RpY3MuZnVsbCIsInRleHRwb3N0LmZ1bGwiLCJ0aWVyLmZ1bGwiLCJ1c2VycHJvZmlsZWRhdGFhZ2dyZWdhdGUuZnVsbCIsInZpZGVvbWFuYWdlci5mdWxsIiwid2FsbGFnZ3JlZ2F0ZS5mdWxsIiwib2ZmbGluZV9hY2Nlc3MiXSwiYW1yIjpbInB3ZCJdLCJjbGllbnRfaWQiOiJmbHV0dGVyIiwic3ViIjoiZjg1Y2E5NzAtYjg0ZC00YjczLTgwZmItMGMzZWRiMmY4ODAzIiwiYXV0aF90aW1lIjoxNjczNTQ0NjA0LCJpZHAiOiJsb2NhbCIsImp0aSI6IkI2NDBCRjRDMDlBNjZCM0M5MzdBNjM4OEIyRDZBNEEzIn0.fh77k21QQyPArgKQtD2p-diufgzMVxB9alV49owIqlPB-A44FhAbT1KMIcPX2yYRQPOOnshQVk4qY7wKiFFKSEae0pnGfuUmuNBDK69qSJ48wgGYPaQTp4o-12VGiJYpuRmeqceu_KyR45ZE46YHmVCQrG5XoEu2nnRplPExNG4s61gTW1wljaONl6-4rZ49Zz9ptLYk91LwYNwT9HG_-HYFk3Jc6g1KCyS78s4aEuGgOun7cmjsocmDWoqHECpvXp7YNsgZ4jvd69EHTmRpYQi9fVzpDxIawgsyXmv8-8STNxHl5LiY6OAQZk8Xnd70bYLjb-lZUEupwRisxX-PUQ';
 }

lib/core/shared/data/config/prod_config.dart

@@ -15,4 +15,7 @@ class ProdConfig implements Config {
 
   @override
   String get turnUrl => '';
+
+  @override
+  String get accesToken => '';
 }

lib/core/shared/domain/config/i_config.dart

@@ -1,6 +1,7 @@
 abstract class Config {
   String get flavorName;
   String get baseUrl;
+  String get accesToken;
   String get turnUrl;
   bool get enableLogging;
 }

lib/features/home/data/repositories/web_rtc_repository.dart

@@ -8,6 +8,8 @@ import 'package:demo_webrtc/core/core.dart';
 import 'package:demo_webrtc/features/home/home.dart';
 import 'package:flutter_webrtc/flutter_webrtc.dart';
 import 'package:injectable/injectable.dart';
+import 'package:sdp_transform/sdp_transform.dart';
+import 'package:signalr_core/signalr_core.dart';
 
 @Injectable(as: IWebRTCRepository)
 class WebRtcRepository implements IWebRTCRepository {
@@ -19,9 +21,65 @@ class WebRtcRepository implements IWebRTCRepository {
   RTCPeerConnection? _peerConnection;
   MediaStream? _localStream;
 
+  HubConnection? _connection;
+
+  bool _offer = false;
+
   late final RTCVideoRenderer _localVideoRenderer;
   late final RTCVideoRenderer _remoteVideoRenderer;
 
+  @override
+  Future<void> initSockets() async {
+    try {
+      _connection ??= HubConnectionBuilder()
+          .withUrl(
+            Uri.https(_config.baseUrl, 'chat/messaging').toString(),
+            HttpConnectionOptions(
+              accessTokenFactory: _accessTokenFactory,
+            ),
+          )
+          .withAutomaticReconnect()
+          .build();
+      await _connection!.start();
+      _connection!.on('ReceiveMessage', _recivedMessage);
+    } catch (_) {
+      rethrow;
+    }
+  }
+
+  @override
+  Future<void> sendSdp(String value) async {
+    try {
+      await _connection?.invoke(
+        'Send',
+        args: [
+          '52A0C3A5-F2B2-4877-A184-08DAF413495A',
+          value,
+        ],
+      );
+    } catch (_) {
+      rethrow;
+    }
+  }
+
+  void _recivedMessage(List<dynamic>? messages) {
+    if (messages != null) {
+      final message = messages.first;
+      final sdp = message['message'] as String;
+      // final userFromUsername = message['userFromUsername'] as String;
+
+      _addToStream(RemoteSDPRecived(sdp));
+    }
+  }
+
+  Future<String?> _accessTokenFactory() {
+    try {
+      return Future.value(_config.accesToken);
+    } catch (_) {
+      return Future.value();
+    }
+  }
+
   @override
   Future<RTCVideoRenderer> initLocalRender() async {
     try {
@@ -55,6 +113,7 @@ class WebRtcRepository implements IWebRTCRepository {
   @override
   Future<void> close() async {
     await _localVideoRenderer.dispose();
+    await _connection?.stop();
   }
 
   Future<MediaStream> _getUserMedia() async {
@@ -63,7 +122,8 @@ class WebRtcRepository implements IWebRTCRepository {
         'audio': true,
         'video': {'facingMode': 'user'}
       };
-      _localStream = await navigator.mediaDevices.getUserMedia(mediaConstraints);
+      _localStream =
+          await navigator.mediaDevices.getUserMedia(mediaConstraints);
       _localVideoRenderer.srcObject = _localStream;
       _addToStream(LocalAudioTracks(_localStream!.getAudioTracks()));
       _addToStream(LocalVideoTracks(_localStream!.getVideoTracks()));
@@ -114,8 +174,7 @@ class WebRtcRepository implements IWebRTCRepository {
   Future<RTCPeerConnection> _createPeerConnection() async {
     final peerConnection = await createPeerConnection(
       _configuration,
-      // _offerSdpConstraints,
-      _loopbackConstraints,
+      _offerSdpConstraints,
     );
     await peerConnection.addStream(await _getUserMedia());
     peerConnection
@@ -129,6 +188,7 @@ class WebRtcRepository implements IWebRTCRepository {
   Future<String> createOffer() async {
     final description = await _peerConnection!.createOffer(_constraints);
     await _peerConnection!.setLocalDescription(description);
+    _offer = true;
     return _session(description);
   }
 
@@ -148,8 +208,7 @@ class WebRtcRepository implements IWebRTCRepository {
     // final sdp = write(parse(value), null);
     final description = RTCSessionDescription(
       value,
-      'answer',
-      // 'offer',
+      _offer ? 'answer' : 'offer',
     );
     // log(sdp);
     // log(description.toMap().toString());
@@ -170,14 +229,14 @@ class WebRtcRepository implements IWebRTCRepository {
 
   String _session(RTCSessionDescription description) {
     try {
+      final j2 = parse(description.sdp!);
+      log('$j2');
       return description.sdp!;
       // final j = jsonDecode(description.sdp!);
-      // final j2 = parse(description.sdp!);
       // print(j);
       // log('$j2');
       // return j2;
     } catch (e) {
-      print(e);
       rethrow;
     }
   }
@@ -191,3 +250,11 @@ class WebRtcRepository implements IWebRTCRepository {
         ],
       };
 }
+
+extension HubConnectionStateX on HubConnectionState {
+  bool get connecting => this == HubConnectionState.connecting;
+  bool get reconnecting => this == HubConnectionState.reconnecting;
+  bool get disconnecting => this == HubConnectionState.disconnecting;
+  bool get connected => this == HubConnectionState.connected;
+  bool get disconnected => this == HubConnectionState.disconnected;
+}

lib/features/home/domain/repositories/i_web_rtc_repository.dart

@@ -1,6 +1,7 @@
 import 'package:flutter_webrtc/flutter_webrtc.dart';
 
 abstract class IWebRTCRepository {
+  Future<void> initSockets();
   Future<RTCVideoRenderer> initLocalRender();
   Future<RTCVideoRenderer> initRemoteRender();
   Stream<WebRTCData> get onLocalWebRTC;
@@ -9,6 +10,7 @@ abstract class IWebRTCRepository {
   Future<String> createAnswer();
   Future<void> setRemoteDescription(String value);
   Future<void> addCandidate(String value);
+  Future<void> sendSdp(String value);
 }
 
 abstract class WebRTCData {}
@@ -36,3 +38,9 @@ class RemoteVideoTracks implements WebRTCData {
 
   final List<MediaStreamTrack> videoTracks;
 }
+
+class RemoteSDPRecived implements WebRTCData {
+  RemoteSDPRecived(this.sdp);
+
+  final String sdp;
+}

lib/features/home/presentation/bloc/home_bloc.dart

@@ -22,6 +22,7 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
     on<_Answer>(_answerToState);
     on<_Description>(_descriptionToState);
     on<_Candidate>(_candidateToState);
+    on<_SdpRecived>(_sdpRecivedToState);
   }
 
   final IWebRTCRepository _repository;
@@ -37,6 +38,11 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
 
   void init() {
     _controller = TextEditingController();
+    try {
+      _repository.initSockets();
+    } catch (_) {
+      print(_);
+    }
   }
 
   Future<void> _startToState(_, Emitter<HomeState> emit) async {
@@ -72,6 +78,9 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
         log('local-video-track: $videoTrack');
       }
     }
+    if (data is RemoteSDPRecived) {
+      add(HomeEvent.onSdpRecived(sdp: data.sdp));
+    }
   }
 
   Future<void> _remoteConnectToState(_, Emitter<HomeState> emit) async {
@@ -96,7 +105,7 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
   Future<void> _offerToState(_, Emitter<HomeState> emit) async {
     try {
       final session = await _repository.createOffer();
-      log(session);
+      await _repository.sendSdp(session);
     } catch (_) {
       print(_);
     }
@@ -105,28 +114,45 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
   Future<void> _answerToState(_, Emitter<HomeState> emit) async {
     try {
       final session = await _repository.createAnswer();
-      log(session);
+      await _repository.sendSdp(session);
     } catch (_) {
       print(_);
     }
   }
 
   Future<void> _descriptionToState(_, Emitter<HomeState> emit) async {
     try {
-      log(value);
-      await _repository.setRemoteDescription(value);
+      await _repository.setRemoteDescription(
+        state.sdpForDescription ?? state.sdpForSetCandidate!,
+      );
     } catch (_) {
       print(_);
     }
   }
 
   Future<void> _candidateToState(_, Emitter<HomeState> emit) async {
     try {
-      await _repository.addCandidate(value);
+      await _repository.addCandidate(
+        state.sdpForDescription ?? state.sdpForSetCandidate!,
+      );
     } catch (_) {
       print(_);
     }
   }
 
   String get value => _controller.text;
+
+  void _sdpRecivedToState(
+    _SdpRecived event,
+    Emitter<HomeState> emit,
+  ) {
+    final state = this.state.copyWith(
+          activeAnswer: true,
+          activeSetCandidate: true,
+          activeSetDescription: true,
+          sdpForDescription: event.sdp,
+          sdpForSetCandidate: event.sdp,
+        );
+    emit(state);
+  }
 }