resumable upload support

Author: lohanidamodar

appwrite/client.py

@@ -11,7 +11,7 @@ def __init__(self):
         self._endpoint = 'https://HOSTNAME/v1'
         self._global_headers = {
             'content-type': '',
-            'x-sdk-version': 'appwrite:python:0.7.0',
+            'x-sdk-version': 'appwrite:python:0.8.0',
             'X-Appwrite-Response-Format' : '0.13.0',
         }
 
@@ -116,6 +116,7 @@ def chunked_upload(
         params = None,
         param_name = '',
         on_progress = None,
+        upload_id = ''
     ):
         file_path = str(params[param_name])
         file_name = os.path.basename(file_path)
@@ -133,6 +134,18 @@ def chunked_upload(
 
         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)
@@ -153,6 +166,7 @@ def chunked_upload(
                 headers["x-appwrite-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,
@@ -161,6 +175,8 @@ def chunked_upload(
                     "chunksUploaded": result["chunksUploaded"],
                 })
 
+            counter = counter + 1
+
         return result
 
     def flatten(self, data, prefix='', stringify=False):

appwrite/services/functions.py

@@ -218,9 +218,12 @@ def create_deployment(self, function_id, entrypoint, code, activate, on_progress
 
         param_name = 'code'
 
+
+        upload_id = ''
+
         return self.client.chunked_upload(path, {
             'content-type': 'multipart/form-data',
-        }, params, param_name, on_progress)
+        }, params, param_name, on_progress, upload_id)
 
     def get_deployment(self, function_id, deployment_id):
         """Get Deployment"""

appwrite/services/storage.py

@@ -220,9 +220,13 @@ def create_file(self, bucket_id, file_id, file, read = None, write = None, on_pr
 
         param_name = 'file'
 
+
+        upload_id = ''
+        upload_id = file_id
+
         return self.client.chunked_upload(path, {
             'content-type': 'multipart/form-data',
-        }, params, param_name, on_progress)
+        }, params, param_name, on_progress, upload_id)
 
     def get_file(self, bucket_id, file_id):
         """Get File"""

setup.py

@@ -3,15 +3,15 @@
 setuptools.setup(
   name = 'appwrite',
   packages = ['appwrite', 'appwrite/services'],
-  version = '0.7.0',
+  version = '0.8.0',
   license='BSD-3-Clause',
   description = 'Appwrite is an open-source self-hosted backend server that abstract and simplify complex and repetitive development tasks behind a very simple REST API',
   author = 'Appwrite Team',
   author_email = '[email protected]',
   maintainer = 'Appwrite Team',
   maintainer_email = '[email protected]',
   url = 'https://appwrite.io/support',
-  download_url='https://github.com/appwrite/sdk-for-python/archive/0.7.0.tar.gz',
+  download_url='https://github.com/appwrite/sdk-for-python/archive/0.8.0.tar.gz',
   # keywords = ['SOME', 'MEANINGFULL', 'KEYWORDS'],
   install_requires=[
           'requests',