Merge pull request #414 from appwrite/feat-resumable-upload-ruby

Feat resumable upload ruby

Author: abnegate

templates/ruby/lib/container/client.rb.twig

@@ -100,6 +100,7 @@ module {{ spec.title | caseUcfirst }}
             headers:,
             params:,
             param_name: '',
+            id_param_name: nil,
             on_progress: nil,
             response_type: nil
         )
@@ -118,11 +119,22 @@ module {{ spec.title | caseUcfirst }}
                 )
             end
 
-            input = ::File.open(file_path)
             offset = 0
+            id_param_name = id_param_name.to_sym if id_param_name
+            if id_param_name&.empty? == false && params[id_param_name] != "unique()"
+                # Make a request to check if a file already exists
+                current = call(
+                    method: "GET",
+                    path: "#{path}/#{params[id_param_name]}",
+                    headers: headers,
+                    params: {}
+                )
+                chunks_uploaded = current['chunksUploaded'].to_i
+                offset = [size, (chunks_uploaded * @chunk_size)].min
+            end
 
             while offset < size
-                slice = input.read(@chunk_size)
+                slice = IO.read(file_path, @chunk_size, offset)
 
                 params[param_name] = File.new(file_path, slice)
                 headers['content-range'] = "bytes #{offset}-#{[offset + @chunk_size - 1, size].min}/#{size}"
@@ -144,8 +156,8 @@ module {{ spec.title | caseUcfirst }}
                     id: result['$id'],
                     progress: ([offset, size].min).to_f/size.to_f * 100.0,
                     size_uploaded: [offset, size].min,
-                    chunks_total: result['chunks_total'],
-                    chunks_uploaded: result['chunks_uploaded']
+                    chunks_total: result['chunksTotal'],
+                    chunks_uploaded: result['chunksUploaded']
                 }) unless on_progress.nil?
             end
 

templates/ruby/lib/container/services/service.rb.twig

@@ -41,6 +41,8 @@ module {{spec.title | caseUcfirst}}
             }
 
 {% if 'multipart/form-data' in method.consumes %}
+            id_param_name = {% if method.parameters.all | filter(p => p.isUploadID) | length > 0 %}{% for parameter in method.parameters.all | filter(parameter => parameter.isUploadID) %}"{{ parameter.name }}"{% endfor %}{% else %}nil{% endif %}
+
 {% for parameter in method.parameters.all %}
 {% if parameter.type == 'file' %}
             param_name = '{{ parameter.name }}'
@@ -52,6 +54,7 @@ module {{spec.title | caseUcfirst}}
                 headers: headers,
                 params: params,
                 param_name: param_name,
+                id_param_name: id_param_name,
                 on_progress: on_progress,
 {% if method.responseModel and method.responseModel != 'any' %}
                 response_type: Models::{{method.responseModel | caseUcfirst}}