gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.sdc.asdctool.impl.validator.executers;
   2
   3 import fj.data.Either;
   4 import org.openecomp.sdc.asdctool.impl.validator.tasks.TopologyTemplateValidationTask;
   5 import org.openecomp.sdc.asdctool.impl.validator.utils.ReportManager;
   6 import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
   7 import org.openecomp.sdc.be.dao.jsongraph.TitanDao;
   8 import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
   9 import org.openecomp.sdc.be.dao.titan.TitanOperationStatus;
  10 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
  11 import org.openecomp.sdc.be.datatypes.enums.GraphPropertyEnum;
  12 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
  13 import org.openecomp.sdc.be.model.jsontitan.operations.TopologyTemplateOperation;
  14 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  15 import org.slf4j.Logger;
  16 import org.slf4j.LoggerFactory;
  17 import org.springframework.beans.factory.annotation.Autowired;
  18
  19 import java.util.*;
  20
  21 /**
  22  * Created by chaya on 7/3/2017.
  23  */
  24 public class TopologyTemplateValidatorExecuter {
  25
  26     private static Logger log = LoggerFactory.getLogger(VfValidatorExecuter.class.getName());
  27
  28     @Autowired
  29     protected TitanDao titanDao;
  30
  31     @Autowired
  32     protected ToscaOperationFacade toscaOperationFacade;
  33
  34     @Autowired
  35     protected TopologyTemplateOperation topologyTemplateOperation;
  36
  37     protected String name;
  38
  39     public void setName(String name) {
  40         this.name = name;
  41     }
  42
  43     public String getName() {
  44         return name;
  45     }
  46
  47     public void reportValidateTaskStatus(TopologyTemplateValidationTask validationTask, boolean success, GraphVertex vertexScanned) {
  48         ReportManager.reportValidationTaskStatus(vertexScanned, validationTask.getTaskName(), validationTask.getTaskResultStatus(), success);
  49     }
  50
  51     protected List<GraphVertex> getVerticesToValidate(ComponentTypeEnum type) {
  52         Map<GraphPropertyEnum, Object> props = new EnumMap<>(GraphPropertyEnum.class);
  53         props.put(GraphPropertyEnum.COMPONENT_TYPE, type.name());
  54         if(type.equals(ComponentTypeEnum.RESOURCE)) {
  55             props.put(GraphPropertyEnum.RESOURCE_TYPE, ResourceTypeEnum.VF);
  56         }
  57
  58         Either<List<GraphVertex>, TitanOperationStatus> results = titanDao.getByCriteria(VertexTypeEnum.TOPOLOGY_TEMPLATE, props);
  59         if (results.isRight()) {
  60             System.out.println("getVerticesToValidate failed "+ results.right().value());
  61             return new ArrayList<GraphVertex>();
  62         }
  63         System.out.println("getVerticesToValidate: "+results.left().value().size()+" vertices to scan");
  64         return results.left().value();
  65     }
  66
  67     protected boolean validate(List<? extends TopologyTemplateValidationTask> tasks, List<GraphVertex> vertices) {
  68         ReportManager.reportStartValidatorRun(getName(), vertices.size());
  69         Set<String> failedTasks = new HashSet<>();
  70         Set<String> successTasks = new HashSet<>();
  71         boolean successAllVertices = true;
  72         for (GraphVertex vertex: vertices) {
  73             boolean successAllTasks = true;
  74             for (TopologyTemplateValidationTask task: tasks) {
  75                 ReportManager.reportStartTaskRun(vertex, task.getTaskName());
  76                 boolean success = task.validate(vertex);
  77                 if (!success) {
  78                     failedTasks.add(task.getTaskName());
  79                     successAllVertices = false;
  80                     successAllTasks = false;
  81                 } else {
  82                     successTasks.add(task.getTaskName());
  83                 }
  84                 reportValidateTaskStatus(task, success, vertex);
  85             }
  86             String componentScanStatus = successAllTasks? "success" : "failed";
  87             System.out.println("Topology Template "+vertex.getUniqueId()+" Validation finished with "+componentScanStatus);
  88         }
  89         ReportManager.reportValidatorTypeSummary(getName(), failedTasks, successTasks);
  90         return successAllVertices;
  91     }
  92 }