}
}
- JSONObject responseJsonObject = null;
+ JSONObject responseJsonObject;
responseJsonObject = this.success();
response.setContentType(CONTENTTYPE);
PrintWriter out = response.getWriter();
policyParams.put("newPolicySplit_0", newPolicySplit[0]);
List<Object> queryData = controller.getDataByQuery(policyEntityquery, policyParams);
if(!queryData.isEmpty()){
- entity = (PolicyEntity) queryData.get(0);
return error("Policy rename failed. Since, the policy with same name already exists.");
}
params.put("oldPolicySplit_0", oldPolicySplit[0]);
List<Object> oldEntityData = controller.getDataByQuery(oldpolicyEntityquery, params);
if(!oldEntityData.isEmpty()){
- String groupQuery = "FROM PolicyGroupEntity where (";
+ StringBuilder groupQuery = new StringBuilder();
+ groupQuery.append("FROM PolicyGroupEntity where (");
SimpleBindings geParams = new SimpleBindings();
for(int i=0; i<oldEntityData.size(); i++){
entity = (PolicyEntity) oldEntityData.get(i);
if(i == 0){
- groupQuery = groupQuery + "policyid = :policyId";
+ groupQuery.append("policyid = :policyId");
geParams.put("policyId", entity.getPolicyId());
}else{
- groupQuery = groupQuery + " or policyid = :policyId" + i;
+ groupQuery.append(" or policyid = :policyId" + i);
geParams.put("policyId" + i, entity.getPolicyId());
}
}
- groupQuery = groupQuery + ")";
- List<Object> groupEntityData = controller.getDataByQuery(groupQuery, geParams);
+ groupQuery.append(")");
+ List<Object> groupEntityData = controller.getDataByQuery(groupQuery.toString(), geParams);
if(! groupEntityData.isEmpty()){
return error("Policy rename failed. Since the policy or its version is active in PDP Groups.");
}
String path = params.getString("path");
try{
if(params.has("subScopename")){
- if(!params.getString("subScopename").equals("")){
+ if(! "".equals(params.getString("subScopename"))) {
name = params.getString("path").replace("/", File.separator) + File.separator +params.getString("subScopename");
}
}else{
}
}
LOGGER.debug("addFolder path: {} name: {}" + path +name);
- if(!name.equals("")){
+ if(! "".equals(name)){
if(name.startsWith(File.separator)){
name = name.substring(1);
}
@RequestMapping(value={"/getDictionary/*"}, method={RequestMethod.GET})
public void getDictionaryController(HttpServletRequest request, HttpServletResponse response){
String uri = request.getRequestURI().replace("/getDictionary", "");
- String body = null;
+ String body;
ResponseEntity<?> responseEntity = sendToPAP(null, uri, HttpMethod.GET);
if(responseEntity != null){
body = responseEntity.getBody().toString();
@RequestMapping(value={"/searchDictionary"}, method={RequestMethod.POST})
public ModelAndView searchDictionaryController(HttpServletRequest request, HttpServletResponse response) throws IOException {
- Object resultList = null;
+ Object resultList;
String uri = request.getRequestURI();
if(uri.startsWith("/")){
uri = uri.substring(uri.indexOf('/')+1);
@RequestMapping(value={"/searchPolicy"}, method={RequestMethod.POST})
public ModelAndView searchPolicy(HttpServletRequest request, HttpServletResponse response) throws IOException{
- Object resultList = null;
+ Object resultList;
String uri = request.getRequestURI()+"?action=search";
if(uri.startsWith("/")){
uri = uri.substring(uri.indexOf('/')+1);
* Set up link with PAP Servlet and get our initial set of Groups
* @throws Exception
*/
- public RESTfulPAPEngine (String myURLString) throws PAPException, IOException {
+ public RESTfulPAPEngine (String myURLString) throws PAPException {
//
// Get our URL to the PAP servlet
//
try {
String fullURL = papServletURLString;
if (parameters != null && parameters.length > 0) {
- String queryString = "";
+ StringBuilder queryString = new StringBuilder();
for (String p : parameters) {
- queryString += "&" + p;
+ queryString.append("&" + p);
}
fullURL += "?" + queryString.substring(1);
}
if (anyOfList != null) {
Iterator<AnyOfType> iterAnyOf = anyOfList.iterator();
- String targetInHuman = "";
+ StringBuilder targetInHuman = new StringBuilder();
while (iterAnyOf.hasNext()) {
AnyOfType anyOf = iterAnyOf.next();
List<AllOfType> allOfList = anyOf.getAllOf();
if (matchList != null) {
Iterator<MatchType> iterMatch = matchList.iterator();
if (matchList.size() > 1)
- targetInHuman += "(";
+ targetInHuman.append("(");
while (iterMatch.hasNext()) {
MatchType match = iterMatch.next();
//
attribute.getAttributeId().stringValue());
this.attributeIdentifiersMap.put(succintIdentifier,ai);
- targetInHuman += "<i><a href=\"#" + succintIdentifier + "\">" + succintIdentifier + "</a></i> " + functionName + " ";
+ targetInHuman.append("<i><a href=\"#" + succintIdentifier + "\">" + succintIdentifier + "</a></i> " + functionName + " ");
int numAttributes = attribute.getValues().size();
int count = 0;
int countValues = 0;
for (Object o : value_s) {
countValues++;
- targetInHuman += " <I>" + o + "</I>";
+ targetInHuman.append(" <I>" + o + "</I>");
if (countValues < numValues) {
- targetInHuman += ", or";
+ targetInHuman.append(", or");
}
}
} else {
- targetInHuman += " <I>" + v.getValue() + "</I>";
+ targetInHuman.append(" <I>" + v.getValue() + "</I>");
if (count < numAttributes) {
- targetInHuman += ", or ";
+ targetInHuman.append(", or ");
}
}
}
}
if (iterMatch.hasNext()) {
- targetInHuman += " and ";
+ targetInHuman.append(" and ");
}
} // end iterMatch
if (matchList.size() > 1) {
- targetInHuman += ")";
+ targetInHuman.append(")");
}
}
if (iterAllOf.hasNext()) {
- targetInHuman += " or ";
+ targetInHuman.append(" or ");
}
} // end iterAllOf
}
if (iterAnyOf.hasNext()) {
- targetInHuman = "(" + targetInHuman + ")" + " or ";
+ targetInHuman = new StringBuilder();
+ targetInHuman.append("(" + targetInHuman + ")" + " or ");
} else {
if (anyOfList.size() > 1) {
- targetInHuman += ")";
+ targetInHuman.append(")");
}
}
} // end iterAnyOf
if (exps == null || exps.isEmpty())
return "";
else {
- String forResult = "";
+ StringBuilder forResult = new StringBuilder();
for (JAXBElement<?> e : exps) {
Object v = e.getValue();
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("one-and-only children: " + v);
}
if (v != null) {
- forResult += stringifyExpression(v);
+ forResult.append(stringifyExpression(v));
}
}
- return forResult;
+ return forResult.toString();
}
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(functionName + " 1 expression: " + numExpr);
}
- String applySubresult = "";
+ StringBuilder applySubresult = new StringBuilder();
for (JAXBElement<?> e : apply.getExpression()) {
Object v = e.getValue();
if (v != null) {
- applySubresult += this.stringifyExpression(e.getValue());
+ applySubresult.append(this.stringifyExpression(e.getValue()));
}
}
- return " " + removePrimitives(functionName) + " (" + applySubresult + ")";
+ return " " + removePrimitives(functionName) + " (" + applySubresult.toString() + ")";
} else {
// > 1 arguments
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(functionName + " > 1 expressions: " + numExpr);
}
- String applySubresult = "";
+ StringBuilder applySubresult = new StringBuilder();
int exprCount = 0;
for (JAXBElement<?> e : apply.getExpression()) {
exprCount++;
if (ev != null) {
if (ev instanceof ApplyType) {
if (((ApplyType) ev).getFunctionId().contains("one-and-only")) {
- applySubresult += this.stringifyExpression(e.getValue());
+ applySubresult.append(this.stringifyExpression(e.getValue()));
} else {
- applySubresult += "(" + this.stringifyExpression(e.getValue()) + ")";
+ applySubresult.append("(" + this.stringifyExpression(e.getValue()) + ")");
}
} else {
- applySubresult += this.stringifyExpression(e.getValue());
+ applySubresult.append(this.stringifyExpression(e.getValue()));
}
if (exprCount < numExpr) {
- applySubresult += " " + removePrimitives(functionName) + " ";
+ applySubresult.append(" " + removePrimitives(functionName) + " ");
}
}
}
- return applySubresult;
+ return applySubresult.toString();
}
}
if (expression instanceof AttributeDesignatorType) {
if (expression instanceof AttributeValueType) {
AttributeValueType avt = (AttributeValueType) expression;
List<Object> content = avt.getContent();
- String value_s = "";
+ StringBuilder value_s = new StringBuilder();
for (Object o: content) {
- value_s += " " + o.toString();
+ value_s.append(" " + o.toString());
}
- return " " + value_s;
+ return " " + value_s.toString();
}
if (expression instanceof VariableReferenceType) {
//
faultSignatureDatas.add(faultDatas);
}
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
if(!policyJsonData.getConnecttriggerSignatures().isEmpty()){
- resultBody = resultBody + "(";
+ resultBody.append("(");
for(int i = policyJsonData.getConnecttriggerSignatures().size()-1; i>=0 ; i--){
String connectBody = connectTriggerSignature(i, policyJsonData.getConnecttriggerSignatures(), trapSignatureDatas.get(0));
- resultBody = resultBody + connectBody;
+ resultBody.append(connectBody);
}
- resultBody = resultBody + ")";
+ resultBody.append(resultBody + ")");
}else{
if(!trapSignatureDatas.isEmpty()){
- resultBody = callTrap("nill", trapSignatureDatas.get(0));
+ resultBody.append(callTrap("nill", trapSignatureDatas.get(0)));
}
}
ClosedLoopSignatures triggerSignatures = new ClosedLoopSignatures();
- triggerSignatures.setSignatures(resultBody);
+ triggerSignatures.setSignatures(resultBody.toString());
if(policyData.getClearTimeOut() != null){
triggerSignatures.setTimeWindow(Integer.parseInt(policyData.getClearTimeOut()));
triggerSignatures.setTrapMaxAge(Integer.parseInt(policyData.getTrapMaxAge()));
}
jsonBody.setTriggerSignatures(triggerSignatures);
- String faultBody = "";
+ StringBuilder faultBody = new StringBuilder();
if(!policyJsonData.getConnectVerificationSignatures().isEmpty()){
- faultBody = faultBody + "(";
+ faultBody.append("(");
for(int i = policyJsonData.getConnectVerificationSignatures().size()-1; i>=0 ; i--){
String connectBody = connectTriggerSignature(i, policyJsonData.getConnectVerificationSignatures(), faultSignatureDatas.get(0));
- faultBody = faultBody + connectBody;
+ faultBody.append(connectBody);
}
- faultBody = faultBody + ")";
+ faultBody.append(")");
}else{
if(!faultSignatureDatas.isEmpty()){
- faultBody = callTrap("nill", faultSignatureDatas.get(0));
+ faultBody.append(callTrap("nill", faultSignatureDatas.get(0)));
}
}
ClosedLoopSignatures faultSignatures = new ClosedLoopSignatures();
- faultSignatures.setSignatures(faultBody);
+ faultSignatures.setSignatures(faultBody.toString());
if(policyData.getVerificationclearTimeOut() != null){
faultSignatures.setTimeWindow(Integer.parseInt(policyData.getVerificationclearTimeOut()));
ClosedLoopFaultTriggerUISignatures uifaultSignatures = new ClosedLoopFaultTriggerUISignatures();
@SuppressWarnings("unchecked")
private String connectTriggerSignature(int index, ArrayList<Object> triggerSignatures, Object object) {
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
Map<String, String> connectTraps = (Map<String, String>) triggerSignatures.get(index);
try{
String notBox = "";
if(connectTraps.keySet().contains("notBox")){
notBox = connectTraps.get("notBox");
}
- resultBody = resultBody + "(" + notBox;
+ resultBody.append("(" + notBox);
}catch(NullPointerException e){
policyLogger.info("General error" , e);
- resultBody = resultBody + "(";
+ resultBody.append("(");
}
String connectTrap1 = connectTraps.get("connectTrap1");
if(connectTrap1.startsWith("Trap") || connectTrap1.startsWith("Fault")){
String trapBody = callTrap(connectTrap1, object);
if(trapBody!=null){
- resultBody = resultBody + trapBody;
+ resultBody.append(trapBody);
}
}else if(connectTrap1.startsWith("C")){
for(int i=0; i<= triggerSignatures.size(); i++){
Map<String,String> triggerSignature = (Map<String, String>) triggerSignatures.get(i);
if(triggerSignature.get("id").equals(connectTrap1)){
- resultBody = resultBody + "(";
+ resultBody.append("(");
String connectBody = connectTriggerSignature(i, triggerSignatures, object);
- resultBody = resultBody + connectBody + ")";
+ resultBody.append(connectBody + ")");
}else{
i++;
}
}
try{
String trapCount1 = connectTraps.get("trapCount1");
- resultBody = resultBody + ", Time = " + trapCount1 + ")";
+ resultBody.append(", Time = " + trapCount1 + ")");
}catch(NullPointerException e){
policyLogger.info("General error" , e);
}
try{
String operatorBox = connectTraps.get("operatorBox");
- resultBody = resultBody + operatorBox +"(";
+ resultBody.append(operatorBox +"(");
}catch (NullPointerException e){
policyLogger.info("General error" , e);
}
if(connectTrap2.startsWith("Trap") || connectTrap2.startsWith("Fault")){
String trapBody = callTrap(connectTrap2, object);
if(trapBody!=null){
- resultBody = resultBody + trapBody;
+ resultBody.append(trapBody);
}
}else if(connectTrap2.startsWith("C")){
for(int i=0; i<= triggerSignatures.size(); i++){
Map<String,String> triggerSignature = (Map<String, String>) triggerSignatures.get(i);
if(triggerSignature.get("id").equals(connectTrap2)){
- resultBody = resultBody + "(";
+ resultBody.append("(");
String connectBody = connectTriggerSignature(i, triggerSignatures, object);
- resultBody = resultBody + connectBody + ")";
+ resultBody.append(connectBody + ")");
}else{
i++;
}
}
try{
String trapCount2 = connectTraps.get("trapCount2");
- resultBody = resultBody + ", Time = " + trapCount2 + ")";
+ resultBody.append(", Time = " + trapCount2 + ")");
}catch(NullPointerException e){
policyLogger.info("General error" , e);
}
- return resultBody;
+ return resultBody.toString();
}
//connect traps data set to JSON Body as String
@SuppressWarnings({ "unchecked", "rawtypes" })
private String getUIConnectTraps(ArrayList<Object> connectTrapSignatures) {
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
String connectMainBody = "";
for(int j = 0; j < connectTrapSignatures.size(); j++){
Map<String, String> connectTraps = (Map<String, String>)connectTrapSignatures.get(j);
}
connectBody = notBox + "@!" + connectTrap1 + "@!" + trapCount1 + "@!" + operatorBox + "@!" + connectTrap2 + "@!" + trapCount2 + "#!?!";
}
- resultBody = resultBody + connectBody;
+ resultBody.append(connectBody);
}
connectMainBody = connectMainBody + resultBody;
return connectMainBody;
// get Trigger signature from JSON body
@SuppressWarnings({ "rawtypes", "unchecked" })
private String getUITriggerSignature(String trap, Object object2) {
- String triggerBody = "";
+ StringBuilder triggerBody = new StringBuilder();
TrapDatas trapDatas = (TrapDatas) object2;
ArrayList<Object> attributeList = new ArrayList<>();
// Read the Trap
}
for(int j = 0; j < attributeList.size(); j++){
- String signatureBody = "";
+ StringBuilder signatureBody = new StringBuilder();
ArrayList<Object> connectTraps = (ArrayList<Object>) attributeList.get(j);
for(int i =0 ; i < connectTraps.size(); i++){
String connectBody = "";
}
connectBody = notBox + "@!" + trigger1 + "@!" + operatorBox + "@!" + trigger2 + "#!";
}
- signatureBody = signatureBody + connectBody;
+ signatureBody.append(connectBody);
}
- triggerBody = triggerBody + signatureBody + "?!";
+ triggerBody.append(signatureBody + "?!");
}
- return triggerBody;
+ return triggerBody.toString();
}
public void prePopulateClosedLoopFaultPolicyData(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
}
private GroupPolicyScopeList getPolicyObject(String policyScope) {
- GroupPolicyScopeList groupList= (GroupPolicyScopeList) commonClassDao.getEntityItem(GroupPolicyScopeList.class, "name", policyScope);
- return groupList;
+ return (GroupPolicyScopeList) commonClassDao.getEntityItem(GroupPolicyScopeList.class, "name", policyScope);
}
private PolicyRestAdapter constructJson(PolicyRestAdapter policyAdapter, String jsonContent, String dummyValue) {
Map gsonObject = (Map) gson.fromJson(subAttributes, Object.class);
JSONObject object = new JSONObject();
- JSONArray array = new JSONArray();
+ JSONArray array;
for (Entry<String, String> keySet : attributeMap.entrySet()){
array = new JSONArray();
@SuppressWarnings("unchecked")
private JSONObject recursiveReference(String name, Map<String,String> subAttributeMap, String enumAttribute) {
JSONObject object = new JSONObject();
- Map<String, String> map = new HashMap<>();
+ Map<String, String> map;
Object returnClass = subAttributeMap.get(name);
map = (Map<String, String>) returnClass;
- JSONArray array = new JSONArray();
+ JSONArray array;
for( Entry<String, String> m:map.entrySet()){
String[] splitValue = m.getValue().split(":");
JsonNode root = mapper.readTree(request.getReader());
String value = root.get("policyData").toString().replaceAll("^\"|\"$", "");
- String servicename = value.toString().split("-v")[0];
+ String servicename = value.split("-v")[0];
Set<String> returnList = getVersionList(servicename);
response.setCharacterEncoding("UTF-8");
}
private Set<String> getVersionList(String name) {
- MicroServiceModels workingModel = new MicroServiceModels();
+ MicroServiceModels workingModel;
Set<String> list = new HashSet<>();
List<Object> microServiceModelsData = commonClassDao.getDataById(MicroServiceModels.class, "modelName", name);
for (int i = 0; i < microServiceModelsData.size(); i++) {
String policyScopeName = null;
ObjectMapper mapper = new ObjectMapper();
try {
- DCAEMicroServiceObject msBody = (DCAEMicroServiceObject) mapper.readValue(entity.getConfigurationData().getConfigBody(), DCAEMicroServiceObject.class);
+ DCAEMicroServiceObject msBody = mapper.readValue(entity.getConfigurationData().getConfigBody(), DCAEMicroServiceObject.class);
policyScopeName = getPolicyScope(msBody.getPolicyScope());
policyAdapter.setPolicyScope(policyScopeName);
//Convert the map values and set into JSON body
public Map<String, String> convertMap(Map<String, String> attributesMap, Map<String, String> attributesRefMap) {
Map<String, String> attribute = new HashMap<>();
- String temp = null;
+ StringBuilder temp = null;
String key;
String value;
for (Entry<String, String> entry : attributesMap.entrySet()) {
temp = null;
for (Object textList : arrayList.getValue()){
if (temp == null){
- temp = "[" + textList;
+ temp = new StringBuilder();
+ temp.append("[" + textList);
}else{
- temp = temp + "," + textList;
+ temp.append("," + textList);
}
}
attribute.put(key, temp+ "]");
private void retreiveDependency(String workingFile, Boolean modelClass) {
MSModelUtils utils = new MSModelUtils(PolicyController.getMsOnapName(), PolicyController.getMsPolicyName());
- HashMap<String, MSAttributeObject> tempMap = new HashMap<>();
+ HashMap<String, MSAttributeObject> tempMap;
tempMap = utils.processEpackage(workingFile, MODEL_TYPE.XMI);
String jsonBody="";
termCollectorList = new ArrayList <>();
tagCollectorList = new ArrayList <>();
- if(policyData.getAttributes().size() > 0){
+ if(! policyData.getAttributes().isEmpty()){
for(Object attribute : policyData.getAttributes()){
if(attribute instanceof LinkedHashMap<?, ?>){
String key = ((LinkedHashMap<?, ?>) attribute).get("key").toString();
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
JsonNode root = mapper.readTree(request.getReader());
PolicyRestAdapter policyData = mapper.readValue(root.get("policyData").toString(), PolicyRestAdapter.class);
- if(policyData.getAttributes().size() > 0){
+ if(! policyData.getAttributes().isEmpty()){
for(Object attribute : policyData.getAttributes()){
if(attribute instanceof LinkedHashMap<?, ?>){
String key = ((LinkedHashMap<?, ?>) attribute).get("key").toString();
PolicyController controller = getPolicyControllerInstance();
Set<OnapPDPGroup> groups = controller.getPapEngine().getOnapPDPGroups();
if (groups == null) {
- papStatus = "UNKNOWN";
throw new PAPException("PAP not running");
}else {
papStatus = "IS_OK";
private long getRequestCounts(String host, int port, String jmxAttribute) {
policyLogger.debug("Create an RMI connector client and connect it to the JMX connector server");
- HashMap map = new HashMap();
- map = null;
+ HashMap map = null;
JMXConnector jmxConnection;
try {
jmxConnection = JMXConnectorFactory.newJMXConnector(createConnectionURL(host, port), map);
@SuppressWarnings({ "rawtypes", "unchecked" })
private Object getPolicy(String host, int port, String jmxAttribute){
policyLogger.debug("Create an RMI connector client and connect it to the JMX connector server for Policy: " + host);
- HashMap map = new HashMap();
- map = null;
+ HashMap map = null;
JMXConnector jmxConnection;
try {
jmxConnection = JMXConnectorFactory.newJMXConnector(createConnectionURL(host, port), map);
@RequestMapping(value={"/watchPolicy"}, method={org.springframework.web.bind.annotation.RequestMethod.POST})
public ModelAndView watchPolicy(HttpServletRequest request, HttpServletResponse response) throws IOException{
- String path = "";
+ StringBuilder path = new StringBuilder();
String responseValue = "";
try {
String userId = UserUtils.getUserSession(request).getOrgUserId();
for (int i = 0; i < arrayNode.size(); i++) {
JsonNode individualElement = arrayNode.get(i);
if(i == 0){
- path = path + individualElement.toString().replace("\"", "").trim();
+ path.append(individualElement.toString().replace("\"", "").trim());
}else{
- path = path + File.separator + individualElement.toString().replace("\"", "").trim();
+ path.append(File.separator + individualElement.toString().replace("\"", "").trim());
}
}
}
@RequestMapping(value={"/save_NonSuperRolesData"}, method={org.springframework.web.bind.annotation.RequestMethod.POST})
public ModelAndView SaveRolesEntityData(HttpServletRequest request, HttpServletResponse response){
try{
- String scopeName = null;
+ StringBuilder scopeName = new StringBuilder();
ObjectMapper mapper = new ObjectMapper();
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
String userId = UserUtils.getUserSession(request).getOrgUserId();
ReadScopes adapter = mapper.readValue(root.get("editRoleData").toString(), ReadScopes.class);
for(int i = 0; i < adapter.getScope().size(); i++){
if(i == 0){
- scopeName = adapter.getScope().get(0);
+ scopeName.append(adapter.getScope().get(0));
}else{
- scopeName = scopeName + "," + adapter.getScope().get(i);
+ scopeName.append("," + adapter.getScope().get(i));
}
}
LOGGER.info("****************************************Logging UserID for Roles Function********************************************************");
roles.setId(adapter.getId());
roles.setLoginId(adapter.getLoginId());
roles.setRole(adapter.getRole());
- roles.setScope(scopeName);
+ roles.setScope(scopeName.toString());
commonClassDao.update(roles);
response.setCharacterEncoding("UTF-8");
response.setContentType("application / json");
Code Review / policy / engine.git / commitdiff