2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.asdctool.impl.validator.executers;
23 import fj.data.Either;
24 import org.openecomp.sdc.asdctool.impl.validator.tasks.TopologyTemplateValidationTask;
25 import org.openecomp.sdc.asdctool.impl.validator.utils.ReportManager;
26 import org.openecomp.sdc.asdctool.impl.validator.utils.VertexResult;
27 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
28 import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
29 import org.openecomp.sdc.be.dao.jsongraph.JanusGraphDao;
30 import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
31 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
32 import org.openecomp.sdc.be.datatypes.enums.GraphPropertyEnum;
33 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
34 import org.openecomp.sdc.common.log.wrappers.Logger;
35 import org.springframework.beans.factory.annotation.Autowired;
37 import java.util.ArrayList;
38 import java.util.EnumMap;
39 import java.util.HashSet;
40 import java.util.List;
45 * Created by chaya on 7/3/2017.
47 public class TopologyTemplateValidatorExecuter {
49 private static Logger log = Logger.getLogger(VfValidatorExecuter.class.getName());
51 protected JanusGraphDao janusGraphDao;
53 protected String name;
56 public TopologyTemplateValidatorExecuter(JanusGraphDao janusGraphDao) {
57 this.janusGraphDao = janusGraphDao;
60 public void setName(String name) {
64 public String getName() {
68 protected List<GraphVertex> getVerticesToValidate(ComponentTypeEnum type) {
69 Map<GraphPropertyEnum, Object> props = new EnumMap<>(GraphPropertyEnum.class);
70 props.put(GraphPropertyEnum.COMPONENT_TYPE, type.name());
71 if(type.equals(ComponentTypeEnum.RESOURCE)) {
72 props.put(GraphPropertyEnum.RESOURCE_TYPE, ResourceTypeEnum.VF);
75 Either<List<GraphVertex>, JanusGraphOperationStatus> results = janusGraphDao
76 .getByCriteria(VertexTypeEnum.TOPOLOGY_TEMPLATE, props);
77 if (results.isRight()) {
78 log.error("getVerticesToValidate failed "+ results.right().value());
79 return new ArrayList<>();
81 log.info("getVerticesToValidate: "+results.left().value().size()+" vertices to scan");
82 return results.left().value();
85 protected boolean validate(List<? extends TopologyTemplateValidationTask> tasks, List<GraphVertex> vertices) {
86 ReportManager.reportStartValidatorRun(getName(), vertices.size());
87 Set<String> failedTasks = new HashSet<>();
88 Set<String> successTasks = new HashSet<>();
89 boolean successAllVertices = true;
91 int verticesSize = vertices.size();
93 for (GraphVertex vertex: vertices) {
95 boolean successAllTasks = true;
96 for (TopologyTemplateValidationTask task: tasks) {
97 ReportManager.reportStartTaskRun(vertex, task.getTaskName());
98 VertexResult result = task.validate(vertex);
99 if (!result.getStatus()) {
100 failedTasks.add(task.getTaskName());
101 successAllVertices = false;
102 successAllTasks = false;
103 } else if (successAllTasks && vertexNum == verticesSize) {
104 successTasks.add(task.getTaskName());
106 ReportManager.printValidationTaskStatus(vertex, task.getTaskName(), result.getStatus());
107 ReportManager.reportTaskEnd(vertex.getUniqueId(), task.getTaskName(), result);
109 String componentScanStatus = successAllTasks? "success" : "failed";
110 log.info("Topology Template "+vertex.getUniqueId()+" Validation finished with "+componentScanStatus);
112 ReportManager.reportValidatorTypeSummary(getName(), failedTasks, successTasks);
113 return successAllVertices;