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