Merge branch 'master' into general-clean-up

Author: hozan23

.github/workflows/pull_request.yml

@@ -12,14 +12,14 @@ jobs:
       # tests can't run in parallel as they write and read data with same keys
       max-parallel: 1
       matrix:
-        python-version: ["3.7", "3.8", "3.9"]
+        python-version: ["3.7", "3.8", "3.9", "3.10", "3.11"]
     steps:
       # Get the code into the container
       - name: Checkout
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
       # Setup Python
       - name: Setup Python
-        uses: actions/setup-python@v2
+        uses: actions/setup-python@v4
         with:
           python-version: ${{ matrix.python-version }}
       # Test the code

.github/workflows/tag_release.yml

@@ -11,10 +11,10 @@ jobs:
    steps:
     # Get the code into our container
     - name: Checkout
-      uses: actions/checkout@v2
+      uses: actions/checkout@v3
     # Setup Python
     - name: Setup Python
-      uses: actions/setup-python@v2
+      uses: actions/setup-python@v4
       with:
         python-version: ^3.5
     # Install dependencies

.github/workflows/test_release.yml

@@ -9,10 +9,10 @@ jobs:
    steps:
     # Get the code into our container
     - name: Checkout
-      uses: actions/checkout@v2
+      uses: actions/checkout@v3
     # Setup Python
     - name: Setup Python
-      uses: actions/setup-python@v2
+      uses: actions/setup-python@v4
       with:
         python-version: ^3.5
     # Install dependencies

README.md

@@ -1,6 +1,6 @@
 # Deta Python Library (SDK)
 
-Supports Python 3.5+ only. [Read the docs.](https://deta.space/docs/en/reference/base/sdk)  
+Please use a [supported version of Python](https://devguide.python.org/versions/).  This package requires a minimum of Python 3.6.  [Read the docs.](https://deta.space/docs/en/build/reference/sdk)  
 
 Install from PyPi
 

deta/__init__.py

@@ -21,8 +21,7 @@
 except ImportError:
     pass
 
-__version__ = "1.1.0"
-
+__version__ = "1.2.0"
 
 def Base(name: str):
     project_key, project_id = _get_project_key_id()
@@ -45,6 +44,7 @@ def Base(self, name: str, host: Union[str, None] = None):
 
     def AsyncBase(self, name: str, host: Union[str, None] = None):
         from ._async.client import _AsyncBase
+
         return _AsyncBase(name, self.project_key, self.project_id, host)
 
     def Drive(self, name: str, host: Union[str, None] = None):

deta/_async/client.py

@@ -93,16 +93,17 @@ async def put(
         if key:
             data["key"] = key
 
+
         insert_ttl(data, self.__ttl_attribute,
                    expire_in=expire_in, expire_at=expire_at)
         async with self._session.put(
             f"{self._base_url}/items", json={"items": [data]}
         ) as resp:
             if resp.status == 207:
                 resp_json = await resp.json()
-                return resp_json["processed"]["items"][0]
-            else:
-                return None
+                if "processed" in resp_json:
+                    return resp_json["processed"]["items"][0]
+            return None
 
     async def put_many(
         self,
@@ -134,6 +135,7 @@ async def fetch(
         *,
         limit: int = 1000,
         last: Union[str, None] = None,
+        desc: bool = False,
     ):
         payload = {}
         if query:
@@ -142,6 +144,9 @@ async def fetch(
             payload["limit"] = limit
         if last:
             payload["last"] = last
+        if desc:
+            payload["sort"] = "desc" 
+
         async with self._session.post(f"{self._base_url}/query", json=payload) as resp:
             resp_json = await resp.json()
             paging = resp_json.get("paging")

deta/base.py

@@ -160,8 +160,11 @@ def put(
             "/items", "PUT", {"items": [data]}, content_type=JSON_MIME
         )
 
-        if res and code == 207:
-            return res["processed"]["items"][0]  # pyright: ignore
+
+        if code == 207 and "processed" in res:
+            return res["processed"]["items"][0]
+        else:
+            return None
 
     def put_many(
         self,
@@ -191,11 +194,13 @@ def _fetch(
         query: Union[dict, list, None] = None,
         buffer: Union[int, None] = None,
         last: Union[str, None] = None,
-    ):
+        desc: bool = False, 
+    ) -> typing.Optional[typing.Tuple[int, list]]:
         """This is where actual fetch happens."""
         payload = {
             "limit": buffer,
             "last": last if not isinstance(last, bool) else None,
+            "sort": "desc" if desc else "",
         }
 
         if query:
@@ -214,12 +219,16 @@ def fetch(
         *,
         limit: int = 1000,
         last: Union[str, None] = None,
+        desc: bool = False, 
+
     ):
         """
         fetch items from the database.
             `query` is an optional filter or list of filters. Without filter, it will return the whole db.
         """
-        res = self._fetch(query, limit, last)
+        
+        _, res = self._fetch(query, limit, last, desc)
+
 
         paging = res.get("paging")  # pyright: ignore
 
@@ -238,7 +247,7 @@ def update(
         """
         update an item in the database
         `updates` specifies the attribute names and values to update,add or remove
-        `key` is the kye of the item to be updated
+        `key` is the key of the item to be updated
         """
 
         if key == "":

deta/service.py

@@ -5,10 +5,19 @@
 import struct
 from typing import Union
 import urllib.error
+from pathlib import Path
 
 JSON_MIME = "application/json"
 
 
+class CustomJSONEncoder(json.JSONEncoder):
+
+    def default(self, o: typing.Any) -> typing.Any:
+        if isinstance(o, Path):
+            return o.resolve().as_posix()
+        return super().default(o)
+
+
 class _Service:
     def __init__(
         self,
@@ -75,7 +84,9 @@ def _request(
             pass
 
         # send request
-        body = json.dumps(data) if content_type == JSON_MIME else data
+        body = json.dumps(
+            data, cls=CustomJSONEncoder
+        ) if content_type == JSON_MIME else data
 
         # response
         res = self._send_request_with_retry(method, url, headers, body)
@@ -92,8 +103,9 @@ def _request(
             # return None if not found
             if status == 404:
                 return status, None
-            raise urllib.error.HTTPError(
-                url, status, res.reason, res.headers, res.fp)
+            fp = res.fp if res.fp is not None else ''  # FIXME: workaround to fix traceback printing for HTTPError
+            raise urllib.error.HTTPError(url, status, res.reason, res.headers, fp)
+
 
         # if stream return the response and client without reading and closing the client
         if stream:

pytest.ini

@@ -0,0 +1,3 @@
+[pytest]
+addopts = --color=yes
+asyncio_mode = auto

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name="deta",
-    version="1.1.0",
+    version="1.2.0",
     description="Python SDK for Deta Base & Deta Drive.",
     url="http://github.com/deta/deta-python",
     author="Deta",