Add Matching Fields For MS Model

[policy/engine.git] / POLICY-SDK-APP / src / main / java / org / onap / policy / controller / CreateDcaeMicroServiceController.java

diff --git a/POLICY-SDK-APP/src/main/java/org/onap/policy/controller/CreateDcaeMicroServiceController.java b/POLICY-SDK-APP/src/main/java/org/onap/policy/controller/CreateDcaeMicroServiceController.java
index 431482d..422c18a 100644 (file)
--- a/POLICY-SDK-APP/src/main/java/org/onap/policy/controller/CreateDcaeMicroServiceController.java
+++ b/POLICY-SDK-APP/src/main/java/org/onap/policy/controller/CreateDcaeMicroServiceController.java
@@ -113,7 +113,7 @@ import oasis.names.tc.xacml._3_0.core.schema.wd_17.TargetType;
 @RequestMapping("/")
 public class CreateDcaeMicroServiceController extends RestrictedBaseController {
        private static final Logger LOGGER = FlexLogger.getLogger(CreateDcaeMicroServiceController.class);
-
+       private Map<String, String>  matchableValues;
        private static CommonClassDao commonClassDao;
        
        public static CommonClassDao getCommonClassDao() {
@@ -151,7 +151,7 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
        public static final String DEFAULT=".default";
        public static final String REQUIRED=".required";
        public static final String MANYFALSE=":MANY-false";
-       
+       public static final String MATCHABLE=".matchable";
        
        @Autowired
        private CreateDcaeMicroServiceController(CommonClassDao commonClassDao){
@@ -520,6 +520,7 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
        
        HashMap<String,String> parseDataNodes(Map<String,String> map){
                HashMap<String,String> dataMapForJson=new HashMap <>(); 
+               matchableValues = new HashMap <>(); 
                for(String uniqueDataKey: uniqueDataKeys){
                        if(uniqueDataKey.contains("%")){
                                String[] uniqueDataKeySplit= uniqueDataKey.split("%");
@@ -538,6 +539,15 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                        String requiredValue= map.get(findRequired);
                                        LOGGER.info("requiredValue is:"+ requiredValue);
                                        
+                                       String matchable =DATATYPE+uniqueDataKeySplit[0]+PROPERTIES+uniqueDataKeySplit[1]+MATCHABLE;
+
+                                       String matchableValue= map.get(matchable);
+
+                                       if("true".equalsIgnoreCase(matchableValue)){                                            
+                                               String key=uniqueDataKeySplit[uniqueDataKeySplit.length -1];
+                                               matchableValues.put(key, "matching-true");                                              
+                                       }
+                                       
                                        StringBuilder attributeIndividualStringBuilder= new StringBuilder();
                                        attributeIndividualStringBuilder.append(typeValue+":defaultValue-");
                                        attributeIndividualStringBuilder.append(defaultValue+":required-");
@@ -545,6 +555,8 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                        dataMapForJson.put(uniqueDataKey, attributeIndividualStringBuilder.toString());         
                                }
                                else if(typeValue != null && typeValue.equalsIgnoreCase(LIST)){
+                                       
+
                                        String findList= DATATYPE+uniqueDataKeySplit[0]+PROPERTIES+uniqueDataKeySplit[1]+".entry_schema.type";
                                        String listValue=map.get(findList);
                                        if(listValue!=null){
@@ -569,6 +581,9 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                                                        break;
                                                                }
                                                                else{
+                                                                       if(constraintsValue.contains("=")){
+                                                                               constraintsValue = constraintsValue.replace("=", "equal-sign");
+                                                                       }
                                                                        dataConstraints.add(constraintsValue);
                                                                        dataListBuffer.append(constraintsValue+",");
                                                                }
@@ -588,6 +603,8 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                        dataMapForJson.put(uniqueDataKey, referenceIndividualStringBuilder.toString());
                                        
                                }
+                       }else{
+                               matchableValues.put(uniqueDataKey, "matching-true");
                        }
                }
                return dataMapForJson;
@@ -695,12 +712,19 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                attributeIndividualStringBuilder.append(keyValues.get("default")+":required-");
                                attributeIndividualStringBuilder.append(keyValues.get("required")+":MANY-false");
                                attributeStringBuilder.append(attributeIndividualStringBuilder+",");    
-
+                if("true".equalsIgnoreCase(keyValues.get("matchable"))){
+                                   matchableValues.put(keySetString, "matching-true");
+                }
                        }
                        else if(keyValues.get("type") != null && keyValues.get("type").equalsIgnoreCase(LIST)){
+                               
+                if("true".equalsIgnoreCase(keyValues.get("matchable"))){
+                                   matchableValues.put(keySetString, "matching-true");
+                }
                                //List Datatype
                                Set<String> keys= keyValues.keySet();
                                Iterator<String> itr=keys.iterator();
+                               boolean isDefinedType = false;
                                while(itr.hasNext()){
                                        String key= itr.next();
                                        if(!("type").equals(key) ||("required").equals(key))
@@ -713,22 +737,26 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                                                            constraints.add(keyValues.get(key));
                                                        }
                                                }else{
-                                                       //This is user defined string
+                                                       //This is user defined type
                                                        String trimValue=value.substring(value.lastIndexOf('.')+1);
                                                        StringBuilder referenceIndividualStringBuilder= new StringBuilder();
                                                        referenceIndividualStringBuilder.append(keySetString+"="+trimValue+":MANY-true");
                                                        referenceStringBuilder.append(referenceIndividualStringBuilder+",");
+                                                       isDefinedType = true;
                                                }
                                        }                               
 
                                }
 
-                               if(keyValues.get("type").equalsIgnoreCase(LIST) &&
-                                       (constraints == null || constraints.isEmpty()) ) {
+                               if(!isDefinedType && keyValues.get("type").equalsIgnoreCase(LIST) &&
+                                       (constraints == null || constraints.isEmpty()) ) {   //type is list but no constraints defined.
                                                referenceStringBuilder.append(keySetString+"=MANY-true"+",");
                                }
                        }else{
                                //User defined Datatype. 
+                if("true".equalsIgnoreCase(keyValues.get("matchable"))){
+                                   matchableValues.put(keySetString, "matching-true");
+                }
                                String value=keyValues.get("type");
                                if(value != null && !value.isEmpty()){
                                        String trimValue=value.substring(value.lastIndexOf('.')+1);
@@ -987,9 +1015,9 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                        LOGGER.info("allkeys : " + allkeys);
                }
                
-               String allManyTrueKeys = "";
+               String nameOfTrueKey = "";
                if(allkeys != null){
-                       allManyTrueKeys = allkeys.toString();
+                       nameOfTrueKey = allkeys.toString();
                }
                
                String jsonModel = createMicroSeriveJson(returnModel, allkeys);
@@ -1033,10 +1061,10 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                PrintWriter out = response.getWriter();
                String responseString = mapper.writeValueAsString(returnModel);
                JSONObject j;
-               if("".equals(allManyTrueKeys)){
+               if("".equals(nameOfTrueKey)){
                        j = new JSONObject("{dcaeModelData: " + responseString + ",jsonValue: " + jsonModel + "}");     
                }else{
-                       j = new JSONObject("{dcaeModelData: " + responseString + ",jsonValue: " + jsonModel + ",allManyTrueKeys: " + allManyTrueKeys+ "}");     
+                       j = new JSONObject("{dcaeModelData: " + responseString + ",jsonValue: " + jsonModel + ",allManyTrueKeys: " + nameOfTrueKey+ "}");       
                }
                list.add(j);
                out.write(list.toString());
@@ -1610,7 +1638,7 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
                        msAttributes.setAttribute(returnAttributeList);
                        
                        msAttributes.setSubClass(this.retmap);
-                       
+                       msAttributes.setMatchingSet(matchableValues);
                        HashMap<String, String> returnReferenceList =new HashMap<>();
                        returnReferenceList.put(className, this.referenceAttributes);
                        msAttributes.setRefAttribute(returnReferenceList);
@@ -1714,9 +1742,9 @@ public class CreateDcaeMicroServiceController extends RestrictedBaseController {
        }
                
        private List<File> listModelFiles(String directoryName) {
-               File directory = new File(directoryName);
+               File fileDirectory = new File(directoryName);
                List<File> resultList = new ArrayList<>();
-               File[] fList = directory.listFiles();
+               File[] fList = fileDirectory.listFiles();
                for (File file : fList) {
                        if (file.isFile()) {
                                resultList.add(file);