マルチ転送フィルターを設定可能にする

CHANGES.md

@@ -11,6 +11,13 @@
 
 ## develop
 
+- [ADD] forwardingfilters を設定可能にする
+  - マルチ転送フィルターを設定できるように項目を追加
+  - @torikizi
+- [ADD] forwardingfilter に name と priority を追加
+  - 既存の forwardingfilter に name と priority を追加
+  - @torikizi
+
 ## sora-unity-sdk-2024.4.0
 
 - [UPDATE] Sora Unity SDK 2024.4.0 にあげる

SoraUnitySdkSamples/Assets/SoraSample.cs

@@ -123,15 +123,78 @@ public class RuleList
     {
         public Rule[] data;
     }
+    [System.Serializable]
+    public class ForwardingFilter
+    {
+        public bool enableAction = false;
+        public string action;
+        public bool enableName = false;
+        public string name;
+        public bool enablePriority = false;
+        public int priority;
+        public RuleList[] rules;
+        public bool enableVersion = false;
+        public string version = "";
+        public bool enableMetadata = false;
+        public string metadata = "";
+    }
+
+    [Serializable]
+    private class ForwardingFilterMetadata
+    {
+        public string metadata;
+    }
+    public static Sora.ForwardingFilter ConvertForwardingFilter(ForwardingFilter forwardingFilter)
+    {
+        var filter = new Sora.ForwardingFilter();
+
+        if (forwardingFilter.enableAction) filter.Action = forwardingFilter.action;
+        if (forwardingFilter.enableName) filter.Name = forwardingFilter.name;
+        if (forwardingFilter.enablePriority) filter.Priority = forwardingFilter.priority;
+
+        if (forwardingFilter.rules != null)
+        {
+            foreach (var ruleListData in forwardingFilter.rules)
+            {
+                var ruleList = new List<Sora.ForwardingFilter.Rule>();
+                foreach (var rule in ruleListData.data)
+                {
+                    var newRule = new Sora.ForwardingFilter.Rule
+                    {
+                        Field = rule.field,
+                        Operator = rule.op
+                    };
+                    newRule.Values.AddRange(rule.values);
+                    ruleList.Add(newRule);
+                }
+
+                if (ruleList.Any())
+                {
+                    filter.Rules.Add(ruleList);
+                }
+            }
+        }
+
+        if (forwardingFilter.enableVersion) filter.Version = forwardingFilter.version;
+        if (forwardingFilter.enableMetadata)
+        {
+            filter.Metadata = JsonUtility.ToJson(new ForwardingFilterMetadata()
+            {
+                metadata = forwardingFilter.metadata
+            });
+        }
+
+        return filter;
+    }
 
     [Header("ForwardingFilter の設定")]
-    public bool enableForwardingFilterAction = false;
-    public string forwardingFilterAction;
-    public RuleList[] forwardingFilter;
-    public bool enableForwardingFilterVersion = false;
-    public string forwardingFilterVersion = "";
-    public bool enableForwardingFilterMetadata = false;
-    public string forwardingFilterMetadataMessage = "";
+    [System.Obsolete("forwardingFilter は非推奨です。代わりに forwardingFilters を使用してください。")]
+    public bool enableForwardingFilter = false;
+    public ForwardingFilter forwardingFilter;
+
+    [Header("ForwardingFilters の設定")]
+    public bool enableForwardingFilters = false;
+    public ForwardingFilter[] forwardingFilters;
 
     [Header("DataChannel シグナリングの設定")]
     public bool dataChannelSignaling = false;
@@ -597,12 +660,6 @@ class VideoH264Params
         public string profile_level_id;
     }
 
-    [Serializable]
-    class ForwardingFilterMetadata
-    {
-        public string forwarding_filter_metadata;
-    }
-
     public void OnClickStart()
     {
 
@@ -677,16 +734,6 @@ public void OnClickStart()
             };
             videoH264ParamsJson = JsonUtility.ToJson(h264Params);
         }
-        // enableForwardingFilterMetadata が true の場合はメタデータを設定する
-        string forwardingFilterMetadataJson = "";
-        if (enableForwardingFilterMetadata)
-        {
-            var ffm = new ForwardingFilterMetadata()
-            {
-                forwarding_filter_metadata = forwardingFilterMetadataMessage
-            };
-            forwardingFilterMetadataJson = JsonUtility.ToJson(ffm);
-        }
 
         InitSora();
 
@@ -777,30 +824,23 @@ public void OnClickStart()
             }
             fixedDataChannelLabels = config.DataChannels.Select(x => x.Label).ToArray();
         }
-        if (forwardingFilter.Length != 0)
+        if (enableForwardingFilter)
+        {
+            config.ForwardingFilter = ConvertForwardingFilter(forwardingFilter);
+        }
+        if (enableForwardingFilters)
         {
-            config.ForwardingFilter = new Sora.ForwardingFilter();
-            if (enableForwardingFilterAction) config.ForwardingFilter.Action = forwardingFilterAction;
-            foreach (var rs in forwardingFilter)
+            config.ForwardingFilters = new List<Sora.ForwardingFilter>();
+
+            foreach (var filter in forwardingFilters)
             {
-                var ccrs = new List<Sora.ForwardingFilter.Rule>();
-                foreach (var r in rs.data)
+                var newFilter = ConvertForwardingFilter(filter);
+                if (newFilter != null)
                 {
-                    var ccr = new Sora.ForwardingFilter.Rule();
-                    ccr.Field = r.field;
-                    ccr.Operator = r.op;
-                    foreach (var v in r.values)
-                    {
-                        ccr.Values.Add(v);
-                    }
-                    ccrs.Add(ccr);
+                    config.ForwardingFilters.Add(newFilter);
                 }
-                config.ForwardingFilter.Rules.Add(ccrs);
             }
-            if (enableForwardingFilterVersion) config.ForwardingFilter.Version = forwardingFilterVersion;
-            if (enableForwardingFilterMetadata) config.ForwardingFilter.Metadata = forwardingFilterMetadataJson;
         }
-
         sora.Connect(config);
         SetState(State.Started);
         Debug.LogFormat("Sora is Created: signalingUrl={0}, channelId={1}", signalingUrl, channelId);