gerrit.onap Code Review - policy/apex-pdp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.apex.service.engine.event;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.junit.Assert.assertTrue;
  26 import static org.junit.Assert.fail;
  27
  28 import java.io.ByteArrayInputStream;
  29 import java.io.IOException;
  30 import java.util.Date;
  31 import java.util.HashMap;
  32 import java.util.List;
  33 import java.util.Map;
  34
  35 import org.junit.Before;
  36 import org.junit.BeforeClass;
  37 import org.junit.Test;
  38 import org.onap.policy.apex.context.parameters.SchemaParameters;
  39 import org.onap.policy.apex.model.basicmodel.concepts.ApexException;
  40 import org.onap.policy.apex.model.basicmodel.handling.ApexModelException;
  41 import org.onap.policy.apex.model.basicmodel.handling.ApexModelReader;
  42 import org.onap.policy.apex.model.basicmodel.service.ModelService;
  43 import org.onap.policy.apex.model.eventmodel.concepts.AxEvent;
  44 import org.onap.policy.apex.model.eventmodel.concepts.AxEvents;
  45 import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
  46 import org.onap.policy.apex.model.utilities.TextFileUtils;
  47 import org.onap.policy.apex.service.engine.event.impl.jsonprotocolplugin.Apex2JSONEventConverter;
  48 import org.onap.policy.apex.service.engine.event.impl.jsonprotocolplugin.JSONEventProtocolParameters;
  49 import org.slf4j.ext.XLogger;
  50 import org.slf4j.ext.XLoggerFactory;
  51
  52 /**
  53  * @author Liam Fallon (liam.fallon@ericsson.com)
  54  */
  55 public class TestJSONEventHandler {
  56     private static final XLogger logger = XLoggerFactory.getXLogger(TestJSONEventHandler.class);
  57
  58     @BeforeClass
  59     public static void setupEventModel() throws IOException, ApexModelException {
  60         final String policyModelString =
  61                 TextFileUtils.getTextFileAsString("src/test/resources/policymodels/SamplePolicyModelMVEL.json");
  62         final ApexModelReader<AxPolicyModel> modelReader = new ApexModelReader<AxPolicyModel>(AxPolicyModel.class);
  63         final AxPolicyModel apexPolicyModel = modelReader.read(new ByteArrayInputStream(policyModelString.getBytes()));
  64
  65         // Set up the models in the model service
  66         apexPolicyModel.register();
  67     }
  68
  69     @Before
  70     public void initializeDefaultSchemaParameters() {
  71         new SchemaParameters();
  72     }
  73
  74     @Test
  75     public void testJSONtoApexEvent() throws ApexException {
  76         try {
  77             final Apex2JSONEventConverter jsonEventConverter = new Apex2JSONEventConverter();
  78             assertNotNull(jsonEventConverter);
  79             jsonEventConverter.init(new JSONEventProtocolParameters());
  80
  81             final String apexEventJSONStringIn = JSONEventGenerator.jsonEvent();
  82
  83             logger.debug("input event\n" + apexEventJSONStringIn);
  84
  85             final List<ApexEvent> apexEventList = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
  86             for (final ApexEvent apexEvent : apexEventList) {
  87                 assertNotNull(apexEvent);
  88
  89                 logger.debug(apexEvent.toString());
  90
  91                 assertTrue(apexEvent.getName().equals("Event0000") || apexEvent.getName().equals("Event0100"));
  92                 assertTrue(apexEvent.getVersion().equals("0.0.1"));
  93                 assertTrue(apexEvent.getNameSpace().equals("org.onap.policy.apex.sample.events"));
  94                 assertTrue(apexEvent.getSource().equals("test"));
  95                 assertTrue(apexEvent.getTarget().equals("apex"));
  96                 assertTrue(apexEvent.get("TestSlogan").toString().startsWith("Test slogan for External Event"));
  97
  98                 final Object testMatchCaseSelected = apexEvent.get("TestMatchCaseSelected");
  99                 assertTrue(testMatchCaseSelected == null);
 100             }
 101         } catch (final Exception e) {
 102             e.printStackTrace();
 103             throw new ApexException("Exception reading Apex event JSON file", e);
 104         }
 105     }
 106
 107     @Test
 108     public void testJSONtoApexBadEvent() throws ApexException {
 109         try {
 110             final Apex2JSONEventConverter jsonEventConverter = new Apex2JSONEventConverter();
 111             assertNotNull(jsonEventConverter);
 112             jsonEventConverter.init(new JSONEventProtocolParameters());
 113
 114             String apexEventJSONStringIn = null;
 115
 116             try {
 117                 apexEventJSONStringIn = JSONEventGenerator.jsonEventNoName();
 118                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 119                 fail("Test should throw an exception here");
 120             } catch (final ApexEventException e) {
 121                 assertEquals("Failed to unmarshal JSON event: event received without mandatory parameter \"name\" ",
 122                         e.getMessage().substring(0, 82));
 123             }
 124
 125             try {
 126                 apexEventJSONStringIn = JSONEventGenerator.jsonEventBadName();
 127                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 128                 fail("Test should throw an exception here");
 129             } catch (final ApexEventException e) {
 130                 assertTrue(e.getMessage()
 131                         .startsWith("Failed to unmarshal JSON event: field \"name\" with value \"%%%%\" is invalid"));
 132             }
 133
 134             try {
 135                 apexEventJSONStringIn = JSONEventGenerator.jsonEventNoExName();
 136                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 137                 fail("Test should throw an exception here");
 138             } catch (final ApexEventException e) {
 139                 assertEquals("Failed to unmarshal JSON event: an event definition for an event named \"I_DONT_EXI",
 140                         e.getMessage().substring(0, 82));
 141             }
 142
 143             apexEventJSONStringIn = JSONEventGenerator.jsonEventNoVersion();
 144             ApexEvent event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 145             assertEquals("0.0.1", event.getVersion());
 146
 147             try {
 148                 apexEventJSONStringIn = JSONEventGenerator.jsonEventBadVersion();
 149                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 150                 fail("Test should throw an exception here");
 151             } catch (final ApexEventException e) {
 152                 assertTrue(e.getMessage().startsWith(
 153                         "Failed to unmarshal JSON event: field \"version\" with value \"#####\" is invalid"));
 154             }
 155
 156             try {
 157                 apexEventJSONStringIn = JSONEventGenerator.jsonEventNoExVersion();
 158                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 159                 fail("Test should throw an exception here");
 160             } catch (final ApexEventException e) {
 161                 assertTrue(e.getMessage().startsWith(
 162                         "Failed to unmarshal JSON event: an event definition for an event named \"Event0000\" with version \"1.2.3\" not found in Apex model"));
 163             }
 164
 165             apexEventJSONStringIn = JSONEventGenerator.jsonEventNoNamespace();
 166             event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 167             assertEquals("org.onap.policy.apex.sample.events", event.getNameSpace());
 168
 169             try {
 170                 apexEventJSONStringIn = JSONEventGenerator.jsonEventBadNamespace();
 171                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 172                 fail("Test should throw an exception here");
 173             } catch (final ApexEventException e) {
 174                 assertTrue(e.getMessage().startsWith(
 175                         "Failed to unmarshal JSON event: field \"nameSpace\" with value \"hello.&&&&\" is invalid"));
 176             }
 177
 178             try {
 179                 apexEventJSONStringIn = JSONEventGenerator.jsonEventNoExNamespace();
 180                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 181                 fail("Test should throw an exception here");
 182             } catch (final ApexEventException e) {
 183                 assertTrue(e.getMessage().startsWith(
 184                         "Failed to unmarshal JSON event: namespace \"pie.in.the.sky\" on event \"Event0000\" "
 185                                 + "does not match namespace \"org.onap.policy.apex.sample.events\" for that event in the Apex model"));
 186             }
 187
 188             apexEventJSONStringIn = JSONEventGenerator.jsonEventNoSource();
 189             event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 190             assertEquals("Outside", event.getSource());
 191
 192             try {
 193                 apexEventJSONStringIn = JSONEventGenerator.jsonEventBadSource();
 194                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 195                 fail("Test should throw an exception here");
 196             } catch (final ApexEventException e) {
 197                 assertTrue(e.getMessage().startsWith(
 198                         "Failed to unmarshal JSON event: field \"source\" with value \"%!@**@!\" is invalid"));
 199             }
 200
 201             apexEventJSONStringIn = JSONEventGenerator.jsonEventNoTarget();
 202             event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 203             assertEquals("Match", event.getTarget());
 204
 205             try {
 206                 apexEventJSONStringIn = JSONEventGenerator.jsonEventBadTarget();
 207                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 208                 fail("Test should throw an exception here");
 209             } catch (final ApexEventException e) {
 210                 assertTrue(e.getMessage().startsWith(
 211                         "Failed to unmarshal JSON event: field \"target\" with value \"KNIO(*S)A(S)D\" is invalid"));
 212             }
 213
 214             try {
 215                 apexEventJSONStringIn = JSONEventGenerator.jsonEventMissingFields();
 216                 jsonEventConverter.toApexEvent(null, apexEventJSONStringIn);
 217                 fail("Test should throw an exception here");
 218             } catch (final ApexEventException e) {
 219                 assertTrue(e.getMessage().startsWith("Failed to unmarshal JSON event: error parsing Event0000:0.0.1 "
 220                         + "event from Json. Field \"TestMatchCase\" is missing, but is mandatory."));
 221             }
 222
 223             apexEventJSONStringIn = JSONEventGenerator.jsonEventNullFields();
 224             event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 225             assertEquals(event.get("TestSlogan"), null);
 226             assertEquals(event.get("TestMatchCase"), (byte) -1);
 227             assertEquals(event.get("TestTimestamp"), (long) -1);
 228             assertEquals(event.get("TestTemperature"), -1.0);
 229
 230             // Set the missing fields as optional in the model
 231             final AxEvent eventDefinition = ModelService.getModel(AxEvents.class).get("Event0000");
 232             eventDefinition.getParameterMap().get("TestSlogan").setOptional(true);
 233             eventDefinition.getParameterMap().get("TestMatchCase").setOptional(true);
 234             eventDefinition.getParameterMap().get("TestTimestamp").setOptional(true);
 235             eventDefinition.getParameterMap().get("TestTemperature").setOptional(true);
 236
 237             apexEventJSONStringIn = JSONEventGenerator.jsonEventMissingFields();
 238             event = jsonEventConverter.toApexEvent(null, apexEventJSONStringIn).get(0);
 239             assertEquals(null, event.get("TestSlogan"));
 240             assertEquals(null, event.get("TestMatchCase"));
 241             assertEquals(null, event.get("TestTimestamp"));
 242             assertEquals(null, event.get("TestTemperature"));
 243         } catch (final Exception e) {
 244             e.printStackTrace();
 245             throw new ApexException("Exception reading Apex event JSON file", e);
 246         }
 247     }
 248
 249     @Test
 250     public void testApexEventToJSON() throws ApexException {
 251         try {
 252             final Apex2JSONEventConverter jsonEventConverter = new Apex2JSONEventConverter();
 253             assertNotNull(jsonEventConverter);
 254
 255             final Date event0000StartTime = new Date();
 256             final Map<String, Object> event0000DataMap = new HashMap<String, Object>();
 257             event0000DataMap.put("TestSlogan", "This is a test slogan");
 258             event0000DataMap.put("TestMatchCase", 12345);
 259             event0000DataMap.put("TestTimestamp", event0000StartTime.getTime());
 260             event0000DataMap.put("TestTemperature", 34.5445667);
 261
 262             final ApexEvent apexEvent0000 =
 263                     new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.sample.events", "test", "apex");
 264             apexEvent0000.putAll(event0000DataMap);
 265
 266             final String apexEvent0000JSONString = (String) jsonEventConverter.fromApexEvent(apexEvent0000);
 267
 268             logger.debug(apexEvent0000JSONString);
 269
 270             assertTrue(apexEvent0000JSONString.contains("\"name\": \"Event0000\""));
 271             assertTrue(apexEvent0000JSONString.contains("\"version\": \"0.0.1\""));
 272             assertTrue(apexEvent0000JSONString.contains("\"nameSpace\": \"org.onap.policy.apex.sample.events\""));
 273             assertTrue(apexEvent0000JSONString.contains("\"source\": \"test\""));
 274             assertTrue(apexEvent0000JSONString.contains("\"target\": \"apex\""));
 275             assertTrue(apexEvent0000JSONString.contains("\"TestSlogan\": \"This is a test slogan\""));
 276             assertTrue(apexEvent0000JSONString.contains("\"TestMatchCase\": 12345"));
 277             assertTrue(apexEvent0000JSONString.contains("\"TestTimestamp\": " + event0000StartTime.getTime()));
 278             assertTrue(apexEvent0000JSONString.contains("\"TestTemperature\": 34.5445667"));
 279
 280             final Date event0004StartTime = new Date(1434363272000L);
 281             final Map<String, Object> event0004DataMap = new HashMap<String, Object>();
 282             event0004DataMap.put("TestSlogan", "Test slogan for External Event");
 283             event0004DataMap.put("TestMatchCase", new Integer(2));
 284             event0004DataMap.put("TestTimestamp", new Long(event0004StartTime.getTime()));
 285             event0004DataMap.put("TestTemperature", new Double(1064.43));
 286             event0004DataMap.put("TestMatchCaseSelected", new Integer(2));
 287             event0004DataMap.put("TestMatchStateTime", new Long(1434370506078L));
 288             event0004DataMap.put("TestEstablishCaseSelected", new Integer(0));
 289             event0004DataMap.put("TestEstablishStateTime", new Long(1434370506085L));
 290             event0004DataMap.put("TestDecideCaseSelected", new Integer(3));
 291             event0004DataMap.put("TestDecideStateTime", new Long(1434370506092L));
 292             event0004DataMap.put("TestActCaseSelected", new Integer(2));
 293             event0004DataMap.put("TestActStateTime", new Long(1434370506095L));
 294
 295             final ApexEvent apexEvent0004 =
 296                     new ApexEvent("Event0004", "0.0.1", "org.onap.policy.apex.sample.events", "test", "apex");
 297             apexEvent0004.putAll(event0004DataMap);
 298
 299             final String apexEvent0004JSONString = (String) jsonEventConverter.fromApexEvent(apexEvent0004);
 300
 301             logger.debug(apexEvent0004JSONString);
 302
 303             assertTrue(apexEvent0004JSONString.contains("\"name\": \"Event0004\""));
 304             assertTrue(apexEvent0004JSONString.contains("\"version\": \"0.0.1\""));
 305             assertTrue(apexEvent0004JSONString.contains("\"nameSpace\": \"org.onap.policy.apex.sample.events\""));
 306             assertTrue(apexEvent0004JSONString.contains("\"source\": \"test\""));
 307             assertTrue(apexEvent0004JSONString.contains("\"target\": \"apex\""));
 308             assertTrue(apexEvent0004JSONString.contains("\"TestSlogan\": \"Test slogan for External Event\""));
 309             assertTrue(apexEvent0004JSONString.contains("1434370506078"));
 310             assertTrue(apexEvent0004JSONString.contains("1064.43"));
 311         } catch (final Exception e) {
 312             e.printStackTrace();
 313             throw new ApexException("Exception reading Apex event JSON file", e);
 314         }
 315     }
 316 }