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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Samsung. All rights reserved.
   4  *  Modifications Copyright (C) 2019 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.plugins.event.carrier.restserver;
  23
  24 import static org.junit.Assert.assertEquals;
  25 import static org.junit.Assert.assertNotNull;
  26 import static org.junit.Assert.assertNull;
  27
  28 import java.lang.reflect.Field;
  29 import org.junit.After;
  30 import org.junit.Before;
  31 import org.junit.Test;
  32 import org.onap.policy.apex.service.engine.event.ApexEventException;
  33 import org.onap.policy.apex.service.engine.event.ApexEventReceiver;
  34 import org.onap.policy.apex.service.engine.event.PeeredReference;
  35 import org.onap.policy.apex.service.engine.event.SynchronousEventCache;
  36 import org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters;
  37 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
  38 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode;
  39
  40 public class ApexRestServerProducerTest {
  41
  42     ApexRestServerProducer apexRestServerProducer = null;
  43     EventHandlerParameters producerParameters = null;
  44     ApexEventReceiver incomingEventReceiver = null;
  45     ApexRestServerConsumer apexRestServerConsumer = null;
  46     RestServerCarrierTechnologyParameters restServerCarrierTechnologyParameters = null;
  47     SynchronousEventCache synchronousEventCache = null;
  48
  49     /**
  50      * Set up testing.
  51      *
  52      * @throws Exception on test set up errors.
  53      */
  54     @Before
  55     public void setUp() throws Exception {
  56         apexRestServerConsumer = new ApexRestServerConsumer();
  57         producerParameters = new EventHandlerParameters();
  58         apexRestServerProducer = new ApexRestServerProducer();
  59     }
  60
  61     @After
  62     public void tearDown() {
  63         apexRestServerProducer.stop();
  64     }
  65
  66     @Test(expected = ApexEventException.class)
  67     public void testInitWithNonWebSocketCarrierTechnologyParameters() throws ApexEventException {
  68         producerParameters.setCarrierTechnologyParameters(new CarrierTechnologyParameters() {});
  69         apexRestServerProducer.init("TestApexRestServerProducer", producerParameters);
  70     }
  71
  72     @Test(expected = ApexEventException.class)
  73     public void testInitWithWebSocketCarrierTechnologyParameters() throws ApexEventException {
  74         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  75         producerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
  76         apexRestServerProducer.init("TestApexRestServerProducer", producerParameters);
  77     }
  78
  79
  80     @Test(expected = ApexEventException.class)
  81     public void testInitWithNonDefaultValue() throws ApexEventException, NoSuchFieldException,
  82             SecurityException, IllegalArgumentException, IllegalAccessException {
  83         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  84         Field field = RestServerCarrierTechnologyParameters.class.getDeclaredField("host");
  85         field.setAccessible(true);
  86         field.set(restServerCarrierTechnologyParameters, "1ocalhost");
  87         field = RestServerCarrierTechnologyParameters.class.getDeclaredField("port");
  88         field.setAccessible(true);
  89         field.set(restServerCarrierTechnologyParameters, 65535);
  90         producerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
  91         apexRestServerProducer.init("TestApexRestServerProducer", producerParameters);
  92     }
  93
  94     @Test
  95     public void testInitWithSynchronousMode() throws ApexEventException {
  96         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  97         producerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
  98         producerParameters.setPeeredMode(EventHandlerPeeredMode.SYNCHRONOUS, true);
  99         apexRestServerProducer.init("TestApexRestServerProducer", producerParameters);
 100         assertEquals("TestApexRestServerProducer", apexRestServerProducer.getName());
 101     }
 102
 103     @Test
 104     public void testGetName() {
 105         assertNull(apexRestServerProducer.getName());
 106     }
 107
 108     @Test
 109     public void testGetPeeredReference() {
 110         assertNull(apexRestServerProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
 111     }
 112
 113     @Test
 114     public void testSetPeeredReference() {
 115         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR,
 116                 apexRestServerConsumer, apexRestServerProducer);
 117         apexRestServerProducer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR,
 118                 peeredReference);
 119         assertNotNull(apexRestServerProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
 120     }
 121 }