feat: support for 0.13.0

Author: TorstenDittmann

README.md

@@ -1,12 +1,12 @@
 # Appwrite Python SDK
 
 ![License](https://img.shields.io/github/license/appwrite/sdk-for-python.svg?style=flat-square)
-![Version](https://img.shields.io/badge/api%20version-0.12.0-blue.svg?style=flat-square)
+![Version](https://img.shields.io/badge/api%20version-0.13.0-blue.svg?style=flat-square)
 [![Build Status](https://img.shields.io/travis/com/appwrite/sdk-generator?style=flat-square)](https://travis-ci.com/appwrite/sdk-generator)
 [![Twitter Account](https://img.shields.io/twitter/follow/appwrite?color=00acee&label=twitter&style=flat-square)](https://twitter.com/appwrite)
 [![Discord](https://img.shields.io/discord/564160730845151244?label=discord&style=flat-square)](https://appwrite.io/discord)
 
-**This SDK is compatible with Appwrite server version 0.12.x. For older versions, please check [previous releases](https://github.com/appwrite/sdk-for-python/releases).**
+**This SDK is compatible with Appwrite server version 0.13.x. For older versions, please check [previous releases](https://github.com/appwrite/sdk-for-python/releases).**
 
 Appwrite is an open-source backend as a service server that abstract and simplify complex and repetitive development tasks behind a very simple to use REST API. Appwrite aims to help you develop your apps faster and in a more secure way. Use the Python SDK to integrate your app with the Appwrite server to easily start interacting with all of Appwrite backend APIs and tools. For full API documentation and tutorials go to [https://appwrite.io/docs](https://appwrite.io/docs)
 

appwrite/client.py

@@ -1,15 +1,18 @@
 import io
 import requests
+import os
+from .input_file import InputFile
 from .exception import AppwriteException
 
 class Client:
     def __init__(self):
+        self._chunk_size = 5*1024*1024
         self._self_signed = False
         self._endpoint = 'https://HOSTNAME/v1'
         self._global_headers = {
             'content-type': '',
-            'x-sdk-version': 'appwrite:python:0.6.1',
-            'X-Appwrite-Response-Format' : '0.12.0',
+            'x-sdk-version': 'appwrite:python:0.6.0',
+            'X-Appwrite-Response-Format' : '0.13.0',
         }
 
     def set_self_signed(self, status=True):
@@ -56,6 +59,7 @@ def call(self, method, path='', headers=None, params=None):
         data = {}
         json = {}
         files = {}
+        stringify = False
 
         headers = {**self._global_headers, **headers}
 
@@ -69,17 +73,17 @@ def call(self, method, path='', headers=None, params=None):
 
         if headers['content-type'].startswith('multipart/form-data'):
             del headers['content-type']
-            
+            stringify = True
             for key in data.copy():
-                if isinstance(data[key], io.BufferedIOBase):
-                    files[key] = data[key]
+                if isinstance(data[key], InputFile):
+                    files[key] = (data[key].name, data[key].file)
                     del data[key]
         response = None
         try:
             response = requests.request(  # call method dynamically https://stackoverflow.com/a/4246075/2299554
                 method=method,
                 url=self._endpoint + path,
-                params=self.flatten(params),
+                params=self.flatten(params, stringify=stringify),
                 data=self.flatten(data),
                 json=json,
                 files=files,
@@ -99,13 +103,67 @@ def call(self, method, path='', headers=None, params=None):
             if response != None:
                 content_type = response.headers['Content-Type']
                 if content_type.startswith('application/json'):
-                    raise AppwriteException(response.json()['message'], response.status_code, response.json())
+                    raise AppwriteException(response.json()['message'], response.status_code, response.json().get('type'), response.json())
                 else:
                     raise AppwriteException(response.text, response.status_code)
             else:
                 raise AppwriteException(e)
 
-    def flatten(self, data, prefix=''):
+    def chunked_upload(
+        self,
+        path,
+        headers = None,
+        params = None,
+        param_name = '',
+        on_progress = None,
+    ):
+        file_path = str(params[param_name])
+        file_name = os.path.basename(file_path)
+        size = os.stat(file_path).st_size
+
+        if size < self._chunk_size:
+            slice = open(file_path, 'rb').read()
+            params[param_name] = InputFile(file_path, file_name, slice)
+            return self.call(
+                'post',
+                path,
+                headers,
+                params
+            )
+
+        input = open(file_path, 'rb')
+        offset = 0
+
+        while offset < size:
+            slice = input.read(self._chunk_size) or input.read(size - offset)
+
+            params[param_name] = InputFile(file_path, file_name, slice)
+            headers["content-range"] = f'bytes {offset}-{min((offset + self._chunk_size) - 1, size)}/{size}'
+
+            result = self.call(
+                'post',
+                path,
+                headers,
+                params,
+            )
+            
+            offset = offset + self._chunk_size
+            
+            if "$id" in result: 
+                headers["x-appwrite-id"] = result["$id"]
+
+            if on_progress is not None:
+                on_progress({
+                    "$id": result["$id"],
+                    "progress": min(offset, size)/size * 100,
+                    "sizeUploaded": end+1,
+                    "chunksTotal": result["chunksTotal"],
+                    "chunksUploaded": result["chunksUploaded"],
+                })
+
+        return result
+
+    def flatten(self, data, prefix='', stringify=False):
         output = {}
         i = 0
 
@@ -116,9 +174,12 @@ def flatten(self, data, prefix=''):
             i += 1
 
             if isinstance(value, list) or isinstance(value, dict):
-                output = {**output, **self.flatten(value, finalKey)}
+                output = {**output, **self.flatten(value, finalKey, stringify)}
             else:
-                output[finalKey] = value
+                if stringify:
+                    output[finalKey] = str(value)
+                else:
+                    output[finalKey] = value
 
         return output
 

appwrite/exception.py

@@ -1,6 +1,7 @@
 class AppwriteException(Exception):
-    def __init__(self, message, code = 0, response = None):
+    def __init__(self, message, code = 0, type = None, response = None):
         self.message = message
         self.code = code
+        self.type = type
         self.response = response
         super().__init__(self.message)

appwrite/input_file.py

@@ -0,0 +1,5 @@
+class InputFile:
+    def __init__(self, path, name, file):
+        self.path = path
+        self.name = name
+        self.file = file

appwrite/services/account.py

@@ -215,6 +215,20 @@ def get_session(self, session_id):
             'content-type': 'application/json',
         }, params)
 
+    def update_session(self, session_id):
+        """Update Session (Refresh Tokens)"""
+
+        if session_id is None: 
+            raise AppwriteException('Missing required parameter: "session_id"')
+
+        params = {}
+        path = '/account/sessions/{sessionId}'
+        path = path.replace('{sessionId}', session_id)                
+
+        return self.client.call('patch', path, {
+            'content-type': 'application/json',
+        }, params)
+
     def delete_session(self, session_id):
         """Delete Account Session"""