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.websocket;
  21
  22 import static org.junit.Assert.assertEquals;
  23 import static org.junit.Assert.assertNotNull;
  24 import static org.junit.Assert.assertNull;
  25 import org.junit.After;
  26 import org.junit.Before;
  27 import org.junit.Test;
  28 import org.mockito.Mockito;
  29 import org.mockito.MockitoAnnotations;
  30 import org.mockito.stubbing.Answer;
  31 import org.onap.policy.apex.service.engine.event.ApexEventConsumer;
  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 ApexWebSocketProducerTest {
  41
  42     ApexWebSocketProducer apexWebSocketProducer = null;
  43     EventHandlerParameters producerParameters = null;
  44     ApexEventReceiver incomingEventReceiver = null;
  45     ApexEventConsumer apexWebSocketConsumer = null;
  46     WebSocketCarrierTechnologyParameters webSocketCarrierTechnologyParameters = null;
  47     SynchronousEventCache synchronousEventCache = null;
  48     private static final long DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT = 1000;
  49
  50     /**
  51      * Set up testing.
  52      *
  53      * @throws Exception on test set up errors.
  54      */
  55     @Before
  56     public void setUp() throws Exception {
  57         apexWebSocketConsumer = new ApexWebSocketConsumer();
  58         producerParameters = new EventHandlerParameters();
  59         apexWebSocketProducer = new ApexWebSocketProducer();
  60     }
  61
  62     @After
  63     public void tearDown() {
  64         apexWebSocketProducer.stop();
  65     }
  66
  67     @Test(expected = ApexEventException.class)
  68     public void testInitWithNonWebSocketCarrierTechnologyParameters() throws ApexEventException {
  69         producerParameters.setCarrierTechnologyParameters(new CarrierTechnologyParameters() {});
  70         apexWebSocketProducer.init("TestApexWebSocketProducer", producerParameters);
  71     }
  72
  73     @Test
  74     public void testInitWithWebSocketCarrierTechnologyParameters() throws ApexEventException {
  75         webSocketCarrierTechnologyParameters = new WebSocketCarrierTechnologyParameters();
  76         producerParameters.setCarrierTechnologyParameters(webSocketCarrierTechnologyParameters);
  77         apexWebSocketProducer.init("TestApexWebSocketProducer", producerParameters);
  78         assertEquals("TestApexWebSocketProducer", apexWebSocketProducer.getName());
  79     }
  80
  81     @Test
  82     public void testGetName() {
  83         assertNull(apexWebSocketProducer.getName());
  84     }
  85
  86     @Test
  87     public void testGetPeeredReference() {
  88         assertNull(apexWebSocketProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
  89     }
  90
  91     @Test
  92     public void testSetPeeredReference() {
  93         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR,
  94                 apexWebSocketConsumer, apexWebSocketProducer);
  95         apexWebSocketProducer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR, peeredReference);
  96         assertNotNull(apexWebSocketProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
  97     }
  98
  99     @Test(expected = NullPointerException.class)
 100     public void testSendEvent() throws ApexEventException {
 101         producerParameters
 102                 .setCarrierTechnologyParameters(new WebSocketCarrierTechnologyParameters() {});
 103         synchronousEventCache = new SynchronousEventCache(EventHandlerPeeredMode.SYNCHRONOUS,
 104                 apexWebSocketConsumer, apexWebSocketProducer, DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT);
 105         apexWebSocketProducer.setPeeredReference(EventHandlerPeeredMode.SYNCHRONOUS,
 106                 synchronousEventCache);
 107         apexWebSocketProducer.sendEvent(1000L, "TestApexWebSocketProducer", "apexEvent");
 108     }
 109
 110     @Test
 111     public void testReceiveString() {
 112         MockitoAnnotations.initMocks(this);
 113         ApexWebSocketProducer apexWebSocketProducerMock = Mockito.mock(ApexWebSocketProducer.class);
 114
 115         Mockito.doAnswer((Answer<?>) invocation -> {
 116             Object[] args = invocation.getArguments();
 117             assertEquals("TestRecieveString", args[0]);
 118             return null;
 119         }).when(apexWebSocketProducerMock).receiveString("TestRecieveString");
 120
 121         apexWebSocketProducerMock.receiveString("TestRecieveString");
 122     }
 123 }