add server publish to private user

arenaxr · Oct 9, 2024 · a87f66d · a87f66d
1 parent cd246ae
commit a87f66d
Showing 1 changed file with 8 additions and 13 deletions.
diff --git a/Runtime/Scripts/Signaling/ARENAMQTTSignaling.cs b/Runtime/Scripts/Signaling/ARENAMQTTSignaling.cs
@@ -76,14 +76,9 @@ private void Publish(string toUid, string msg)
                 idtag: "-",
                 touid: toUid
             );
-            if (toUid == null)
-            {
-                scene.Publish(pubRenderServerTopic.PUB_SCENE_RENDER, payload);
-            }
-            else
-            {
-                scene.Publish(pubRenderServerTopic.PUB_SCENE_RENDER_PRIVATE, payload);
-            }
+            var topic = (toUid == null) ? pubRenderServerTopic.PUB_SCENE_RENDER : pubRenderServerTopic.PUB_SCENE_RENDER_PRI_SERV;
+            scene.Publish(topic, payload);
+            Debug.Log($"MQTT Sent: {topic} {msg}");
         }
 
         public void SendConnect()
@@ -110,7 +105,7 @@ public void SendOffer(string id, RTCSessionDescription offer)
                 }
             };
 
-            Publish(id, JsonUtility.ToJson(routedMessage));
+            Publish(null, JsonUtility.ToJson(routedMessage));
         }
 
         public void SendAnswer(string id, RTCSessionDescription answer)
@@ -126,7 +121,7 @@ public void SendAnswer(string id, RTCSessionDescription answer)
                 }
             };
 
-            Publish(id, JsonUtility.ToJson(routedMessage));
+            Publish(null, JsonUtility.ToJson(routedMessage));
         }
 
         public void SendHealthCheck(string id){
@@ -139,7 +134,7 @@ public void SendHealthCheck(string id){
                 id = id,
                 data = $"{scene.namespaceName}/{scene.sceneName}"
             };
-            Publish(id, JsonUtility.ToJson(healthCheck));
+            Publish(null, JsonUtility.ToJson(healthCheck));
         }
 
         public void UpdateHALInfo(string id, bool halStatus)
@@ -162,7 +157,7 @@ public void SendCandidate(string id, RTCIceCandidate candidate)
                 }
             };
 
-            Publish(id, JsonUtility.ToJson(routedMessage));
+            Publish(null, JsonUtility.ToJson(routedMessage));
         }
 
         public void SendStats(string stats)
@@ -174,7 +169,7 @@ protected void ProcessMessage(string topic, string content)
         {
             if ( !m_subbedTopics.Any(s => topic.Contains( s.Substring(0,s.Length-5) )) ) return;
 
-            Debug.Log($"MQTT Recieved: {topic} {content}");
+            Debug.Log($"MQTT Received: {topic} {content}");
 
             try
             {