add more frame cryptor api.

Author: cloudwebrtc

CHANGELOG.md

@@ -1,6 +1,10 @@
 # Changelog
 
 --------------------------------------------
+[1.1.2] - 2023-09-14
+
+* Add more frame cryptor api.
+
 [1.1.2] - 2023-08-14
 
 * Add async functions for get pc states.

lib/src/e2ee.worker/e2ee.worker.dart

@@ -209,6 +209,18 @@ void main() async {
           }
         }
         break;
+      case 'setSharedKey':
+        {
+          var key = Uint8List.fromList(base64Decode(msg['key'] as String));
+          var keyIndex = msg['keyIndex'];
+          if (keyProviderOptions.sharedKey) {
+            for (var c in participantCryptors) {
+              c.setKey(keyIndex, key);
+            }
+            return;
+          }
+        }
+        break;
       case 'ratchetKey':
         {
           var keyIndex = msg['keyIndex'];
@@ -233,6 +245,17 @@ void main() async {
           }
         }
         break;
+      case 'ratchetSharedKey':
+        {
+          var keyIndex = msg['keyIndex'];
+          for (var c in participantCryptors) {
+            var keySet = c.getKeySet(keyIndex);
+            c.ratchetKey(keyIndex).then((_) async {
+              await c.ratchet(keySet!.material, keyProviderOptions.ratchetSalt);
+            });
+          }
+        }
+        break;
       case 'setKeyIndex':
         {
           var keyIndex = msg['index'];
@@ -246,6 +269,16 @@ void main() async {
           }
         }
         break;
+      case 'setSifTrailer':
+        {
+          var sifTrailer =
+              Uint8List.fromList(base64Decode(msg['sifTrailer'] as String));
+          keyProviderOptions.uncryptedMagicBytes = sifTrailer;
+          for (var c in participantCryptors) {
+            c.keyOptions.uncryptedMagicBytes = sifTrailer;
+          }
+        }
+        break;
       case 'updateCodec':
         {
           var codec = msg['codec'] as String;

lib/src/frame_cryptor_impl.dart

@@ -228,6 +228,49 @@ class KeyProviderImpl implements KeyProvider {
 
     return _ratchetKeyCompleter!.future;
   }
+
+  @override
+  Future<Uint8List> exportKey(
+      {required String participantId, required int index}) {
+    throw UnimplementedError('exportKey not supported for web');
+  }
+
+  @override
+  Future<Uint8List> exportSharedKey({int index = 0}) {
+    throw UnimplementedError('exportSharedKey not supported for web');
+  }
+
+  @override
+  Future<Uint8List> ratchetSharedKey({int index = 0}) async {
+    jsutil.callMethod(worker, 'postMessage', [
+      jsutil.jsify({
+        'msgType': 'ratchetSharedKey',
+        'keyIndex': index,
+      })
+    ]);
+    return Uint8List(0);
+  }
+
+  @override
+  Future<void> setSharedKey({required Uint8List key, int index = 0}) async {
+    jsutil.callMethod(worker, 'postMessage', [
+      jsutil.jsify({
+        'msgType': 'setSharedKey',
+        'keyIndex': index,
+        'key': base64Encode(key),
+      })
+    ]);
+  }
+
+  @override
+  Future<void> setSifTrailer({required Uint8List trailer}) async {
+    jsutil.callMethod(worker, 'postMessage', [
+      jsutil.jsify({
+        'msgType': 'setSifTrailer',
+        'sifTrailer': base64Encode(trailer),
+      })
+    ]);
+  }
 }
 
 class FrameCryptorFactoryImpl implements FrameCryptorFactory {

pubspec.yaml

@@ -1,6 +1,6 @@
 name: dart_webrtc
 description: Use the dart/js library to re-wrap the webrtc js interface of the browser, to adapted common browsers.
-version: 1.1.2
+version: 1.1.3
 homepage: https://github.com/flutter-webrtc/dart-webrtc
 
 environment:
@@ -10,7 +10,7 @@ dependencies:
   collection: ^1.17.1
   js: ^0.6.4  
   platform_detect: ^2.0.7
-  webrtc_interface: 1.1.1
+  webrtc_interface: 1.1.2
 
 dev_dependencies:
   build_runner: ^2.3.3