Fix socket creation in Realtime.kt

The socket was being created unnecessarily whenever a subscription was removed. This change ensures that the socket is only created when there are active channels.

Author: camka14

templates/kmp/shared/src/commonMain/kotlin/io/package/BaseClient.kt.twig

@@ -361,14 +361,14 @@ abstract class BaseClient<This : BaseClient<This>>(
 
                 if (response.contentType()?.match(ContentType.Application.Json) == true) {
                     val map = json.decodeFromString<Map<String, JsonElement>>(body)
-                    throw AppwriteException(
+                    throw {{ spec.title | caseUcfirst }}Exception(
                         (map["message"] as? JsonPrimitive)?.content ?: "",
                         (map["code"] as? JsonPrimitive)?.int ?: 0,
                         (map["type"] as? JsonPrimitive)?.content ?: "",
                         body
                     )
                 } else {
-                    throw AppwriteException(body, response.status.value)
+                    throw {{ spec.title | caseUcfirst }}Exception(body, response.status.value)
                 }
             }
 
@@ -383,7 +383,7 @@ abstract class BaseClient<This : BaseClient<This>>(
                         body.isEmpty() -> when (responseType) {
                             String::class -> "" as T
                             Boolean::class -> true as T
-                            else -> throw AppwriteException(
+                            else -> throw {{ spec.title | caseUcfirst }}Exception(
                                 "Empty response body",
                                 response.status.value
                             )
@@ -394,7 +394,7 @@ abstract class BaseClient<This : BaseClient<This>>(
                             serializer?.let { json.decodeFromString(it, body) }
                                 ?: json.decodeFromString(responseType.serializer(), body)
                         } catch (e: Exception) {
-                            throw AppwriteException(
+                            throw {{ spec.title | caseUcfirst }}Exception(
                                 "Failed to parse JSON response: ${e.message}",
                                 response.status.value,
                                 response = body

templates/kmp/shared/src/commonMain/kotlin/io/package/services/Realtime.kt.twig

@@ -2,7 +2,7 @@ package {{ sdk.namespace | caseDot }}.services
 
 import {{ sdk.namespace | caseDot }}.Client
 import {{ sdk.namespace | caseDot }}.Service
-import {{ sdk.namespace | caseDot }}.exceptions.AppwriteException
+import {{ sdk.namespace | caseDot }}.exceptions.{{ spec.title | caseUcfirst }}Exception
 import {{ sdk.namespace | caseDot }}.extensions.forEachAsync
 import {{ sdk.namespace | caseDot }}.extensions.fromJson
 import {{ sdk.namespace | caseDot }}.extensions.getSerializer
@@ -53,32 +53,31 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
 
     private fun createSocket() {
         launch(Dispatchers.IO) {
+            try {
 
-            if (activeChannels.isEmpty()) {
-                reconnect = false
-                closeSocket()
-                return@launch
-            }
-
-            val queryParams = buildString {
-                append("project=${client.config["project"]}")
-                activeChannels.forEach {
-                    append("&channels[]=$it")
+                if (activeChannels.isEmpty()) {
+                    reconnect = false
+                    closeSocket()
+                    return@launch
                 }
-            }
 
-            if (webSocketSession != null) {
-                reconnect = false
-                closeSocket()
-            }
+                val queryParams = buildString {
+                    append("project=${client.config["project"]}")
+                    activeChannels.forEach {
+                        append("&channels[]=$it")
+                    }
+                }
 
-            webSocketSession = client.httpClient.webSocketSession {
-                url("${client.endpointRealtime}/realtime?$queryParams")
-            }
+                if (webSocketSession != null) {
+                    reconnect = false
+                    closeSocket()
+                }
 
-            reconnectAttempts = 0  // Reset attempts on successful connection
+                webSocketSession = client.httpClient.webSocketSession {
+                    url("${client.endpointRealtime}/realtime?$queryParams")
+                }
 
-            try {
+                reconnectAttempts = 0  // Reset attempts on successful connection
                 webSocketSession?.let { session ->
                     for (frame in session.incoming) {
                         when (frame) {
@@ -87,6 +86,7 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
                         }
                     }
                 }
+
             } catch (e: Exception) {
                 handleFailure(e)
             } finally {
@@ -149,7 +149,6 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
         return RealtimeSubscription {
             activeSubscriptions.remove(counter)
             cleanUp(channels)
-            createSocket()
         }
     }
 
@@ -174,7 +173,7 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
     }
 
     private fun handleResponseError(message: RealtimeResponse) {
-        throw message.data.jsonCast<AppwriteException>()
+        throw message.data.jsonCast<{{ spec.title | caseUcfirst }}Exception>()
     }
 
     @Throws(Throwable::class)