asdctool/src/main/java/org/openecomp/sdc/asdctool/impl/validator/executers/TopologyTemplateValidatorExecuter.java

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