2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2016-2018 Ericsson. All rights reserved.
4 * Modifications Copyright (C) 2019-2020 Nordix Foundation.
5 * ================================================================================
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
18 * SPDX-License-Identifier: Apache-2.0
19 * ============LICENSE_END=========================================================
22 package org.onap.policy.apex.testsuites.integration.executor.event;
24 import static org.junit.Assert.assertEquals;
25 import static org.junit.Assert.assertNotNull;
26 import static org.junit.Assert.assertNull;
27 import static org.junit.Assert.assertTrue;
29 import java.io.IOException;
30 import java.util.Date;
31 import java.util.HashMap;
33 import org.junit.After;
34 import org.junit.Before;
35 import org.junit.Test;
36 import org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelperParameters;
37 import org.onap.policy.apex.context.parameters.ContextParameterConstants;
38 import org.onap.policy.apex.context.parameters.ContextParameters;
39 import org.onap.policy.apex.context.parameters.SchemaParameters;
40 import org.onap.policy.apex.core.engine.EngineParameters;
41 import org.onap.policy.apex.core.engine.engine.ApexEngine;
42 import org.onap.policy.apex.core.engine.engine.impl.ApexEngineFactory;
43 import org.onap.policy.apex.core.engine.event.EnEvent;
44 import org.onap.policy.apex.model.basicmodel.concepts.ApexException;
45 import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
46 import org.onap.policy.apex.model.basicmodel.handling.ApexModelException;
47 import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
48 import org.onap.policy.apex.plugins.executor.mvel.MvelExecutorParameters;
49 import org.onap.policy.apex.testsuites.integration.common.model.SampleDomainModelFactory;
50 import org.onap.policy.common.parameters.ParameterService;
51 import org.slf4j.ext.XLogger;
52 import org.slf4j.ext.XLoggerFactory;
55 * The Class TestEventInstantiation.
57 * @author Liam Fallon (liam.fallon@ericsson.com)
59 public class TestEventInstantiation {
60 // Logger for this class
61 private static final XLogger logger = XLoggerFactory.getXLogger(TestEventInstantiation.class);
63 private SchemaParameters schemaParameters;
64 private ContextParameters contextParameters;
65 private EngineParameters engineParameters;
71 public void beforeTest() {
72 schemaParameters = new SchemaParameters();
74 schemaParameters.setName(ContextParameterConstants.SCHEMA_GROUP_NAME);
75 schemaParameters.getSchemaHelperParameterMap().put("JAVA", new JavaSchemaHelperParameters());
77 ParameterService.register(schemaParameters);
79 contextParameters = new ContextParameters();
81 contextParameters.setName(ContextParameterConstants.MAIN_GROUP_NAME);
82 contextParameters.getDistributorParameters().setName(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
83 contextParameters.getLockManagerParameters().setName(ContextParameterConstants.LOCKING_GROUP_NAME);
84 contextParameters.getPersistorParameters().setName(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
86 ParameterService.register(contextParameters);
87 ParameterService.register(contextParameters.getDistributorParameters());
88 ParameterService.register(contextParameters.getLockManagerParameters());
89 ParameterService.register(contextParameters.getPersistorParameters());
91 engineParameters = new EngineParameters();
92 engineParameters.getExecutorParameterMap().put("MVEL", new MvelExecutorParameters());
93 ParameterService.register(engineParameters);
100 public void afterTest() {
101 ParameterService.deregister(engineParameters);
103 ParameterService.deregister(contextParameters.getDistributorParameters());
104 ParameterService.deregister(contextParameters.getLockManagerParameters());
105 ParameterService.deregister(contextParameters.getPersistorParameters());
106 ParameterService.deregister(contextParameters);
108 ParameterService.deregister(schemaParameters);
112 * Test event instantiation.
114 * @throws ApexModelException on errors in handling Apex models
115 * @throws IOException Signals that an I/O exception has occurred.
116 * @throws ApexException the apex exception
119 public void testEventInstantiation() throws ApexModelException, IOException, ApexException {
120 final String xmlFileName = "xml/ApexModel_MVEL.xml";
122 logger.debug("Running TestEventInstantiation test on file {} . . .", xmlFileName);
124 final AxPolicyModel apexPolicyModel = new SampleDomainModelFactory().getSamplePolicyModel("MVEL");
125 assertNotNull(apexPolicyModel);
127 final ApexEngine apexEngine = new ApexEngineFactory().createApexEngine(apexPolicyModel.getKey());
128 apexEngine.updateModel(apexPolicyModel, false);
131 final EnEvent event = apexEngine.createEvent(new AxArtifactKey("Event0000", "0.0.1"));
133 Object slogan1 = event.put("TestSlogan", "This is a slogan");
135 slogan1 = event.get("TestSlogan");
136 assertNotNull(slogan1);
137 assertEquals("This is a slogan", slogan1);
139 Object mc1 = event.put("TestMatchCase", Byte.valueOf("4"));
141 mc1 = event.get("TestMatchCase");
143 assertEquals((byte) 4, mc1);
145 Object mc2 = event.put("TestMatchCase", Byte.valueOf("16"));
147 assertEquals((byte) 4, mc2);
148 mc2 = event.get("TestMatchCase");
150 assertEquals((byte) 16, mc2);
152 final Date timeNow = new Date();
153 Object timestamp1 = event.put("TestTimestamp", timeNow.getTime());
154 assertNull(timestamp1);
155 timestamp1 = event.get("TestTimestamp");
156 assertNotNull(timestamp1);
157 assertEquals(timeNow.getTime(), timestamp1);
159 final double temperature = 123.456789;
160 Object temp1 = event.put("TestTemperature", temperature);
162 temp1 = event.get("TestTemperature");
163 assertNotNull(temp1);
164 assertEquals(temperature, temp1);
166 Object value = event.put("TestMatchCase", null);
167 assertEquals(16, ((Byte) value).intValue());
168 value = event.get("TestMatchCase");
172 event.put("TestMatchCase", "Hello");
173 } catch (final Exception e) {
174 assertEquals("Event0000:0.0.1:NULL:TestMatchCase: object \"Hello\" of class \"java.lang.String\" "
175 + "not compatible with class \"java.lang.Byte\"", e.getMessage());
179 event.put("TestMatchCase", 123.45);
180 } catch (final Exception e) {
181 assertEquals("Event0000:0.0.1:NULL:TestMatchCase: object \"123.45\" of class \"java.lang.Double\" "
182 + "not compatible with class \"java.lang.Byte\"", e.getMessage());
185 event.put("TestMatchCase", Byte.valueOf("16"));
187 final String slogan2 = (String) event.get("TestSlogan");
188 assertNotNull(slogan2);
189 assertEquals("This is a slogan", slogan2);
191 final byte mc21 = (byte) event.get("TestMatchCase");
193 assertEquals(16, mc21);
195 final byte mc22 = (byte) event.get("TestMatchCase");
197 assertEquals((byte) 16, mc22);
199 final long timestamp2 = (Long) event.get("TestTimestamp");
200 assertNotNull(timestamp2);
201 assertEquals(timestamp2, timestamp1);
203 final double temp2 = (double) event.get("TestTemperature");
204 assertNotNull(temp2);
205 assertTrue(temp2 == 123.456789);
207 final Double temp3 = (Double) event.get("TestTemperature");
208 assertNotNull(temp3);
209 assertTrue(temp3 == 123.456789);
211 final Date aDate = new Date(1433453067123L);
212 final Map<String, Object> eventDataList = new HashMap<String, Object>();
213 eventDataList.put("TestSlogan", "This is a test slogan");
214 eventDataList.put("TestMatchCase", Byte.valueOf("123"));
215 eventDataList.put("TestTimestamp", aDate.getTime());
216 eventDataList.put("TestTemperature", 34.5445667);
218 event.putAll(eventDataList);
220 final String slogan3 = (String) event.get("TestSlogan");
221 assertNotNull(slogan3);
222 assertEquals("This is a test slogan", slogan3);
224 final byte mc31 = (byte) event.get("TestMatchCase");
226 assertEquals((byte) 123, mc31);
228 final long timestamp3 = (Long) event.get("TestTimestamp");
229 assertNotNull(timestamp3);
230 assertEquals(timestamp3, aDate.getTime());
232 final double temp4 = (double) event.get("TestTemperature");
233 assertNotNull(temp4);
234 assertTrue(temp4 == 34.5445667);
236 logger.debug(event.toString());