package org.onap.policy.apex.auth.clicodegen;
import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
import java.io.File;
import java.io.FileInputStream;
assertEquals(0, generateCli(codeGen, apexPolicyModel));
}
+ @Test
+ void testTaskDefFields() {
+ CodeGeneratorCliEditor editor = new CodeGeneratorCliEditor();
+ var st = editor.createTaskDefinitionInfields("InFieldTask", "1.0.0", "field1", "schema", "1.0.1");
+ assertNotNull(st);
+
+ var st2 = editor.createTaskDefinitionOutfields("OutFieldTask", "1.0.0", "field2", "schema", "1.0.1");
+ assertNotNull(st2);
+
+ var st3 = editor.createPolicyStateDefFinalizerLogic("dummy", "1.0.0", "dummyState",
+ "logicName", "flavor", "logic");
+ assertNotNull(st3);
+ }
+
/**
* Generate the CLI from the model.
*
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
import java.util.List;
+import java.util.Properties;
+import java.util.SortedMap;
+import java.util.TreeMap;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
otherCommand.getKeywordlist().add("TestKeyword");
assertNotEquals(commandLineCommand, otherCommand);
}
+
+ @Test
+ void testExecuteInvalidCommand() {
+ var handler = new ApexModelHandler(new Properties());
+ var command = new CommandLineCommand();
+ command.setApiMethod("java.invalid"); // invalid class
+ assertThrows(CommandLineException.class, () -> handler.executeCommand(command, null, null));
+
+ command.setApiMethod("org.onap.policy.apex.model.modelapi.ApexModel.invalid"); //invalid method
+ assertThrows(CommandLineException.class, () -> handler.executeCommand(command, null, null));
+
+ command.setApiMethod("org.onap.policy.apex.model.modelapi.ApexModel.saveToFile");
+ SortedMap<String, CommandLineArgumentValue> map = new TreeMap<>();
+ map.put("key", new CommandLineArgumentValue(null));
+ assertThrows(CommandLineException.class, () -> handler.executeCommand(command, map, null));
+ }
+
+ @Test
+ void testCommandLineArgument() {
+ var argument = new CommandLineArgument();
+ assertThat(argument).isEqualByComparingTo(argument);
+ var otherArgument = new CommandLineArgument("otherArgument");
+ assertThat(argument).isLessThan(otherArgument);
+
+ }
+
+ @Test
+ void testKeyWordNodeCommands() {
+ var kn = new KeywordNode("test");
+ var cmd = new CommandLineCommand();
+ List<String> keywordList = List.of("key1", "key2");
+ kn.processKeywords(keywordList, cmd);
+ assertNotNull(kn.getCommands());
+ }
}
assertEquals(3336, tempModelFileOutCharCount);
assertTrue(tempLogFileIn.delete());
- assertTrue(tempModelFileIn.delete());
assertTrue(tempLogFileOut.delete());
assertTrue(tempModelFileOut.delete());
+ tempModelFileIn.delete();
}
}
*/
@AfterEach
public void removeGeneratedFiles() {
- assertTrue(tempModelFile.delete());
assertTrue(tempLogFile.delete());
+ tempModelFile.delete();
}
/**
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.auth.clieditor;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.io.IOException;
+import org.junit.jupiter.api.Test;
+
+
+class CommandLineParametersTest {
+
+ @Test
+ void testMetadataFile() {
+ var clParameters = new CommandLineParameters();
+ assertNotNull(clParameters.getMetadataLocation());
+ assertFalse(clParameters.checkSetMetadataFileName());
+ clParameters.setMetadataFileName("testFile");
+ assertEquals("file: \"testFile\"", clParameters.getMetadataLocation());
+ assertTrue(clParameters.checkSetMetadataFileName());
+ }
+
+ @Test
+ void testApexPropertiesFile() throws IOException {
+ var clParameters = new CommandLineParameters();
+ assertNotNull(clParameters.getApexPropertiesLocation());
+ assertNotNull(clParameters.getApexPropertiesStream());
+ assertFalse(clParameters.checkSetApexPropertiesFileName());
+ clParameters.setApexPropertiesFileName("testApexPropertiesFile");
+ assertTrue(clParameters.checkSetApexPropertiesFileName());
+ }
+
+ @Test
+ void testInputModelFile() {
+ var clParameters = new CommandLineParameters();
+ assertFalse(clParameters.checkSetInputModelFileName());
+ assertFalse(clParameters.checkSetLogFileName());
+ clParameters.validate();
+ }
+}
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertTrue;
import java.io.File;
import java.io.IOException;
*/
@AfterEach
void removeGeneratedModels() {
- assertTrue(tempModelFile.delete());
+ tempModelFile.delete();
}
/**
package org.onap.policy.apex.auth.clieditor;
import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertTrue;
import java.io.File;
import java.io.IOException;
*/
@AfterEach
void removeGeneratedModels() {
- assertTrue(tempModelFile.delete());
+ tempModelFile.delete();
}
/**
writtenModel.getKeyInformation().getKeyInfoMap().clear();
compareModel.getKeyInformation().getKeyInfoMap().clear();
- assertEquals(writtenModel, compareModel);
+ assertEquals(normalizeNewlines(writtenModel.toString()), normalizeNewlines(compareModel.toString()));
// The output event is in this file
final File outputLogFile = new File(tempLogFile.getCanonicalPath());
// Check what we got is what we expected to get
assertEquals(outputLogCompareString, outputLogString);
}
+
+ private String normalizeNewlines(String input) {
+ return input.replace("\r\n", "\n");
+ }
}
package org.onap.policy.apex.auth.clieditor;
import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertTrue;
import java.io.File;
import java.io.IOException;
*/
@AfterEach
void removeTempFiles() {
- assertTrue(tempLogicModelFile.delete());
- assertTrue(tempAvroModelFile.delete());
+ tempLogicModelFile.delete();
+ tempAvroModelFile.delete();
}
/**
package org.onap.policy.apex.context.impl;
+import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelperParameters;
import org.onap.policy.apex.context.parameters.ContextParameterConstants;
import org.onap.policy.apex.context.parameters.ContextParameters;
+import org.onap.policy.apex.context.parameters.DistributorParameters;
+import org.onap.policy.apex.context.parameters.PersistorParameters;
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.AxConcept;
contextParameters.getDistributorParameters().setName(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
contextParameters.getLockManagerParameters().setName(ContextParameterConstants.LOCKING_GROUP_NAME);
contextParameters.getPersistorParameters().setName(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+ contextParameters.getPersistorParameters().setFlushPeriod(30000);
ParameterService.register(contextParameters);
ParameterService.register(contextParameters.getDistributorParameters());
assertThatThrownBy(album::flush).hasMessage("map flush failed, supplied map is null");
AxContextAlbums albums = new AxContextAlbums();
ModelService.registerModel(AxContextAlbums.class, albums);
+
+ assertThatThrownBy(() -> {
+ distributor.createContextAlbum(new AxContextAlbums().getKey());
+ }).hasMessage("context album NULL:0.0.0 does not exist");
+
albums.getAlbumsMap().put(axContextAlbum.getKey(), axContextAlbum);
distributor.createContextAlbum(album.getKey());
+ axContextAlbum.setItemSchema(new AxArtifactKey());
+ albums.getAlbumsMap().put(axContextAlbum.getKey(), axContextAlbum);
+ assertThatThrownBy(() -> {
+ distributor.createContextAlbum(album.getKey());
+ }).hasMessageContaining("context album definition for TestContextAlbum:0.0.1 is invalid");
+
+ axContextAlbum.setItemSchema(new AxArtifactKey("invalid", "0.0.1"));
+ albums.getAlbumsMap().put(axContextAlbum.getKey(), axContextAlbum);
+ assertThatThrownBy(() -> {
+ distributor.createContextAlbum(album.getKey());
+ }).hasMessage("schema \"invalid:0.0.1\" for context album TestContextAlbum:0.0.1 does not exist");
+
album.flush();
ModelService.clear();
}
+
+ @Test
+ void testParametersToString() {
+ assertThat(ParameterService.get(ContextParameterConstants.MAIN_GROUP_NAME).toString())
+ .isInstanceOf(String.class);
+ assertThat(ParameterService.get(ContextParameterConstants.SCHEMA_GROUP_NAME).toString())
+ .isInstanceOf(String.class);
+ }
+
+ @Test
+ void testParameterSetter() {
+ var parameters = new PersistorParameters();
+ parameters.setFlushPeriod(0);
+ parameters.setPluginClass("TestPlugin.class");
+ assertEquals(300000, parameters.getFlushPeriod());
+
+ var distributorParameters = new DistributorParameters();
+ distributorParameters.setName("test");
+ distributorParameters.setPluginClass("TestPlugin.class");
+ assertEquals("test", distributorParameters.getName());
+
+ var contextParameters = new ContextParameters();
+ contextParameters.setDistributorParameters(distributorParameters);
+ assertEquals("test", contextParameters.getDistributorParameters().getName());
+ }
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.context.impl;
+
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+import org.junit.jupiter.api.Test;
+import org.onap.policy.apex.context.ContextException;
+import org.onap.policy.apex.context.impl.distribution.jvmlocal.JvmLocalDistributor;
+import org.onap.policy.apex.context.impl.locking.LockManagerFactory;
+import org.onap.policy.apex.context.impl.locking.jvmlocal.JvmLocalLockManager;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.LockManagerParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.common.parameters.ParameterService;
+
+class LockManagerTest {
+
+ @Test
+ void testLock() {
+ var lockManager = new JvmLocalLockManager();
+ assertDoesNotThrow(() -> lockManager.lockForReading("test", "test"));
+ assertDoesNotThrow(() -> lockManager.unlockForReading("test", "test"));
+ assertThrows(ContextException.class, () -> lockManager.unlockForReading("test", "test"));
+ assertDoesNotThrow(() -> lockManager.lockForWriting("test", "test"));
+ assertDoesNotThrow(() -> lockManager.unlockForWriting("test", "test"));
+ assertThrows(ContextException.class, () -> lockManager.unlockForWriting("test", "test"));
+ }
+
+ @Test
+ void testShutDown() {
+ var lockManager = new JvmLocalLockManager();
+ assertDoesNotThrow(lockManager::shutdown);
+ }
+
+ @Test
+ void testCreateLockManager() {
+ var lockManagerFactory = new LockManagerFactory();
+ var parameters = new LockManagerParameters();
+ parameters.setPluginClass("invalid.class");
+ ParameterService.register(parameters);
+ assertThrows(ContextException.class, () -> lockManagerFactory.createLockManager(new AxArtifactKey()));
+ ParameterService.deregister(ContextParameterConstants.LOCKING_GROUP_NAME);
+
+ // different plugin instance
+ parameters.setPluginClass(JvmLocalDistributor.class.getName());
+ ParameterService.register(parameters);
+ assertThrows(ContextException.class, () -> lockManagerFactory.createLockManager(new AxArtifactKey()));
+ ParameterService.deregister(ContextParameterConstants.LOCKING_GROUP_NAME);
+
+ parameters.setPluginClass(LockManagerParameters.DEFAULT_LOCK_MANAGER_PLUGIN_CLASS);
+ ParameterService.register(parameters);
+ assertDoesNotThrow(() -> lockManagerFactory.createLockManager(new AxArtifactKey()));
+ ParameterService.deregister(ContextParameterConstants.LOCKING_GROUP_NAME);
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.context.impl;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+import java.util.TreeSet;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Test;
+import org.onap.policy.apex.context.ContextException;
+import org.onap.policy.apex.context.impl.distribution.jvmlocal.JvmLocalDistributor;
+import org.onap.policy.apex.context.impl.persistence.PersistorFactory;
+import org.onap.policy.apex.context.impl.persistence.ephemeral.EphemeralPersistor;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.PersistorParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.basicmodel.concepts.AxReferenceKey;
+import org.onap.policy.common.parameters.ParameterService;
+
+
+class PersistorTest {
+
+ @AfterAll
+ public static void cleanUpAfterTest() {
+ ParameterService.deregister(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+ ParameterService.clear();
+ }
+
+ @Test
+ void testContextItemRead() throws ContextException {
+ var persistor = new EphemeralPersistor();
+ assertNull(persistor.readContextItem(new AxReferenceKey(), null));
+ assertThat(persistor.readContextItems(null, null)).isInstanceOf(TreeSet.class);
+ persistor.init(new AxArtifactKey("testkey", "1.0.0"));
+ assertEquals("testkey", persistor.getKey().getName());
+ }
+
+ @Test
+ void testWriteContextItem() {
+ var persistor = new EphemeralPersistor();
+ assertThat(persistor.writeContextItem(new Object())).isInstanceOf(Object.class);
+ }
+
+ @Test
+ void testPersistorFactory() {
+ var factory = new PersistorFactory();
+ PersistorParameters params = new PersistorParameters();
+ params.setPluginClass("invalid.class");
+ ParameterService.register(params);
+ assertThrows(ContextException.class, () -> factory.createPersistor(new AxArtifactKey()));
+ ParameterService.deregister(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+
+ params.setPluginClass(JvmLocalDistributor.class.getName());
+ ParameterService.register(params);
+ assertThrows(ContextException.class, () -> factory.createPersistor(new AxArtifactKey()));
+ ParameterService.deregister(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+
+ params.setPluginClass(PersistorParameters.DEFAULT_PERSISTOR_PLUGIN_CLASS);
+ ParameterService.register(params);
+ assertDoesNotThrow(() -> factory.createPersistor(new AxArtifactKey()));
+ }
+}
package org.onap.policy.apex.context.impl.schema;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
+import java.util.Map;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelperParameters;
import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.SchemaHelperParameters;
import org.onap.policy.apex.context.parameters.SchemaParameters;
import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
import org.onap.policy.apex.model.basicmodel.service.ModelService;
.hasMessage("Owner:0.0.1: class/type java.lang.Bad for context schema \"IntSchema:0.0.1\" "
+ "not found. Check the class path of the JVM");
}
+
+ @Test
+ void testSchemaHelperParameter() {
+ var schemaHelperParameters = new SchemaHelperParameters();
+ assertNotNull(schemaHelperParameters.toString());
+ }
+
+ @Test
+ void testSchemaParameterSetter() {
+ var parameters = new SchemaParameters();
+ parameters.setName("testSchema");
+ parameters.setSchemaHelperParameterMap(Map.of("test", new SchemaHelperParameters()));
+ assertEquals("testSchema", parameters.getName());
+ }
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.context.impl.schema.java;
+
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import org.onap.policy.apex.context.ContextException;
+import org.onap.policy.apex.context.impl.distribution.DistributorFactory;
+import org.onap.policy.apex.context.impl.distribution.DistributorFlushTimerTask;
+import org.onap.policy.apex.context.impl.distribution.jvmlocal.JvmLocalDistributor;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.ContextParameters;
+import org.onap.policy.apex.context.parameters.DistributorParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.basicmodel.service.ModelService;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextAlbum;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextAlbums;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextModel;
+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;
+
+
+class DistributorTest {
+
+ @BeforeAll
+ public static void prepareForTest() {
+ final var contextParameters = new ContextParameters();
+ contextParameters.getLockManagerParameters()
+ .setPluginClass("org.onap.policy.apex.context.impl.locking.jvmlocal.JvmLocalLockManager");
+ contextParameters.getDistributorParameters().setName(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
+ contextParameters.getLockManagerParameters().setName(ContextParameterConstants.LOCKING_GROUP_NAME);
+
+ ParameterService.register(contextParameters);
+ ParameterService.register(contextParameters.getDistributorParameters());
+ ParameterService.register(contextParameters.getLockManagerParameters());
+ ParameterService.register(contextParameters.getPersistorParameters());
+ }
+
+ /**
+ * Clear down the test data.
+ */
+ @AfterAll
+ public static void cleanUpAfterTest() {
+ ParameterService.deregister(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
+ ParameterService.deregister(ContextParameterConstants.LOCKING_GROUP_NAME);
+ ParameterService.deregister(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+ ParameterService.clear();
+ }
+
+ @Test
+ void testModelRegister() throws ContextException {
+ var schemas = new AxContextSchemas();
+ var simpleIntSchema = new AxContextSchema(new AxArtifactKey("SimpleIntSchema", "0.0.1"), "JAVA",
+ "java.lang.Integer");
+ schemas.getSchemasMap().put(simpleIntSchema.getKey(), simpleIntSchema);
+
+ var axContextAlbum = new AxContextAlbum(new AxArtifactKey("TestContextAlbum", "0.0.1"), "Policy",
+ true, AxArtifactKey.getNullKey());
+
+ axContextAlbum.setItemSchema(simpleIntSchema.getKey());
+ var model = new AxContextModel(new AxArtifactKey("TestArtifact", "0.0.1"));
+ var albums = new AxContextAlbums();
+ albums.getAlbumsMap().put(axContextAlbum.getKey(), axContextAlbum);
+ model.setAlbums(albums);
+ model.setSchemas(schemas);
+ var distributor = new JvmLocalDistributor();
+ assertDoesNotThrow(() -> distributor.registerModel(model));
+
+ distributor.flush();
+ ModelService.clear();
+ }
+
+ @Test
+ void testDistributorFlushTimer() throws ContextException {
+ var distributor = new JvmLocalDistributor();
+ distributor.init(new AxArtifactKey("test", "0.0.1"));
+ var timerTask = new DistributorFlushTimerTask(distributor);
+ assertDoesNotThrow(timerTask::run);
+ assertDoesNotThrow(timerTask::toString);
+ assertTrue(timerTask.cancel());
+ }
+
+ @Test
+ void testDistributorFactory() {
+ var dfactory = new DistributorFactory();
+ var axArtifactKey = new AxArtifactKey("testKey", "1.0.1");
+ assertDoesNotThrow(() -> dfactory.getDistributor(axArtifactKey));
+ ParameterService.deregister(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
+ var params = new DistributorParameters();
+ params.setPluginClass("invalid.class");
+ ParameterService.register(params);
+ assertThrows(ContextException.class, () -> dfactory.getDistributor(axArtifactKey));
+ ParameterService.deregister(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
+ params.setPluginClass("org.onap.policy.apex.context.impl.persistence.ephemeral.EphemeralPersistor");
+ ParameterService.register(params);
+ assertThrows(ContextException.class, () -> dfactory.getDistributor(axArtifactKey));
+ }
+
+ @Test
+ void testAbstractDistributor() throws ContextException {
+ var distributor = new JvmLocalDistributor();
+ assertThrows(ContextException.class, () -> distributor.removeContextAlbum(new AxArtifactKey()));
+ assertDoesNotThrow(distributor::flush);
+ distributor.init(new AxArtifactKey());
+ assertDoesNotThrow(distributor::clear);
+
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.core.infrastructure.threading;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import org.junit.jupiter.api.Test;
+import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
+
+
+class MessageExceptionTest {
+
+ @Test
+ void testMessageException() {
+ var exception = new MessagingException("Test error");
+ assertEquals("Test error", exception.getMessage());
+
+ var exception2 = new MessagingException("Test error2", new NullPointerException());
+ assertThat(exception2).isInstanceOf(MessagingException.class).hasMessage("Test error2");
+ }
+}
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2022-2023 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.examples.acm;
-
-import jakarta.ws.rs.GET;
-import jakarta.ws.rs.POST;
-import jakarta.ws.rs.Path;
-import jakarta.ws.rs.Produces;
-import jakarta.ws.rs.QueryParam;
-import jakarta.ws.rs.core.Response;
-import java.util.List;
-import java.util.concurrent.atomic.AtomicInteger;
-import org.slf4j.ext.XLogger;
-import org.slf4j.ext.XLoggerFactory;
-
-/**
- * The Class AcmTestRestDmaapEndpoint creates rest server endpoints for simulating sending/receiving events on DMaaP.
- */
-@Path("/")
-@Produces("application/json")
-public class AcmTestRestDmaapEndpoint {
-
- private static final XLogger LOGGER = XLoggerFactory.getXLogger(AcmTestRestDmaapEndpoint.class);
- private final Object lock = new Object();
- private static String loggedOutputEvent = "";
- private static final AtomicInteger counter = new AtomicInteger(1);
-
- /**
- * DMaaP input of events. This input event triggers the policy
- *
- * @param timeout the timeout to wait for
- * @return the response
- */
- @Path("events/AC_ELEMENT_MSG/APEX/1")
- @GET
- public Response getMessages(@QueryParam("timeout") final int timeout) {
- String createRequest = "{\"messageType\":\"STATUS\","
- + "\"elementId\":{\"name\":\"onap.policy.clamp.ac.startertobridge\",\"version\":\"1.0.0\"},"
- + "\"message\":\"starter: onap.policy.clamp.ac.starter 1.0.0\",\"messageId\":\""
- + counter.incrementAndGet() + "\",\"timestamp\":\"2022-08-19T07:37:01.198592Z\"}";
- LOGGER.info("Create request received: \n {}", createRequest);
-
- return Response.status(200).entity(List.of(createRequest)).build();
- }
-
- /**
- * Post new message.
- *
- * @param jsonString the message
- * @return the response
- */
- @Path("events/POLICY_UPDATE_MSG")
- @POST
- public Response policyMessage(final String jsonString) {
- LOGGER.info("\n*** POLICY LOG ENTRY START ***\n {} \n *** POLICY LOG ENTRY END ***", jsonString);
- synchronized (lock) {
- loggedOutputEvent += jsonString + "\n";
- }
- return Response.status(200).build();
- }
-
- /**
- * Get the logged event for test verification.
- *
- * @return the response
- */
- @Path("events/getLoggedEvent")
- @GET
- public Response getDetails() {
- String loggedEvent;
- synchronized (lock) {
- loggedEvent = loggedOutputEvent;
- }
- if (null == loggedEvent) {
- return Response.status(500).entity("Error: Log event not yet generated.").build();
- }
- return Response.status(200).entity(loggedEvent).build();
- }
-}
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2022-2024 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.examples.acm;
-
-import org.onap.policy.common.endpoints.http.server.HttpServletServer;
-import org.onap.policy.common.endpoints.http.server.HttpServletServerFactoryInstance;
-import org.onap.policy.common.gson.GsonMessageBodyHandler;
-import org.onap.policy.common.utils.network.NetworkUtil;
-
-/**
- * The Class AcmTestServerDmaap that manages test servers for REST requests for the test.
- */
-public class AcmTestServerDmaap implements AutoCloseable {
- private static final String HOST = "localhost";
- private HttpServletServer restServer;
- private int restServerPort = 3904;
-
- /**
- * Instantiates a new REST simulator for DMaaP requests.
- */
- public AcmTestServerDmaap() {
- restServer = HttpServletServerFactoryInstance.getServerFactory().build("AcmTestRestDmaapEndpoint", false, HOST,
- restServerPort, false, "/", false, false);
- restServer.addServletClass(null, AcmTestRestDmaapEndpoint.class.getName());
- restServer.setSerializationProvider(GsonMessageBodyHandler.class.getName());
- restServer.start();
- }
-
- /**
- * Validate the Rest server.
- * @throws InterruptedException if is not alive
- */
- public void validate() throws InterruptedException {
- if (!NetworkUtil.isTcpPortOpen(HOST, restServerPort, 50, 200L)) {
- throw new IllegalStateException("port " + restServerPort + " is still not in use");
- }
- }
-
- @Override
- public void close() {
- if (restServer != null) {
- restServer.stop();
- restServer = null;
- }
- }
-}
"eventInputParameters": {
"DmaapConsumer": {
"carrierTechnologyParameters": {
- "carrierTechnology": "RESTCLIENT",
- "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters",
+ "carrierTechnology": "KAFKA",
+ "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters",
"parameters": {
- "url": "http://localhost:3904/events/AC_ELEMENT_MSG/APEX/1?timeout=30000"
+ "bootstrapServers": "kafka:9092",
+ "groupId": "clamp-grp",
+ "enableAutoCommit": "true",
+ "autoCommitTime": "1000",
+ "sessionTimeout": "30000",
+ "consumerPollTime": "100",
+ "consumerTopicList": [
+ "ac_element_msg"
+ ],
+ "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer",
+ "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer",
+ "kafkaProperties": [ ]
}
},
"eventProtocolParameters": {
},
"DmaapReplyProducer": {
"carrierTechnologyParameters": {
- "carrierTechnology": "RESTCLIENT",
- "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters",
+ "carrierTechnology": "KAFKA",
+ "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters",
"parameters": {
- "url": "http://localhost:3904/events/POLICY_UPDATE_MSG"
+ "bootstrapServers": "kafka:9092",
+ "acks": "all",
+ "retries": "0",
+ "batchSize": "16384",
+ "lingerTime": "1",
+ "bufferMemory": "33554432",
+ "producerTopic": "policy_update_msg",
+ "keySerializer": "org.apache.kafka.common.serialization.StringSerializer",
+ "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer",
+ "kafkaProperties": [ ]
}
},
"eventProtocolParameters": {
package org.onap.policy.apex.examples.acm;
-import static org.awaitility.Awaitility.await;
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertTrue;
-import jakarta.ws.rs.client.ClientBuilder;
-import java.util.concurrent.TimeUnit;
+import java.nio.file.Files;
+import java.nio.file.Path;
import org.junit.jupiter.api.Test;
import org.onap.policy.apex.auth.clieditor.tosca.ApexCliToscaEditorMain;
-import org.onap.policy.apex.service.engine.main.ApexMain;
+
/**
* Test class to run an example policy for ACM interaction. Event received on
@Test
void testExample() {
- try (var dmmap = new AcmTestServerDmaap()) {
- dmmap.validate();
+ try {
// @formatter:off
final String[] cliArgs = new String[] {
};
// @formatter:on
- new ApexCliToscaEditorMain(cliArgs);
-
- // @formatter:off
- final String[] apexArgs = {
- "-rfr",
- "target/classes",
- "-p",
- "target/classes/APEXacElementPolicy.json"
- };
- // @formatter:on
-
- final var client = ClientBuilder.newClient();
- final var apexMain = new ApexMain(apexArgs);
-
- await().atMost(5000, TimeUnit.MILLISECONDS).until(apexMain::isAlive);
+ assertDoesNotThrow(() -> new ApexCliToscaEditorMain(cliArgs));
+ assertTrue(Files.exists(Path.of("target/classes/APEXacElementPolicy.json")));
- String getLoggedEventUrl = "http://localhost:3904/events/getLoggedEvent";
- await().atMost(20000, TimeUnit.MILLISECONDS).until(() -> {
- var response = client.target(getLoggedEventUrl).request("application/json").get();
- var responseEntity = response.readEntity(String.class);
- return responseEntity != null && !responseEntity.isEmpty();
- });
- apexMain.shutdown();
} catch (Exception e) {
e.printStackTrace();
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 Huawei. All rights reserved.
- * Modifications Copyright (C) 2019-2021 Nordix Foundation.
+ * Modifications Copyright (C) 2019-2021,2024 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* @param contentType http content type
* @return String response message
*/
- public String httpRequest(String requestUrl, String requestMethod, String outputStr, String username, String pass,
+ public String httpRequest(URL requestUrl, String requestMethod, String outputStr, String username, String pass,
String contentType) {
var result = "";
var builder = new StringBuilder();
LOGGER.info("httpsRequest starts {} method {}", requestUrl, requestMethod);
disableCertificateValidation();
- var url = new URL(requestUrl);
- HttpURLConnection httpUrlConn = (HttpURLConnection) url.openConnection();
+ var httpUrlConn = (HttpURLConnection) requestUrl.openConnection();
httpUrlConn.setDoOutput(true);
httpUrlConn.setDoInput(true);
import static org.mockito.Mockito.when;
import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.URL;
import javax.net.ssl.HttpsURLConnection;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
-import org.mockito.Mockito;
class WebClientTest {
- HttpsURLConnection mockedHttpsUrlConnection;
- String sampleString = "Response Code :200";
+ private HttpsURLConnection mockedHttpsUrlConnection;
+ private URL url;
+ private String sampleString = "Response Code :200";
/**
* Set up the mocked REST manager.
@BeforeEach
void setupMockedRest() throws IOException {
mockedHttpsUrlConnection = mock(HttpsURLConnection.class);
+ url = mock(URL.class);
+ when(url.openConnection()).thenReturn(mockedHttpsUrlConnection);
InputStream inputStream = new ByteArrayInputStream(sampleString.getBytes());
+ OutputStream outputStream = new ByteArrayOutputStream();
when(mockedHttpsUrlConnection.getInputStream()).thenReturn(inputStream);
- Mockito.doNothing().when(mockedHttpsUrlConnection).connect();
+ when(mockedHttpsUrlConnection.getOutputStream()).thenReturn(outputStream);
}
@Test
- void testHttpsRequest() {
+ void testHttpsPostRequest() {
WebClient cl = new WebClient();
String result = cl
- .httpRequest("https://some.random.url/data", "POST", null, "admin", "admin", "application/json");
+ .httpRequest(url, "POST", null, "admin", "admin", "application/json");
assertNotNull(result);
}
@Test
- void testHttpRequest() {
+ void testHttpsGetRequest() {
WebClient cl = new WebClient();
String result = cl
- .httpRequest("http://some.random.url/data", "GET", null, "admin", "admin", "application/json");
+ .httpRequest(url, "GET", "sample output string", "admin", "admin", "application/json");
assertNotNull(result);
}
@Test
void testModelValid() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValid();
- var expectedResult = ResourceUtils.getResourceAsString(VALID_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(VALID_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testApexModelValidateWarning() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateWarning();
- var expectedResult = ResourceUtils.getResourceAsString(WARNING_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(WARNING_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testModelValidateInvalidModel() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateInvalidModel();
- var expectedResult = ResourceUtils.getResourceAsString(INVALID_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testModelValidateMalstructured() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateMalstructured();
- var expectedResult = ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING));
assertEquals(expectedResult, result.toString());
}
void testModelWriteReadJson() throws Exception {
testApexModel.testApexModelWriteReadJson();
}
+
+ private String normalizeNewlines(String input) {
+ return input.replace("\r\n", "\n");
+ }
}
@Test
void testApexModelValidateObservation() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateObservation();
- var expectedResult = ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testApexModelValidateWarning() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateWarning();
- var expectedResult = ResourceUtils.getResourceAsString(WARNING_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(WARNING_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testModelValidateInvalidModel() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateInvalidModel();
- var expectedResult = ResourceUtils.getResourceAsString(INVALID_MODEL_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_STRING));
assertEquals(expectedResult, result.toString());
}
@Test
void testModelValidateMalstructured() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateMalstructured();
- var expectedResult = ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING);
+ var expectedResult = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING));
assertEquals(expectedResult, result.toString());
}
void testModelWriteReadJson() throws Exception {
testApexModel.testApexModelWriteReadJson();
}
+
+ private String normalizeNewlines(String input) {
+ return input.replace("\r\n", "\n");
+ }
}
@Test
void testApexModelValidateObservation() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateObservation();
- String expected = ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING);
+ var expected = normalizeNewlines(ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING));
assertEquals(expected, result.toString());
}
@Test
void testApexModelValidateWarning() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateWarning();
- String expected = ResourceUtils.getResourceAsString(WARNING_MODEL_STRING);
+ var expected = normalizeNewlines(ResourceUtils.getResourceAsString(WARNING_MODEL_STRING));
assertEquals(expected, result.toString());
}
@Test
void testModelValidateInvalidModel() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateInvalidModel();
- String expected = ResourceUtils.getResourceAsString(INVALID_MODEL_STRING);
+ var expected = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_STRING));
assertEquals(expected, result.toString());
}
@Test
void testModelValidateMalstructured() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateMalstructured();
- String expected = ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING);
+ var expected = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING));
assertEquals(expected, result.toString());
}
void testModelWriteReadJson() throws Exception {
testApexModel.testApexModelWriteReadJson();
}
+
+ private String normalizeNewlines(String input) {
+ return input.replace("\r\n", "\n");
+ }
}
@Test
void testApexModelValidateObservation() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateObservation();
- assertEquals(ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING), result.toString());
+ var expectedOutput = normalizeNewlines(ResourceUtils.getResourceAsString(OBSERVATION_MODEL_STRING));
+ assertEquals(expectedOutput, result.toString());
}
@Test
void testApexModelValidateWarning() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateWarning();
- assertEquals(ResourceUtils.getResourceAsString(WARNING_MODEL_STRING), result.toString());
+ var expectedOutput = normalizeNewlines(ResourceUtils.getResourceAsString(WARNING_MODEL_STRING));
+ assertEquals(expectedOutput, result.toString());
}
@Test
void testModelValidateInvalidModel() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateInvalidModel();
- assertEquals(ResourceUtils.getResourceAsString(INVALID_MODEL_STRING), result.toString());
+ var expectedOutput = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_STRING));
+ assertEquals(expectedOutput, result.toString());
}
@Test
void testModelValidateMalstructured() throws Exception {
final AxValidationResult result = testApexModel.testApexModelValidateMalstructured();
- assertEquals(ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING), result.toString());
+ var expectedOutput = normalizeNewlines(ResourceUtils.getResourceAsString(INVALID_MODEL_MALSTRUCTURED_STRING));
+ assertEquals(expectedOutput, result.toString());
}
@Test
void testModelWriteReadJson() throws Exception {
testApexModel.testApexModelWriteReadJson();
}
+
+ private String normalizeNewlines(String input) {
+ return input.replace("\r\n", "\n");
+ }
}
import java.io.PrintStream;
import java.util.concurrent.TimeUnit;
import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.TestMethodOrder;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.Mockito;
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2024 Nordix Foundation. All rights reserved.
+ * ================================================================================
+ * 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.testsuites.integration.common.concepts;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+import java.util.Date;
+import java.util.Map;
+import java.util.TreeSet;
+import org.junit.jupiter.api.Test;
+import org.onap.policy.apex.context.test.concepts.TestContextBooleanItem;
+import org.onap.policy.apex.context.test.concepts.TestContextByteItem;
+import org.onap.policy.apex.context.test.concepts.TestContextDateItem;
+import org.onap.policy.apex.context.test.concepts.TestContextDateLocaleItem;
+import org.onap.policy.apex.context.test.concepts.TestContextDateTzItem;
+import org.onap.policy.apex.context.test.concepts.TestContextDoubleItem;
+import org.onap.policy.apex.context.test.concepts.TestContextFloatItem;
+import org.onap.policy.apex.context.test.concepts.TestContextIntItem;
+import org.onap.policy.apex.context.test.concepts.TestContextLongItem;
+import org.onap.policy.apex.context.test.concepts.TestContextLongObjectItem;
+import org.onap.policy.apex.context.test.concepts.TestContextStringItem;
+import org.onap.policy.apex.context.test.concepts.TestContextTreeMapItem;
+import org.onap.policy.apex.context.test.concepts.TestContextTreeSetItem;
+
+class ConceptsTest {
+
+ @Test
+ void testConceptBooleanItem() {
+ assertDoesNotThrow(() -> new TestContextBooleanItem());
+ assertDoesNotThrow(() -> new TestContextBooleanItem(true));
+ var item = new TestContextBooleanItem();
+ item.setFlag(false);
+ assertFalse(item.isFlag());
+ }
+
+ @Test
+ void testContextByteItem() {
+ assertDoesNotThrow(() -> new TestContextByteItem());
+ assertDoesNotThrow(() -> new TestContextByteItem((byte) 1));
+ var byteItem = new TestContextByteItem();
+ byteItem.setByteValue((byte) 0);
+ assertEquals((byte) 0, byteItem.getByteValue());
+ assertEquals((byte) 1, byteItem.getIncrementedByteValue());
+ }
+
+ @Test
+ void testContextDateItem() {
+ assertDoesNotThrow(() -> new TestContextDateItem());
+ assertDoesNotThrow(() -> new TestContextDateItem(new Date()));
+ assertDoesNotThrow(() -> new TestContextDateItem(1726611256L));
+ var date = new TestContextDateItem();
+ date.setDateValue(new Date());
+ assertThat(date.getDateValue()).isInstanceOf(Date.class);
+ var date2 = new TestContextDateItem();
+ assertThat(date2.getMonth()).isInstanceOf(Integer.class);
+ assertThat(date2.getYear()).isInstanceOf(Integer.class);
+ assertThat(date2.getDay()).isInstanceOf(Integer.class);
+ assertThat(date2.getTime()).isInstanceOf(Long.class);
+ assertThat(date2.getMilliSecond()).isInstanceOf(Integer.class);
+ assertThat(date2.getMinute()).isInstanceOf(Integer.class);
+ assertThat(date2.getHour()).isInstanceOf(Integer.class);
+ assertThat(date2.getSecond()).isInstanceOf(Integer.class);
+ var date3 = new TestContextDateItem(null);
+ assertNotNull(date3.getDateValue());
+ }
+
+ @Test
+ void testContextDateLocaleItem() {
+ assertDoesNotThrow(() -> new TestContextDateLocaleItem());
+ assertDoesNotThrow(() -> new TestContextDateLocaleItem(new TestContextDateLocaleItem()));
+ assertDoesNotThrow(() -> new TestContextDateLocaleItem(new TestContextDateItem(), "UTC", true,
+ 1, "english", "Ireland"));
+ var localeItem = new TestContextDateLocaleItem();
+ localeItem.setTzValue("utc");
+ assertNotNull(localeItem.getTzValue());
+ }
+
+ @Test
+ void testContextDateTzItem() {
+ assertDoesNotThrow(() -> new TestContextDateTzItem());
+ assertDoesNotThrow(() -> new TestContextDateTzItem(new TestContextDateTzItem()));
+ assertDoesNotThrow(() -> new TestContextDateTzItem(new TestContextDateItem(), "utc", false));
+ var tzItem = new TestContextDateTzItem();
+ tzItem.setTzValue("utc");
+ assertNotNull(tzItem.getTzValue());
+ assertThat(tzItem.getTzValue()).isInstanceOf(String.class);
+ }
+
+ @Test
+ void testContextDoubleItem() {
+ assertDoesNotThrow(() -> new TestContextDoubleItem());
+ assertDoesNotThrow(() -> new TestContextDoubleItem(0));
+ var doubleItem = new TestContextDoubleItem();
+ doubleItem.setDoubleValue(0);
+ assertEquals(1, doubleItem.getIncrementedDoubleValue());
+ }
+
+ @Test
+ void testContextFloatItem() {
+ assertDoesNotThrow(() -> new TestContextFloatItem());
+ assertDoesNotThrow(() -> new TestContextFloatItem(0));
+ var floatItem = new TestContextFloatItem();
+ floatItem.setFloatValue(0);
+ assertEquals(1, floatItem.getIncrementedFloatValue());
+ }
+
+ @Test
+ void testContextIntItem() {
+ assertDoesNotThrow(() -> new TestContextIntItem());
+ assertDoesNotThrow(() -> new TestContextIntItem(0));
+ var intItem = new TestContextIntItem();
+ intItem.setIntValue(0);
+ assertEquals(1, intItem.getIncrementedIntValue());
+ }
+
+ @Test
+ void testContextLongItem() {
+ assertDoesNotThrow(() -> new TestContextLongItem());
+ assertDoesNotThrow(() -> new TestContextLongItem(0));
+ var longItem = new TestContextLongItem();
+ longItem.setLongValue(0);
+ assertEquals(1, longItem.getIncrementedLongValue());
+ }
+
+ @Test
+ void testContextLongObjectItem() {
+ assertDoesNotThrow(() -> new TestContextLongObjectItem());
+ assertDoesNotThrow(() -> new TestContextLongObjectItem(0L));
+ var longObjItem = new TestContextLongObjectItem();
+ longObjItem.setLongValue(0L);
+ assertEquals(1, longObjItem.getIncrementedLongValue());
+ }
+
+ @Test
+ void testContextStringItem() {
+ assertDoesNotThrow(() -> new TestContextStringItem());
+ assertDoesNotThrow(() -> new TestContextStringItem("test"));
+ var strItem = new TestContextStringItem();
+ strItem.setStringValue("test");
+ assertEquals("test", strItem.getStringValue());
+ }
+
+ @Test
+ void testContextTreeMapItem() {
+ assertDoesNotThrow(() -> new TestContextTreeMapItem());
+ assertDoesNotThrow(() -> new TestContextTreeMapItem(Map.of("", "")));
+ var treeMapItem = new TestContextTreeMapItem();
+ treeMapItem.setMapValue(Map.of("test", "testVal"));
+ assertEquals("testVal", treeMapItem.getMapValue().get("test"));
+ }
+
+ @Test
+ void testContextTreeSetItem() {
+ assertDoesNotThrow(() -> new TestContextTreeSetItem());
+ var items = new TreeSet<String>();
+ assertDoesNotThrow(() -> new TestContextTreeSetItem(items));
+ }
+
+
+
+}
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
-import static org.junit.jupiter.api.Assertions.assertTrue;
import java.io.File;
import java.nio.file.FileSystems;
@BeforeEach
void beforeSetUp() {
if (file.exists()) {
- assertTrue(file.delete());
+ file.delete();
}
}
@AfterEach
void testDown() {
if (file.exists()) {
- assertTrue(file.delete());
+ file.delete();
}
}
}
Code Review / policy / apex-pdp.git / commitdiff