1 files changed, 156 insertions, 0 deletions
diff --git a/appc-inbound/appc-interfaces-service/bundle/src/main/java/org/onap/appc/interfaces/service/executorImpl/ServiceExecutorImpl.java b/appc-inbound/appc-interfaces-service/bundle/src/main/java/org/onap/appc/interfaces/service/executorImpl/ServiceExecutorImpl.java
new file mode 100644
index 000000000..3b30c3e8c
--- /dev/null
+++ b/appc-inbound/appc-interfaces-service/bundle/src/main/java/org/onap/appc/interfaces/service/executorImpl/ServiceExecutorImpl.java
@@ -0,0 +1,156 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : APPC
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Copyright (C) 2017 Amdocs
+ * =============================================================================
+ * 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.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.appc.interfaces.service.executorImpl;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.onap.appc.aai.client.aai.AaiService;
+import org.onap.appc.interfaces.service.data.Request;
+import org.onap.appc.interfaces.service.data.ScopeOverlap;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.adaptors.aai.AAIClient;
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.common.base.Strings;
+
+public class ServiceExecutorImpl {
+
+    private static final EELFLogger log = EELFManager.getInstance().getLogger(ServiceExecutorImpl.class);
+    private AAIClient aaiClient;
+    public String isRequestOverLap(String requestData) throws Exception {
+        String response = "\"requestOverlap\"  : ";
+        log.info("Response from ServiceExecutorImpl");
+        ScopeOverlap scopeOverlap = new ScopeOverlap();
+        ObjectMapper mapper = new ObjectMapper();
+        scopeOverlap = mapper.readValue(requestData, ScopeOverlap.class);
+        // return response + String.valueOf(checkForOverLap(scopeOverlap));
+        boolean isOverlap = checkForOverLap(scopeOverlap);
+        scopeOverlap.setOverlap(String.valueOf(isOverlap));
+        if (scopeOverlap.getOverlap() != null && scopeOverlap.getOverlap().equalsIgnoreCase("false")){
+            log.info(response + "false");
+            return response + "false";
+        }
+        else{
+            log.info(response + "true");
+            return response + "true";
+        }
+    }
+
+    private boolean checkForOverLap(ScopeOverlap scopeOverlap) throws Exception {
+        log.info("Checking for isScopeOverlap");
+        if (scopeOverlap.getInProgressRequest() == null) {
+            return Boolean.FALSE;
+        }else if ( scopeOverlap.getInProgressRequest().isEmpty()){
+            return Boolean.FALSE;
+        }
+        else if (scopeOverlap.getInProgressRequest().size() == 0) {
+            return Boolean.FALSE;
+        }
+        if (scopeOverlap.getCurrentRequest().getActionIdentifiers().getVnfId() != null) {
+            return Boolean.TRUE;
+        } else if (scopeOverlap.getCurrentRequest().getActionIdentifiers().getVfModuleId() != null) {
+            return Boolean.TRUE;
+        } else if (scopeOverlap.getCurrentRequest().getActionIdentifiers().getvServerId() != null) {
+            return isVserverOrVnfcIdOverLap(scopeOverlap);
+        } else if (scopeOverlap.getCurrentRequest().getActionIdentifiers().getVnfcName() != null) {
+                return isVserverOrVnfcIdOverLap(scopeOverlap);
+        } else {
+            throw new Exception(" Action Identifier doesn't have VnfId, VfModuleId, VServerId, VnfcName ");
+        }
+    }
+
+    private boolean isVnfcNameOverLap(ScopeOverlap scopeOverlap) throws Exception {
+        
+        AaiService aaiService =new AaiService(aaiClient);
+        SvcLogicContext ctx = new SvcLogicContext();
+        Map<String, String> params = new HashMap<String, String>();
+        List<String> inProgressVServerIds = new ArrayList<String>();
+        String currentVnfcVserverId = new String();
+        String currentRequestVnfcName = scopeOverlap.getCurrentRequest().getActionIdentifiers().getVnfcName();
+        String currentRequestVServerId = scopeOverlap.getCurrentRequest().getActionIdentifiers().getvServerId();
+        List<Request> inProgressRequests = scopeOverlap.getInProgressRequest();
+        params.put("vnfId", scopeOverlap.getVnfId());
+        try {
+            aaiService.getGenericVnfInfo(params, ctx);
+            int vm_count = Integer.parseInt(ctx.getAttribute("vm-count"));
+                for(Request inprogressRequest:inProgressRequests){    
+                    if(inprogressRequest.getActionIdentifiers().getVnfcName() != null){
+                    for (int i = 0; i < vm_count; i++){                    
+                        if (ctx.getAttribute("vm[" + i + "].vnfc-name") != null && ctx.getAttribute("vm[" + i + "].vnfc-name")
+                        .equals(inprogressRequest.getActionIdentifiers().getVnfcName()))
+                            inProgressVServerIds.add(ctx.getAttribute("vm[" + i + "].vserver-id"));
+                        log.debug("Received vserver-id from AAI: "+ inProgressVServerIds);
+                    }
+                }
+            }
+            for(Request inProgVserverIds:inProgressRequests)
+                if(inProgVserverIds.getActionIdentifiers().getvServerId()!=null)
+                    inProgressVServerIds.add(inProgVserverIds.getActionIdentifiers().getvServerId());
+            if(currentRequestVnfcName != null){
+                for (int i = 0; i < vm_count; i++)
+                    if (ctx.getAttribute("vm[" + i + "].vnfc-name") != null && ctx.getAttribute("vm[" + i + "].vnfc-name")
+                            .equals(currentRequestVnfcName))
+                 currentVnfcVserverId = ctx.getAttribute("vm[" + i + "].vserver-id");
+                log.debug("Received vserver-id from AAI: "+ currentVnfcVserverId);
+                return inProgressVServerIds.contains(currentVnfcVserverId);
+            }
+            for (Request request : inProgressRequests) {
+                if(!Strings.isNullOrEmpty(currentRequestVServerId)  && currentRequestVServerId.equalsIgnoreCase(request.getActionIdentifiers().getvServerId()))
+                    return Boolean.TRUE;
+            }
+            if(currentRequestVServerId != null)    {
+                return  inProgressVServerIds.contains(currentRequestVServerId);
+            }
+            return Boolean.FALSE;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.debug(e.getMessage());
+            throw e;
+        }
+    }
+
+    private boolean isVserverOrVnfcIdOverLap(ScopeOverlap scopeOverlap) throws Exception {
+        List<Request> inProgressRequests = scopeOverlap.getInProgressRequest();
+        for (Request request : inProgressRequests) {
+            if(request.getActionIdentifiers().getVnfId()!= null)
+            return Boolean.TRUE ;
+            }
+        for (Request request : inProgressRequests) {
+            if(request.getActionIdentifiers().getVfModuleId()!= null)
+                return Boolean.TRUE ;
+        }
+        String currentVserverID = scopeOverlap.getCurrentRequest().getActionIdentifiers().getvServerId();
+        for (Request request : inProgressRequests) {
+            if(currentVserverID != null && currentVserverID.equalsIgnoreCase(request.getActionIdentifiers().getvServerId()))
+                return Boolean.TRUE ;
+        }
+        return isVnfcNameOverLap(scopeOverlap);
+    }
+}