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 javax.ws.rs.core.Response;
  27 import org.junit.After;
  28 import org.junit.Before;
  29 import org.junit.Test;
  30 import org.onap.policy.apex.service.engine.event.ApexEventException;
  31 import org.onap.policy.apex.service.engine.event.ApexEventReceiver;
  32 import org.onap.policy.apex.service.engine.event.PeeredReference;
  33 import org.onap.policy.apex.service.engine.event.SynchronousEventCache;
  34 import org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters;
  35 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
  36 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode;
  37
  38 public class ApexRestServerConsumerTest {
  39
  40     ApexRestServerConsumer apexRestServerConsumer = null;
  41     EventHandlerParameters consumerParameters = null;
  42     ApexEventReceiver incomingEventReceiver = null;
  43     ApexRestServerProducer apexRestServerProducer = null;
  44     RestServerCarrierTechnologyParameters restServerCarrierTechnologyParameters = null;
  45     SynchronousEventCache synchronousEventCache = null;
  46
  47     /**
  48      * Set up testing.
  49      *
  50      * @throws Exception on test set up errors.
  51      */
  52     @Before
  53     public void setUp() throws Exception {
  54         apexRestServerConsumer = new ApexRestServerConsumer();
  55         consumerParameters = new EventHandlerParameters();
  56         apexRestServerProducer = new ApexRestServerProducer();
  57         apexRestServerConsumer.start();
  58     }
  59
  60     @After
  61     public void tearDown() {
  62         apexRestServerConsumer.stop();
  63     }
  64
  65     @Test(expected = ApexEventException.class)
  66     public void testInitWithNonWebSocketCarrierTechnologyParameters() throws ApexEventException {
  67         consumerParameters.setCarrierTechnologyParameters(new CarrierTechnologyParameters() {});
  68         apexRestServerConsumer.init("TestApexRestServerConsumer", consumerParameters,
  69                 incomingEventReceiver);
  70     }
  71
  72     @Test(expected = ApexEventException.class)
  73     public void testInitWithWebSocketCarrierTechnologyParameters() throws ApexEventException {
  74         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  75         consumerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
  76         apexRestServerConsumer.init("TestApexRestServerConsumer", consumerParameters,
  77                 incomingEventReceiver);
  78     }
  79
  80     @Test(expected = ApexEventException.class)
  81     public void testInitWithSynchronousMode() throws ApexEventException, NoSuchFieldException,
  82             SecurityException, IllegalArgumentException, IllegalAccessException {
  83         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  84         Field field = RestServerCarrierTechnologyParameters.class.getDeclaredField("standalone");
  85         field.setAccessible(true);
  86         field.set(restServerCarrierTechnologyParameters, true);
  87         consumerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
  88         consumerParameters.setPeeredMode(EventHandlerPeeredMode.SYNCHRONOUS, true);
  89         apexRestServerConsumer.init("TestApexRestServerConsumer", consumerParameters,
  90                 incomingEventReceiver);
  91     }
  92
  93     @Test(expected = IllegalStateException.class)
  94     public void testInitWithSynchronousModeAndProperValues()
  95             throws ApexEventException, NoSuchFieldException, SecurityException,
  96             IllegalArgumentException, IllegalAccessException {
  97
  98         restServerCarrierTechnologyParameters = new RestServerCarrierTechnologyParameters();
  99
 100         Field field = RestServerCarrierTechnologyParameters.class.getDeclaredField("standalone");
 101         field.setAccessible(true);
 102         field.set(restServerCarrierTechnologyParameters, true);
 103         field = RestServerCarrierTechnologyParameters.class.getDeclaredField("host");
 104         field.setAccessible(true);
 105         field.set(restServerCarrierTechnologyParameters, "1ocalhost");
 106         field = RestServerCarrierTechnologyParameters.class.getDeclaredField("port");
 107         field.setAccessible(true);
 108         field.set(restServerCarrierTechnologyParameters, 65535);
 109
 110         consumerParameters.setCarrierTechnologyParameters(restServerCarrierTechnologyParameters);
 111         consumerParameters.setPeeredMode(EventHandlerPeeredMode.SYNCHRONOUS, true);
 112         apexRestServerConsumer.init("TestApexRestServerConsumer", consumerParameters,
 113                 incomingEventReceiver);
 114     }
 115
 116     @Test
 117     public void testGetName() {
 118         assertNull(apexRestServerConsumer.getName());
 119     }
 120
 121     @Test
 122     public void testGetPeeredReference() {
 123         assertNull(apexRestServerConsumer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
 124     }
 125
 126     @Test
 127     public void testSetPeeredReference() {
 128         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR,
 129                 apexRestServerConsumer, apexRestServerProducer);
 130         apexRestServerConsumer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR,
 131                 peeredReference);
 132         assertNotNull(apexRestServerConsumer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
 133     }
 134
 135     @Test
 136     public void testReceiveEvent() throws ApexEventException {
 137         Response response = apexRestServerConsumer.receiveEvent("");
 138         assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
 139     }
 140
 141     @Test(expected = NullPointerException.class)
 142     public void testReceiveEventWithNonDefaultValues()
 143             throws ApexEventException, NoSuchFieldException, SecurityException,
 144             IllegalArgumentException, IllegalAccessException {
 145
 146         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR,
 147                 apexRestServerConsumer, apexRestServerProducer);
 148         apexRestServerConsumer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR,
 149                 peeredReference);
 150
 151         ApexEventReceiver apexEventReceiver = new SupportApexEventReceiver();
 152
 153         Field field = ApexRestServerConsumer.class.getDeclaredField("eventReceiver");
 154         field.setAccessible(true);
 155         field.set(apexRestServerConsumer, apexEventReceiver);
 156         field = ApexRestServerConsumer.class.getDeclaredField("name");
 157         field.setAccessible(true);
 158         field.set(apexRestServerConsumer, "TestApexRestServerConsumer");
 159
 160         apexRestServerConsumer.receiveEvent("TestApexRestServerConsumer");
 161
 162     }
 163
 164
 165 }