This is an automated email from the ASF dual-hosted git repository.
timi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-superset.git
The following commit(s) were added to refs/heads/master by this push:
new d9a7d56 remove user params (#6345)
d9a7d56 is described below
commit d9a7d565a0644a045a026ca28846847101ec1109
Author: timifasubaa <[email protected]>
AuthorDate: Tue Nov 13 09:27:08 2018 -0800
remove user params (#6345)
---
superset/security.py | 33 ++++++++++++++++-----------------
superset/views/core.py | 5 ++---
2 files changed, 18 insertions(+), 20 deletions(-)
diff --git a/superset/security.py b/superset/security.py
index f6ac6b7..7ad3ebf 100644
--- a/superset/security.py
+++ b/superset/security.py
@@ -83,36 +83,35 @@ class SupersetSecurityManager(SecurityManager):
if schema:
return '[{}].[{}]'.format(database, schema)
- def can_access(self, permission_name, view_name, user=None):
+ def can_access(self, permission_name, view_name):
"""Protecting from has_access failing from missing perms/view"""
- if not user:
- user = g.user
+ user = g.user
if user.is_anonymous:
return self.is_item_public(permission_name, view_name)
return self._has_view_access(user, permission_name, view_name)
- def all_datasource_access(self, user=None):
+ def all_datasource_access(self):
return self.can_access(
- 'all_datasource_access', 'all_datasource_access', user=user)
+ 'all_datasource_access', 'all_datasource_access')
- def database_access(self, database, user=None):
+ def database_access(self, database):
return (
self.can_access(
- 'all_database_access', 'all_database_access', user=user) or
- self.can_access('database_access', database.perm, user=user)
+ 'all_database_access', 'all_database_access') or
+ self.can_access('database_access', database.perm)
)
- def schema_access(self, datasource, user=None):
+ def schema_access(self, datasource):
return (
- self.database_access(datasource.database, user=user) or
- self.all_datasource_access(user=user) or
- self.can_access('schema_access', datasource.schema_perm, user=user)
+ self.database_access(datasource.database) or
+ self.all_datasource_access() or
+ self.can_access('schema_access', datasource.schema_perm)
)
- def datasource_access(self, datasource, user=None):
+ def datasource_access(self, datasource):
return (
- self.schema_access(datasource, user=user) or
- self.can_access('datasource_access', datasource.perm, user=user)
+ self.schema_access(datasource) or
+ self.can_access('datasource_access', datasource.perm)
)
def get_datasource_access_error_msg(self, datasource):
@@ -430,8 +429,8 @@ class SupersetSecurityManager(SecurityManager):
),
)
- def assert_datasource_permission(self, datasource, user=None):
- if not self.datasource_access(datasource, user):
+ def assert_datasource_permission(self, datasource):
+ if not self.datasource_access(datasource):
raise SupersetSecurityException(
self.get_datasource_access_error_msg(datasource),
self.get_datasource_access_link(datasource),
diff --git a/superset/views/core.py b/superset/views/core.py
index 675b041..d8aa88b 100755
--- a/superset/views/core.py
+++ b/superset/views/core.py
@@ -905,9 +905,8 @@ class Superset(BaseSupersetView):
for r in session.query(DAR).all():
datasource = ConnectorRegistry.get_datasource(
r.datasource_type, r.datasource_id, session)
- user = security_manager.get_user_by_id(r.created_by_fk)
if not datasource or \
- security_manager.datasource_access(datasource, user):
+ security_manager.datasource_access(datasource):
# datasource does not exist anymore
session.delete(r)
session.commit()
@@ -1121,7 +1120,7 @@ class Superset(BaseSupersetView):
form_data=form_data,
force=force,
)
- security_manager.assert_datasource_permission(viz_obj.datasource,
g.user)
+ security_manager.assert_datasource_permission(viz_obj.datasource)
if csv:
return CsvResponse(
