Adding support for /revision

Author: apetenchea

arangoasync/collection.py

@@ -18,6 +18,7 @@
 from arangoasync.exceptions import (
     CollectionPropertiesError,
     CollectionResponsibleShardError,
+    CollectionRevisionError,
     CollectionShardsError,
     CollectionStatisticsError,
     CollectionTruncateError,
@@ -638,7 +639,7 @@ async def shards(self, details: Optional[bool] = None) -> Result[Json]:
                 servers for these shards.
 
         Returns:
-            dict: Collection shards and properties.
+            dict: Collection shards.
 
         Raises:
             CollectionShardsError: If retrieval fails.
@@ -659,7 +660,31 @@ async def shards(self, details: Optional[bool] = None) -> Result[Json]:
         def response_handler(resp: Response) -> Json:
             if not resp.is_success:
                 raise CollectionShardsError(resp, request)
-            return Response.format_body(self.deserializer.loads(resp.raw_body))
+            return cast(Json, self.deserializer.loads(resp.raw_body)["shards"])
+
+        return await self._executor.execute(request, response_handler)
+
+    async def revision(self) -> Result[str]:
+        """Return collection revision.
+
+        Returns:
+            str: Collection revision.
+
+        Raises:
+            CollectionRevisionError: If retrieval fails.
+
+        References:
+            - `get-the-collection-revision-id <https://docs.arangodb.com/stable/develop/http-api/collections/#get-the-collection-revision-id>`__
+        """  # noqa: E501
+        request = Request(
+            method=Method.GET,
+            endpoint=f"/_api/collection/{self.name}/revision",
+        )
+
+        def response_handler(resp: Response) -> str:
+            if not resp.is_success:
+                raise CollectionRevisionError(resp, request)
+            return cast(str, self.deserializer.loads(resp.raw_body)["revision"])
 
         return await self._executor.execute(request, response_handler)
 

arangoasync/exceptions.py

@@ -199,6 +199,10 @@ class CollectionResponsibleShardError(ArangoServerError):
     """Failed to retrieve responsible shard."""
 
 
+class CollectionRevisionError(ArangoServerError):
+    """Failed to retrieve collection revision."""
+
+
 class CollectionShardsError(ArangoServerError):
     """Failed to retrieve collection shards."""
 

tests/test_collection.py

@@ -6,6 +6,7 @@
 from arangoasync.exceptions import (
     CollectionPropertiesError,
     CollectionResponsibleShardError,
+    CollectionRevisionError,
     CollectionShardsError,
     CollectionStatisticsError,
     CollectionTruncateError,
@@ -53,6 +54,12 @@ async def test_collection_misc_methods(doc_col, bad_col, docs, cluster):
         with pytest.raises(CollectionShardsError):
             await bad_col.shards()
 
+    # Revision
+    revision = await doc_col.revision()
+    assert isinstance(revision, str)
+    with pytest.raises(CollectionRevisionError):
+        await bad_col.revision()
+
 
 @pytest.mark.asyncio
 async def test_collection_index(doc_col, bad_col, cluster):