Repository: incubator-ranger Updated Branches: refs/heads/master 1bd72ed39 -> 97fb9510e
RANGER-1061 : Add admin user to default policy of Atlas Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/97fb9510 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/97fb9510 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/97fb9510 Branch: refs/heads/master Commit: 97fb9510e0baa3481444d24d7675e90ecd3ea5ad Parents: 1bd72ed Author: Gautam Borad <[email protected]> Authored: Fri Jun 24 12:56:30 2016 +0530 Committer: Gautam Borad <[email protected]> Committed: Wed Jun 29 10:55:33 2016 +0530 ---------------------------------------------------------------------- .../org/apache/ranger/biz/ServiceDBStore.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/97fb9510/security-admin/src/main/java/org/apache/ranger/biz/ServiceDBStore.java ---------------------------------------------------------------------- diff --git a/security-admin/src/main/java/org/apache/ranger/biz/ServiceDBStore.java b/security-admin/src/main/java/org/apache/ranger/biz/ServiceDBStore.java index 58908bf..9af5b5f 100644 --- a/security-admin/src/main/java/org/apache/ranger/biz/ServiceDBStore.java +++ b/security-admin/src/main/java/org/apache/ranger/biz/ServiceDBStore.java @@ -2535,6 +2535,13 @@ public class ServiceDBStore extends AbstractServiceStore { // do nothing } + if (StringUtils.equals(xServiceDef.getImplclassname(), EmbeddedServiceDefsUtil.ATLAS_IMPL_CLASS_NAME)){ + VXUser vXUserAdmin = chkAdminUserExists("admin"); + if(vXUserAdmin != null){ + users.add(vXUserAdmin.getName()); + } + } + RangerService rangerService = getServiceByName(createdService.getName()); if (rangerService != null){ Map<String, String> map = rangerService.getConfigs(); @@ -2574,6 +2581,17 @@ public class ServiceDBStore extends AbstractServiceStore { return policyItem; } + private VXUser chkAdminUserExists(String adminUser) { + VXUser vXUser = null; + if(!StringUtils.isEmpty(adminUser)){ + XXUser xxUser = daoMgr.getXXUser().findByUserName(adminUser); + if (xxUser != null) { + vXUser = xUserService.populateViewBean(xxUser); + } + } + return vXUser; + } + private VXUser getLookupUser(String authType, String lookupPrincipal, String lookupKeytab) { VXUser vXUser = null; if(!StringUtils.isEmpty(authType) && authType.equalsIgnoreCase(KERBEROS_TYPE)){
