Authenticate WebRTC using WAMP

Author: Mahad-10

app/src/main/java/io/xconn/wampwebrtc/Helpers.kt

@@ -1,7 +1,6 @@
 package io.xconn.wampwebrtc
 
 import io.xconn.wampproto.Joiner
-import io.xconn.wampproto.serializers.Serializer
 import org.json.JSONObject
 
 fun convertJsonToMap(jsonString: String): Map<String, Any> {
@@ -18,10 +17,9 @@ fun convertJsonToMap(jsonString: String): Map<String, Any> {
 
 suspend fun join(
     peer: Peer,
-    realm: String,
-    serializer: Serializer,
+    config: ClientConfig,
 ): PeerBaseSession {
-    val joiner = Joiner(realm, serializer)
+    val joiner = Joiner(config.realm, config.serializer, config.authenticator)
     val hello = joiner.sendHello()
 
     peer.send(hello as ByteArray)
@@ -32,7 +30,7 @@ suspend fun join(
 
         if (toSend == null) {
             val sessionDetails = joiner.getSessionDetails()
-            val base = PeerBaseSession(peer, sessionDetails, serializer)
+            val base = PeerBaseSession(peer, sessionDetails, config.serializer)
             return base
         }
 

app/src/main/java/io/xconn/wampwebrtc/Types.kt

@@ -1,6 +1,7 @@
 package io.xconn.wampwebrtc
 
 import io.xconn.wampproto.SessionDetails
+import io.xconn.wampproto.auth.ClientAuthenticator
 import io.xconn.wampproto.messages.Message
 import io.xconn.wampproto.serializers.Serializer
 import io.xconn.xconn.IBaseSession
@@ -59,6 +60,7 @@ data class ClientConfig(
     val serializer: Serializer,
     val subProtocol: String,
     val iceServers: List<IceServer>,
+    val authenticator: ClientAuthenticator,
 )
 
 data class OfferConfig(

app/src/main/java/io/xconn/wampwebrtc/WAMPSession.kt

@@ -13,7 +13,7 @@ class WAMPSession(
         val webRTCSession = webRTCConnection.connect(config)
 
         val peer = WebRTCPeer(webRTCSession.channel, config.serializer, queue)
-        val baseSession = join(peer, config.realm, config.serializer)
+        val baseSession = join(peer, config)
 
         return Session(baseSession)
     }