Add api and casbin related interfaces (#198)

* Add get all apis and more interface

* Add casbin get related interface

* typo

* update function name

Author: wu-clan

backend/app/api/v1/api.py

@@ -15,14 +15,20 @@
 router = APIRouter()
 
 
+@router.get('/all', summary='获取所有接口', dependencies=[DependsJwtAuth])
+async def get_all_apis():
+    data = await ApiService.get_all()
+    return await response_base.success(data=data)
+
+
 @router.get('/{pk}', summary='获取接口详情', dependencies=[DependsJwtAuth])
 async def get_api(pk: int):
     api = await ApiService.get(pk=pk)
     return await response_base.success(data=api)
 
 
 @router.get('', summary='（模糊条件）分页获取所有接口', dependencies=[DependsJwtAuth, PageDepends])
-async def get_all_apis(
+async def get_api_list(
     db: CurrentSession,
     name: Annotated[str | None, Query()] = None,
     method: Annotated[str | None, Query()] = None,

backend/app/api/v1/casbin.py

@@ -41,6 +41,12 @@ async def get_all_policies():
     return await response_base.success(data=policies)
 
 
+@router.get('/policy/{role}/all', summary='获取指定角色的所有P权限规则', dependencies=[DependsJwtAuth])
+async def get_role_policies(role: str):
+    policies = await CasbinService.get_policy_list_by_role(role=role)
+    return await response_base.success(data=policies)
+
+
 @router.post('/policy', summary='添加P权限规则', dependencies=[DependsRBAC])
 async def create_policy(p: CreatePolicy):
     """

backend/app/crud/crud_api.py

@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
-from typing import NoReturn
+from typing import NoReturn, Sequence
 
 from sqlalchemy import Select, select, desc, delete, and_
 from sqlalchemy.ext.asyncio import AsyncSession
@@ -14,7 +14,7 @@ class CRUDApi(CRUDBase[Api, CreateApi, UpdateApi]):
     async def get(self, db: AsyncSession, pk: int) -> Api | None:
         return await self.get_(db, pk=pk)
 
-    async def get_all(self, name: str = None, method: str = None, path: str = None) -> Select:
+    async def get_list(self, name: str = None, method: str = None, path: str = None) -> Select:
         se = select(self.model).order_by(desc(self.model.created_time))
         where_list = []
         if name:
@@ -27,6 +27,10 @@ async def get_all(self, name: str = None, method: str = None, path: str = None)
             se = se.where(and_(*where_list))
         return se
 
+    async def get_all(self, db: AsyncSession) -> Sequence[Api]:
+        apis = await db.execute(select(self.model))
+        return apis.scalars().all()
+
     async def get_by_name(self, db: AsyncSession, name: str) -> Api | None:
         api = await db.execute(select(self.model).where(self.model.name == name))
         return api.scalars().first()

backend/app/services/api_service.py

@@ -1,5 +1,7 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
+from typing import Sequence
+
 from sqlalchemy import Select
 
 from backend.app.common.exception import errors
@@ -20,7 +22,13 @@ async def get(*, pk: int) -> Api:
 
     @staticmethod
     async def get_select(*, name: str = None, method: str = None, path: str = None) -> Select:
-        return await ApiDao.get_all(name=name, method=method, path=path)
+        return await ApiDao.get_list(name=name, method=method, path=path)
+
+    @staticmethod
+    async def get_all() -> Sequence[Api]:
+        async with async_db_session() as db:
+            apis = await ApiDao.get_all(db)
+            return apis
 
     @staticmethod
     async def create(*, obj: CreateApi) -> None:

backend/app/services/casbin_service.py

@@ -28,6 +28,12 @@ async def get_policy_list():
         data = await enforcer.get_policy()
         return data
 
+    @staticmethod
+    async def get_policy_list_by_role(*, role: str):
+        enforcer = await RBAC.enforcer()
+        data = await enforcer.get_filtered_named_policy('p', 0, role)
+        return data
+
     @staticmethod
     async def create_policy(*, p: CreatePolicy):
         enforcer = await RBAC.enforcer()