leguadmin/xbackend
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

重新加载casbin模型

Browse Source
This commit is contained in:
wuaho 2021-09-17 15:51:06 +08:00
parent 3264449565
commit 577761583b
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
api/api_v1/authz/authz.py
View File

@ -33,7 +33,7 @@ async def add_role_domain(
casbin_enforcer.add_role_for_user_in_domain(user=item.username,
role=item.role_id,
domain=item.game)
casbin_enforcer.load_model()
return schemas.Msg(code=0, msg='添加成功', data=True)
@ -74,6 +74,7 @@ async def del_role_domain(
res = casbin_enforcer.delete_roles_for_user_in_domain(user=data_in.username,
role=data_in.role_id,
domain=data_in.game)
casbin_enforcer.load_model()
await crud.role.delete_id(db, data_in.role_id)
return schemas.Msg(code=0, msg='ok', data=res)
@ -90,6 +91,7 @@ async def add_policy(
res = 0
for path in data_id.path_list:
res = casbin_enforcer.add_policy(data_id.role_id, data_id.game, path, data_id.act)
casbin_enforcer.load_model()
return schemas.Msg(code=0, msg='ok', data=res)
@ -103,6 +105,7 @@ async def remove_policy(
"""
res = casbin_enforcer.remove_policy(data_id.role_id, data_id.game, data_id.path, data_id.act)
casbin_enforcer.load_model()
return schemas.Msg(code=0, msg='ok', data=res)
@ -150,7 +153,7 @@ async def del_api(
paths = await crud.api_list.find_ids(db, data_in.ids, {'path': 1})
for item in paths:
casbin_enforcer.remove_filtered_policy(2, item['path'])
casbin_enforcer.load_model()
# 删除保存的记录
res = await crud.api_list.del_api(db, data_in)

2
utils/adapter.py
View File

@ -142,4 +142,4 @@ class Adapter(persist.Adapter):
casbin_adapter = Adapter(settings.DATABASE_URI, settings.MDB_DB)
casbin_enforcer = casbin.Enforcer('rbac_model.conf', casbin_adapter)
casbin_model = casbin_enforcer.get_model()
casbin_model = casbin_enforcer.get_model()