changes webrtc

Author: br-programmer

.metadata

@@ -4,7 +4,7 @@
 # This file should be version controlled.
 
 version:
-  revision: 135454af32477f815a7525073027a3ff9eff1bfd
+  revision: f1875d570e39de09040c8f79aa13cc56baab8db1
   channel: stable
 
 project_type: app
@@ -13,26 +13,11 @@ project_type: app
 migration:
   platforms:
     - platform: root
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-    - platform: android
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-    - platform: ios
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-    - platform: linux
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-    - platform: macos
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
+      create_revision: f1875d570e39de09040c8f79aa13cc56baab8db1
+      base_revision: f1875d570e39de09040c8f79aa13cc56baab8db1
     - platform: web
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-    - platform: windows
-      create_revision: 135454af32477f815a7525073027a3ff9eff1bfd
-      base_revision: 135454af32477f815a7525073027a3ff9eff1bfd
+      create_revision: f1875d570e39de09040c8f79aa13cc56baab8db1
+      base_revision: f1875d570e39de09040c8f79aa13cc56baab8db1
 
   # User provided section
 

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

@@ -1,12 +1,14 @@
 // ignore_for_file: use_setters_to_change_properties, use_late_for_private_fields_and_variables, inference_failure_on_collection_literal
 
 import 'dart:async';
+import 'dart:convert';
 import 'dart:developer';
 
 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';
 
 @Injectable(as: IWebRTCRepository)
 class WebRtcRepository implements IWebRTCRepository {
@@ -39,7 +41,6 @@ class WebRtcRepository implements IWebRTCRepository {
       _remoteVideoRenderer = RTCVideoRenderer();
       await _remoteVideoRenderer.initialize();
       _peerConnection = await _createPeerConnection();
-      await _createOffer();
       return _remoteVideoRenderer;
     } catch (_) {
       rethrow;
@@ -83,6 +84,7 @@ class WebRtcRepository implements IWebRTCRepository {
         'sdpSemantics': 'plan-b',
         'iceServers': [
           {'url': 'stun:stun.l.google.com:19302'}
+          // {'url': 'eturnal.stunturn.svc.cluster.local:3479'}
           // {'url': _config.turnUrl}
         ]
       };
@@ -124,10 +126,47 @@ class WebRtcRepository implements IWebRTCRepository {
     return peerConnection;
   }
 
-  Future<void> _createOffer() async {
-    final description = await _peerConnection!.createOffer(
-      {'offerToReceiveVideo': 1},
+  @override
+  Future<Map<String, dynamic>> createOffer() async {
+    final description = await _peerConnection!.createOffer(_constraints);
+    await _peerConnection!.setLocalDescription(description);
+    return _sesion(description);
+  }
+
+  @override
+  Future<Map<String, dynamic>> createAnswer() async {
+    final description = await _peerConnection!.createAnswer(_constraints);
+    await _peerConnection!.setLocalDescription(description);
+    return _sesion(description);
+  }
+
+  @override
+  Future<void> setRemoteDescription(String value) async {
+    final session = await jsonDecode(value) as Map<String, dynamic>;
+    final sdp = write(session, null);
+    final description = RTCSessionDescription(
+      sdp,
+      'answer',
+      //  : 'offer',
     );
-    _peerConnection!.setLocalDescription(description);
+    log(description.toMap().toString());
+    await _peerConnection!.setRemoteDescription(description);
   }
+
+  @override
+  Future<void> addCandidate(String value) async {
+    final session = await jsonDecode(value);
+    log((session['candidate'] as String?) ?? '');
+    final candidate = RTCIceCandidate(
+      session['candidate'] as String?,
+      session['sdpMid'] as String?,
+      session['sdpMlineIndex'] as int?,
+    );
+    await _peerConnection!.addCandidate(candidate);
+  }
+
+  Map<String, dynamic> _sesion(RTCSessionDescription description) =>
+      parse(description.sdp!);
+
+  Map<String, dynamic> get _constraints => {'offerToReceiveVideo': 1};
 }

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

@@ -5,6 +5,10 @@ abstract class IWebRTCRepository {
   Future<RTCVideoRenderer> initRemoteRender();
   Stream<WebRTCData> get onLocalWebRTC;
   Future<void> close();
+  Future<Map<String, dynamic>> createOffer();
+  Future<Map<String, dynamic>> createAnswer();
+  Future<void> setRemoteDescription(String value);
+  Future<void> addCandidate(String value);
 }
 
 abstract class WebRTCData {}

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

@@ -3,6 +3,7 @@ import 'dart:developer';
 
 import 'package:bloc/bloc.dart';
 import 'package:demo_webrtc/features/home/home.dart';
+import 'package:flutter/material.dart';
 import 'package:flutter_webrtc/flutter_webrtc.dart';
 import 'package:freezed_annotation/freezed_annotation.dart';
 import 'package:injectable/injectable.dart';
@@ -17,6 +18,10 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
   HomeBloc(this._repository) : super(HomeState.initial()) {
     on<_Start>(_startToState);
     on<_RemoteConnect>(_remoteConnectToState);
+    on<_Offer>(_offerToState);
+    on<_Answer>(_answerToState);
+    on<_Description>(_descriptionToState);
+    on<_Candidate>(_candidateToState);
   }
 
   final IWebRTCRepository _repository;
@@ -27,6 +32,13 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
   RTCVideoRenderer get localRender => _localRender;
   RTCVideoRenderer get remoteRender => _remoteRender;
 
+  late final TextEditingController _controller;
+  TextEditingController get controller => _controller;
+
+  void init() {
+    _controller = TextEditingController();
+  }
+
   Future<void> _startToState(_, Emitter<HomeState> emit) async {
     try {
       Wakelock.enable();
@@ -76,7 +88,47 @@ class HomeBloc extends Bloc<HomeEvent, HomeState> {
   Future<void> close() async {
     await _subscription.cancel();
     await _repository.close();
+    _controller.dispose();
     Wakelock.disable();
     return super.close();
   }
+
+  Future<void> _offerToState(_, Emitter<HomeState> emit) async {
+    try {
+      final session = await _repository.createOffer();
+      print('==============');
+      print(session);
+      print('==============');
+    } catch (_) {
+      print(_);
+    }
+  }
+
+  Future<void> _answerToState(_, Emitter<HomeState> emit) async {
+    try {
+      final session = await _repository.createAnswer();
+      print(session);
+    } catch (_) {
+      print(_);
+    }
+  }
+
+  Future<void> _descriptionToState(_, Emitter<HomeState> emit) async {
+    try {
+      print(value);
+      await _repository.setRemoteDescription(value);
+    } catch (_) {
+      print(_);
+    }
+  }
+
+  Future<void> _candidateToState(_, Emitter<HomeState> emit) async {
+    try {
+      await _repository.addCandidate(value);
+    } catch (_) {
+      print(_);
+    }
+  }
+
+  String get value => _controller.text;
 }