Feat android/kotlin realtime

src/SDK/Language/Android.php

@@ -136,8 +136,14 @@ public function getFiles()
             ],
             [
                 'scope'         => 'default',
-                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/models/Error.kt',
-                'template'      => '/android/library/src/main/java/io/appwrite/models/Error.kt.twig',
+                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/extensions/CollectionExtensions.kt',
+                'template'      => '/android/library/src/main/java/io/appwrite/extensions/CollectionExtensions.kt.twig',
+                'minify'        => false,
+            ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/models/RealtimeModels.kt',
+                'template'      => '/android/library/src/main/java/io/appwrite/models/RealtimeModels.kt.twig',
                 'minify'        => false,
             ],
             [
@@ -160,10 +166,16 @@ public function getFiles()
             ],
             [
                 'scope'         => 'default',
-                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/services/BaseService.kt',
+                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/services/Service.kt',
                 'template'      => '/android/library/src/main/java/io/appwrite/services/Service.kt.twig',
                 'minify'        => false,
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/services/Realtime.kt',
+                'template'      => '/android/library/src/main/java/io/appwrite/services/Realtime.kt.twig',
+                'minify'        => false,
+            ],
             [
                 'scope'         => 'service',
                 'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/services/{{service.name | caseUcfirst}}.kt',

templates/android/.github/workflows/publish.yml

@@ -50,4 +50,5 @@ jobs:
           SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
           SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
           SIGNING_SECRET_KEY_RING_FILE: ${{ secrets.SIGNING_SECRET_KEY_RING_FILE }}
-          SONATYPE_STAGING_PROFILE_ID: ${{ secrets.SONATYPE_STAGING_PROFILE_ID }}
+          SONATYPE_STAGING_PROFILE_ID: ${{ secrets.SONATYPE_STAGING_PROFILE_ID }}
+          SDK_VERSION: ${{ github.event.release.tag_name }}

templates/android/library/build.gradle.twig

@@ -7,7 +7,7 @@ plugins {
 ext {
     PUBLISH_GROUP_ID = '{{ sdk.namespace | caseDot }}'
     PUBLISH_ARTIFACT_ID = '{{ sdk.gitRepoName | caseDash }}'
-    PUBLISH_VERSION = '{{ sdk.version }}'
+    PUBLISH_VERSION = System.getenv('SDK_VERSION')
     POM_URL = 'https://github.com/{{ sdk.gitUserName }}/{{ sdk.gitRepoName }}'
     POM_SCM_URL = 'https://github.com/{{ sdk.gitUserName }}/{{ sdk.gitRepoName }}'
     POM_ISSUE_URL = 'https://github.com/{{ sdk.gitUserName }}/{{ sdk.gitRepoName }}/issues'
@@ -53,8 +53,8 @@ android {
 
 dependencies {
     implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8:${KotlinCompilerVersion.VERSION}")
-    api("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.4.3")
-    api("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.4.3")
+    api("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.5.1")
+    api("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.5.0")
 
     api(platform("com.squareup.okhttp3:okhttp-bom:4.9.0"))
     api("com.squareup.okhttp3:okhttp")
@@ -65,15 +65,16 @@ dependencies {
     implementation("net.gotev:cookie-store:1.3.5")
     implementation("androidx.lifecycle:lifecycle-runtime-ktx:2.3.1")
     implementation("androidx.lifecycle:lifecycle-common-java8:2.3.1")
-    implementation("androidx.appcompat:appcompat:1.2.0")
-    implementation("androidx.fragment:fragment-ktx:1.3.2")
-    implementation("androidx.activity:activity-ktx:1.2.2")
+    implementation("androidx.appcompat:appcompat:1.3.1")
+    implementation("androidx.fragment:fragment-ktx:1.3.6")
+    implementation("androidx.activity:activity-ktx:1.3.1")
     implementation("androidx.browser:browser:1.3.0")
 
     testImplementation 'junit:junit:4.+'
-    testImplementation "androidx.test.ext:junit-ktx:1.1.2"
-    testImplementation "androidx.test:core-ktx:1.3.0"
+    testImplementation "androidx.test.ext:junit-ktx:1.1.3"
+    testImplementation "androidx.test:core-ktx:1.4.0"
     testImplementation "org.robolectric:robolectric:4.5.1"
+    testApi("org.jetbrains.kotlinx:kotlinx-coroutines-test:1.5.1")
 }
 
 apply from: "${rootProject.projectDir}/scripts/publish-module.gradle"

templates/android/library/src/main/java/io/appwrite/Client.kt.twig

@@ -5,8 +5,7 @@ import android.content.pm.PackageManager
 import com.google.gson.Gson
 import io.appwrite.appwrite.BuildConfig
 import {{ sdk.namespace | caseDot }}.exceptions.{{ spec.title | caseUcfirst }}Exception
-import {{ sdk.namespace | caseDot }}.extensions.JsonExtensions.fromJson
-import {{ sdk.namespace | caseDot }}.models.Error
+import {{ sdk.namespace | caseDot }}.extensions.fromJson
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.Job
@@ -36,6 +35,7 @@ import kotlin.coroutines.resume
 class Client @JvmOverloads constructor(
     context: Context,
     var endPoint: String = "https://appwrite.io/v1",
+    var endPointRealtime: String? = null,
     private var selfSigned: Boolean = false
 ) : CoroutineScope {
 
@@ -151,14 +151,31 @@ class Client @JvmOverloads constructor(
     }
 
     /**
-     * Set endpoint
+     * Set endpoint and realtime endpoint.
      * 
      * @param endpoint
      *
      * @return this     
      */
     fun setEndpoint(endPoint: String): Client {
         this.endPoint = endPoint
+
+        if (this.endPointRealtime == null && endPoint.startsWith("http")) {
+            this.endPointRealtime = endPoint.replaceFirst("http", "ws")
+        }
+
+        return this
+    }
+
+    /**
+    * Set realtime endpoint
+    *
+    * @param endpoint
+    *
+    * @return this
+    */
+    fun setEndpointRealtime(endPoint: String): Client {
+        this.endPointRealtime = endPoint
         return this
     }
 
@@ -297,9 +314,9 @@ class Client @JvmOverloads constructor(
 
                     val contentType: String = response.headers["content-type"] ?: ""
                     val error = if (contentType.contains("application/json", ignoreCase = true)) {
-                        bodyString.fromJson(Error::class.java)
+                        bodyString.fromJson<{{ spec.title | caseUcfirst }}Exception>()
                     } else {
-                        Error(bodyString, response.code)
+                        {{ spec.title | caseUcfirst }}Exception(bodyString, response.code)
                     }
 
                     it.cancel(AppwriteException(

templates/android/library/src/main/java/io/appwrite/extensions/CollectionExtensions.kt.twig

@@ -0,0 +1,12 @@
+package {{ sdk.namespace | caseDot }}.extensions
+
+import kotlinx.coroutines.Dispatchers.IO
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.withContext
+
+suspend fun <T> Collection<T>.forEachAsync(
+    callback: suspend (T) -> Unit
+) = withContext(IO) {
+    map { async { callback.invoke(it) } }.awaitAll()
+}

templates/android/library/src/main/java/io/appwrite/extensions/JsonExtensions.kt.twig

@@ -2,11 +2,33 @@ package {{ sdk.namespace | caseDot }}.extensions
 
 import com.google.gson.Gson
 
-object JsonExtensions {
+val gson = Gson()
 
-    fun Any.toJson(): String =
-        Gson().toJson(this)
+fun Any.toJson(): String =
+    gson.toJson(this)
 
-    fun <T> String.fromJson(clazz: Class<T>): T =
-        Gson().fromJson(this, clazz)
-}
+fun <T> String.fromJson(clazz: Class<T>): T =
+    gson.fromJson(this, clazz)
+
+inline fun <reified T> String.fromJson(): T =
+    gson.fromJson(this, T::class.java)
+
+fun <T> Any.jsonCast(to: Class<T>): T =
+    toJson().fromJson(to)
+
+inline fun <reified T> Any.jsonCast(): T =
+    toJson().fromJson(T::class.java)
+
+fun <T> Any.tryJsonCast(to: Class<T>): T? = try {
+    toJson().fromJson(to)
+} catch (ex: Exception) {
+    ex.printStackTrace()
+    null
+}
+
+inline fun <reified T> Any.tryJsonCast(): T? = try {
+    toJson().fromJson(T::class.java)
+} catch (ex: Exception) {
+    ex.printStackTrace()
+    null
+}

templates/android/library/src/main/java/io/appwrite/models/RealtimeModels.kt.twig

@@ -0,0 +1,31 @@
+package {{ sdk.namespace | caseDot }}.models
+
+import java.io.Closeable
+
+data class RealtimeSubscription(
+    private val close: () -> Unit
+) : Closeable {
+    override fun close() = close.invoke()
+}
+
+data class RealtimeCallback(
+    val payloadClass: Class<*>,
+    val callback: (RealtimeResponseEvent<*>) -> Unit
+)
+
+open class RealtimeResponse(
+    val type: String,
+    val data: Any
+)
+
+data class RealtimeResponseEvent<T>(
+    val event: String,
+    val channels: Collection<String>,
+    val timestamp: Long,
+    var payload: T
+)
+
+enum class RealtimeCode(val value: Int) {
+    POLICY_VIOLATION(1008),
+    UNKNOWN_ERROR(-1)
+}