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