return true;
}
- private boolean isProblematicService( Service service, String serviceName) throws IOException {
+ private boolean isProblematicService( Service service, String serviceName) {
List<ComponentInstance> componentInstances = service.getComponentInstances();
} catch (Exception e) {
e.printStackTrace();
- GraphPropertiesDictionary[] values = GraphPropertiesDictionary.values();
-
Object property1 = vertex.value(GraphPropertiesDictionary.HEALTH_CHECK.getProperty());
System.out.println(property1);
@Autowired
protected List<IArtifactValidatorExecuter> validators;
- @Autowired
- protected ReportManager reportManager;
-
private boolean allValid = true;
-
public boolean validateAll() {
for (IArtifactValidatorExecuter validatorExec: validators) {
System.out.println("ValidatorExecuter "+validatorExec.getName()+" started");
@Autowired
protected List<ValidatorExecuter> validators;
- @Autowired
- protected ReportManager reportManager;
-
private boolean allValid = true;
-
public boolean validateAll() {
for (ValidatorExecuter validatorExec: validators) {
System.out.println("ValidatorExecuter "+validatorExec.getName()+" started");
@Autowired
protected TitanDao titanDao;
- @Autowired
- protected TopologyTemplateOperation topologyTemplateOperation;
-
protected String name;
public void setName(String name) {
@Autowired
ArtifactValidationUtils artifactValidationUtils;
- @Autowired
- protected TopologyTemplateOperation topologyTemplateOperation;
-
public VfArtifactValidationTask() {
this.name = "VF Artifact Validation Task";
}
public class ArtifactValidatorTool {
private static Logger log = LoggerFactory.getLogger(ValidationTool.class.getName());
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
String outputPath = args[0];
ValidationConfigManager.setOutputFullFilePath(outputPath);
private static Logger log = LoggerFactory.getLogger(DataSchemaMenu.class.getName());
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
String operation = args[0];
private static Logger log = LoggerFactory.getLogger(EsToCassandraDataMigrationMenu.class.getName());
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
if (args == null || args.length < 2) {
usageAndExit();
*/
public class RemoveUtils {
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
if (args == null || args.length < 1) {
removeUsage();
"Usage: updateIsVnfTrue <titan.properties> <systemServiceName1,systemServiceName2,...,systemServiceNameN>");
}
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
if (args == null || args.length < 1) {
usageAndExit();
private static Logger log = LoggerFactory.getLogger(ValidationTool.class.getName());
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
String outputPath = args[0];
ValidationConfigManager.setOutputFullFilePath(outputPath);
return titanDao.getByCriteria(vertexType, propertiesToMatch, propertiesNotToMatch, JsonParseFlagEnum.ParseMetadata);
}
- protected Either<List<String>, TitanOperationStatus> findResourcesPathRecursively(GraphVertex nodeTypeV, List<String> allCertifiedUids) {
- Either<List<GraphVertex>, TitanOperationStatus> parentResourceRes = titanDao.getParentVertecies(nodeTypeV, EdgeLabelEnum.DERIVED_FROM, JsonParseFlagEnum.ParseMetadata);
- if (parentResourceRes.isRight()) {
- return Either.right(parentResourceRes.right().value());
- }
- List<GraphVertex> derivedResourcesUid = new ArrayList<>();
- for (GraphVertex chV : parentResourceRes.left().value()) {
- Optional<String> op = allCertifiedUids.stream().filter(id -> id.equals((String) chV.getJsonMetadataField(JsonPresentationFields.UNIQUE_ID))).findAny();
- if (op.isPresent()) {
- derivedResourcesUid.add(chV);
- }
- }
- return null;
- }
-
private Either<List<GraphVertex>, StorageOperationStatus> getLatestByName(GraphPropertyEnum property, String nodeName) {
Map<GraphPropertyEnum, Object> propertiesToMatch = new EnumMap<>(GraphPropertyEnum.class);
// graph.commit();
graph.tx().commit();
- String exportedGraph = out.toString();
-
result = outputFile;
} catch (Exception e) {
@Test
- public void testGetOutputFilePath() throws Exception {
+ public void testGetOutputFilePath() {
String result;
// default test
}
@Test
- public void testGetCsvReportFilePath() throws Exception {
+ public void testGetCsvReportFilePath() {
String result;
// default test
@Test
- public void testSetCsvReportFilePath() throws Exception {
+ public void testSetCsvReportFilePath() {
String outputPath = "";
// default test
@Test
- public void testSetValidationConfiguration() throws Exception {
+ public void testSetValidationConfiguration() {
String path = "";
Properties result;
@Test
- public void testGetValidationConfiguration() throws Exception {
+ public void testGetValidationConfiguration() {
Properties result;
// default test
@Test
- public void testBasicServiceValidator() throws Exception {
+ public void testBasicServiceValidator() {
ValidationToolConfiguration testSubject;
ServiceValidatorExecuter result;
@Test
- public void testVfArtifactValidationTask() throws Exception {
+ public void testVfArtifactValidationTask() {
ValidationToolConfiguration testSubject;
VfArtifactValidationTask result;
@Test
- public void testServiceArtifactValidationTask() throws Exception {
+ public void testServiceArtifactValidationTask() {
ValidationToolConfiguration testSubject;
ServiceArtifactValidationTask result;
@Test
- public void testModuleJsonTask() throws Exception {
+ public void testModuleJsonTask() {
ValidationToolConfiguration testSubject;
ModuleJsonTask result;
@Test
- public void testValidationToolBL() throws Exception {
+ public void testValidationToolBL() {
ValidationToolConfiguration testSubject;
ValidationToolBL result;
@Test
- public void testBasicVfValidator() throws Exception {
+ public void testBasicVfValidator() {
ValidationToolConfiguration testSubject;
VfValidatorExecuter result;
}
@Test
- public void testArtifactCassandraDao() throws Exception {
+ public void testArtifactCassandraDao() {
ValidationToolConfiguration testSubject;
ArtifactCassandraDao result;
@Test
- public void testArtifactValidationUtils() throws Exception {
+ public void testArtifactValidationUtils() {
ValidationToolConfiguration testSubject;
ArtifactValidationUtils result;
@Test
- public void testJsonGroupsOperation() throws Exception {
+ public void testJsonGroupsOperation() {
ValidationToolConfiguration testSubject;
GroupsOperation result;
@Test
- public void testCassandraClient() throws Exception {
+ public void testCassandraClient() {
ValidationToolConfiguration testSubject;
CassandraClient result;
@Test
- public void testDaoStrategy() throws Exception {
+ public void testDaoStrategy() {
ValidationToolConfiguration testSubject;
TitanClientStrategy result;
@Test
- public void testToscaOperationFacade() throws Exception {
+ public void testToscaOperationFacade() {
ValidationToolConfiguration testSubject;
ToscaOperationFacade result;
@Test
- public void testNodeTypeOperation() throws Exception {
+ public void testNodeTypeOperation() {
ValidationToolConfiguration testSubject;
DerivedNodeTypeResolver migrationDerivedNodeTypeResolver = null;
NodeTypeOperation result;
@Test
- public void testTopologyTemplateOperation() throws Exception {
+ public void testTopologyTemplateOperation() {
ValidationToolConfiguration testSubject;
TopologyTemplateOperation result;
@Test
- public void testMigrationDerivedNodeTypeResolver() throws Exception {
+ public void testMigrationDerivedNodeTypeResolver() {
ValidationToolConfiguration testSubject;
DerivedNodeTypeResolver result;
@Test
- public void testTitanDao() throws Exception {
+ public void testTitanDao() {
ValidationToolConfiguration testSubject;
TitanGraphClient titanGraphClient = null;
TitanDao result;
@Test
- public void testCategoryOperation() throws Exception {
+ public void testCategoryOperation() {
ValidationToolConfiguration testSubject;
CategoryOperation result;
@Test
- public void testArtifactsOperation() throws Exception {
+ public void testArtifactsOperation() {
ValidationToolConfiguration testSubject;
ArtifactsOperations result;
@Test
- public void testToscaDataOperation() throws Exception {
+ public void testToscaDataOperation() {
ValidationToolConfiguration testSubject;
ToscaDataOperation result;
@Test
- public void testToscaElementLifecycleOperation() throws Exception {
+ public void testToscaElementLifecycleOperation() {
ValidationToolConfiguration testSubject;
ToscaElementLifecycleOperation result;
@Test
- public void testGetName() throws Exception {
+ public void testGetName() {
ServiceValidatorExecuter testSubject;
String result;
@Test
- public void testSetName() throws Exception {
+ public void testSetName() {
TopologyTemplateValidatorExecuter testSubject;
String name = "";
@Test
- public void testGetName() throws Exception {
+ public void testGetName() {
TopologyTemplateValidatorExecuter testSubject;
String result;
@Test
- public void testGetName() throws Exception {
+ public void testGetName() {
VfValidatorExecuter testSubject;
String result;
@Test
- public void testAddNotFoundArtifact() throws Exception {
+ public void testAddNotFoundArtifact() {
ArtifactsVertexResult testSubject;
String artifactId = "";
@Test
- public void testGetResult() throws Exception {
+ public void testGetResult() {
ArtifactsVertexResult testSubject;
String result;
@Test
- public void testGetByType() throws Exception {
+ public void testGetByType() {
String elementType = "";
ElementTypeEnum result;
@Test
- public void testGetAllTypes() throws Exception {
+ public void testGetAllTypes() {
List<String> result;
// default test
@Test
- public void testGetElementType() throws Exception {
+ public void testGetElementType() {
ElementTypeEnum testSubject;
String result;
@Test
- public void testSetElementType() throws Exception {
+ public void testSetElementType() {
ElementTypeEnum testSubject;
String elementType = "";
@Test
- public void testGetClazz() throws Exception {
+ public void testGetClazz() {
ElementTypeEnum testSubject;
Class result;
@Test
- public void testSetClazz() throws Exception {
+ public void testSetClazz() {
ElementTypeEnum testSubject;
Class clazz = null;
@Test
- public void testGetName() throws Exception {
+ public void testGetName() {
ValidationTaskResult testSubject;
String result;
@Test
- public void testSetName() throws Exception {
+ public void testSetName() {
ValidationTaskResult testSubject;
String name = "";
@Test
- public void testGetResultMessage() throws Exception {
+ public void testGetResultMessage() {
ValidationTaskResult testSubject;
String result;
@Test
- public void testSetResultMessage() throws Exception {
+ public void testSetResultMessage() {
ValidationTaskResult testSubject;
String resultMessage = "";
@Test
- public void testIsSuccessful() throws Exception {
+ public void testIsSuccessful() {
ValidationTaskResult testSubject;
boolean result;
@Test
- public void testSetSuccessful() throws Exception {
+ public void testSetSuccessful() {
ValidationTaskResult testSubject;
boolean successful = false;
@Test
- public void testGetStatus() throws Exception {
+ public void testGetStatus() {
VertexResult testSubject;
boolean result;
@Test
- public void testSetStatus() throws Exception {
+ public void testSetStatus() {
VertexResult testSubject;
boolean status = false;
@Test
- public void testGetResult() throws Exception {
+ public void testGetResult() {
VertexResult testSubject;
String result;
}
@Test(dataProvider = "versionComparisionProvider")
- public void testVersionCompareTo2(String firstVersion, String otherVersion, int expectedComparisionResult) throws Exception {
+ public void testVersionCompareTo2(String firstVersion, String otherVersion, int expectedComparisionResult) {
assertEquals(DBVersion.fromString(firstVersion).compareTo(DBVersion.fromString(otherVersion)), expectedComparisionResult);
}
}
private SdcRepoService sdcRepoServiceMock;
@BeforeMethod
- public void setUp() throws Exception {
+ public void setUp() {
MockitoAnnotations.initMocks(this);
}
@Test
- public void testMigrate_noMigrations() throws Exception {
+ public void testMigrate_noMigrations() {
when(migrationResolverMock.resolveMigrations()).thenReturn(Collections.emptyList());
testInstance.migrate(false);
verify(sdcRepoServiceMock, new Times(0)).clearTasksForCurrentMajor();
}
@Test
- public void testMigrate_enforceFlag_removeAllMigrationTasksForCurrentVersion() throws Exception {
+ public void testMigrate_enforceFlag_removeAllMigrationTasksForCurrentVersion() {
when(migrationResolverMock.resolveMigrations()).thenReturn(Collections.emptyList());
testInstance.migrate(true);
verify(sdcRepoServiceMock, new Times(1)).clearTasksForCurrentMajor();
}
@Test
- public void testMigrate_stopAfterFirstFailure() throws Exception {
+ public void testMigrate_stopAfterFirstFailure() {
when(migrationResolverMock.resolveMigrations()).thenReturn(Arrays.asList(new SuccessfulMigration(), new FailedMigration(), new SuccessfulMigration()));
testInstance.migrate(false);
verify(sdcRepoServiceMock, new Times(0)).clearTasksForCurrentMajor();
public class MigrationExecutorImplTest {
@Test
- public void testExecuteMigration() throws Exception {
+ public void testExecuteMigration() {
MigrationExecutionResult execute = new MigrationExecutorImpl().execute(DummyMigrationFactory.SUCCESSFUL_MIGRATION);
assertMigrationTaskEntryByMigrationExecutionResult(execute, DummyMigrationFactory.SUCCESSFUL_MIGRATION);
}
@Test
- public void testGetMsg() throws Exception {
+ public void testGetMsg() {
MigrationResult testSubject;
String result;
@Test
- public void testSetMsg() throws Exception {
+ public void testSetMsg() {
MigrationResult testSubject;
String msg = "";
@Test
- public void testGetMigrationStatus() throws Exception {
+ public void testGetMigrationStatus() {
MigrationResult testSubject;
MigrationStatus result;
@Test
- public void testSetMigrationStatus() throws Exception {
+ public void testSetMigrationStatus() {
MigrationResult testSubject;
MigrationStatus migrationStatus = null;
@BeforeMethod
- public void setUp() throws Exception {
+ public void setUp() {
MockitoAnnotations.initMocks(this);
testInstance.setMigrations(migrations);
}
@Test
- public void testResolveMigrations_getMigrationsWithVersionGreaterThanLatest() throws Exception {
+ public void testResolveMigrations_getMigrationsWithVersionGreaterThanLatest() {
when(sdcRepoServiceMock.getLatestDBVersion()).thenReturn(DBVersion.fromString("1710.2"));
testInstance.setPostMigrations(Collections.emptyList());
List<IMigrationStage> resolvedMigrations = testInstance.resolveMigrations();
}
@Test
- public void testResolveMigration_noLatestVersionForCurrentMajorVersion() throws Exception {
+ public void testResolveMigration_noLatestVersionForCurrentMajorVersion() {
when(sdcRepoServiceMock.getLatestDBVersion()).thenReturn(DBVersion.fromString("1710.-1"));
testInstance.setPostMigrations(Collections.emptyList());
List<IMigrationStage> resolvedMigrations = testInstance.resolveMigrations();
}
@Test
- public void testResolveMigrations_emptyMigrationsList() throws Exception {
+ public void testResolveMigrations_emptyMigrationsList() {
testInstance.setMigrations(Collections.emptyList());
testInstance.setPostMigrations(Collections.emptyList());
when(sdcRepoServiceMock.getLatestDBVersion()).thenReturn(DBVersion.fromString("1710.-1"));
private MigrationTasksDao migrationTasksDaoMock;
@BeforeMethod
- public void setUp() throws Exception {
+ public void setUp() {
MockitoAnnotations.initMocks(this);
}
@Test
- public void testGetLatestVersion_noMinorVersionForCurrentVersion() throws Exception {
+ public void testGetLatestVersion_noMinorVersionForCurrentVersion() {
when(migrationTasksDaoMock.getLatestMinorVersion(DBVersion.CURRENT_VERSION.getMajor())).thenReturn(null);
DBVersion latestDBVersion = testInstance.getLatestDBVersion();
assertEquals(latestDBVersion.getMajor(), DBVersion.CURRENT_VERSION.getMajor());
}
@Test
- public void testGetLatestVersion() throws Exception {
+ public void testGetLatestVersion() {
when(migrationTasksDaoMock.getLatestMinorVersion(DBVersion.CURRENT_VERSION.getMajor())).thenReturn(BigInteger.TEN);
DBVersion latestDBVersion = testInstance.getLatestDBVersion();
assertEquals(latestDBVersion.getMajor(), DBVersion.CURRENT_VERSION.getMajor());
}
@Test
- public void testCreateMigrationTask() throws Exception {
+ public void testCreateMigrationTask() {
MigrationTaskEntry taskEntry = new MigrationTaskEntry();
testInstance.createMigrationTask(taskEntry);
verify(migrationTasksDaoMock, new Times(1)).createMigrationTask(taskEntry);
private List<Migration> migrations;
@BeforeMethod
- public void setUp() throws Exception {
+ public void setUp() {
ClassScanner classScanner = new ClassScanner();
migrations = classScanner.getAllClassesOfType(MIGRATIONS_BASE_PACKAGE, Migration.class);
}
@Test
- public void testNoTasksWithSameVersion() throws Exception {
+ public void testNoTasksWithSameVersion() {
Map<DBVersion, List<Migration>> migrationsByVersion = migrations.stream().collect(Collectors.groupingBy(Migration::getVersion));
migrationsByVersion.forEach((version, migrations) -> {
if (migrations.size() > 1) {
}
@Test
- public void testNoTaskWithVersionGreaterThanCurrentVersion() throws Exception {
+ public void testNoTaskWithVersionGreaterThanCurrentVersion() {
Set<Migration> migrationsWithVersionsGreaterThanCurrent = migrations.stream().filter(mig -> mig.getVersion().compareTo(DBVersion.CURRENT_VERSION) > 0)
.collect(Collectors.toSet());
@Test
- public void testTest() throws Exception {
+ public void testTest() {
EntryPoint testSubject;
String result;
&& ComponentTypeEnum.SERVICE == componentTypeEnum;
}
- private StorageOperationStatus concatServiceNameToVLINetworkRolePropertyValue(ToscaOperationFacade toscaOperationFacade, ComponentTypeEnum componentTypeEnum, String componentId, String resourceInstanceId, ComponentInstanceProperty property) {
- return concatServiceNameToVLINetworkRolePropertiesValues(toscaOperationFacade, componentTypeEnum, componentId, resourceInstanceId, Arrays.asList(property));
- }
-
// US833308 VLI in service - specific network_role property value logic
private StorageOperationStatus concatServiceNameToVLINetworkRolePropertiesValues(ToscaOperationFacade toscaOperationFacade, ComponentTypeEnum componentTypeEnum, String componentId, String resourceInstanceId, List<ComponentInstanceProperty> properties) {
for (ComponentInstanceProperty property: properties) {
component.getComponentType().toString());
}
- private Boolean onFailedToLockComponent(ResponseFormat responseFormat) {
- throw new ComponentException(responseFormat);
- }
-
-
public Either<List<GroupDefinition>, ResponseFormat> createGroups(Component component, final List<GroupDefinition> groupDefinitions) {
Map<String, GroupDataDefinition> groups = new HashMap<>();
}
}
- private void auditCreateResource(User user, Resource persistedResource, AuditingActionEnum actionEnum) {
- ResponseFormat responseFormat = componentsUtils.getResponseFormat(ActionStatus.CREATED);
- componentsUtils.auditResource(responseFormat, user, persistedResource, actionEnum);
- }
-
private Either<Resource, ResponseFormat> createResourceTransaction(Resource resource, User user,
boolean isNormative, boolean inTransaction) {
// validate resource name uniqueness
return Either.left(eitherResourceResponse.left().value());
}
- private Either<Boolean, ResponseFormat> validateHighestVersion(User modifier, LifeCycleTransition lifeCycleTransition, Resource resource, String resourceCurrVersion) {
- ResponseFormat errorResponse;
- if (!resource.isHighestVersion()) {
- log.debug("resource version {} is not the last version of resource {}", resource.getVersion(), resource.getName());
- errorResponse = componentUtils.getResponseFormat(ActionStatus.COMPONENT_HAS_NEWER_VERSION, resource.getName(), ComponentTypeEnum.RESOURCE.name().toLowerCase());
- componentUtils.auditResource(errorResponse, modifier, resource, lifeCycleTransition.getAuditingAction(), ResourceAuditData.newBuilder()
- .state(resource.getLifecycleState().name()).version(resourceCurrVersion).build());
- return Either.right(errorResponse);
- }
- return Either.left(true);
- }
-
private Either<Boolean, ResponseFormat> validateHighestVersion(User modifier, LifeCycleTransition lifeCycleTransition, Component component, String resourceCurrVersion, ComponentTypeEnum componentType) {
ResponseFormat errorResponse;
if (!component.isHighestVersion()) {
log.info("lock resource with id {}", componentId);
TitanOperationStatus lockElementStatus = null;
try {
-
lockElementStatus = titanGenericDao.lockElement(componentId, nodeType);
-
} catch (Exception e) {
lockElementStatus = TitanOperationStatus.ALREADY_LOCKED;
}
-
/**
* update value of attribute on resource instance
*
}
}
- private Either<GroupInstance, TitanOperationStatus> getGroupInstanceFromGraph(String uniqueId, boolean skipProperties, boolean skipArtifacts) {
-
- Either<GroupInstance, TitanOperationStatus> result = null;
-
- Either<GroupInstanceData, TitanOperationStatus> groupInstRes = titanGenericDao.getNode(UniqueIdBuilder.getKeyByNodeType(NodeTypeEnum.GroupInstance), uniqueId, GroupInstanceData.class);
- if (groupInstRes.isRight()) {
- TitanOperationStatus status = groupInstRes.right().value();
- log.debug("Failed to retrieve group {} from graph. Status is {}", uniqueId, status);
- BeEcompErrorManager.getInstance().logBeFailedRetrieveNodeError("Fetch Group", uniqueId, String.valueOf(status));
- result = Either.right(status);
- return result;
- }
-
- GroupInstanceData groupInstData = groupInstRes.left().value();
-
- GroupInstance groupInstance = new GroupInstance(groupInstData.getGroupDataDefinition());
- String instOriginGroupId = groupInstance.getGroupUid();
- Either<GroupDefinition, TitanOperationStatus> groupRes = groupOperation.getGroupFromGraph(instOriginGroupId, false, true, false);
-
- if (groupRes.isRight()) {
- TitanOperationStatus status = groupRes.right().value();
- result = Either.right(status);
-
- }
- GroupDefinition groupDefinition = groupRes.left().value();
- Either<Map<String, PropertyValueData>, TitanOperationStatus> groupInstancePropertyValuesRes = getAllGroupInstancePropertyValuesData(groupInstData);
- if(groupInstancePropertyValuesRes.isRight()){
- result = Either.right(groupInstancePropertyValuesRes.right().value());
- }
- buildGroupInstanceFromGroup(groupInstance, groupDefinition, groupInstancePropertyValuesRes.left().value());
-
- /*
- * if (false == skipProperties) { Either<List<GroupProperty>, TitanOperationStatus> propertiesRes = getGroupProperties(uniqueId); if (propertiesRes.isRight()) { TitanOperationStatus status = propertiesRes.right().value(); if (status !=
- * TitanOperationStatus.OK) { result = Either.right(status); return result; } } else { List<GroupProperty> properties = propertiesRes.left().value(); groupDefinition.setProperties(properties); } }
- */
-
- if (false == skipArtifacts) {
- Either<List<ImmutablePair<String, String>>, TitanOperationStatus> artifactsRes = getGroupArtifactsPairs(uniqueId);
- if (artifactsRes.isRight()) {
- TitanOperationStatus status = artifactsRes.right().value();
- if (status != TitanOperationStatus.OK) {
- result = Either.right(status);
- return result;
- }
- } else {
- List<String> artifactsUid = new ArrayList<>();
- List<String> artifactsUUID = new ArrayList<>();
-
- List<ImmutablePair<String, String>> list = artifactsRes.left().value();
- if (list != null) {
- for (ImmutablePair<String, String> pair : list) {
- String uid = pair.left;
- String UUID = pair.right;
- artifactsUid.add(uid);
- artifactsUUID.add(UUID);
- }
- groupInstance.setGroupInstanceArtifacts(artifactsUid);
- groupInstance.setGroupInstanceArtifactsUuid(artifactsUUID);
- }
- }
- }
- result = Either.left(groupInstance);
-
- return result;
-
- }
-
private void buildGroupInstanceFromGroup(GroupInstance groupInstance, GroupDefinition groupDefinition, Map<String, PropertyValueData> groupInstancePropertyValues) {
groupInstance.setGroupName(groupDefinition.getName());
}
- private Either<Map<String, DataTypeDefinition>, TitanOperationStatus> findAllDataTypeDefinition(DataTypeDefinition dataTypeDefinition) {
-
- Map<String, DataTypeDefinition> nameToDataTypeDef = new HashMap<>();
-
- DataTypeDefinition typeDefinition = dataTypeDefinition;
-
- while (typeDefinition != null) {
-
- List<PropertyDefinition> properties = typeDefinition.getProperties();
- if (properties != null) {
- for (PropertyDefinition propertyDefinition : properties) {
- String type = propertyDefinition.getType();
- Either<DataTypeDefinition, TitanOperationStatus> dataTypeByName = this.getDataTypeUsingName(type);
- if (dataTypeByName.isRight()) {
- return Either.right(dataTypeByName.right().value());
- } else {
- DataTypeDefinition value = dataTypeByName.left().value();
- if (false == nameToDataTypeDef.containsKey(type)) {
- nameToDataTypeDef.put(type, value);
- }
- }
-
- }
- }
-
- typeDefinition = typeDefinition.getDerivedFrom();
- }
-
- return Either.left(nameToDataTypeDef);
- }
-
public Either<List<ComponentInstanceProperty>, TitanOperationStatus> getAllPropertiesOfResourceInstanceOnlyPropertyDefId(String resourceInstanceUid, NodeTypeEnum instanceNodeType) {
Either<TitanVertex, TitanOperationStatus> findResInstanceRes = titanGenericDao.getVertexByProperty(UniqueIdBuilder.getKeyByNodeType(instanceNodeType), resourceInstanceUid);
return componentName + GeneratorConstants.TOSCA_SERVICE_TEMPLATE_FILE_NAME_SUFFIX;
}
- private String getNodeTemplateId(String componentName, String idPrefix, String idSuffix) {
- StringBuilder builder = new StringBuilder();
- //builder.append(idPrefix);
- builder.append(componentName);
- builder.append(idSuffix);
- return builder.toString();
- }
-
private ServiceTemplate createInitMainServiceTemplate(String releaseVendor) {
ServiceTemplate mainServiceTemplate = new ServiceTemplate();
Map<String, String> templateMetadata = new HashMap<>();
//*************** CREATE GLOBAL SUBSTITUTION SERVICE TEMPLATE **********************
- private ServiceTemplate createGlobalSubstitutionServiceTemplate(ServiceTemplate
- substitutionServiceTemplate,
- String componentName) {
- ServiceTemplate globalSubstitutionServiceTemplate = fetchGlobalSubstitutionServiceTemplate();
- NodeType substitutionNodeType =
- createGlobalSubstitutionNodeType(substitutionServiceTemplate, componentName);
- String substitutionNodeTypeId = getSubstitutionNodeTypeId(componentName);
- DataModelUtil.addNodeType(globalSubstitutionServiceTemplate, substitutionNodeTypeId,
- substitutionNodeType);
- return globalSubstitutionServiceTemplate;
- }
-
private ServiceTemplate createInitGlobalSubstitutionServiceTemplate() {
ServiceTemplate globalSubstitutionServiceTemplate = new ServiceTemplate();
Map<String, String> templateMetadata = new HashMap<>();
return CommonMethods.arrayToSeparatedString(versionLevels, '.');
}
-
- // version calculator when there are no version restrictions
- /* @Override
- public String calculate(String baseVersion, VersionCreationMethod creationMethod) {
-
- return calculate(baseVersion,creationMethod,2);
- }
-
- private String calculate(String baseVersion, VersionCreationMethod creationMethod,int
- maxVersionLevels) {
- if (baseVersion == null) {
- return INITIAL_VERSION;
- }
-
- String[] versionLevels = baseVersion.split("\\.");
- if (versionLevels.length > maxVersionLevels) {
- throw new IllegalArgumentException(VERSION_STRING_VIOLATION_MSG);
- }
-
- int index;
- int versionLevel = calcVersionLevel(versionLevels);
- if (versionLevel == -1) {
- throw new IllegalArgumentException(
- VERSION_STRING_VIOLATION_MSG + " given version:" + baseVersion);
- }
- int requiredVersionLevelIncrease;
- switch (creationMethod) {
- case parent_level:
- if (versionLevel == 0) {
- throw new IllegalArgumentException(
- PARENT_LEVEL_VERSION_CANNOT_BE_CREATED_FROM_TOP_LEVEL + " version:" + baseVersion);
-
- }
- requiredVersionLevelIncrease = versionLevel - 1;
- versionLevels[versionLevel] = "0";
- index = Integer.getInteger(versionLevels[requiredVersionLevelIncrease]);
- index++;
- versionLevels[requiredVersionLevelIncrease] = Integer.toString(index);
- break;
- case same_level:
- requiredVersionLevelIncrease = versionLevel;
- index = Integer.valueOf(versionLevels[requiredVersionLevelIncrease]);
- index++;
- versionLevels[requiredVersionLevelIncrease] = Integer.toString(index);
- break;
- case sub_level:
- if (versionLevel == versionLevels.length - 1) {
- throw new IllegalArgumentException(
- SUB_LEVEL_VERSION_CANNOT_BE_CREATED_FROM_LOWEST_LEVEL + " version:" + baseVersion);
- }
- requiredVersionLevelIncrease = versionLevel + 1;
- if(requiredVersionLevelIncrease>maxVersionLevels){
- throw new IllegalArgumentException(INVALID_CREATION_METHOD_MSG+" max " +
- "levels:"+maxVersionLevels + "requested level:"+requiredVersionLevelIncrease);
- }
- String newVersion = baseVersion + ".1";
- versionLevels = newVersion.split("\\.");
-
- break;
- default:
- throw new IllegalArgumentException(VERSION_CALCULATION_ERROR_MSG + " base " +
- "version:" + baseVersion + " creation method:" + creationMethod);
-
- }
-
- return CommonMethods.arrayToSeparatedString(versionLevels, '.');
- }*/
-
-
@Override
public void injectAdditionalInfo(Version version, Set<String> existingVersions) {
String optionalVersion;
}
-
- private int calcVersionLevel(String[] versionLevels) {
- for (int i = versionLevels.length - 1; i >= 0; i--) {
- if (!versionLevels[i].equals("0")) {
- return i;
- }
- }
- return -1;
- }
}
Code Review / sdc.git / commitdiff