import java.util.Set;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
+
import org.junit.Before;
import org.junit.Test;
import org.onap.aai.schemaif.SchemaProviderException;
import org.onap.aai.schemaif.json.definitions.JsonSchema;
import org.onap.aai.schemaif.json.definitions.JsonVertexSchema;
-
public class JsonSchemaProviderTest {
JsonSchemaProviderConfig config = new JsonSchemaProviderConfig();
// Test Edge Schema
JsonEdgeSchema edgeSchema = null;
for (JsonEdgeSchema edge : jsonSchema.getRelationshipTypes()) {
- if ( (edge.getFrom().equals("onap.nodes.sdwan.uCPE"))
- && (edge.getTo().equals("onap.nodes.sdwan.service.SubscriberService")) ) {
+ if ((edge.getFrom().equals("onap.nodes.sdwan.uCPE"))
+ && (edge.getTo().equals("onap.nodes.sdwan.service.SubscriberService"))) {
edgeSchema = edge;
break;
}
// Test Node Schema
JsonVertexSchema vertexSchema = null;
for (JsonVertexSchema v : jsonSchema.getNodeTypes()) {
- if ( (v.getName().equals("org.onap.resource.NetworkRules")) ) {
+ if ((v.getName().equals("org.onap.resource.NetworkRules"))) {
vertexSchema = v;
break;
}
JsonPropertySchema propSchema = null;
for (JsonPropertySchema p : vertexSchema.getProperties()) {
- if ( (p.getName().equals("network_policy_entries")) ) {
+ if ((p.getName().equals("network_policy_entries"))) {
propSchema = p;
break;
}
// Test DataType Schema
DataTypeDefinition dataType = null;
for (DataTypeDefinition d : jsonSchema.getDataTypes()) {
- if ( (d.getName().equals("org.onap.datatypes.network.VlanRequirements")) ) {
+ if ((d.getName().equals("org.onap.datatypes.network.VlanRequirements"))) {
dataType = d;
break;
}
propSchema = null;
for (JsonPropertySchema p : dataType.getProperties()) {
- if ( (p.getName().equals("vlan_type")) ) {
+ if ((p.getName().equals("vlan_type"))) {
propSchema = p;
break;
}
assertEquals(false, propSchema.getRequired());
assertEquals("string", propSchema.getDataType());
assertEquals("", propSchema.getDefaultValue());
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- VertexSchema vertSchema =
- schemaProvider.getVertexSchema("tosca.nodes.objectstorage",
- schemaProvider.getLatestSchemaVersion());
+ VertexSchema vertSchema = schemaProvider.getVertexSchema("tosca.nodes.objectstorage",
+ schemaProvider.getLatestSchemaVersion());
System.out.println(vertSchema.toString());
// Validate vertex schema
assertFalse(propSchema.isRequired());
assertTrue(propSchema.isReserved());
assertEquals(0, propSchema.getDataType().getType().compareTo(Type.STRING));
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
EdgeSchema edgeSchema = schemaProvider.getEdgeSchema("tosca.relationships.hostedOn",
- "tosca.nodes.Softwarecomponent", "tosca.nodes.compute",
- schemaProvider.getLatestSchemaVersion());
+ "tosca.nodes.Softwarecomponent", "tosca.nodes.compute", schemaProvider.getLatestSchemaVersion());
System.out.println(edgeSchema.toString());
// Validate edge schema
assertEquals(edgeSchema.getMultiplicity(), EdgeSchema.Multiplicity.MANY_2_MANY);
assertEquals("NONE", edgeSchema.getAnnotationValue("contains-other-v"));
-
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- Set<EdgeSchema> edgeSchemaList =
- schemaProvider.getAdjacentEdgeSchema("tosca.nodes.Database",
- schemaProvider.getLatestSchemaVersion());
+ Set<EdgeSchema> edgeSchemaList = schemaProvider.getAdjacentEdgeSchema("tosca.nodes.Database",
+ schemaProvider.getLatestSchemaVersion());
// Validate edge schema
assertEquals(3, edgeSchemaList.size());
break;
}
}
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- Set<EdgeSchema> edgeSchemaList =
- schemaProvider.getEdgeSchemaForSourceTarget("tosca.nodes.LoadBalancer",
- "tosca.nodes.Database",
- schemaProvider.getLatestSchemaVersion());
+ Set<EdgeSchema> edgeSchemaList = schemaProvider.getEdgeSchemaForSourceTarget("tosca.nodes.LoadBalancer",
+ "tosca.nodes.Database", schemaProvider.getLatestSchemaVersion());
// Validate edge schema
assertEquals(2, edgeSchemaList.size());
assertEquals("tosca.nodes.LoadBalancer", es.getSource());
assertEquals("tosca.nodes.Database", es.getTarget());
assertEquals(es.getMultiplicity(), EdgeSchema.Multiplicity.MANY_2_MANY);
- }
- else if (es.getName().equals("tosca.relationships.RoutesTo")) {
+ } else if (es.getName().equals("tosca.relationships.RoutesTo")) {
assertEquals("tosca.nodes.LoadBalancer", es.getSource());
assertEquals("tosca.nodes.Database", es.getTarget());
assertEquals(es.getMultiplicity(), EdgeSchema.Multiplicity.MANY_2_MANY);
- }
- else {
+ } else {
fail();
}
}
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- EdgeSchema edgeSchema =
- schemaProvider.getEdgeSchema("amdocs.linkedTo", "service-instance",
- "onap.nodes.sdwan.ManagementDomain", schemaProvider.getLatestSchemaVersion());
+ EdgeSchema edgeSchema = schemaProvider.getEdgeSchema("amdocs.linkedTo", "service-instance",
+ "onap.nodes.sdwan.ManagementDomain", schemaProvider.getLatestSchemaVersion());
assertEquals("amdocs.linkedTo", edgeSchema.getName());
assertEquals("service-instance", edgeSchema.getSource());
assertNull(edgeSchema);
-
- edgeSchema =
- schemaProvider.getEdgeSchema("amdocs.unknownRelationship", "unknown",
- "onap.nodes.sdwan.ManagementDomain", schemaProvider.getLatestSchemaVersion());
+ edgeSchema = schemaProvider.getEdgeSchema("amdocs.unknownRelationship", "unknown",
+ "onap.nodes.sdwan.ManagementDomain", schemaProvider.getLatestSchemaVersion());
assertEquals("amdocs.unknownRelationship", edgeSchema.getName());
assertEquals("unknown", edgeSchema.getSource());
assertEquals("onap.nodes.sdwan.ManagementDomain", edgeSchema.getTarget());
- edgeSchema =
- schemaProvider.getEdgeSchema("amdocs.unknownRelationship", "onap.nodes.sdwan.ManagementDomain",
- "unknown", schemaProvider.getLatestSchemaVersion());
+ edgeSchema = schemaProvider.getEdgeSchema("amdocs.unknownRelationship", "onap.nodes.sdwan.ManagementDomain",
+ "unknown", schemaProvider.getLatestSchemaVersion());
assertEquals("amdocs.unknownRelationship", edgeSchema.getName());
assertEquals("onap.nodes.sdwan.ManagementDomain", edgeSchema.getSource());
assertEquals("unknown", edgeSchema.getTarget());
- Set<EdgeSchema> edgeSchemaList =
- schemaProvider.getEdgeSchemaForSourceTarget("service-instance",
- "onap.nodes.sdwan.ManagementDomain",
- schemaProvider.getLatestSchemaVersion());
+ Set<EdgeSchema> edgeSchemaList = schemaProvider.getEdgeSchemaForSourceTarget("service-instance",
+ "onap.nodes.sdwan.ManagementDomain", schemaProvider.getLatestSchemaVersion());
assertEquals(1, edgeSchemaList.size());
edgeSchemaList = schemaProvider.getEdgeSchemaForSourceTarget("unknown", "unknown",
schemaProvider.getLatestSchemaVersion());
assertEquals(1, edgeSchemaList.size());
-
- edgeSchemaList = schemaProvider.getAdjacentEdgeSchema("service-instance", schemaProvider.getLatestSchemaVersion());
+ edgeSchemaList =
+ schemaProvider.getAdjacentEdgeSchema("service-instance", schemaProvider.getLatestSchemaVersion());
System.out.println("EDGE LIST: \n\n" + edgeSchemaList);
assertEquals(8, edgeSchemaList.size());
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
"cloud-region", "bad-node", schemaProvider.getLatestSchemaVersion());
assertNull(edgeSchema);
- Set<EdgeSchema> edgeSchemaList =
- schemaProvider.getAdjacentEdgeSchema("org.onap.nodes.bad-node",
- schemaProvider.getLatestSchemaVersion());
+ Set<EdgeSchema> edgeSchemaList = schemaProvider.getAdjacentEdgeSchema("org.onap.nodes.bad-node",
+ schemaProvider.getLatestSchemaVersion());
assertTrue(edgeSchemaList.isEmpty());
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- VertexSchema vertSchema =
- schemaProvider.getVertexSchema("onap.nodes.sdwan.ManagementDomain",
- schemaProvider.getLatestSchemaVersion());
+ VertexSchema vertSchema = schemaProvider.getVertexSchema("onap.nodes.sdwan.ManagementDomain",
+ schemaProvider.getLatestSchemaVersion());
System.out.println(vertSchema.toString());
// Validate schema
PropertySchema propSchema = vertSchema.getPropertySchema("controllers");
assertEquals(0, propSchema.getDataType().getType().compareTo(Type.LIST));
- ListDataType listType = (ListDataType)propSchema.getDataType();
+ ListDataType listType = (ListDataType) propSchema.getDataType();
assertEquals(0, listType.getListType().getType().compareTo(Type.STRING));
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- VertexSchema vertSchema =
- schemaProvider.getVertexSchema("onap.nodes.sdwan.ManagementDomain",
- schemaProvider.getLatestSchemaVersion());
+ VertexSchema vertSchema = schemaProvider.getVertexSchema("onap.nodes.sdwan.ManagementDomain",
+ schemaProvider.getLatestSchemaVersion());
System.out.println(vertSchema.toString());
// Validate schema
PropertySchema propSchema = vertSchema.getPropertySchema("analyticClusters");
assertEquals(0, propSchema.getDataType().getType().compareTo(Type.MAP));
- MapDataType mapType = (MapDataType)propSchema.getDataType();
+ MapDataType mapType = (MapDataType) propSchema.getDataType();
assertEquals(0, mapType.getMapType().getType().compareTo(Type.STRING));
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
JsonSchemaProvider schemaProvider = new JsonSchemaProvider(config);
schemaProvider.loadSchema(testSchema, schemaProvider.getLatestSchemaVersion());
- VertexSchema vertSchema =
- schemaProvider.getVertexSchema("org.onap.resource.extContrailCP",
- schemaProvider.getLatestSchemaVersion());
+ VertexSchema vertSchema = schemaProvider.getVertexSchema("org.onap.resource.extContrailCP",
+ schemaProvider.getLatestSchemaVersion());
System.out.println(vertSchema.toString());
System.out.println("\n\nSize: " + vertSchema.getPropertySchemaList().size());
// Validate property schema
PropertySchema propSchema = vertSchema.getPropertySchema("exCP_naming");
assertEquals(0, propSchema.getDataType().getType().compareTo(Type.COMPLEX));
- ComplexDataType complexType = (ComplexDataType)propSchema.getDataType();
+ ComplexDataType complexType = (ComplexDataType) propSchema.getDataType();
List<PropertySchema> complexProps = complexType.getSubProperties();
assertEquals(4, complexProps.size());
assertNotNull(subProp);
assertFalse(subProp.isRequired());
assertEquals(0, subProp.getDataType().getType().compareTo(Type.STRING));
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
System.out.println(jsonSchema.toJson());
assertEquals(1, jsonSchema.getDataTypes().size());
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
String testSchema = readFile("src/test/resources/json/schemaServiceResponse.json");
SchemaServiceResponse schema = SchemaServiceResponse.fromJson(testSchema);
schema.getData().validate();
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
StringWriter writer = new StringWriter();
PrintWriter printWriter = new PrintWriter(writer);
ex.printStackTrace(printWriter);
try {
String testSchema = readFile("src/test/resources/json/badEdgeSchema.json");
schema = SchemaServiceResponse.fromJson(testSchema);
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
fail();
return;
}
try {
String testSchema = readFile("src/test/resources/json/badVertexSchema.json");
schema = SchemaServiceResponse.fromJson(testSchema);
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
fail();
return;
}
try {
String testSchema = readFile("src/test/resources/json/badTypeSchema.json");
schema = SchemaServiceResponse.fromJson(testSchema);
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
fail();
return;
}
try {
String testSchema = readFile("src/test/resources/json/badPropSchema.json");
schema = SchemaServiceResponse.fromJson(testSchema);
- }
- catch (Exception ex) {
+ } catch (Exception ex) {
fail();
return;
}