X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=auth%2Fauth-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fservice%2Ffacade%2FAuthzFacadeImpl.java;h=4b4fee71b132a8b4e7464fe51168cb130ebe085e;hb=9dab8be3addc9b1bcf650b35d3834f99200cb957;hp=e77e09088e8264a5475c48b53c50406dfcaf6b33;hpb=4c709df6500a95057a92ec3ea5c739738764388d;p=aaf%2Fauthz.git diff --git a/auth/auth-service/src/main/java/org/onap/aaf/auth/service/facade/AuthzFacadeImpl.java b/auth/auth-service/src/main/java/org/onap/aaf/auth/service/facade/AuthzFacadeImpl.java index e77e0908..4b4fee71 100644 --- a/auth/auth-service/src/main/java/org/onap/aaf/auth/service/facade/AuthzFacadeImpl.java +++ b/auth/auth-service/src/main/java/org/onap/aaf/auth/service/facade/AuthzFacadeImpl.java @@ -7,9 +7,9 @@ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -44,7 +44,9 @@ import static org.onap.aaf.auth.layer.Result.OK; import java.io.IOException; import java.lang.reflect.Method; +import java.util.ArrayList; import java.util.Date; +import java.util.List; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; @@ -66,9 +68,9 @@ import org.onap.aaf.auth.service.mapper.Mapper.API; import org.onap.aaf.cadi.aaf.client.Examples; import org.onap.aaf.misc.env.APIException; import org.onap.aaf.misc.env.Data; +import org.onap.aaf.misc.env.Data.TYPE; import org.onap.aaf.misc.env.Env; import org.onap.aaf.misc.env.TimeTaken; -import org.onap.aaf.misc.env.Data.TYPE; import org.onap.aaf.misc.env.util.Chrono; import org.onap.aaf.misc.rosetta.Marshal; import org.onap.aaf.misc.rosetta.env.RosettaDF; @@ -78,7 +80,7 @@ import aaf.v2_0.Api; /** * AuthzFacade - * + * * This Service Facade encapsulates the essence of the API Service can do, and provides * a single created object for elements such as RosettaDF. * @@ -89,14 +91,14 @@ import aaf.v2_0.Api; * a) In the future, we may support multiple Response Formats, aka JSON or XML, based on User Request. * 4) Log Service info, warnings and exceptions as necessary * 5) When asked by the API layer, this will create and write Error content to the OutputStream - * - * Note: This Class does NOT set the HTTP Status Code. That is up to the API layer, so that it can be + * + * Note: This Class does NOT set the HTTP Status Code. That is up to the API layer, so that it can be * clearly coordinated with the API Documentation - * + * * @author Pavani & Jonathan * */ -public abstract class AuthzFacadeImpl extends FacadeImpl implements AuthzFacade +public abstract class AuthzFacadeImpl extends FacadeImpl implements AuthzFacade { private static final String FORBIDDEN = "Forbidden"; private static final String NOT_FOUND = "Not Found"; @@ -133,14 +135,13 @@ public abstract class AuthzFacadeImpl) service.mapper().getMarshal(API.CERTS)); - ; (userRoleRequestDF = env.newDataFactory(service.mapper().getClass(API.USER_ROLE_REQ))).in(dataType).out(dataType); (rolePermRequestDF = env.newDataFactory(service.mapper().getClass(API.ROLE_PERM_REQ))).in(dataType).out(dataType); (nsRequestDF = env.newDataFactory(service.mapper().getClass(API.NS_REQ))).in(dataType).out(dataType); @@ -153,14 +154,14 @@ public abstract class AuthzFacadeImpl mapper() { return service.mapper(); } - + /* (non-Javadoc) * @see com.att.authz.facade.AuthzFacade#error(org.onap.aaf.auth.env.test.AuthzTrans, javax.servlet.http.HttpServletResponse, int) - * + * * Note: Conforms to AT&T TSS RESTful Error Structure */ @Override @@ -169,15 +170,20 @@ public abstract class AuthzFacadeImpl dlist = new ArrayList<>(); + dlist.add(null); + String os; + for(Object s : result.variables) { + if(s!=null && (os=s.toString()).length()>0) { + dlist.add(os); + } + } + detail = new String[dlist.size()]; + dlist.toArray(detail); } - //int httpstatus; - switch(result.status) { case ERR_ActionNotCompleted: msgId = "SVC1202"; @@ -207,7 +213,7 @@ public abstract class AuthzFacadeImpl rp = service.createNS(trans,request,type); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,CREATE_NS); @@ -380,14 +384,13 @@ public abstract class AuthzFacadeImpl rp = service.addAdminNS(trans,ns,id); - switch(rp.status) { - case OK: - //TODO Perms?? - setContentType(resp,nsRequestDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + //TODO Perms?? + setContentType(resp,nsRequestDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,ADD_NS_ADMIN); @@ -405,12 +408,11 @@ public abstract class AuthzFacadeImpl rp = service.delAdminNS(trans, ns, id); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_NS_ADMIN); @@ -428,13 +430,12 @@ public abstract class AuthzFacadeImpl rp = service.addResponsibleNS(trans,ns,id); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,ADD_NS_RESPONSIBLE); @@ -452,13 +453,12 @@ public abstract class AuthzFacadeImpl rp = service.delResponsibleNS(trans, ns, id); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_NS_RESPONSIBLE); @@ -472,21 +472,20 @@ public abstract class AuthzFacadeImpl getNSsByName(AuthzTrans trans, HttpServletResponse resp, String ns) { + public Result getNSsByName(AuthzTrans trans, HttpServletResponse resp, String ns, boolean full) { TimeTaken tt = trans.start(GET_NS_BY_NAME + ' ' + ns, Env.SUB|Env.ALWAYS); try { - Result rp = service.getNSbyName(trans, ns); - switch(rp.status) { - case OK: - RosettaData data = nssDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,nssDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + Result rp = service.getNSbyName(trans, ns, full ); + if(rp.status == OK) { + RosettaData data = nssDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,nssDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_NS_BY_NAME); @@ -495,7 +494,7 @@ public abstract class AuthzFacadeImpl rp = service.getNSbyAdmin(trans, user, full); - switch(rp.status) { - case OK: - RosettaData data = nssDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,nssDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = nssDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,nssDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_NS_BY_ADMIN); @@ -524,7 +522,7 @@ public abstract class AuthzFacadeImpl rp = service.getNSbyResponsible(trans, user, full); - switch(rp.status) { - case OK: - RosettaData data = nssDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); + if(rp.status == OK){ + RosettaData data = nssDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); - setContentType(resp,nssDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + setContentType(resp,nssDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_NS_BY_RESPONSIBLE); @@ -563,19 +560,17 @@ public abstract class AuthzFacadeImpl rp = service.getNSbyEither(trans, user, full); - - switch(rp.status) { - case OK: - RosettaData data = nssDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); + if(rp.status == OK) { + RosettaData data = nssDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); - setContentType(resp,nssDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + setContentType(resp,nssDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_NS_BY_EITHER); @@ -593,17 +588,16 @@ public abstract class AuthzFacadeImpl rp = service.getNSsChildren(trans, parent); - switch(rp.status) { - case OK: - RosettaData data = nssDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,nssDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = nssDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,nssDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_NS_CHILDREN); @@ -625,17 +619,16 @@ public abstract class AuthzFacadeImpl rp = service.updateNsDescription(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,UPDATE_NS_DESC); @@ -644,7 +637,7 @@ public abstract class AuthzFacadeImpl rp = service.deleteNS(trans,ns); - switch(rp.status) { - case OK: - setContentType(resp,nsRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,nsRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_NS); @@ -669,11 +661,11 @@ public abstract class AuthzFacadeImpl rp = service.createNsAttrib(trans,ns,key,value); - switch(rp.status) { - case OK: - setContentType(resp, keysDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp, keysDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,NS_CREATE_ATTRIB); @@ -706,17 +697,16 @@ public abstract class AuthzFacadeImpl rp = service.readNsByAttrib(trans, key); - switch(rp.status) { - case OK: - RosettaData data = keysDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,keysDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = keysDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,keysDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,READ_NS_BY_ATTRIB); @@ -734,13 +724,12 @@ public abstract class AuthzFacadeImpl rp = service.updateNsAttrib(trans,ns,key,value); - switch(rp.status) { - case OK: - setContentType(resp, keysDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp, keysDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,NS_UPDATE_ATTRIB); @@ -759,13 +748,12 @@ public abstract class AuthzFacadeImpl rp = service.deleteNsAttrib(trans,ns,key); - switch(rp.status) { - case OK: - setContentType(resp, keysDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp, keysDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,NS_DELETE_ATTRIB); @@ -790,14 +778,14 @@ public abstract class AuthzFacadeImpl createPerm(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { - TimeTaken tt = trans.start( CREATE_PERMISSION, Env.SUB|Env.ALWAYS); + TimeTaken tt = trans.start( CREATE_PERMISSION, Env.SUB|Env.ALWAYS); try { REQUEST rreq; try { @@ -805,19 +793,18 @@ public abstract class AuthzFacadeImpl rp = service.createPerm(trans,rreq); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,CREATE_PERMISSION); @@ -826,7 +813,7 @@ public abstract class AuthzFacadeImpl getPermsByType(AuthzTrans trans, HttpServletResponse resp, String perm) { TimeTaken tt = trans.start(GET_PERMS_BY_TYPE + ' ' + perm, Env.SUB|Env.ALWAYS); try { - + Result rp = service.getPermsByType(trans, perm); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMS_BY_TYPE); @@ -856,28 +842,27 @@ public abstract class AuthzFacadeImpl getPermsByName(AuthzTrans trans, HttpServletResponse resp, + public Result getPermsByName(AuthzTrans trans, HttpServletResponse resp, String type, String instance, String action) { - + TimeTaken tt = trans.start(GET_PERMS_BY_NAME + ' ' + type + '|' + instance + '|' + action, Env.SUB|Env.ALWAYS); try { - + Result rp = service.getPermsByName(trans, type, instance, action); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMS_BY_TYPE); @@ -895,18 +880,17 @@ public abstract class AuthzFacadeImpl rp = service.getPermsByUser(trans, user); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMISSIONS_BY_USER, user); @@ -915,7 +899,7 @@ public abstract class AuthzFacadeImpl rp = service.getPermsByUserScope(trans, user, scopes); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMISSIONS_BY_USER_SCOPE, user); @@ -946,7 +929,7 @@ public abstract class AuthzFacadeImpl rp = service.getPermsByUser(trans, perms, user); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMISSIONS_BY_USER_WITH_QUERY , user); @@ -988,7 +970,7 @@ public abstract class AuthzFacadeImpl rp = service.getPermsByRole(trans, roleName); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMISSIONS_BY_ROLE); @@ -1017,24 +998,23 @@ public abstract class AuthzFacadeImpl getPermsByNS(AuthzTrans trans,HttpServletResponse resp,String ns) { TimeTaken tt = trans.start(GET_PERMISSIONS_BY_NS + ' ' + ns, Env.SUB|Env.ALWAYS); try { Result rp = service.getPermsByNS(trans, ns); - switch(rp.status) { - case OK: - RosettaData data = permsDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = permsDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_PERMISSIONS_BY_NS); @@ -1052,7 +1032,7 @@ public abstract class AuthzFacadeImpl renamePerm(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp, String origType, String origInstance, String origAction) { String cmdDescription = UPDATE_PERMISSION; - TimeTaken tt = trans.start( cmdDescription + ' ' + origType + ' ' + origInstance + ' ' + origAction, Env.SUB|Env.ALWAYS); + TimeTaken tt = trans.start( cmdDescription + ' ' + origType + ' ' + origInstance + ' ' + origAction, Env.SUB|Env.ALWAYS); try { REQUEST rreq; try { @@ -1060,19 +1040,18 @@ public abstract class AuthzFacadeImpl rp = service.renamePerm(trans,rreq, origType, origInstance, origAction); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,cmdDescription); @@ -1081,7 +1060,7 @@ public abstract class AuthzFacadeImpl updatePermDescription(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(UPDATE_PERM_DESC, Env.SUB|Env.ALWAYS); @@ -1094,17 +1073,16 @@ public abstract class AuthzFacadeImpl rp = service.updatePermDescription(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,permRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,UPDATE_PERM_DESC); @@ -1113,8 +1091,8 @@ public abstract class AuthzFacadeImpl resetPermRoles(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(SET_PERMISSION_ROLES_TO, Env.SUB|Env.ALWAYS); @@ -1127,18 +1105,16 @@ public abstract class AuthzFacadeImpl rp = service.resetPermRoles(trans, rreq); - - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,SET_PERMISSION_ROLES_TO); @@ -1147,7 +1123,7 @@ public abstract class AuthzFacadeImpl deletePerm(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(DELETE_PERMISSION, Env.SUB|Env.ALWAYS); @@ -1160,18 +1136,17 @@ public abstract class AuthzFacadeImpl rp = service.deletePerm(trans,rreq); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_PERMISSION); @@ -1186,12 +1161,11 @@ public abstract class AuthzFacadeImpl rp = service.deletePerm(trans,type,instance,action); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_PERMISSION); @@ -1207,7 +1181,7 @@ public abstract class AuthzFacadeImpl rp = service.createRole(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,roleRequestDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,roleRequestDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,CREATE_ROLE); @@ -1254,18 +1227,17 @@ public abstract class AuthzFacadeImpl rp = service.getRolesByName(trans, role); - switch(rp.status) { - case OK: - RosettaData data = roleDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,roleDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = roleDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,roleDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_ROLES_BY_NAME); @@ -1283,18 +1255,17 @@ public abstract class AuthzFacadeImpl rp = service.getRolesByUser(trans, user); - switch(rp.status) { - case OK: - RosettaData data = roleDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,roleDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = roleDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,roleDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_ROLES_BY_USER, user); @@ -1312,22 +1283,21 @@ public abstract class AuthzFacadeImpl rp = service.getRolesByNS(trans, ns); - switch(rp.status) { - case OK: - if (!rp.isEmpty()) { - RosettaData data = roleDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - } else { - Question.logEncryptTrace(trans, NO_DATA); + if(rp.status == OK) { + if (!rp.isEmpty()) { + RosettaData data = roleDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); } - setContentType(resp,roleDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + data.to(resp.getOutputStream()); + } else { + Question.logEncryptTrace(trans, NO_DATA); + } + setContentType(resp,roleDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_ROLES_BY_NS); @@ -1346,23 +1316,23 @@ public abstract class AuthzFacadeImpl rp = service.getRolesByNameOnly(trans, nameOnly); - switch(rp.status) { - case OK: - if (!rp.isEmpty()) { - RosettaData data = roleDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - } else { - Question.logEncryptTrace(trans, NO_DATA); + if(rp.status == OK) { + if (!rp.isEmpty()) { + RosettaData data = roleDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); } - setContentType(resp,roleDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + data.to(resp.getOutputStream()); + } else { + Question.logEncryptTrace(trans, NO_DATA); + } + setContentType(resp,roleDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } + } catch (Exception e) { trans.error().log(e,IN,GET_ROLES_BY_NAME_ONLY); return Result.err(e); @@ -1379,18 +1349,17 @@ public abstract class AuthzFacadeImpl rp = service.getRolesByPerm(trans, type,instance,action); - switch(rp.status) { - case OK: - RosettaData data = roleDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,roleDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = roleDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,roleDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_ROLES_BY_PERM); @@ -1416,17 +1385,16 @@ public abstract class AuthzFacadeImpl rp = service.updateRoleDescription(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,roleRequestDF.getOutType()); - return Result.ok(); - default: - return rp; + if(rp.status == OK) { + setContentType(resp,roleRequestDF.getOutType()); + return Result.ok(); + }else{ + return rp; } } catch (Exception e) { trans.error().log(e,IN,UPDATE_ROLE_DESC); @@ -1448,18 +1416,17 @@ public abstract class AuthzFacadeImpl rp = service.addPermToRole(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,ADD_PERM_TO_ROLE); @@ -1481,18 +1448,17 @@ public abstract class AuthzFacadeImpl rp = service.delPermFromRole(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_PERM_FROM_ROLE); @@ -1511,13 +1477,12 @@ public abstract class AuthzFacadeImpl rp = service.delPermFromRole(trans, role, type, instance, action); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - resp.getOutputStream().println(); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + resp.getOutputStream().println(); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_PERM_FROM_ROLE); @@ -1532,12 +1497,11 @@ public abstract class AuthzFacadeImpl rp = service.deleteRole(trans, role); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_ROLE); @@ -1559,17 +1523,16 @@ public abstract class AuthzFacadeImpl rp = service.deleteRole(trans, rreq); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_ROLE); @@ -1587,13 +1550,14 @@ public abstract class AuthzFacadeImpl createUserCred(AuthzTrans trans, HttpServletRequest req) { TimeTaken tt = trans.start(CREATE_CRED, Env.SUB|Env.ALWAYS); @@ -1604,8 +1568,8 @@ public abstract class AuthzFacadeImpl getCredsByNS(AuthzTrans trans, HttpServletResponse resp, String ns) { TimeTaken tt = trans.start(GET_CREDS_BY_NS + ' ' + ns, Env.SUB|Env.ALWAYS); - + try { Result ru = service.getCredsByNS(trans,ns); - switch(ru.status) { - case OK: - RosettaData data = usersDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans,trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - return Result.ok(); - default: - return Result.err(ru); + if(ru.status == OK) { + RosettaData data = usersDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans,trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_CREDS_BY_NS); @@ -1683,30 +1646,29 @@ public abstract class AuthzFacadeImpl getCredsByID(AuthzTrans trans, HttpServletResponse resp, String id) { TimeTaken tt = trans.start(GET_CREDS_BY_ID + ' ' + id, Env.SUB|Env.ALWAYS); - + try { Result ru = service.getCredsByID(trans,id); - switch(ru.status) { - case OK: - RosettaData data = usersDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - return Result.ok(); - default: - return Result.err(ru); + if(ru.status == OK) { + RosettaData data = usersDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_CREDS_BY_ID); @@ -1714,7 +1676,7 @@ public abstract class AuthzFacadeImpl doesCredentialMatch(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(DOES_CRED_MATCH, Env.SUB|Env.ALWAYS); @@ -1750,14 +1712,14 @@ public abstract class AuthzFacadeImpl result = service.validateBasicAuth(trans,basicAuth); - switch(result.status){ - case OK: - resp.getOutputStream().write(Chrono.utcStamp(result.value).getBytes()); - return Result.ok(); + if(result.status == OK) { + resp.getOutputStream().write(Chrono.utcStamp(result.value).getBytes()); + return Result.ok(); } return Result.err(result); } catch (Exception e) { @@ -1786,22 +1747,21 @@ public abstract class AuthzFacadeImpl getCertInfoByID(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp, String id) { TimeTaken tt = trans.start(GET_CERT_BY_ID, Env.SUB|Env.ALWAYS); - try { + try { Result rci = service.getCertInfoByID(trans,req,id); - - switch(rci.status) { - case OK: - if (Question.willSpecialLog(trans, trans.user())) { - RosettaData data = certsDF.newData(trans).load(rci.value); - Question.logEncryptTrace(trans,data.asString()); - data.to(resp.getOutputStream()); - } else { - certsDF.direct(trans, rci.value, resp.getOutputStream()); - } - setContentType(resp,certsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rci); + + if(rci.status == OK) { + if (Question.willSpecialLog(trans, trans.user())) { + RosettaData data = certsDF.newData(trans).load(rci.value); + Question.logEncryptTrace(trans,data.asString()); + data.to(resp.getOutputStream()); + } else { + certsDF.direct(trans, rci.value, resp.getOutputStream()); + } + setContentType(resp,certsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rci); } } catch (Exception e) { trans.error().log(e,IN,GET_CERT_BY_ID); @@ -1816,11 +1776,11 @@ public abstract class AuthzFacadeImpl createDelegate(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(CREATE_DELEGATE, Env.SUB|Env.ALWAYS); - try { + try { Data data = delgRequestDF.newData().load(req.getInputStream()); if (Question.willSpecialLog(trans, trans.user())) { Question.logEncryptTrace(trans,data.asString()); @@ -1834,11 +1794,11 @@ public abstract class AuthzFacadeImpl updateDelegate(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(UPDATE_DELEGATE, Env.SUB|Env.ALWAYS); - try { + try { Data data = delgRequestDF.newData().load(req.getInputStream()); if (Question.willSpecialLog(trans, trans.user())) { Question.logEncryptTrace(trans,data.asString()); @@ -1852,7 +1812,7 @@ public abstract class AuthzFacadeImpl deleteDelegate(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(DELETE_DELEGATE, Env.SUB|Env.ALWAYS); @@ -1870,7 +1830,7 @@ public abstract class AuthzFacadeImpl deleteDelegate(AuthzTrans trans, String userName) { TimeTaken tt = trans.start(DELETE_DELEGATE + ' ' + userName, Env.SUB|Env.ALWAYS); @@ -1883,24 +1843,23 @@ public abstract class AuthzFacadeImpl getDelegatesByUser(AuthzTrans trans, String user, HttpServletResponse resp) { TimeTaken tt = trans.start(GET_DELEGATE_USER, Env.SUB|Env.ALWAYS); try { Result rd = service.getDelegatesByUser(trans, user); - - switch(rd.status) { - case OK: - RosettaData data = delgDF.newData(trans).load(rd.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,delgDF.getOutType()); - return Result.ok(); - default: - return Result.err(rd); + + if(rd.status == OK) { + RosettaData data = delgDF.newData(trans).load(rd.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,delgDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rd); } } catch (Exception e) { trans.error().log(e,IN,GET_DELEGATE_USER); @@ -1915,17 +1874,16 @@ public abstract class AuthzFacadeImpl rd = service.getDelegatesByDelegate(trans, delegate); - switch(rd.status) { - case OK: - RosettaData data = delgDF.newData(trans).load(rd.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - setContentType(resp,delgDF.getOutType()); - return Result.ok(); - default: - return Result.err(rd); + if(rd.status == OK) { + RosettaData data = delgDF.newData(trans).load(rd.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + setContentType(resp,delgDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rd); } } catch (Exception e) { trans.error().log(e,IN,GET_DELEGATE_DELG); @@ -1939,8 +1897,6 @@ public abstract class AuthzFacadeImpl rp = service.createUserRole(trans,request); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,REQUEST_USER_ROLE); @@ -1974,25 +1929,24 @@ public abstract class AuthzFacadeImpl getUserInRole(AuthzTrans trans, HttpServletResponse resp, String user, String role) { TimeTaken tt = trans.start(GET_USERROLES + ' ' + user + '|' + role, Env.SUB|Env.ALWAYS); try { Result ru = service.getUserInRole(trans,user,role); - switch(ru.status) { - case OK: - RosettaData data = usersDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(ru.status == OK) { + RosettaData data = usersDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(ru); + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_USERROLES); @@ -2008,19 +1962,18 @@ public abstract class AuthzFacadeImpl ru = service.getUserRolesByUser(trans,user); - switch(ru.status) { - case OK: - RosettaData data = userrolesDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(ru.status == OK) { + RosettaData data = userrolesDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(ru); + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_USERROLES_BY_USER); @@ -2030,105 +1983,35 @@ public abstract class AuthzFacadeImpl getUserRolesByRole(AuthzTrans trans, HttpServletResponse resp, String role) { TimeTaken tt = trans.start(GET_USERROLES_BY_ROLE + ' ' + role, Env.SUB|Env.ALWAYS); try { Result ru = service.getUserRolesByRole(trans,role); - switch(ru.status) { - case OK: - RosettaData data = userrolesDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - setCacheControlOff(resp); - return Result.ok(); - default: - return Result.err(ru); - } - } catch (Exception e) { - trans.error().log(e,IN,GET_USERROLES_BY_ROLE); - return Result.err(e); - } finally { - tt.done(); - } - - } - - - @Override - public Result resetUsersForRole(AuthzTrans trans, HttpServletResponse resp, HttpServletRequest req) { - TimeTaken tt = trans.start(SET_USERS_FOR_ROLE, Env.SUB|Env.ALWAYS); - try { - REQUEST rreq; - try { - RosettaData data = userRoleRequestDF.newData().load(req.getInputStream()); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - rreq = data.asObject(); - } catch (APIException e) { - trans.error().log("Invalid Input",IN, SET_USERS_FOR_ROLE); - return Result.err(Status.ERR_BadData,"Invalid Input"); - } - - Result rp = service.resetUsersForRole(trans, rreq); - - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); - } - } catch (Exception e) { - trans.error().log(e,IN,SET_USERS_FOR_ROLE); - return Result.err(e); - } finally { - tt.done(); - } - - } - - @Override - public Result resetRolesForUser(AuthzTrans trans, HttpServletResponse resp, HttpServletRequest req) { - TimeTaken tt = trans.start(SET_ROLES_FOR_USER, Env.SUB|Env.ALWAYS); - try { - REQUEST rreq; - try { - RosettaData data = userRoleRequestDF.newData().load(req.getInputStream()); + if(ru.status == OK) { + RosettaData data = userrolesDF.newData(trans).load(ru.value); if (Question.willSpecialLog(trans, trans.user())) { Question.logEncryptTrace(trans,data.asString()); } - rreq = data.asObject(); - } catch (APIException e) { - trans.error().log("Invalid Input",IN, SET_ROLES_FOR_USER); - return Result.err(Status.ERR_BadData,"Invalid Input"); - } - - Result rp = service.resetRolesForUser(trans, rreq); - - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + setCacheControlOff(resp); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { - trans.error().log(e,IN,SET_ROLES_FOR_USER); + trans.error().log(e,IN,GET_USERROLES_BY_ROLE); return Result.err(e); } finally { tt.done(); } - + } + /* (non-Javadoc) * @see com.att.authz.facade.AuthzFacade#extendUserRoleExpiration(org.onap.aaf.auth.env.test.AuthzTrans, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, java.lang.String, java.lang.String) */ @@ -2150,12 +2033,11 @@ public abstract class AuthzFacadeImpl rp = service.deleteUserRole(trans,user,role); - switch(rp.status) { - case OK: - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,DELETE_USER_ROLE); @@ -2169,7 +2051,7 @@ public abstract class AuthzFacadeImpl updateApproval(AuthzTrans trans, HttpServletRequest req, HttpServletResponse resp) { TimeTaken tt = trans.start(UPDATE_APPROVAL, Env.SUB|Env.ALWAYS); @@ -2180,13 +2062,12 @@ public abstract class AuthzFacadeImpl rp = service.updateApproval(trans, data.asObject()); - - switch(rp.status) { - case OK: - setContentType(resp,approvalDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + + if(rp.status == OK) { + setContentType(resp,approvalDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,UPDATE_APPROVAL); @@ -2195,24 +2076,23 @@ public abstract class AuthzFacadeImpl getApprovalsByUser(AuthzTrans trans, HttpServletResponse resp, String user) { TimeTaken tt = trans.start(GET_APPROVALS_BY_USER + ' ' + user, Env.SUB|Env.ALWAYS); try { Result rp = service.getApprovalsByUser(trans, user); - switch(rp.status) { - case OK: - RosettaData data = approvalDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } - data.to(resp.getOutputStream()); - - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + if(rp.status == OK) { + RosettaData data = approvalDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + data.to(resp.getOutputStream()); + + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_APPROVALS_BY_USER, user); @@ -2227,18 +2107,17 @@ public abstract class AuthzFacadeImpl rp = service.getApprovalsByApprover(trans, approver); - switch(rp.status) { - case OK: - RosettaData data = approvalDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rp.status == OK) { + RosettaData data = approvalDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_APPROVALS_BY_APPROVER,approver); @@ -2253,18 +2132,17 @@ public abstract class AuthzFacadeImpl rp = service.getApprovalsByTicket(trans, ticket); - switch(rp.status) { - case OK: - RosettaData data = approvalDF.newData(trans).load(rp.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rp.status == OK) { + RosettaData data = approvalDF.newData(trans).load(rp.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,permsDF.getOutType()); - return Result.ok(); - default: - return Result.err(rp); + data.to(resp.getOutputStream()); + setContentType(resp,permsDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rp); } } catch (Exception e) { trans.error().log(e,IN,GET_APPROVALS_BY_TICKET); @@ -2275,7 +2153,7 @@ public abstract class AuthzFacadeImpl ru = service.getUsersByRole(trans,role); - switch(ru.status) { - case OK: - RosettaData data = usersDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(ru.status == OK) { + RosettaData data = usersDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - return Result.ok(); - default: - return Result.err(ru); + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_USERS_ROLE); @@ -2312,23 +2189,22 @@ public abstract class AuthzFacadeImpl getUsersByPermission(AuthzTrans trans, HttpServletResponse resp, + public Result getUsersByPermission(AuthzTrans trans, HttpServletResponse resp, String type, String instance, String action) { TimeTaken tt = trans.start(GET_USERS_PERMISSION + ' ' + type + ' ' + instance + ' ' +action, Env.SUB|Env.ALWAYS); try { Result ru = service.getUsersByPermission(trans,type,instance,action); - switch(ru.status) { - case OK: - RosettaData data = usersDF.newData(trans).load(ru.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(ru.status == OK) { + RosettaData data = usersDF.newData(trans).load(ru.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,usersDF.getOutType()); - return Result.ok(); - default: - return Result.err(ru); + data.to(resp.getOutputStream()); + setContentType(resp,usersDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(ru); } } catch (Exception e) { trans.error().log(e,IN,GET_USERS_PERMISSION); @@ -2338,11 +2214,12 @@ public abstract class AuthzFacadeImpl rh = service.getHistoryByUser(trans,user,yyyymm,sort); - switch(rh.status) { - case OK: - RosettaData data = historyDF.newData(trans).load(rh.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rh.status == OK) { + RosettaData data = historyDF.newData(trans).load(rh.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,historyDF.getOutType()); - return Result.ok(); - default: - return Result.err(rh); + data.to(resp.getOutputStream()); + setContentType(resp,historyDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rh); } } catch (Exception e) { trans.error().log(e,IN,GET_HISTORY_USER); @@ -2409,18 +2285,17 @@ public abstract class AuthzFacadeImpl rh = service.getHistoryByRole(trans,role,yyyymm,sort); - switch(rh.status) { - case OK: - RosettaData data = historyDF.newData(trans).load(rh.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rh.status == OK) { + RosettaData data = historyDF.newData(trans).load(rh.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,historyDF.getOutType()); - return Result.ok(); - default: - return Result.err(rh); + data.to(resp.getOutputStream()); + setContentType(resp,historyDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rh); } } catch (Exception e) { trans.error().log(e,IN,GET_HISTORY_ROLE); @@ -2452,18 +2327,17 @@ public abstract class AuthzFacadeImpl rh = service.getHistoryByNS(trans,ns,yyyymm,sort); - switch(rh.status) { - case OK: - RosettaData data = historyDF.newData(trans).load(rh.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rh.status == OK) { + RosettaData data = historyDF.newData(trans).load(rh.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,historyDF.getOutType()); - return Result.ok(); - default: - return Result.err(rh); + data.to(resp.getOutputStream()); + setContentType(resp,historyDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rh); } } catch (Exception e) { trans.error().log(e,IN,GET_HISTORY_NS); @@ -2495,18 +2369,17 @@ public abstract class AuthzFacadeImpl rh = service.getHistoryByPerm(trans,perm,yyyymm,sort); - switch(rh.status) { - case OK: - RosettaData data = historyDF.newData(trans).load(rh.value); - if (Question.willSpecialLog(trans, trans.user())) { - Question.logEncryptTrace(trans,data.asString()); - } + if(rh.status == OK) { + RosettaData data = historyDF.newData(trans).load(rh.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } - data.to(resp.getOutputStream()); - setContentType(resp,historyDF.getOutType()); - return Result.ok(); - default: - return Result.err(rh); + data.to(resp.getOutputStream()); + setContentType(resp,historyDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rh); } } catch (Exception e) { trans.error().log(e,IN,GET_HISTORY_PERM); @@ -2516,9 +2389,52 @@ public abstract class AuthzFacadeImpl getHistoryBySubject(AuthzTrans trans, HttpServletResponse resp, String subject, String target, int[] yyyymm, final int sort) { + StringBuilder sb = new StringBuilder(); + sb.append(GET_HISTORY_SUBJECT); + sb.append(' '); + sb.append(subject); + sb.append(" for "); + boolean first = true; + for (int i : yyyymm) { + if (first) { + first = false; + } else { + sb.append(','); + } + sb.append(i); + } + TimeTaken tt = trans.start(sb.toString(), Env.SUB|Env.ALWAYS); + + try { + Result rh = service.getHistoryBySubject(trans,subject,target,yyyymm,sort); + if(rh.status == OK) { + RosettaData data = historyDF.newData(trans).load(rh.value); + if (Question.willSpecialLog(trans, trans.user())) { + Question.logEncryptTrace(trans,data.asString()); + } + + data.to(resp.getOutputStream()); + setContentType(resp,historyDF.getOutType()); + return Result.ok(); + }else{ + return Result.err(rh); + } + } catch (Exception e) { + trans.error().log(e,IN,GET_HISTORY_USER); + return Result.err(e); + } finally { + tt.done(); + } + } + + public static final String CACHE_CLEAR = "cacheClear "; + + /* (non-Javadoc) * @see com.att.authz.facade.AuthzFacade#cacheClear(org.onap.aaf.auth.env.test.AuthzTrans, java.lang.String) */ @@ -2543,7 +2459,7 @@ public abstract class AuthzFacadeImpl getAPI(AuthzTrans trans, HttpServletResponse resp, RServlet rservlet) { TimeTaken tt = trans.start(API_REPORT, Env.SUB); @@ -2619,9 +2535,9 @@ public abstract class AuthzFacadeImpl getAPIExample(AuthzTrans trans, HttpServletResponse resp, String nameOrContentType, boolean optional) { TimeTaken tt = trans.start(API_EXAMPLE, Env.SUB); try { - String content =Examples.print(apiDF.getEnv(), nameOrContentType, optional); + String content =Examples.print(apiDF.getEnv(), nameOrContentType, optional); resp.getOutputStream().print(content); setContentType(resp,content.contains("