reformated kotlin_client package

Author: ambjn

kotlin_client/src/main/java/com/huddle01/kotlin_client/HuddleClient.kt

@@ -2,8 +2,8 @@ package com.huddle01.kotlin_client
 
 import RequestOuterClass.Request
 import android.content.Context
-import com.huddle01.kotlin_client.core.Room
 import com.huddle01.kotlin_client.core.LocalPeer
+import com.huddle01.kotlin_client.core.Room
 import com.huddle01.kotlin_client.core.Socket
 import com.huddle01.kotlin_client.models.enum_class.ConnectionState
 import com.huddle01.kotlin_client.models.enum_class.RoomStates
@@ -79,7 +79,7 @@ class HuddleClient(projectId: String, context: Context) {
 
     init {
         enableLogs()
-        initSDKConnection(application = context.applicationContext as  android.app.Application)
+        initSDKConnection(application = context.applicationContext as android.app.Application)
         Timber.i("✅ Initializing HuddleClient")
         this.projectId = projectId
         _socket = Socket.getInstance()
@@ -158,7 +158,7 @@ class HuddleClient(projectId: String, context: Context) {
         Timber.plant(Timber.DebugTree())
     }
 
-    private fun initSDKConnection(application:  android.app.Application) {
+    private fun initSDKConnection(application: android.app.Application) {
         MediasoupClient.initialize(
             context = application,
             logHandler = object : LogHandler {

kotlin_client/src/main/java/com/huddle01/kotlin_client/common/EnhancedMap.kt

@@ -1,7 +1,7 @@
 package com.huddle01.kotlin_client.common
 
 class EnhancedMap<T>(
-    private val compareFn: (String, String) -> Boolean = ::defaultCompareFn
+    private val compareFn: (String, String) -> Boolean = ::defaultCompareFn,
 ) {
     private val map: MutableMap<String, T> = mutableMapOf()
 

kotlin_client/src/main/java/com/huddle01/kotlin_client/common/ProtoParsing.kt

@@ -1,6 +1,10 @@
 package com.huddle01.kotlin_client.common
 
+import AppDataOuterClass
 import RtpCapabilities
+import RtpParameters
+import SctpCapabilities
+import SdpInfo
 import com.huddle01.kotlin_client.utils.JsonUtils
 import org.json.JSONObject
 import org.webrtc.MediaStreamTrack
@@ -136,7 +140,7 @@ object ProtoParsing {
     }
 
     fun getParsedDtlsParameters(
-        protoDtlsParametersList: List<SdpInfo.ProtoDtlsFingerPrints>, role: String
+        protoDtlsParametersList: List<SdpInfo.ProtoDtlsFingerPrints>, role: String,
     ): String {
         val fingerprints = protoDtlsParametersList.joinToString(",") { protoDtlsParams ->
             """{"algorithm":"${protoDtlsParams.algorithm}","value":"${protoDtlsParams.value}"}"""
@@ -239,7 +243,7 @@ object ProtoParsing {
 
     fun parseRtpCapabilities(
         codecs: List<RtpCapabilities.ProtoRtpCodecCapability>,
-        headerExtensions: List<RtpCapabilities.ProtoRtpHeaderExtension>
+        headerExtensions: List<RtpCapabilities.ProtoRtpHeaderExtension>,
     ): String {
         fun parseCodec(codec: RtpCapabilities.ProtoRtpCodecCapability): String {
 
@@ -307,7 +311,7 @@ object ProtoParsing {
         headerExtensions: List<RtpParameters.ProtoHeaderExtensionParameters>,
         encodings: List<RtpParameters.ProtoEncodings>,
         rtcp: RtpParameters.RtcpParameters,
-        mid: String
+        mid: String,
     ): String {
         val codecsJson = codecs.joinToString(",", "\"codecs\":[", "]", transform = ::parseCodec)
         val headerExtensionsJson = headerExtensions.joinToString(

kotlin_client/src/main/java/com/huddle01/kotlin_client/core/LocalPeer.kt

@@ -25,6 +25,8 @@ import android.content.Context
 import android.media.MediaRecorder.AudioSource
 import android.os.Handler
 import android.os.Looper
+import com.google.gson.Gson
+import com.google.gson.reflect.TypeToken
 import com.huddle01.kotlin_client.common.EnhancedMap
 import com.huddle01.kotlin_client.common.ProtoParsing
 import com.huddle01.kotlin_client.constants.maxDataMessageSize
@@ -39,8 +41,6 @@ import com.huddle01.kotlin_client.types.TransportType
 import com.huddle01.kotlin_client.types.estimateSize
 import com.huddle01.kotlin_client.utils.EventEmitter
 import com.huddle01.kotlin_client.utils.PeerConnectionUtils
-import com.google.gson.Gson
-import com.google.gson.reflect.TypeToken
 import io.github.crow_misia.mediasoup.Consumer
 import io.github.crow_misia.mediasoup.Device
 import io.github.crow_misia.mediasoup.Producer
@@ -76,7 +76,7 @@ import java.util.Locale
  *  Where Client Means the currently Running Application.
  */
 class LocalPeer(
-    context: Context
+    context: Context,
 ) : EventEmitter() {
 
     private val scope = CoroutineScope(Job() + Dispatchers.Main)
@@ -432,7 +432,7 @@ class LocalPeer(
 
 
     suspend fun produce(
-        label: String, audioTrack: AudioTrack?, videoTrack: VideoTrack?, appData: String?
+        label: String, audioTrack: AudioTrack?, videoTrack: VideoTrack?, appData: String?,
     ) {
         Timber.i("produce called")
         try {
@@ -642,7 +642,7 @@ class LocalPeer(
      * @returns Consumer?; Returns null if consumer is not found
      */
     fun getConsumer(
-        label: String, peerId: String
+        label: String, peerId: String,
     ): Consumer? {
         val consumer = consumers.get(label, peerId)
         return consumer
@@ -1520,7 +1520,7 @@ class LocalPeer(
         }
 
         override fun onProduce(
-            transport: Transport, kind: String, rtpParameters: String, appData: String?
+            transport: Transport, kind: String, rtpParameters: String, appData: String?,
         ): String {
             try {
                 socket.publish(
@@ -1544,7 +1544,7 @@ class LocalPeer(
             sctpStreamParameters: String,
             label: String,
             protocol: String,
-            appData: String?
+            appData: String?,
         ): String {
             TODO("Not yet implemented")
         }
@@ -1582,7 +1582,7 @@ class LocalPeer(
         dtlsParameters: String,
         sctpParameters: String? = null,
         rtcConfig: PeerConnection.RTCConfiguration? = null,
-        appData: String? = null
+        appData: String? = null,
     ): Transport? {
         Timber.i("createDeviceTransport called for $transportType")
         val transport = when (transportType) {
@@ -1618,7 +1618,7 @@ class LocalPeer(
     }
 
     private fun connectionStateChangeHandler(
-        transport: Transport?, state: String, transportType: String
+        transport: Transport?, state: String, transportType: String,
     ) {
         try {
             Timber.d("🔔 $transportType Transport Connection State Changed, state: $state")
@@ -1715,7 +1715,7 @@ class LocalPeer(
      * Helper function to close the consumer of a remote peer
      */
     private fun closeRemotePeerConsumer(
-        peerId: String, label: String
+        peerId: String, label: String,
     ) {
         try {
             val remotePeer = room.getRemotePeerById(peerId)

kotlin_client/src/main/java/com/huddle01/kotlin_client/core/RemotePeer.kt

@@ -106,7 +106,7 @@ class RemotePeer(
      * Adds label data and manages consumption based on auto-consume setting
      */
     fun addLabelData(
-        label: String, producerId: String, context: Context
+        label: String, producerId: String, context: Context,
     ) {
         _labelsToProducerId[label] = mutableMapOf("producerId" to producerId)
         try {

kotlin_client/src/main/java/com/huddle01/kotlin_client/core/Room.kt

@@ -1,13 +1,14 @@
 package com.huddle01.kotlin_client.core
 
 import RequestOuterClass.Request
-import com.huddle01.kotlin_client.utils.JsonUtils
+import ResponseOuterClass
 import com.huddle01.kotlin_client.models.LobbyPeer
 import com.huddle01.kotlin_client.models.RoomConfig
 import com.huddle01.kotlin_client.models.RoomStats
 import com.huddle01.kotlin_client.models.enum_class.RoomControlType
 import com.huddle01.kotlin_client.models.enum_class.RoomStates
 import com.huddle01.kotlin_client.utils.EventEmitter
+import com.huddle01.kotlin_client.utils.JsonUtils
 import org.json.JSONException
 import org.json.JSONObject
 import timber.log.Timber
@@ -161,7 +162,7 @@ class Room(
      */
     fun setNewLobbyPeers(
         peers: List<ResponseOuterClass.LobbyPeers>? = null,
-        newLobbyPeer: ResponseOuterClass.NewLobbyPeer? = null
+        newLobbyPeer: ResponseOuterClass.NewLobbyPeer? = null,
     ) {
         peers?.forEach { peerMap ->
             peerMap.peerId?.let { peerId ->

kotlin_client/src/main/java/com/huddle01/kotlin_client/core/Socket.kt

@@ -1,33 +1,31 @@
 package com.huddle01.kotlin_client.core
 
-import RequestOuterClass.ConnectRoom
+import RequestOuterClass.CloseConsumer
+import RequestOuterClass.CloseProducer
 import RequestOuterClass.CloseRoom
-import RequestOuterClass.Request
-import ResponseOuterClass.Response
-import RequestOuterClass.UpdateRoomMetadata
-import RequestOuterClass.KickPeer
+import RequestOuterClass.ConnectRoom
+import RequestOuterClass.ConnectTransport
+import RequestOuterClass.Consume
+import RequestOuterClass.CreateTransport
 import RequestOuterClass.DenyLobbyPeer
-import RequestOuterClass.UpdatePeerRole
-import RequestOuterClass.SyncMeetingState
+import RequestOuterClass.KickPeer
+import RequestOuterClass.Produce
+import RequestOuterClass.Request
 import RequestOuterClass.RestartTransportIce
 import RequestOuterClass.ResumeConsumer
-import RequestOuterClass.CreateTransport
-import RequestOuterClass.ConnectTransport
-import RequestOuterClass.Produce
-import RequestOuterClass.Consume
-import RequestOuterClass.CloseProducer
-import RequestOuterClass.CloseConsumer
 import RequestOuterClass.SendData
+import RequestOuterClass.SyncMeetingState
 import RequestOuterClass.UpdatePeerMetadata
+import RequestOuterClass.UpdatePeerRole
+import RequestOuterClass.UpdateRoomMetadata
+import ResponseOuterClass.Response
 import com.huddle01.kotlin_client.common.ProtoParsing
-import com.huddle01.kotlin_client.utils.JsonUtils
 import com.huddle01.kotlin_client.models.GeoData
-import com.huddle01.kotlin_client.utils.EventEmitter
 import com.huddle01.kotlin_client.models.GeoLocation
 import com.huddle01.kotlin_client.models.enum_class.ConnectionState
 import com.huddle01.kotlin_client.types.ESocketCloseCode
-import java.net.HttpURLConnection
-import java.net.URL
+import com.huddle01.kotlin_client.utils.EventEmitter
+import com.huddle01.kotlin_client.utils.JsonUtils
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
@@ -37,7 +35,9 @@ import org.java_websocket.client.WebSocketClient
 import org.java_websocket.enums.ReadyState
 import org.java_websocket.handshake.ServerHandshake
 import timber.log.Timber
+import java.net.HttpURLConnection
 import java.net.URI
+import java.net.URL
 import java.nio.ByteBuffer
 import java.util.Timer
 import kotlin.concurrent.schedule
@@ -497,6 +497,7 @@ class Socket : EventEmitter() {
                 connection?.disconnect()
             }
         }
+
     /**
      * Handle the incoming message from the server based on the events received from the server and call the subscribed event handler
      */

kotlin_client/src/main/java/com/huddle01/kotlin_client/live_data/SupplierMutableLiveData.kt

@@ -10,6 +10,7 @@ class SupplierMutableLiveData<T>(supplier: () -> T) : MutableLiveData<T>() {
         }
 
     }
+
     init {
         value = supplier()
     }

kotlin_client/src/main/java/com/huddle01/kotlin_client/live_data/store/RoomStore.kt

@@ -1,11 +1,11 @@
 package com.huddle01.kotlin_client.live_data.store
 
 import androidx.lifecycle.ViewModel
+import com.huddle01.kotlin_client.live_data.SupplierMutableLiveData
 import com.huddle01.kotlin_client.live_data.store.models.Me
 import com.huddle01.kotlin_client.live_data.store.models.Peers
 import com.huddle01.kotlin_client.live_data.store.models.RoomInfo
 import com.huddle01.kotlin_client.models.enum_class.RoomStates
-import com.huddle01.kotlin_client.live_data.SupplierMutableLiveData
 import io.github.crow_misia.mediasoup.Consumer
 import org.json.JSONObject
 

kotlin_client/src/main/java/com/huddle01/kotlin_client/live_data/store/models/Peers.kt

@@ -3,7 +3,7 @@ package com.huddle01.kotlin_client.live_data.store.models
 import io.github.crow_misia.mediasoup.Consumer
 import org.json.JSONObject
 import timber.log.Timber
-import java.util.*
+import java.util.Collections
 
 class Peers {
     private val peersInfo = Collections.synchronizedMap(LinkedHashMap<String, Peer>())

kotlin_client/src/main/java/com/huddle01/kotlin_client/live_data/store/models/RoomInfo.kt

@@ -4,5 +4,5 @@ import com.huddle01.kotlin_client.models.enum_class.RoomStates
 
 class RoomInfo(
     var roomId: String = "",
-    var connectionState: RoomStates = RoomStates.IDLE
+    var connectionState: RoomStates = RoomStates.IDLE,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/models/GeoData.kt

@@ -2,5 +2,5 @@ package com.huddle01.kotlin_client.models
 
 data class GeoData(
     var region: String,
-    val country: String
+    val country: String,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/models/Reason.kt

@@ -3,5 +3,5 @@ package com.huddle01.kotlin_client.models
 data class Reason(
     val code: Int,
     val tag: String,
-    val message: String
+    val message: String,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/models/RoomConfig.kt

@@ -5,5 +5,5 @@ data class RoomConfig(
     var allowProduce: Boolean = true,
     var allowProduceSources: ProduceSources = ProduceSources(cam = true, mic = true, screen = true),
     var allowConsume: Boolean = true,
-    var allowSendData: Boolean = true
+    var allowSendData: Boolean = true,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/models/RoomStats.kt

@@ -1,5 +1,5 @@
 package com.huddle01.kotlin_client.models
 
 data class RoomStats(
-    val startTime: Long
+    val startTime: Long,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/models/SendData.kt

@@ -3,5 +3,5 @@ package com.huddle01.kotlin_client.models
 data class SendData(
     val to: ArrayList<String>,
     val payload: String,
-    val label: String?
+    val label: String?,
 )

kotlin_client/src/main/java/com/huddle01/kotlin_client/utils/EventEmitter.kt

@@ -30,22 +30,22 @@ open class EventEmitter : EventEmitterInterface {
 
     @Throws(Exception::class)
     override fun on(
-        eventName: String, listener: (args: Array<out Any>) -> Unit
+        eventName: String, listener: (args: Array<out Any>) -> Unit,
     ): EventEmitterInterface {
         return addListener(eventName, listener)
     }
 
 
     @Throws(Exception::class)
     override fun once(
-        eventName: String, listener: (args: Array<out Any>) -> Unit
+        eventName: String, listener: (args: Array<out Any>) -> Unit,
     ): EventEmitterInterface {
         return addListener(eventName, listener, true)
     }
 
 
     override fun addListener(
-        eventName: String, listener: (args: Array<out Any>) -> Unit, isOnce: Boolean
+        eventName: String, listener: (args: Array<out Any>) -> Unit, isOnce: Boolean,
     ): EventEmitterInterface {
         if (defaultMaxListeners != 0 && listenerCount(eventName) >= defaultMaxListeners) {
             //maxListeners exception
@@ -60,7 +60,7 @@ open class EventEmitter : EventEmitterInterface {
 
 
     override fun removeListener(
-        eventName: String, listener: (args: Array<out Any>) -> Unit
+        eventName: String, listener: (args: Array<out Any>) -> Unit,
     ): EventEmitterInterface {
         if (events.containsKey(eventName)) {
             val removeListeners: LinkedList<Listener> = LinkedList()

kotlin_client/src/main/java/com/huddle01/kotlin_client/utils/EventEmitterInterface.kt

@@ -15,12 +15,12 @@ interface EventEmitterInterface {
     fun once(eventName: String, listener: (args: Array<out Any>) -> Unit): EventEmitterInterface
 
     fun addListener(
-        eventName: String, listener: (args: Array<out Any>) -> Unit, isOnce: Boolean = false
+        eventName: String, listener: (args: Array<out Any>) -> Unit, isOnce: Boolean = false,
     ): EventEmitterInterface
 
 
     fun removeListener(
-        eventName: String, listener: (args: Array<out Any>) -> Unit
+        eventName: String, listener: (args: Array<out Any>) -> Unit,
     ): EventEmitterInterface
 
     fun removeAllListeners(eventName: String): EventEmitterInterface