feat: SDK update for version 0.6.0 (#8)

* chore: update Console Python SDK to 0.1.0

* chore: update Console Python SDK to 0.1.0

* chore: update Console Python SDK to 0.2.0

* chore: update Console Python SDK to 0.2.1

* chore: update Console Python SDK to 0.3.0

* chore: update Console Python SDK to 0.4.0

* chore: update Console Python SDK to 0.4.0

* chore: update Console Python SDK to 0.5.0

* chore: update Console Python SDK to 0.5.0

* chore: update Console Python SDK to 0.5.0

* chore: update Console Python SDK to 0.6.0

* chore: update Console Python SDK to 0.6.0

* chore: update Console Python SDK to 0.6.0

* chore: update Console Python SDK to 0.6.0

---------

Co-authored-by: Chirag Aggarwal <chirag@appwrite.io>

Author: ChiragAgg5k

CHANGELOG.md

@@ -1,5 +1,27 @@
 # Change Log
 
+## 0.6.0
+
+* Breaking: `Execution.functionId` replaced by `resourceId` and `resourceType`
+* Breaking: `UsageEventMetric` and `UsageGaugeMetric` are plain string constants, not `Enum` members
+* Breaking: `list_events` and `list_gauges` take `metrics` as plain strings
+* Breaking: `UsageOrganizationProject` usage fields are single totals, not `List[Metric]`
+* Breaking: `conditions`, `resourceData`, `items`, `discounts`, `authorizationDetails` and `rows` are lists, not dicts
+* Breaking: Removed `ProjectKeyScopes.DEDICATEDDATABASES_EXECUTE`
+* Breaking: `Addon` enum renamed to `AddonKey`; `get_addon_price` takes `AddonKey`
+* Added: `huggingface` OAuth2 provider, `OAuth2HuggingFace` and `update_o_auth2_hugging_face`
+* Added: `avatars.get_photo` for Gravatar-backed profile photos
+* Added: `scopes` on `sites.create`, `sites.update` and `Site`
+* Added: `strategy` and `max_bucket_size` on WAF rate limit rules
+* Added: `bun-1.4` runtime and build runtime
+* Added: usage metrics for webhook events, phone auth, messages, per-service build mbSeconds and WAF challenges
+* Added: `BillingPlan.databaseComputeCredit` and `BillingPlan.supportsDedicatedDatabases`
+* Added: `Database.lifecycleState`, `Database.containerStatus` and `Database.error`
+* Added: `DatabaseMigration.changelogWatermark`, `replicating` on replicas and members, `DedicatedDatabaseBranchList.total`
+* Added: `_APP_VCS_PROVIDERS_WITH_PUBLIC_REPOSITORIES` and `_APP_VCS_PROVIDERS_WITH_REPOSITORY_CREATION`
+* Fixed: chunked uploads only probe for prior progress when an `upload_id` is given
+* Updated: `Project.wafEnabled` and `UsageDataPoint.time` are optional
+
 ## 0.5.0
 
 * Breaking: `Preferences` serializes its keys at the top level, not nested under `data`

appwrite_console/__init__.py

@@ -1 +0,0 @@
- 

appwrite_console/client.py

@@ -10,19 +10,20 @@
 from .exception import AppwriteException
 from .encoders.value_class_encoder import ValueClassEncoder
 
+
 class Client:
     def __init__(self):
-        self._chunk_size = 5*1024*1024
+        self._chunk_size = 5 * 1024 * 1024
         self._self_signed = False
         self._endpoint = 'https://cloud.appwrite.io/v1'
         self._global_headers = {
             'content-type': '',
-            'user-agent' : f'AppwritePythonSDK/0.5.0 ({platform.uname().system}; {platform.uname().version}; {platform.uname().machine})',
+            'user-agent': f'AppwritePythonSDK/0.6.0 ({platform.uname().system}; {platform.uname().version}; {platform.uname().machine})',
             'x-sdk-name': 'Console Python',
             'x-sdk-platform': 'console',
             'x-sdk-language': 'python',
-            'x-sdk-version': '0.5.0',
-            'X-Appwrite-Response-Format' : '1.9.6',
+            'x-sdk-version': '0.6.0',
+            'X-Appwrite-Response-Format': '1.9.6',
         }
         self._config = {}
 
@@ -179,7 +180,7 @@ def call(self, method, path='', headers=None, params=None, response_type='json')
                 files=files,
                 headers=headers,
                 verify=(not self._self_signed),
-                allow_redirects=False if response_type == 'location' else True
+                allow_redirects=False if response_type == 'location' else True,
             )
 
             response.raise_for_status()
@@ -202,7 +203,9 @@ def call(self, method, path='', headers=None, params=None, response_type='json')
             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().get('type'), response.text)
+                    raise AppwriteException(
+                        response.json()['message'], response.status_code, response.json().get('type'), response.text
+                    )
                 else:
                     raise AppwriteException(response.text, response.status_code, None, response.text)
             else:
@@ -211,11 +214,11 @@ def call(self, method, path='', headers=None, params=None, response_type='json')
     def chunked_upload(
         self,
         path,
-        headers = None,
-        params = None,
-        param_name = '',
-        on_progress = None,
-        upload_id = ''
+        headers=None,
+        params=None,
+        param_name='',
+        on_progress=None,
+        upload_id='',
     ):
         input_file = params[param_name]
 
@@ -232,21 +235,17 @@ def chunked_upload(
                     input_file.data = input.read()
 
             params[param_name] = input_file
-            return self.call(
-                'post',
-                path,
-                headers,
-                params
-            )
+            return self.call('post', path, headers, params)
 
         offset = 0
         counter = 0
 
-        try:
-            result = self.call('get', path + '/' + upload_id, headers)
-            counter = result['chunksUploaded']
-        except:
-            pass
+        if upload_id:
+            try:
+                result = self.call('get', path + '/' + upload_id, headers)
+                counter = result['chunksUploaded']
+            except:
+                pass
 
         if counter > 0:
             offset = counter * self._chunk_size
@@ -255,11 +254,13 @@ def chunked_upload(
         chunks = []
         while offset < size:
             end = min(offset + self._chunk_size, size)
-            chunks.append({
-                'index': counter,
-                'start': offset,
-                'end': end,
-            })
+            chunks.append(
+                {
+                    'index': counter,
+                    'start': offset,
+                    'end': end,
+                }
+            )
             offset = end
             counter = counter + 1
 
@@ -291,7 +292,7 @@ def upload_chunk(chunk, current_upload_id):
             chunk_input = InputFile.from_bytes(
                 read_chunk(chunk['start'], chunk['end']),
                 input_file.filename,
-                getattr(input_file, 'mime_type', None)
+                getattr(input_file, 'mime_type', None),
             )
             chunk_params = {**params, param_name: chunk_input}
             chunk_headers = {**headers}
@@ -315,13 +316,15 @@ def upload_chunk(chunk, current_upload_id):
         uploaded_size = chunks[0]['end']
 
         if on_progress is not None:
-            on_progress({
-                "$id": result.get("$id"),
-                "progress": uploaded_size / size * 100,
-                "sizeUploaded": uploaded_size,
-                "chunksTotal": total_chunks,
-                "chunksUploaded": completed_count,
-            })
+            on_progress(
+                {
+                    "$id": result.get("$id"),
+                    "progress": uploaded_size / size * 100,
+                    "sizeUploaded": uploaded_size,
+                    "chunksTotal": total_chunks,
+                    "chunksUploaded": completed_count,
+                }
+            )
 
         def upload_remaining_chunk(chunk):
             nonlocal completed_count, uploaded_size, last_result, final_result
@@ -333,13 +336,15 @@ def upload_remaining_chunk(chunk):
                 if is_upload_complete(chunk_result):
                     final_result = chunk_result
                 if on_progress is not None:
-                    on_progress({
-                        "$id": upload_id_header,
-                        "progress": uploaded_size / size * 100,
-                        "sizeUploaded": uploaded_size,
-                        "chunksTotal": total_chunks,
-                        "chunksUploaded": completed_count,
-                    })
+                    on_progress(
+                        {
+                            "$id": upload_id_header,
+                            "progress": uploaded_size / size * 100,
+                            "sizeUploaded": uploaded_size,
+                            "chunksTotal": total_chunks,
+                            "chunksUploaded": completed_count,
+                        }
+                    )
 
         with ThreadPoolExecutor(max_workers=8) as executor:
             futures = [executor.submit(upload_remaining_chunk, chunk) for chunk in chunks[1:]]
@@ -354,8 +359,8 @@ def flatten(self, data, prefix='', stringify=False):
 
         for key in data:
             value = data[key] if isinstance(data, dict) else key
-            finalKey = prefix + '[' + key +']' if prefix else key
-            finalKey = prefix + '[' + str(i) +']' if isinstance(data, list) else finalKey
+            finalKey = prefix + '[' + key + ']' if prefix else key
+            finalKey = prefix + '[' + str(i) + ']' if isinstance(data, list) else finalKey
             i += 1
 
             if isinstance(value, list) or isinstance(value, dict):

appwrite_console/encoders/__init__.py

@@ -1 +0,0 @@
- 

appwrite_console/encoders/value_class_encoder.py

@@ -41,7 +41,7 @@
 from ..enums.supabase_migration_resource import SupabaseMigrationResource
 from ..enums.organization_key_scopes import OrganizationKeyScopes
 from ..enums.region import Region
-from ..enums.addon import Addon
+from ..enums.addon_key import AddonKey
 from ..enums.usage_range import UsageRange
 from ..enums.project_auth_method_id import ProjectAuthMethodId
 from ..enums.project_o_auth2_google_prompt import ProjectOAuth2GooglePrompt
@@ -83,6 +83,7 @@
 from ..enums.detection_framework_type import DetectionFrameworkType
 from ..enums.detection_runtime_type import DetectionRuntimeType
 from ..enums.deployment_status import DeploymentStatus
+from ..enums.execution_resource_type import ExecutionResourceType
 from ..enums.execution_trigger import ExecutionTrigger
 from ..enums.execution_status import ExecutionStatus
 from ..enums.o_auth2_google_prompt import OAuth2GooglePrompt
@@ -96,6 +97,7 @@
 from ..enums.domain_purchase_status import DomainPurchaseStatus
 from ..enums.waf_rule_action import WafRuleAction
 
+
 class ValueClassEncoder(json.JSONEncoder):
     def default(self, o):
         if isinstance(o, AppwriteModel):
@@ -224,7 +226,7 @@ def default(self, o):
         if isinstance(o, Region):
             return o.value
 
-        if isinstance(o, Addon):
+        if isinstance(o, AddonKey):
             return o.value
 
         if isinstance(o, UsageRange):
@@ -350,6 +352,9 @@ def default(self, o):
         if isinstance(o, DeploymentStatus):
             return o.value
 
+        if isinstance(o, ExecutionResourceType):
+            return o.value
+
         if isinstance(o, ExecutionTrigger):
             return o.value
 

appwrite_console/enums/__init__.py

@@ -1 +0,0 @@
- 

appwrite_console/enums/account_key_scopes.py

@@ -1,5 +1,6 @@
 from enum import Enum
 
+
 class AccountKeyScopes(Enum):
     ACCOUNT = "account"
     TEAMS_READ = "teams.read"

appwrite_console/enums/adapter.py

@@ -1,5 +1,6 @@
 from enum import Enum
 
+
 class Adapter(Enum):
     STATIC = "static"
     SSR = "ssr"

appwrite_console/enums/addon.py appwrite_console/enums/addon_key.pyappwrite_console/enums/addon.py renamed to appwrite_console/enums/addon_key.py

@@ -1,6 +1,7 @@
 from enum import Enum
 
-class Addon(Enum):
+
+class AddonKey(Enum):
     BAA = "baa"
     PREMIUMGEODB = "premiumgeodb"
     PREMIUMGEODBORG = "premiumgeodborg"

appwrite_console/enums/appwrite_migration_resource.py

@@ -1,5 +1,6 @@
 from enum import Enum
 
+
 class AppwriteMigrationResource(Enum):
     USER = "user"
     TEAM = "team"