Close the socket on broker disconnect packet

Bump version to 0.0.9

Readme.md

@@ -37,7 +37,7 @@ repositories {
     maven { url "https://jitpack.io" }
 }
 dependencies {
-    implementation 'com.github.davidepianca98:KMQTT:0.0.8'
+    implementation 'com.github.davidepianca98:KMQTT:0.0.9'
 }
 ```
 
@@ -55,7 +55,7 @@ kotlin {
     sourceSets {
         commonMain {
             dependencies {
-                implementation 'com.github.davidepianca98:KMQTT:0.0.8'
+                implementation 'com.github.davidepianca98:KMQTT:0.0.9'
             }
         }
     }

build.gradle.kts

@@ -7,7 +7,7 @@ plugins {
 }
 
 group = "com.github.davidepianca98"
-version = "0.0.8"
+version = "0.0.9"
 
 repositories {
     mavenCentral()
@@ -116,3 +116,16 @@ tasks {
         dependsOn("shadowJar")
     }
 }
+
+publishing {
+    repositories {
+        maven {
+            name = "GitHubPackages"
+            url = uri("https://maven.pkg.github.com/davidepianca98/KMQTT")
+            credentials {
+                username = project.findProperty("gpr.user") as String? ?: System.getenv("GITHUB_USERNAME")
+                password = project.findProperty("gpr.key") as String? ?: System.getenv("GITHUB_PACKAGES")
+            }
+        }
+    }
+}

src/commonMain/kotlin/mqtt/broker/ClientConnection.kt

@@ -101,6 +101,7 @@ class ClientConnection(
     }
 
     private fun close() {
+        client.close()
         broker.sessions[clientId]?.disconnected()
     }
 

src/commonMain/kotlin/socket/Socket.kt

@@ -7,6 +7,8 @@ expect open class Socket : SocketInterface {
     override fun sendRemaining()
 
     override fun read(): UByteArray?
+
+    override fun close()
 }
 
 open class IOException(message: String? = null) : Exception(message)

src/commonMain/kotlin/socket/SocketInterface.kt

@@ -7,4 +7,6 @@ interface SocketInterface {
     fun sendRemaining()
 
     fun read(): UByteArray?
+
+    fun close()
 }

src/jvmMain/kotlin/socket/Socket.kt

@@ -83,7 +83,7 @@ actual open class Socket(private val sendBuffer: ByteBuffer, private val receive
         else null
     }
 
-    fun close() {
+    actual override fun close() {
         val channel = key?.channel() as SocketChannel
         key?.cancel()
         channel.close()

src/linuxArm32HfpMain/kotlin/socket/Socket.kt

@@ -65,7 +65,7 @@ actual open class Socket(
         }
     }
 
-    open fun close() {
+    actual override fun close() {
         shutdown(socket, SHUT_WR)
         close(socket)
     }

src/linuxX64Main/kotlin/socket/Socket.kt

@@ -65,7 +65,7 @@ actual open class Socket(
         }
     }
 
-    open fun close() {
+    actual override fun close() {
         shutdown(socket, SHUT_WR)
         close(socket)
     }

src/mingwMain/kotlin/socket/Socket.kt

@@ -67,7 +67,7 @@ actual open class Socket(
         }
     }
 
-    open fun close() {
+    actual override fun close() {
         shutdown(socket, SD_SEND)
         closesocket(socket)
     }