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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2018 Ericsson. All rights reserved.
   4  *  Modifications Copyright (C) 2020 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.restrequestor;
  23
  24 import static org.assertj.core.api.Assertions.assertThatThrownBy;
  25 import static org.junit.Assert.assertEquals;
  26 import static org.junit.Assert.assertNotNull;
  27 import static org.junit.Assert.fail;
  28
  29 import org.junit.Test;
  30 import org.onap.policy.apex.service.engine.event.ApexEventConsumer;
  31 import org.onap.policy.apex.service.engine.event.ApexEventException;
  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.engine.event.impl.filecarrierplugin.consumer.ApexFileEventConsumer;
  35 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
  36 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode;
  37
  38 /**
  39  * Test the ApexRestRequestorProducer class.
  40  */
  41 public class ApexRestRequestorProducerTest {
  42     // String constants
  43     private static final String PRODUCER_NAME = "ProducerName";
  44
  45     @Test
  46     public void testApexRestRequestorProducerMethods() throws ApexEventException {
  47         ApexRestRequestorProducer producer = new ApexRestRequestorProducer();
  48         assertNotNull(producer);
  49
  50         EventHandlerParameters producerParameters = new EventHandlerParameters();
  51
  52         assertThatThrownBy(() -> {
  53             producer.init(PRODUCER_NAME, producerParameters);
  54         }).hasMessage("specified producer properties are not applicable to REST requestor producer (ProducerName)");
  55
  56         RestRequestorCarrierTechnologyParameters rrctp = new RestRequestorCarrierTechnologyParameters();
  57         producerParameters.setCarrierTechnologyParameters(rrctp);
  58         assertThatThrownBy(() -> {
  59             producer.init(PRODUCER_NAME, producerParameters);
  60         }).hasMessage("REST Requestor producer (ProducerName) must run in peered requestor mode "
  61             + "with a REST Requestor consumer");
  62
  63         producerParameters.setPeeredMode(EventHandlerPeeredMode.REQUESTOR, true);
  64         rrctp.setUrl("ZZZZ");
  65         assertThatThrownBy(() -> {
  66             producer.init(PRODUCER_NAME, producerParameters);
  67         }).hasMessage("URL may not be specified on REST Requestor producer (ProducerName)");
  68
  69         rrctp.setUrl(null);
  70         rrctp.setHttpMethod(RestRequestorCarrierTechnologyParameters.HttpMethod.GET);
  71
  72         assertThatThrownBy(() -> {
  73             producer.init(PRODUCER_NAME, producerParameters);
  74             fail("test should throw an exception here");
  75         }).hasMessage("HTTP method may not be specified on REST Requestor producer (ProducerName)");
  76
  77         rrctp.setHttpMethod(null);
  78         producer.init(PRODUCER_NAME, producerParameters);
  79         producer.stop();
  80
  81         assertEquals(PRODUCER_NAME, producer.getName());
  82         assertEquals(0, producer.getEventsSent());
  83         assertEquals(null, producer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
  84     }
  85
  86     @Test
  87     public void testApexRestRequestorProducerRequest() throws ApexEventException {
  88         EventHandlerParameters producerParameters = new EventHandlerParameters();
  89
  90         RestRequestorCarrierTechnologyParameters rrctp = new RestRequestorCarrierTechnologyParameters();
  91         producerParameters.setCarrierTechnologyParameters(rrctp);
  92         producerParameters.setPeeredMode(EventHandlerPeeredMode.REQUESTOR, true);
  93         rrctp.setUrl(null);
  94         rrctp.setHttpMethod(null);
  95
  96         ApexRestRequestorProducer producer = new ApexRestRequestorProducer();
  97         producer.init(PRODUCER_NAME, producerParameters);
  98         producer.stop();
  99
 100         String eventName = "EventName";
 101         String event = "This is the event";
 102
 103         assertThatThrownBy(() -> {
 104             producer.sendEvent(12345, null, eventName, event);
 105         }).hasMessage("send of event failed, REST response consumer is not defined\n" + "This is the event");
 106
 107         ApexEventConsumer consumer = new ApexFileEventConsumer();
 108         SynchronousEventCache eventCache =
 109             new SynchronousEventCache(EventHandlerPeeredMode.SYNCHRONOUS, consumer, producer, 1000);
 110         producer.setPeeredReference(EventHandlerPeeredMode.SYNCHRONOUS, eventCache);
 111
 112         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR, consumer, producer);
 113         producer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR, peeredReference);
 114         assertThatThrownBy(() -> {
 115             producer.sendEvent(12345, null, eventName, event);
 116         }).hasMessage("send of event failed, REST response consumer "
 117             + "is not an instance of ApexRestRequestorConsumer\n" + "This is the event");
 118     }
 119 }