Add resumable upload support

Author: abnegate

templates/kotlin/src/main/kotlin/io/appwrite/Client.kt.twig

@@ -184,7 +184,7 @@ class Client @JvmOverloads constructor(
         headers:  Map<String, String> = mapOf(),
         params: Map<String, Any?> = mapOf(),
         responseType: Class<T>,
-        convert: ((Map<String, Any,>) -> T)? = null
+        converter: ((Map<String, Any,>) -> T)? = null
     ): T {
         val filteredParams = params.filterValues { it != null }
 
@@ -220,7 +220,7 @@ class Client @JvmOverloads constructor(
                 .get()
                 .build()
 
-            return awaitResponse(request, responseType, convert)
+            return awaitResponse(request, responseType, converter)
         }
 
         val body = if (MultipartBody.FORM.toString() == headers["content-type"]) {
@@ -257,7 +257,7 @@ class Client @JvmOverloads constructor(
             .method(method, body)
             .build()
 
-        return awaitResponse(request, responseType, convert)
+        return awaitResponse(request, responseType, converter)
     }
 
     /**
@@ -275,8 +275,9 @@ class Client @JvmOverloads constructor(
         headers:  MutableMap<String, String>,
         params: MutableMap<String, Any?>,
         responseType: Class<T>,
-        convert: ((Map<String, Any,>) -> T),
+        converter: ((Map<String, Any,>) -> T),
         paramName: String,
+        idParamName: String? = null,
         onProgress: ((UploadProgress) -> Unit)? = null,
     ): T {
         val file = params[paramName] as File
@@ -289,12 +290,12 @@ class Client @JvmOverloads constructor(
                 file.asRequestBody()
             )
             return call(
-                "POST",
+                method = "POST",
                 path,
                 headers,
                 params,
                 responseType,
-                convert
+                converter
             )
         }
 
@@ -303,6 +304,22 @@ class Client @JvmOverloads constructor(
         var offset = 0L
         var result: Map<*, *>? = null
 
+        if (idParamName?.isNotEmpty() == true && params[idParamName] != "unique()") {
+            // Make a request to check if a file already exists
+            try {
+                val current = call(
+                    method = "GET",
+                    path = "$path/$params[idParamName]",
+                    headers = headers,
+                    params = emptyMap(),
+                    responseType = Map::class.java,
+                )
+                val chunksUploaded = current["chunksUploaded"] as Long
+                offset = size.coerceAtMost(chunksUploaded * CHUNK_SIZE)
+            } catch (ex: {{spec.title | caseUcfirst}}Exception) {
+            }
+        }
+
         generateSequence {
             val readBytes = input.read(buffer)
             if (readBytes >= 0) {
@@ -322,11 +339,11 @@ class Client @JvmOverloads constructor(
                 "bytes $offset-${((offset + CHUNK_SIZE) - 1).coerceAtMost(size)}/$size"
 
             result = call(
-                "POST",
+                method = "POST",
                 path,
                 headers,
                 params,
-                Map::class.java
+                responseType = Map::class.java
             )
 
             offset += CHUNK_SIZE
@@ -336,27 +353,27 @@ class Client @JvmOverloads constructor(
                 progress = offset.coerceAtMost(size).toDouble()/size * 100,
                 sizeUploaded = offset.coerceAtMost(size),
                 chunksTotal = result!!["chunkTotal"].toString().toInt(),
-                chunksUploaded = result!!["chunkUploaded"].toString().toInt(),
+                chunksUploaded = result!!["chunksUploaded"].toString().toInt(),
             ))
         }
 
-        return convert(result as Map<String, Any>)
+        return converter(result as Map<String, Any>)
     }
 
     /**
      * Await Response
      *
      * @param request
      * @param responseType
-     * @param convert
+     * @param converter
      *
      * @return [T]
      */
     @Throws({{ spec.title | caseUcfirst }}Exception::class)
     private suspend fun <T> awaitResponse(
         request: Request,
         responseType: Class<T>,
-        convert: ((Map<String, Any,>) -> T)? = null
+        converter: ((Map<String, Any,>) -> T)? = null
     ) = suspendCancellableCoroutine<T> {
         http.newCall(request).enqueue(object : Callback {
             override fun onFailure(call: Call, e: IOException) {
@@ -422,7 +439,7 @@ class Client @JvmOverloads constructor(
                     object : TypeToken<Map<String, Any>>(){}.type
                 )
                 it.resume(
-                    convert?.invoke(map) ?: map as T
+                    converter?.invoke(map) ?: map as T
                 )
             }
         })

templates/kotlin/src/main/kotlin/io/appwrite/services/ServiceTemplate.kt.twig

@@ -112,7 +112,7 @@ class {{ service.name | caseUcfirst }}(client: Client) : Service(client) {
 {{ method.headers|map((header, key) => "            \"#{key}\" to \"#{header}\"")|join(',\n')|raw }}
         )
 {% if method.responseModel %}
-        val convert: (Map<String, Any>) -> {{ _self.resultType(sdk.namespace, method) }} = {
+        val converter: (Map<String, Any>) -> {{ _self.resultType(sdk.namespace, method) }} = {
 {% if method.responseModel == 'any' %}
             it
 {% else %}
@@ -121,20 +121,25 @@ class {{ service.name | caseUcfirst }}(client: Client) : Service(client) {
         }
 {% endif %}
 {% if 'multipart/form-data' in method.consumes %}
+        var idParamName: String? = null
 {% for parameter in method.parameters.all %}
 {% if parameter.type == 'file' %}
         val paramName = "{{ parameter.name }}"
 {% endif %}
+{% if parameter.isUploadID %}
+        idParamName = "{{ parameter.name }}"
+{% endif %}
 {% endfor %}
         return client.chunkedUpload(
             path,
             headers,
             params,
             responseType = {{ _self.resultType(sdk.namespace, method) }}::class.java,
 {% if method.responseModel %}
-            convert = convert,
+            converter,
 {% endif %}
             paramName,
+            idParamName,
             onProgress,
         )
 {% else %}
@@ -145,7 +150,7 @@ class {{ service.name | caseUcfirst }}(client: Client) : Service(client) {
             params,
             responseType = {{ _self.resultType(sdk.namespace, method) }}::class.java,
 {% if method.responseModel %}
-            convert = convert,
+            converter,
 {% endif %}
         )
 {% endif %}