Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 6 additions & 3 deletions flask_authz/casbin_enforcer.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ def wrapper(*args, **kwargs):
self.app.logger.info("Get owner from owner_loader")
for owner in self._owner_loader():
owner = owner.strip('"') if isinstance(owner, str) else owner
if self.e.enforce(owner, uri, request.method):
if self.try_enforcer(owner, uri, request.method):
return func(*args, **kwargs)
for header in map(str.lower, self.app.config.get("CASBIN_OWNER_HEADERS")):
if header in request.headers:
Expand All @@ -107,7 +107,7 @@ def wrapper(*args, **kwargs):
str.lower, self.user_name_headers
):
owner_audit = owner
if self.e.enforce(owner, uri, request.method):
if self.try_enforcer(owner, uri, request.method):
self.app.logger.info(
"access granted: method: %s resource: %s%s"
% (
Expand All @@ -133,7 +133,7 @@ def wrapper(*args, **kwargs):
str.lower, self.user_name_headers
):
owner_audit = owner
if self.e.enforce(owner.strip('"'), uri, request.method):
if self.try_enforcer(owner.strip('"'), uri, request.method):
self.app.logger.info(
"access granted: method: %s resource: %s%s"
% (
Expand Down Expand Up @@ -161,6 +161,9 @@ def wrapper(*args, **kwargs):

return wrapper

def try_enforcer(self, owner, uri, method):
return self.e.enforce(owner, uri, method)

@staticmethod
def sanitize_group_headers(headers_str, delimiter=",") -> list:
"""
Expand Down