flutter-webrtc · cloudwebrtc · Jan 20, 2021 · Jul 4, 2020 · Jul 4, 2020 · Jul 4, 2020
diff --git a/.clang-format b/.clang-format
@@ -0,0 +1,12 @@
+# Defines the Chromium style for automatic reformatting.
+# http://clang.llvm.org/docs/ClangFormatStyleOptions.html
+BasedOnStyle: Chromium
+# This defaults to 'Auto'. Explicitly set it for a while, so that
+# 'vector<vector<int> >' in existing files gets formatted to
+# 'vector<vector<int>>'. ('Auto' means that clang-format will only use
+# 'int>>' if the file already contains at least one such instance.)
+Standard: Cpp11
+SortIncludes: true
+---
+Language: ObjC
+ColumnLimit: 100
diff --git a/README.md b/README.md
@@ -8,8 +8,8 @@ WebRTC plugin for Flutter Mobile/Desktop/Web
 
 | Feature | Android | iOS | [Web](https://flutter.dev/web) | macOS | Windows | Linux | [Fuchsia](https://fuchsia.googlesource.com/) |
 | :-------------: | :-------------:| :-----: | :-----: | :-----: | :-----: | :-----: | :-----: |
-| Audio/Video | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | [WIP] | [WIP] | |
-| Data Channel | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | [WIP] | [WIP] | |
+| Audio/Video | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | [WIP] | |
+| Data Channel | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | [WIP] | |
 | Screen Capture | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | | | | |
 | Unified-Plan | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | | | |
 | Simulcast | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | | | |

diff --git a/example/lib/src/loopback_sample.dart b/example/lib/src/loopback_sample.dart
@@ -89,7 +89,7 @@ class _MyAppState extends State<LoopBackSample> {
 
   void _onAddStream(MediaStream stream) {
     print('New stream: ' + stream.id);
-    //_remoteRenderer.srcObject = stream;
+    _remoteRenderer.srcObject = stream;
   }
 
   void _onRemoveStream(MediaStream stream) {
@@ -175,7 +175,7 @@ class _MyAppState extends State<LoopBackSample> {
       _localStream =
           await navigator.mediaDevices.getUserMedia(mediaConstraints);
       _localRenderer.srcObject = _localStream;
-
+      await _peerConnection.addStream(_localStream);
       /* old API
       await _peerConnection.addStream(_localStream);
       // Unified-Plan
@@ -184,13 +184,13 @@ class _MyAppState extends State<LoopBackSample> {
       });
       */
       // or
-
+      /*
       await _peerConnection.addTransceiver(
         track: _localStream.getAudioTracks()[0],
         init: RTCRtpTransceiverInit(
             direction: TransceiverDirection.SendRecv, streams: [_localStream]),
       );
-
+      */
       /*
       // ignore: unused_local_variable
       var transceiver = await _peerConnection.addTransceiver(
@@ -200,6 +200,7 @@ class _MyAppState extends State<LoopBackSample> {
       );
       */
 
+      /*
       // Unified-Plan Simulcast
       await _peerConnection.addTransceiver(
           track: _localStream.getVideoTracks()[0],
@@ -227,7 +228,7 @@ class _MyAppState extends State<LoopBackSample> {
               ),
             ],
           ));
-      /*
+
       await _peerConnection.addTransceiver(
           kind: RTCRtpMediaType.RTCRtpMediaTypeVideo);
       await _peerConnection.addTransceiver(

diff --git a/lib/src/native/media_stream_impl.dart b/lib/src/native/media_stream_impl.dart
@@ -21,13 +21,13 @@ class MediaStreamNative extends MediaStream {
 
   void setMediaTracks(List<dynamic> audioTracks, List<dynamic> videoTracks) {
     _audioTracks.clear();
-    audioTracks.forEach((track) {
+    audioTracks?.forEach((track) {
       _audioTracks.add(MediaStreamTrackNative(
           track['id'], track['label'], track['kind'], track['enabled']));
     });
 
     _videoTracks.clear();
-    videoTracks.forEach((track) {
+    videoTracks?.forEach((track) {
       _videoTracks.add(MediaStreamTrackNative(
           track['id'], track['label'], track['kind'], track['enabled']));
     });

diff --git a/lib/src/native/rtc_video_view_impl.dart b/lib/src/native/rtc_video_view_impl.dart
@@ -51,13 +51,14 @@ class RTCVideoView extends StatelessWidget {
                 return SizedBox(
                   width: constraints.maxHeight * value.aspectRatio,
                   height: constraints.maxHeight,
-                  child: value.renderVideo ? child : Container(),
+                  child: child,
                 );
               },
               child: Transform(
                 transform: Matrix4.identity()..rotateY(mirror ? -pi : 0.0),
                 alignment: FractionalOffset.center,
-                child: videoRenderer.textureId != null
+                child: videoRenderer.textureId != null &&
+                        videoRenderer.srcObject != null
                     ? Texture(
                         textureId: videoRenderer.textureId,
                         filterQuality: filterQuality,

diff --git a/macos/WebRTC.framework/Headers b/macos/WebRTC.framework/Headers
diff --git a/macos/WebRTC.framework/Headers b/macos/WebRTC.framework/Headers
@@ -0,0 +1 @@
+Versions/Current/Headers
diff --git a/macos/WebRTC.framework/Modules b/macos/WebRTC.framework/Modules
diff --git a/macos/WebRTC.framework/Modules b/macos/WebRTC.framework/Modules
@@ -0,0 +1 @@
+Versions/Current/Modules
diff --git a/macos/WebRTC.framework/Resources b/macos/WebRTC.framework/Resources
diff --git a/macos/WebRTC.framework/Resources b/macos/WebRTC.framework/Resources
@@ -0,0 +1 @@
+Versions/Current/Resources
diff --git a/pubspec.yaml b/pubspec.yaml
@@ -26,3 +26,5 @@ flutter:
         pluginClass: FlutterWebRTCPlugin
       macos:
         pluginClass: FlutterWebRTCPlugin
+      windows:
+        pluginClass: FlutterWebRTCPlugin
diff --git a/windows/.gitignore b/windows/.gitignore
@@ -0,0 +1,4 @@
+flutter/
+
+# Visual Studio files
+*.user
diff --git a/windows/CMakeLists.txt b/windows/CMakeLists.txt
@@ -0,0 +1,46 @@
+cmake_minimum_required(VERSION 3.15)
+set(PROJECT_NAME "flutter_webrtc")
+project(${PROJECT_NAME} LANGUAGES CXX)
+
+# This value is used when generating builds using this plugin, so it must
+# not be changed
+set(PLUGIN_NAME "flutter_webrtc_plugin")
+
+add_definitions(-DLIB_WEBRTC_API_DLL)
+
+add_library(${PLUGIN_NAME} SHARED
+  "flutter_webrtc_plugin.cc"
+  "src/flutter_data_channel.cc"
+  "src/flutter_media_stream.cc"
+  "src/flutter_peerconnection.cc"
+  "src/flutter_video_renderer.cc"
+  "src/flutter_webrtc.cc"
+  "src/flutter_webrtc_base.cc"
+  "third_party/uuidxx/uuidxx.cc"
+)
+
+include_directories(
+  "${CMAKE_CURRENT_SOURCE_DIR}/include"
+  "${CMAKE_CURRENT_SOURCE_DIR}/third_party/uuidxx"
+  "${CMAKE_CURRENT_SOURCE_DIR}/third_party/uuidxx"
+  "${CMAKE_CURRENT_SOURCE_DIR}/third_party/libwebrtc/include"
+)
+
+apply_standard_settings(${PLUGIN_NAME})
+set_target_properties(${PLUGIN_NAME} PROPERTIES
+  CXX_VISIBILITY_PRESET hidden)
+target_compile_definitions(${PLUGIN_NAME} PRIVATE FLUTTER_PLUGIN_IMPL)
+target_include_directories(${PLUGIN_NAME} INTERFACE
+  "${CMAKE_CURRENT_SOURCE_DIR}/include"
+)
+target_link_libraries(${PLUGIN_NAME} PRIVATE 
+  flutter
+  flutter_wrapper_plugin
+  "${CMAKE_CURRENT_SOURCE_DIR}/third_party/libwebrtc/lib/libwebrtc.dll.lib"
+)
+
+# List of absolute paths to libraries that should be bundled with the plugin
+set(flutter_webrtc_bundled_libraries
+  "${CMAKE_CURRENT_SOURCE_DIR}/third_party/libwebrtc/lib/libwebrtc.dll"
+  PARENT_SCOPE
+)
diff --git a/windows/flutter_webrtc_plugin.cc b/windows/flutter_webrtc_plugin.cc
@@ -0,0 +1,72 @@
+#include "flutter_webrtc/flutter_web_r_t_c_plugin.h"
+
+#include <flutter/standard_message_codec.h>
+
+#include "flutter_webrtc.h"
+
+const char *kChannelName = "FlutterWebRTC.Method";
+
+namespace flutter_webrtc_plugin {
+
+// A webrtc plugin for windows/linux.
+class FlutterWebRTCPluginImpl : public FlutterWebRTCPlugin {
+ public:
+  static void RegisterWithRegistrar(flutter::PluginRegistrar *registrar) {
+    auto channel = std::make_unique<flutter::MethodChannel<EncodableValue>>(
+        registrar->messenger(), kChannelName,
+        &flutter::StandardMethodCodec::GetInstance());
+
+    auto *channel_pointer = channel.get();
+
+    // Uses new instead of make_unique due to private constructor.
+    std::unique_ptr<FlutterWebRTCPluginImpl> plugin(
+        new FlutterWebRTCPluginImpl(registrar, std::move(channel)));
+
+    channel_pointer->SetMethodCallHandler(
+        [plugin_pointer = plugin.get()](const auto &call, auto result) {
+          plugin_pointer->HandleMethodCall(call, std::move(result));
+        });
+
+    registrar->AddPlugin(std::move(plugin));
+  }
+
+  virtual ~FlutterWebRTCPluginImpl() {}
+
+  flutter::BinaryMessenger *messenger() { return messenger_; }
+
+  flutter::TextureRegistrar *textures() { return textures_; }
+
+ private:
+  // Creates a plugin that communicates on the given channel.
+  FlutterWebRTCPluginImpl(
+      flutter::PluginRegistrar *registrar,
+      std::unique_ptr<flutter::MethodChannel<EncodableValue>> channel)
+      : channel_(std::move(channel)),
+        messenger_(registrar->messenger()),
+        textures_(registrar->texture_registrar()) {
+    webrtc_ = std::make_unique<FlutterWebRTC>(this);
+  }
+
+  // Called when a method is called on |channel_|;
+  void HandleMethodCall(
      const flutter::MethodCall<EncodableValue> &method_call,
+      std::unique_ptr<flutter::MethodResult<EncodableValue>> result) {
+    // handle method call and forward to webrtc native sdk.
+    webrtc_->HandleMethodCall(method_call, std::move(result));
+  }
+
+ private:
+  std::unique_ptr<flutter::MethodChannel<EncodableValue>> channel_;
+  std::unique_ptr<FlutterWebRTC> webrtc_;
+  flutter::BinaryMessenger *messenger_;
+  flutter::TextureRegistrar *textures_;
+};
+
+}  // namespace flutter_webrtc_plugin
+
+void FlutterWebRTCPluginRegisterWithRegistrar(
+    FlutterDesktopPluginRegistrarRef registrar) {
+  static auto *plugin_registrar = new flutter::PluginRegistrar(registrar);
+  flutter_webrtc_plugin::FlutterWebRTCPluginImpl::RegisterWithRegistrar(
+      plugin_registrar);
+}
diff --git a/windows/include/flutter_data_channel.h b/windows/include/flutter_data_channel.h
@@ -0,0 +1,51 @@
+#ifndef FLUTTER_WEBRTC_RTC_DATA_CHANNEL_HXX
+#define FLUTTER_WEBRTC_RTC_DATA_CHANNEL_HXX
+
+#include "flutter_webrtc_base.h"
+
+namespace flutter_webrtc_plugin {
+
+class FlutterRTCDataChannelObserver : public RTCDataChannelObserver {
+ public:
+  FlutterRTCDataChannelObserver(scoped_refptr<RTCDataChannel> data_channel,
+                                BinaryMessenger *messenger,
+                                const std::string &channel_name);
+  virtual ~FlutterRTCDataChannelObserver();
+
+  virtual void OnStateChange(RTCDataChannelState state) override;
+
+  virtual void OnMessage(const char *buffer, int length, bool binary) override;
+
+  scoped_refptr<RTCDataChannel> data_channel() { return data_channel_; }
+
+ private:
+  std::unique_ptr<EventChannel<EncodableValue>> event_channel_;
+  std::unique_ptr<EventSink<EncodableValue>> event_sink_;
+  scoped_refptr<RTCDataChannel> data_channel_;
+};
+
+class FlutterDataChannel {
+ public:
+  FlutterDataChannel(FlutterWebRTCBase *base) : base_(base) {}
+
+  void CreateDataChannel(const std::string &label,
+                         const EncodableMap &dataChannelDict,
+                         RTCPeerConnection *pc,
+                         std::unique_ptr<MethodResult<EncodableValue>>);
+
+  void DataChannelSend(RTCDataChannel *data_channel, const std::string &type,
+                       const EncodableValue &data,
+                       std::unique_ptr<MethodResult<EncodableValue>>);
+
+  void DataChannelClose(RTCDataChannel *data_channel,
+                        std::unique_ptr<MethodResult<EncodableValue>>);
+
+  RTCDataChannel *DataChannelFormId(int id);
+
+ private:
+  FlutterWebRTCBase *base_;
+};
+
+}  // namespace flutter_webrtc_plugin
+
+#endif  // !FLUTTER_WEBRTC_RTC_DATA_CHANNEL_HXX
diff --git a/windows/include/flutter_media_stream.h b/windows/include/flutter_media_stream.h
@@ -0,0 +1,50 @@
+#ifndef FLUTTER_WEBRTC_RTC_GET_USERMEDIA_HXX
+#define FLUTTER_WEBRTC_RTC_GET_USERMEDIA_HXX
+
+#include "flutter_webrtc_base.h"
+
+namespace flutter_webrtc_plugin {
+
+using namespace flutter;
+
+class FlutterMediaStream {
+ public:
+  FlutterMediaStream(FlutterWebRTCBase *base) : base_(base) {}
+
+  void GetUserMedia(const EncodableMap &constraints,
+                    std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void GetUserAudio(const EncodableMap &constraints,
+                    scoped_refptr<RTCMediaStream> stream, EncodableMap &params);
+
+  void GetUserVideo(const EncodableMap &constraints,
+                    scoped_refptr<RTCMediaStream> stream, EncodableMap &params);
+
+  void GetSources(std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void MediaStreamGetTracks(
+      const std::string &stream_id,
+      std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void MediaStreamDispose(const std::string &stream_id,
+                          std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void MediaStreamTrackSetEnable(
+      const std::string &track_id,
+      std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void MediaStreamTrackSwitchCamera(
+      const std::string &track_id,
+      std::unique_ptr<MethodResult<EncodableValue>> result);
+
+  void MediaStreamTrackDispose(
+      const std::string &track_id,
+      std::unique_ptr<MethodResult<EncodableValue>> result);
+
+ private:
+  FlutterWebRTCBase *base_;
+};
+
+}  // namespace flutter_webrtc_plugin
+
+#endif  // !FLUTTER_WEBRTC_RTC_GET_USERMEDIA_HXX