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

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