[flutter_webrtc_tizen]Upgrade flutter webrtc to 1.4.1 (#993)

Author: xiaowei-guan

packages/flutter_webrtc/CHANGELOG.md

@@ -1,9 +1,12 @@
 ## NEXT
 
+## 0.2.0
+
 * Update minimum Flutter and Dart version to 3.13 and 3.1.
 * Fix analyze issue.
 * Update code format.
 * Adds compatibility with `http` 1.0 in example.
+* Update flutter_webrtc to 1.4.1.
 
 ## 0.1.3
 

packages/flutter_webrtc/README.md

@@ -40,8 +40,8 @@ For other Tizen devices :
 
  ```yaml
 dependencies:
-  flutter_webrtc: ^0.9.46
-  flutter_webrtc_tizen: ^0.1.3
+  flutter_webrtc: ^1.3.1
+  flutter_webrtc_tizen: ^0.2.0
 ```
 
 ## Functionality

packages/flutter_webrtc/example/flutter_webrtc_demo/pubspec.yaml

@@ -10,7 +10,7 @@ dependencies:
   cupertino_icons: ^1.0.3
   flutter:
     sdk: flutter
-  flutter_webrtc: 0.9.46 # Use a fixed version due to build errors.
+  flutter_webrtc: ^1.4.1
   flutter_webrtc_tizen:
     path: ../../
   http: ">=0.13.0 <2.0.0"

packages/flutter_webrtc/example/flutter_webrtc_example/pubspec.yaml

@@ -3,21 +3,24 @@ description: Demonstrates how to use the webrtc plugin.
 publish_to: "none"
 
 environment:
-  sdk: ">=3.1.0 <4.0.0"
+  sdk: ">=3.3.0 <4.0.0"
   flutter: ">=3.13.0"
 
 dependencies:
+  cupertino_icons: ^1.0.2
   flutter:
     sdk: flutter
   flutter_background: ^1.0.0
-  flutter_webrtc: 0.9.46 # Use a fixed version due to build errors.
+  flutter_webrtc: ^1.4.1
   flutter_webrtc_tizen:
     path: ../../
+  gallery_saver_plus: 3.2.4
   path_provider: ^2.0.7
   path_provider_tizen: ^2.0.2
   permission_handler: ^10.4.3
   permission_handler_tizen: ^1.3.0
-  web: ^0.3.0
+  sdp_transform: ^0.3.2
+  web: ^1.0.0
 
 dev_dependencies:
   flutter_test:

packages/flutter_webrtc/pubspec.yaml

@@ -2,10 +2,10 @@ name: flutter_webrtc_tizen
 homepage: https://github.com/flutter-tizen/plugins
 description: Flutter WebRTC plugin for Tizen, based on GoogleWebRTC.
 repository: https://github.com/flutter-tizen/plugins/tree/master/packages/flutter_webrtc
-version: 0.1.3
+version: 0.2.0
 
 environment:
-  sdk: ">=3.1.0 <4.0.0"
+  sdk: ">=3.3.0 <4.0.0"
   flutter: ">=3.13.0"
 
 flutter:

packages/flutter_webrtc/tizen/inc/flutter_common.h

@@ -12,6 +12,9 @@
 
 #include <list>
 #include <memory>
+#include <mutex>
+#include <optional>
+#include <queue>
 #include <string>
 
 typedef flutter::EncodableValue EncodableValue;
@@ -26,6 +29,8 @@ typedef flutter::EventSink<EncodableValue> EventSink;
 typedef flutter::MethodCall<EncodableValue> MethodCall;
 typedef flutter::MethodResult<EncodableValue> MethodResult;
 
+class TaskRunner;
+
 // foo.StringValue() becomes std::get<std::string>(foo)
 // foo.IsString() becomes std::holds_alternative<std::string>(foo)
 
@@ -88,6 +93,14 @@ inline double findDouble(const EncodableMap& map, const std::string& key) {
   return 0.0;
 }
 
+inline std::optional<double> maybeFindDouble(const EncodableMap& map,
+                                             const std::string& key) {
+  auto it = map.find(EncodableValue(key));
+  if (it != map.end() && TypeIs<double>(it->second))
+    return GetValue<double>(it->second);
+  return std::nullopt;
+}
+
 inline std::vector<uint8_t> findVector(const EncodableMap& map,
                                        const std::string& key) {
   auto it = map.find(EncodableValue(key));
@@ -161,7 +174,8 @@ class MethodResultProxy {
 class EventChannelProxy {
  public:
   static std::unique_ptr<EventChannelProxy> Create(
-      BinaryMessenger* messenger, const std::string& channelName);
+      BinaryMessenger* messenger, TaskRunner* task_runner,
+      const std::string& channelName);
 
   virtual ~EventChannelProxy() = default;
 

packages/flutter_webrtc/tizen/inc/flutter_data_channel.h

@@ -10,6 +10,7 @@ class FlutterRTCDataChannelObserver : public RTCDataChannelObserver {
  public:
   FlutterRTCDataChannelObserver(scoped_refptr<RTCDataChannel> data_channel,
                                 BinaryMessenger* messenger,
+                                TaskRunner* task_runner,
                                 const std::string& channel_name);
   virtual ~FlutterRTCDataChannelObserver();
 
@@ -38,6 +39,9 @@ class FlutterDataChannel {
                        const EncodableValue& data,
                        std::unique_ptr<MethodResultProxy>);
 
+  void DataChannelGetBufferedAmount(RTCDataChannel* data_channel,
+                                    std::unique_ptr<MethodResultProxy> result);
+
   void DataChannelClose(RTCDataChannel* data_channel,
                         const std::string& data_channel_uuid,
                         std::unique_ptr<MethodResultProxy>);

packages/flutter_webrtc/tizen/inc/flutter_data_packet_cryptor.h

@@ -0,0 +1,39 @@
+#ifndef FLUTTER_WEBRTC_RTC_DATA_PACKET_CRYPTOR_HXX
+#define FLUTTER_WEBRTC_RTC_DATA_PACKET_CRYPTOR_HXX
+
+#include "flutter_common.h"
+#include "flutter_webrtc_base.h"
+#include "rtc_data_packet_cryptor.h"
+
+namespace flutter_webrtc_plugin {
+
+class FlutterDataPacketCryptor {
+ public:
+  FlutterDataPacketCryptor(FlutterWebRTCBase* base) : base_(base) {}
+
+  bool HandleDataPacketCryptorMethodCall(
+      const MethodCallProxy& method_call,
+      std::unique_ptr<MethodResultProxy> result,
+      std::unique_ptr<MethodResultProxy>* outResult);
+
+  void CreateDataPacketCryptor(const EncodableMap& constraints,
+                               std::unique_ptr<MethodResultProxy> result);
+
+  void DataPacketCryptorDispose(const EncodableMap& constraints,
+                                std::unique_ptr<MethodResultProxy> result);
+
+  void DataPacketCryptorEncrypt(const EncodableMap& constraints,
+                                std::unique_ptr<MethodResultProxy> result);
+
+  void DataPacketCryptorDecrypt(const EncodableMap& constraints,
+                                std::unique_ptr<MethodResultProxy> result);
+
+ private:
+  FlutterWebRTCBase* base_;
+  std::map<std::string, scoped_refptr<libwebrtc::RTCDataPacketCryptor>>
+      data_packet_cryptors_;
+};
+
+}  // namespace flutter_webrtc_plugin
+
+#endif  // FLUTTER_WEBRTC_RTC_DATA_PACKET_CRYPTOR_HXX

packages/flutter_webrtc/tizen/inc/flutter_frame_capturer.h

@@ -0,0 +1,39 @@
+#ifndef FLUTTER_WEBRTC_RTC_FRAME_CAPTURER_HXX
+#define FLUTTER_WEBRTC_RTC_FRAME_CAPTURER_HXX
+
+#include <atomic>
+#include <condition_variable>
+#include <mutex>
+
+#include "flutter_common.h"
+#include "flutter_webrtc_base.h"
+#include "rtc_video_frame.h"
+#include "rtc_video_renderer.h"
+
+namespace flutter_webrtc_plugin {
+
+using namespace libwebrtc;
+
+class FlutterFrameCapturer
+    : public RTCVideoRenderer<scoped_refptr<RTCVideoFrame>> {
+ public:
+  FlutterFrameCapturer(RTCVideoTrack* track, std::string path);
+
+  virtual void OnFrame(scoped_refptr<RTCVideoFrame> frame) override;
+
+  void CaptureFrame(std::unique_ptr<MethodResultProxy> result);
+
+ private:
+  RTCVideoTrack* track_;
+  std::string path_;
+  std::mutex mutex_;
+  std::condition_variable cv_;
+  scoped_refptr<RTCVideoFrame> frame_;
+  std::atomic<bool> catch_frame_;
+
+  bool SaveFrame();
+};
+
+}  // namespace flutter_webrtc_plugin
+
+#endif  // !FLUTTER_WEBRTC_RTC_FRAME_CAPTURER_HXX

packages/flutter_webrtc/tizen/inc/flutter_frame_cryptor.h

@@ -10,8 +10,10 @@ namespace flutter_webrtc_plugin {
 class FlutterFrameCryptorObserver : public libwebrtc::RTCFrameCryptorObserver {
  public:
   FlutterFrameCryptorObserver(BinaryMessenger* messenger,
+                              TaskRunner* task_runner,
                               const std::string& channelName)
-      : event_channel_(EventChannelProxy::Create(messenger, channelName)) {}
+      : event_channel_(
+            EventChannelProxy::Create(messenger, task_runner, channelName)) {}
   void OnFrameCryptionStateChanged(const string participant_id,
                                    libwebrtc::RTCFrameCryptionState state);
 
@@ -23,8 +25,12 @@ class FlutterFrameCryptor {
  public:
   FlutterFrameCryptor(FlutterWebRTCBase* base) : base_(base) {}
 
-  bool HandleFrameCryptorMethodCall(const MethodCallProxy& method_call,
-                                    std::unique_ptr<MethodResultProxy> result);
+  // Since this takes ownership of result, ownership will be passed back to
+  // 'outResult' if this function fails
+  bool HandleFrameCryptorMethodCall(
+      const MethodCallProxy& method_call,
+      std::unique_ptr<MethodResultProxy> result,
+      std::unique_ptr<MethodResultProxy>* outResult);
 
   void FrameCryptorFactoryCreateFrameCryptor(
       const EncodableMap& constraints,
@@ -57,6 +63,7 @@ class FlutterFrameCryptor {
 
   void KeyProviderExportSharedKey(const EncodableMap& constraints,
                                   std::unique_ptr<MethodResultProxy> result);
+
   void KeyProviderSetKey(const EncodableMap& constraints,
                          std::unique_ptr<MethodResultProxy> result);
 
@@ -91,7 +98,6 @@ class FlutterFrameCryptor {
       frame_cryptors_;
   std::map<std::string, scoped_refptr<FlutterFrameCryptorObserver>>
       frame_cryptor_observers_;
-  std::map<std::string, scoped_refptr<libwebrtc::KeyProvider>> key_providers_;
 };
 
 }  // namespace flutter_webrtc_plugin