summaryrefslogtreecommitdiffstats
path: root/plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src')
-rw-r--r--plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src/test/java/org/onap/policy/apex/plugins/context/schema/avro/AvroSchemaUnionTest.java154
1 files changed, 0 insertions, 154 deletions
diff --git a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src/test/java/org/onap/policy/apex/plugins/context/schema/avro/AvroSchemaUnionTest.java b/plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src/test/java/org/onap/policy/apex/plugins/context/schema/avro/AvroSchemaUnionTest.java
deleted file mode 100644
index 47b1593fa..000000000
--- a/plugins/plugins-context/plugins-context-schema/plugins-context-schema-avro/src/test/java/org/onap/policy/apex/plugins/context/schema/avro/AvroSchemaUnionTest.java
+++ /dev/null
@@ -1,154 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 Nordix Foundation.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * SPDX-License-Identifier: Apache-2.0
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.policy.apex.plugins.context.schema.avro;
-
-import static org.junit.Assert.assertEquals;
-
-import java.io.IOException;
-
-import org.apache.avro.generic.GenericRecord;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.onap.policy.apex.context.SchemaHelper;
-import org.onap.policy.apex.context.impl.schema.SchemaHelperFactory;
-import org.onap.policy.apex.context.parameters.ContextParameterConstants;
-import org.onap.policy.apex.context.parameters.SchemaParameters;
-import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
-import org.onap.policy.apex.model.basicmodel.concepts.AxKey;
-import org.onap.policy.apex.model.basicmodel.service.ModelService;
-import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
-import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchemas;
-import org.onap.policy.common.parameters.ParameterService;
-import org.onap.policy.common.utils.resources.TextFileUtils;
-
-/**
- * The Class TestAvroSchemaUnion.
- *
- * @author Liam Fallon (liam.fallon@ericsson.com)
- * @version
- */
-public class AvroSchemaUnionTest {
- private final AxKey testKey = new AxArtifactKey("AvroTest", "0.0.1");
- private AxContextSchemas schemas;
- private String uinionSchema;
-
- /**
- * Inits the test.
- *
- * @throws IOException Signals that an I/O exception has occurred.
- */
- @Before
- public void initTest() throws IOException {
- schemas = new AxContextSchemas(new AxArtifactKey("AvroSchemas", "0.0.1"));
- ModelService.registerModel(AxContextSchemas.class, schemas);
- uinionSchema = TextFileUtils.getTextFileAsString("src/test/resources/avsc/UnionExample.avsc");
- }
-
- /**
- * Inits the context.
- */
- @Before
- public void initContext() {
- SchemaParameters schemaParameters = new SchemaParameters();
- schemaParameters.setName(ContextParameterConstants.SCHEMA_GROUP_NAME);
- schemaParameters.getSchemaHelperParameterMap().put("AVRO", new AvroSchemaHelperParameters());
- ParameterService.register(schemaParameters);
-
- }
-
- /**
- * Clear context.
- */
- @After
- public void clearContext() {
- ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
- }
-
- /**
- * Test union all fields.
- *
- * @throws IOException Signals that an I/O exception has occurred.
- */
- @Ignore
- @Test
- public void testUnionAllFields() throws IOException {
- final AxContextSchema avroSchema =
- new AxContextSchema(new AxArtifactKey("AvroRecord", "0.0.1"), "AVRO", uinionSchema);
-
- schemas.getSchemasMap().put(avroSchema.getKey(), avroSchema);
- final SchemaHelper schemaHelper = new SchemaHelperFactory().createSchemaHelper(testKey, avroSchema.getKey());
-
- final String inString = TextFileUtils.getTextFileAsString("src/test/resources/data/UnionExampleAllFields.json");
- final GenericRecord user = (GenericRecord) schemaHelper.createNewInstance(inString);
-
- assertEquals("Ben", user.get("name").toString());
- assertEquals(7, user.get("favourite_number"));
- assertEquals("red", user.get("favourite_colour").toString());
- }
-
- /**
- * Test union optional field.
- *
- * @throws IOException Signals that an I/O exception has occurred.
- */
- @Ignore
- @Test
- public void testUnionOptionalField() throws IOException {
- final AxContextSchema avroSchema =
- new AxContextSchema(new AxArtifactKey("AvroRecord", "0.0.1"), "AVRO", uinionSchema);
-
- schemas.getSchemasMap().put(avroSchema.getKey(), avroSchema);
- final SchemaHelper schemaHelper = new SchemaHelperFactory().createSchemaHelper(testKey, avroSchema.getKey());
-
- final String inString =
- TextFileUtils.getTextFileAsString("src/test/resources/data/UnionExampleOptionalField.json");
- final GenericRecord user = (GenericRecord) schemaHelper.createNewInstance(inString);
-
- assertEquals("Ben", user.get("name").toString());
- assertEquals(7, user.get("favourite_number"));
- assertEquals("red", user.get("favourite_colour").toString());
- }
-
- /**
- * Test union null field.
- *
- * @throws IOException Signals that an I/O exception has occurred.
- */
- @Ignore
- @Test
- public void testUnionNullField() throws IOException {
- final AxContextSchema avroSchema =
- new AxContextSchema(new AxArtifactKey("AvroRecord", "0.0.1"), "AVRO", uinionSchema);
-
- schemas.getSchemasMap().put(avroSchema.getKey(), avroSchema);
- final SchemaHelper schemaHelper = new SchemaHelperFactory().createSchemaHelper(testKey, avroSchema.getKey());
-
- final String inString = TextFileUtils.getTextFileAsString("src/test/resources/data/UnionExampleNullField.json");
- final GenericRecord user = (GenericRecord) schemaHelper.createNewInstance(inString);
-
- assertEquals("Ben", user.get("name").toString());
- assertEquals(7, user.get("favourite_number"));
- assertEquals("red", user.get("favourite_colour").toString());
- }
-}