feat: support PyMongo Async API

casbin_pymongo_adapter/_rule.py

@@ -0,0 +1,34 @@
+class CasbinRule:
+    """
+    CasbinRule model
+    """
+
+    def __init__(
+        self, ptype=None, v0=None, v1=None, v2=None, v3=None, v4=None, v5=None
+    ):
+        self.ptype = ptype
+        self.v0 = v0
+        self.v1 = v1
+        self.v2 = v2
+        self.v3 = v3
+        self.v4 = v4
+        self.v5 = v5
+
+    def dict(self):
+        d = {"ptype": self.ptype}
+
+        for value in dir(self):
+            if (
+                getattr(self, value) is not None
+                and value.startswith("v")
+                and value[1:].isnumeric()
+            ):
+                d[value] = getattr(self, value)
+
+        return d
+
+    def __str__(self):
+        return ", ".join(self.dict().values())
+
+    def __repr__(self):
+        return '<CasbinRule :"{}">'.format(str(self))

casbin_pymongo_adapter/adapter.py

@@ -1,41 +1,7 @@
 from casbin import persist
 from pymongo import MongoClient
 
-
-class CasbinRule:
-    """
-    CasbinRule model
-    """
-
-    def __init__(
-        self, ptype=None, v0=None, v1=None, v2=None, v3=None, v4=None, v5=None
-    ):
-        self.ptype = ptype
-        self.v0 = v0
-        self.v1 = v1
-        self.v2 = v2
-        self.v3 = v3
-        self.v4 = v4
-        self.v5 = v5
-
-    def dict(self):
-        d = {"ptype": self.ptype}
-
-        for value in dir(self):
-            if (
-                getattr(self, value) is not None
-                and value.startswith("v")
-                and value[1:].isnumeric()
-            ):
-                d[value] = getattr(self, value)
-
-        return d
-
-    def __str__(self):
-        return ", ".join(self.dict().values())
-
-    def __repr__(self):
-        return '<CasbinRule :"{}">'.format(str(self))
+from ._rule import CasbinRule
 
 
 class Adapter(persist.Adapter):

casbin_pymongo_adapter/asynchronous/adapter.py

@@ -0,0 +1,134 @@
+from casbin import persist
+from casbin.persist.adapters.asyncio.adapter import AsyncAdapter
+from pymongo import AsyncMongoClient
+
+from .._rule import CasbinRule
+
+
+class Adapter(AsyncAdapter):
+    """the interface for Casbin adapters."""
+
+    def __init__(self, uri, dbname, collection="casbin_rule"):
+        """Create an adapter for Mongodb
+
+        Args:
+            uri (str): This should be the same requiement as pymongo Client's 'uri' parameter.
+                          See https://pymongo.readthedocs.io/en/stable/api/pymongo/mongo_client.html#pymongo.mongo_client.MongoClient.
+            dbname (str): Database to store policy.
+            collection (str, optional): Collection of the choosen database. Defaults to "casbin_rule".
+        """
+        client = AsyncMongoClient(uri)
+        db = client[dbname]
+        self._collection = db[collection]
+
+    async def load_policy(self, model):
+        """Implementing add Interface for casbin. Load all policy rules from mongodb
+
+        Args:
+            model (CasbinRule): CasbinRule object
+        """
+
+        async for line in self._collection.find():
+            if "ptype" not in line:
+                continue
+            rule = CasbinRule(line["ptype"])
+            for key, value in line.items():
+                setattr(rule, key, value)
+
+            persist.load_policy_line(str(rule), model)
+
+    async def _save_policy_line(self, ptype, rule):
+        line = CasbinRule(ptype=ptype)
+        for index, value in enumerate(rule):
+            setattr(line, f"v{index}", value)
+        await self._collection.insert_one(line.dict())
+
+    async def _delete_policy_lines(self, ptype, rule):
+        line = CasbinRule(ptype=ptype)
+        for index, value in enumerate(rule):
+            setattr(line, f"v{index}", value)
+
+        # if rule is empty, do nothing
+        # else find all given rules and delete them
+        if len(line.dict()) == 0:
+            return 0
+        else:
+            line_dict = line.dict()
+            line_dict_keys_len = len(line_dict)
+            to_delete = [
+                result["_id"]
+                async for result in self._collection.find(line_dict)
+                if line_dict_keys_len == len(result.keys()) - 1
+            ]
+            results = await self._collection.delete_many({"_id": {"$in": to_delete}})
+            return results.deleted_count
+
+    async def save_policy(self, model) -> bool:
+        """Implement add Interface for casbin. Save the policy in mongodb
+
+        Args:
+            model (Class Model): Casbin Model which loads from .conf file usually.
+
+        Returns:
+            bool: True if succeed
+        """
+        for sec in ["p", "g"]:
+            if sec not in model.model.keys():
+                continue
+            for ptype, ast in model.model[sec].items():
+                for rule in ast.policy:
+                    await self._save_policy_line(ptype, rule)
+        return True
+
+    async def add_policy(self, sec, ptype, rule):
+        """Add policy rules to mongodb
+
+        Args:
+            sec (str): Section name, 'g' or 'p'
+            ptype (str): Policy type, 'g', 'g2', 'p', etc.
+            rule (CasbinRule): Casbin rule will be added
+
+        Returns:
+            bool: True if succeed else False
+        """
+        await self._save_policy_line(ptype, rule)
+        return True
+
+    async def remove_policy(self, sec, ptype, rule):
+        """Remove policy rules in mongodb(rules duplicate are also removed)
+
+        Args:
+            ptype (str): Policy type, 'g', 'g2', 'p', etc.
+            rule (CasbinRule): Casbin rule if it is exactly same as will be removed.
+
+        Returns:
+            Number: Number of policies be removed
+        """
+        deleted_count = await self._delete_policy_lines(ptype, rule)
+        return deleted_count > 0
+
+    async def remove_filtered_policy(self, sec, ptype, field_index, *field_values):
+        """Remove policy rules taht match the filter from the storage.
+           This is part of the Auto-Save feature.
+
+        Args:
+            ptype (str): Policy type, 'g', 'g2', 'p', etc.
+            rule (CasbinRule): Casbin rule will be removed
+            field_index (int): The policy index at which the filed_values begins filtering. Its range is [0, 5]
+            field_values(List[str]): A list of rules to filter policy which starts from
+
+        Returns:
+            bool: True if succeed else False
+        """
+        if not (0 <= field_index <= 5):
+            return False
+        if not (1 <= field_index + len(field_values) <= 6):
+            return False
+        query = {
+            f"v{index + field_index}": value
+            for index, value in enumerate(field_values)
+            if value != ""
+        }
+        query["ptype"] = ptype
+        results = await self._collection.delete_many(query)
+        return results.deleted_count > 0

requirements.txt

@@ -1,2 +1,2 @@
 casbin>=0.8.4
-pymongo>=3.10.1
+pymongo>=4.13.0