handle leave message, leave immediately

@@ -2,6 +2,6 @@ package io.livekit.android
 
 
 class Version {
 class Version {
     companion object {
     companion object {
-        const val CLIENT_VERSION = "0.5.0"
+        const val CLIENT_VERSION = "0.5.1"
     }
     }
 }
 }

@@ -275,6 +275,9 @@ constructor(
             LivekitRtc.SignalResponse.MessageCase.JOIN -> {
             LivekitRtc.SignalResponse.MessageCase.JOIN -> {
                 Timber.d { "received unexpected extra join message?" }
                 Timber.d { "received unexpected extra join message?" }
             }
             }
+            LivekitRtc.SignalResponse.MessageCase.LEAVE -> {
+                listener?.onLeave()
+            }
             LivekitRtc.SignalResponse.MessageCase.MESSAGE_NOT_SET,
             LivekitRtc.SignalResponse.MessageCase.MESSAGE_NOT_SET,
             null -> {
             null -> {
                 Timber.v { "empty messageCase!" }
                 Timber.v { "empty messageCase!" }
@@ -296,6 +299,7 @@ constructor(
         fun onParticipantUpdate(updates: List<LivekitModels.ParticipantInfo>)
         fun onParticipantUpdate(updates: List<LivekitModels.ParticipantInfo>)
         fun onActiveSpeakersChanged(speakers: List<LivekitRtc.SpeakerInfo>)
         fun onActiveSpeakersChanged(speakers: List<LivekitRtc.SpeakerInfo>)
         fun onClose(reason: String, code: Int)
         fun onClose(reason: String, code: Int)
+        fun onLeave()
         fun onError(error: Exception)
         fun onError(error: Exception)
     }
     }
 
 

@@ -289,10 +289,16 @@ constructor(
     }
     }
 
 
     override fun onClose(reason: String, code: Int) {
     override fun onClose(reason: String, code: Int) {
+        // TODO: reconnect logic
         Timber.i { "received close event: $reason, code: $code" }
         Timber.i { "received close event: $reason, code: $code" }
         listener?.onDisconnect(reason)
         listener?.onDisconnect(reason)
     }
     }
 
 
+    override fun onLeave() {
+        close()
+        listener?.onDisconnect("")
+    }
+
     override fun onError(error: Exception) {
     override fun onError(error: Exception) {
         listener?.onFailToConnect(error)
         listener?.onFailToConnect(error)
     }
     }