testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/engdep/EngDepMessagingTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
   4  *  Modifications Copyright (C) 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
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  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.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.apex.testsuites.integration.uservice.engdep;
  23
  24 import static org.junit.Assert.assertEquals;
  25 import static org.junit.Assert.assertNotNull;
  26 import static org.junit.Assert.fail;
  27
  28 import java.io.IOException;
  29 import java.net.URISyntaxException;
  30 import java.util.Date;
  31 import java.util.HashMap;
  32 import java.util.Map;
  33
  34 import org.junit.After;
  35 import org.junit.Before;
  36 import org.junit.Test;
  37 import org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelperParameters;
  38 import org.onap.policy.apex.context.parameters.ContextParameterConstants;
  39 import org.onap.policy.apex.context.parameters.ContextParameters;
  40 import org.onap.policy.apex.context.parameters.SchemaParameters;
  41 import org.onap.policy.apex.core.deployment.BatchDeployer;
  42 import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
  43 import org.onap.policy.apex.model.basicmodel.concepts.ApexException;
  44 import org.onap.policy.apex.model.basicmodel.service.ModelService;
  45 import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
  46 import org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters;
  47 import org.onap.policy.apex.service.engine.event.ApexEvent;
  48 import org.onap.policy.apex.service.parameters.engineservice.EngineServiceParameters;
  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;
  53
  54 // CHECKSTYLE:OFF: checkstyle:magicNumber
  55
  56 /**
  57  * The Class EngDepMessagingTest.
  58  *
  59  * @author Liam Fallon (liam.fallon@ericsson.com)
  60  */
  61 public class EngDepMessagingTest {
  62     // Logger for this class
  63     private static final XLogger LOGGER = XLoggerFactory.getXLogger(EngDepMessagingTest.class);
  64
  65     private static final long MAX_START_WAIT = 10000; // 10 sec
  66
  67     private SchemaParameters schemaParameters;
  68     private ContextParameters contextParameters;
  69     private EngineServiceParameters engineServiceParameters;
  70
  71     /**
  72      * Clear relative file root environment variable.
  73      */
  74     @Before
  75     public void clearRelativeFileRoot() {
  76         System.clearProperty("APEX_RELATIVE_FILE_ROOT");
  77     }
  78
  79     /**
  80      * Before test.
  81      */
  82     @Before
  83     public void beforeTest() {
  84         schemaParameters = new SchemaParameters();
  85
  86         schemaParameters.setName(ContextParameterConstants.SCHEMA_GROUP_NAME);
  87         schemaParameters.getSchemaHelperParameterMap().put("JAVA", new JavaSchemaHelperParameters());
  88
  89         ParameterService.register(schemaParameters, true);
  90
  91         contextParameters = new ContextParameters();
  92
  93         contextParameters.setName(ContextParameterConstants.MAIN_GROUP_NAME);
  94         contextParameters.getDistributorParameters().setName(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
  95         contextParameters.getLockManagerParameters().setName(ContextParameterConstants.LOCKING_GROUP_NAME);
  96         contextParameters.getPersistorParameters().setName(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
  97
  98         ParameterService.register(contextParameters, true);
  99         ParameterService.register(contextParameters.getDistributorParameters(), true);
 100         ParameterService.register(contextParameters.getLockManagerParameters(), true);
 101         ParameterService.register(contextParameters.getPersistorParameters(), true);
 102
 103         engineServiceParameters = new EngineServiceParameters();
 104         engineServiceParameters.setName("EngDepMessagingTest");
 105         engineServiceParameters.setVersion("0.0.1");
 106         engineServiceParameters.setDeploymentPort(58820);
 107         engineServiceParameters.setInstanceCount(3);
 108         engineServiceParameters.setId(100);
 109         engineServiceParameters.getEngineParameters().getExecutorParameterMap().put("JAVASCRIPT",
 110                 new JavascriptExecutorParameters());
 111
 112         ParameterService.register(engineServiceParameters, true);
 113         ParameterService.register(engineServiceParameters.getEngineParameters(), true);
 114     }
 115
 116     /**
 117      * After test.
 118      */
 119     @After
 120     public void afterTest() {
 121         ParameterService.deregister(engineServiceParameters);
 122         ParameterService.deregister(engineServiceParameters.getEngineParameters());
 123
 124         ParameterService.deregister(contextParameters.getDistributorParameters());
 125         ParameterService.deregister(contextParameters.getLockManagerParameters());
 126         ParameterService.deregister(contextParameters.getPersistorParameters());
 127         ParameterService.deregister(contextParameters);
 128
 129         ParameterService.deregister(schemaParameters);
 130     }
 131
 132     /**
 133      * Test EngDep messaging.
 134      *
 135      * @throws URISyntaxException the URI syntax exception
 136      * @throws IOException Signals that an I/O exception has occurred.
 137      * @throws ApexException the apex exception
 138      */
 139     @Test
 140     public void testEngDepMessaging() throws URISyntaxException, IOException, ApexException {
 141         LOGGER.debug("engine<-->deployment messaging test starting . .  .");
 142
 143         ModelService.clear();
 144
 145         final EngineTestServer server = new EngineTestServer(engineServiceParameters);
 146         assertNotNull(server);
 147
 148         final Thread serverThread = new Thread(server);
 149         serverThread.start();
 150         final long starttime = System.currentTimeMillis();
 151         while (server.isStarting() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
 152             ThreadUtilities.sleep(100);
 153         }
 154         if (server.isStarting()) {
 155             fail("Test server failed to start after " + MAX_START_WAIT + " ms");
 156         }
 157
 158         final AxPolicyModel apexPolicyModel = new SampleDomainModelFactory().getSamplePolicyModel("JAVASCRIPT");
 159
 160         final BatchDeployer deployer1 = new BatchDeployer("localhost", 58820, System.out);
 161         assertNotNull(deployer1);
 162
 163         deployer1.init();
 164         deployer1.deployModel(apexPolicyModel, false, false);
 165         deployer1.close();
 166
 167         // Send events
 168         final Date testStartTime = new Date();
 169         final Map<String, Object> eventDataMap = new HashMap<>();
 170         eventDataMap.put("TestSlogan", "This is a test slogan");
 171         eventDataMap.put("TestMatchCase", (byte) 123);
 172         eventDataMap.put("TestTimestamp", testStartTime.getTime());
 173         eventDataMap.put("TestTemperature", 34.5445667);
 174
 175         final ApexEvent event0 =
 176                 new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "apex", "test");
 177         event0.putAll(eventDataMap);
 178         server.sendEvent(event0);
 179
 180         final ApexEvent event1 =
 181                 new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "apex", "test");
 182         event1.putAll(eventDataMap);
 183         server.sendEvent(event1);
 184
 185         // Wait for results
 186         while (server.getTotalActionEventsReceived() < 2) {
 187             ThreadUtilities.sleep(100);
 188         }
 189         ThreadUtilities.sleep(500);
 190
 191         assertEquals(2, server.getTotalActionEventsReceived());
 192
 193         deployer1.init();
 194         deployer1.close();
 195
 196         // Test re-initialization of model
 197         final BatchDeployer deployer2 = new BatchDeployer("localhost", 58820, System.out);
 198         assertNotNull(deployer2);
 199
 200         deployer2.init();
 201         deployer2.deployModel(apexPolicyModel, true, true);
 202         deployer2.close();
 203
 204         server.sendEvent(event0);
 205         server.sendEvent(event1);
 206
 207         // Wait for results
 208         while (server.getTotalActionEventsReceived() < 4) {
 209             ThreadUtilities.sleep(100);
 210         }
 211         ThreadUtilities.sleep(500);
 212
 213         assertEquals(4, server.getTotalActionEventsReceived());
 214
 215         deployer2.init();
 216         deployer2.close();
 217
 218         server.stopServer();
 219         LOGGER.debug("engine<-->deployment messaging test finished");
 220     }
 221
 222     /**
 223      * Tear down.
 224      *
 225      * @throws Exception the exception
 226      */
 227     @After
 228     public void tearDown() throws Exception {
 229         ModelService.clear();
 230     }
 231 }