Merge pull request #402 from appwrite/feat-resumable-upload-python

Feat: Python resumable upload

Author: christyjacob4

templates/python/package/client.py.twig

@@ -106,6 +106,7 @@ class Client:
         params = None,
         param_name = '',
         on_progress = None,
+        upload_id = ''
     ):
         file_path = str(params[param_name])
         file_name = os.path.basename(file_path)
@@ -123,6 +124,18 @@ class Client:
 
         input = open(file_path, 'rb')
         offset = 0
+        counter = 0
+
+        if upload_id != 'unique()':
+            try:
+                result = self.call('get', path + '/' + upload_id, headers)
+                counter = result['chunksUploaded']
+            except:
+                pass
+
+        if counter > 0:
+            offset = counter * self._chunk_size
+            input.seek(offset)
 
         while offset < size:
             slice = input.read(self._chunk_size) or input.read(size - offset)
@@ -143,6 +156,7 @@ class Client:
                 headers["x-{{ spec.title | caseLower }}-id"] = result["$id"]
 
             if on_progress is not None:
+                end = min((((counter * self._chunk_size) + self._chunk_size) - 1), size)
                 on_progress({
                     "$id": result["$id"],
                     "progress": min(offset, size)/size * 100,
@@ -151,6 +165,8 @@ class Client:
                     "chunksUploaded": result["chunksUploaded"],
                 })
 
+            counter = counter + 1
+
         return result
 
     def flatten(self, data, prefix='', stringify=False):

templates/python/package/services/service.py.twig

@@ -47,14 +47,22 @@ class {{ service.name | caseUcfirst }}(Service):
 
 {% endif %}
 {% endfor %}
+
+        upload_id = ''
+{% for parameter in method.parameters.all %}
+{% if parameter.isUploadID %}
+        upload_id = {{ parameter.name | escapeKeyword | caseSnake }}
+{% endif %}
+{% endfor %}
+
         return self.client.chunked_upload(path, {
 {% for parameter in method.parameters.header %}
             '{{ parameter.name }}': {{ parameter.name | escapeKeyword | caseSnake }},
 {% endfor %}
 {% for key, header in method.headers %}
             '{{ key }}': '{{ header }}',
 {% endfor %}
-        }, params, param_name, on_progress)
+        }, params, param_name, on_progress, upload_id)
 {% else %}
         return self.client.call('{{ method.method | caseLower }}', path, {
 {% for parameter in method.parameters.header %}