1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
package org.openecomp.sdc.asdctool.impl.validator.tasks.artifacts;
import fj.data.Either;
import org.openecomp.sdc.asdctool.impl.validator.utils.ReportManager;
import org.openecomp.sdc.be.dao.cassandra.ArtifactCassandraDao;
import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus;
import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
import org.openecomp.sdc.be.datatypes.elements.ArtifactDataDefinition;
import org.openecomp.sdc.be.datatypes.elements.MapArtifactDataDefinition;
import org.openecomp.sdc.be.model.ComponentParametersView;
import org.openecomp.sdc.be.model.jsontitan.datamodel.TopologyTemplate;
import org.openecomp.sdc.be.model.jsontitan.datamodel.ToscaElement;
import org.openecomp.sdc.be.model.jsontitan.operations.TopologyTemplateOperation;
import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.*;
/**
* Created by chaya on 7/6/2017.
*/
public class ArtifactValidationUtils {
@Autowired
private ArtifactCassandraDao artifactCassandraDao;
@Autowired
private TopologyTemplateOperation topologyTemplateOperation;
public ArtifactsVertexResult validateArtifactsAreInCassandra(GraphVertex vertex, String taskName, List<ArtifactDataDefinition> artifacts) {
ArtifactsVertexResult result = new ArtifactsVertexResult(true);
for(ArtifactDataDefinition artifact:artifacts) {
boolean isArtifactExist = isArtifcatInCassandra(artifact.getEsId());
String status = isArtifactExist ? "Artifact " + artifact.getEsId() + " is in Cassandra" :
"Artifact " + artifact.getEsId() + " doesn't exist in Cassandra";
ReportManager.writeReportLineToFile(status);
if (!isArtifactExist) {
ReportManager.addFailedVertex(taskName, vertex.getUniqueId());
result.setStatus(false);
result.addNotFoundArtifact(artifact.getUniqueId());
}
}
return result;
}
public boolean isArtifcatInCassandra(String uniueId) {
Either<Long, CassandraOperationStatus> countOfArtifactsEither =
artifactCassandraDao.getCountOfArtifactById(uniueId);
if (countOfArtifactsEither.isRight()) {
// print to console
System.out.print("Failed to retrieve artifact with id: "+uniueId+" from Cassandra" );
return false;
}
Long count = countOfArtifactsEither.left().value();
if (count <1) {
return false;
}
return true;
}
public List<ArtifactDataDefinition> addRelevantArtifacts(Map<String, ArtifactDataDefinition> artifactsMap) {
List<ArtifactDataDefinition> artifacts = new ArrayList<>();
Optional.ofNullable(artifactsMap).orElse(Collections.emptyMap()).forEach( (key, dataDef) -> {
if (dataDef.getEsId() != null && !dataDef.getEsId().isEmpty()) {
artifacts.add(dataDef);
}
});
return artifacts;
}
public ArtifactsVertexResult validateTopologyTemplateArtifacts(GraphVertex vertex, String taskName) {
ArtifactsVertexResult result = new ArtifactsVertexResult();
ComponentParametersView paramView = new ComponentParametersView();
paramView.disableAll();
paramView.setIgnoreArtifacts(false);
paramView.setIgnoreComponentInstances(false);
Either<ToscaElement, StorageOperationStatus> toscaElementEither = topologyTemplateOperation.getToscaElement(vertex.getUniqueId(), paramView);
if (toscaElementEither.isRight()) {
result.setStatus(false);
return result;
}
TopologyTemplate element = (TopologyTemplate) toscaElementEither.left().value();
Map<String, ArtifactDataDefinition> deploymentArtifacts = element.getDeploymentArtifacts();
Map<String, ArtifactDataDefinition> artifacts = element.getArtifacts();
Map<String, ArtifactDataDefinition> apiArtifacts = element.getServiceApiArtifacts();
Map<String, MapArtifactDataDefinition> instanceArtifacts = element.getInstanceArtifacts();
Map<String, MapArtifactDataDefinition> instanceDeploymentArtifacts = element.getInstDeploymentArtifacts();
List<ArtifactDataDefinition> allArtifacts = new ArrayList<>();
allArtifacts.addAll(addRelevantArtifacts(deploymentArtifacts));
allArtifacts.addAll(addRelevantArtifacts(artifacts));
allArtifacts.addAll(addRelevantArtifacts(apiArtifacts));
if (instanceArtifacts != null) {
instanceArtifacts.forEach((key, artifactMap) -> {
allArtifacts.addAll(addRelevantArtifacts(artifactMap.getMapToscaDataDefinition()));
});
}
if (instanceDeploymentArtifacts != null) {
instanceDeploymentArtifacts.forEach((key, artifactMap) -> {
allArtifacts.addAll(addRelevantArtifacts(artifactMap.getMapToscaDataDefinition()));
});
}
return validateArtifactsAreInCassandra(vertex, taskName, allArtifacts);
}
}
|
