sparkybe-onap-service/src/test/java/org/onap/aai/sparky/subscription/SubscriptionServiceProcessorTest.java

   1 package org.onap.aai.sparky.subscription;
   2
   3 import org.apache.camel.Exchange;
   4 import org.apache.camel.Message;
   5 import org.apache.camel.component.restlet.RestletConstants;
   6 import org.junit.Before;
   7 import org.junit.Test;
   8 import org.mockito.Mockito;
   9 import org.onap.aai.sparky.subscription.services.SubscriptionService;
  10 import org.onap.aai.sparky.util.RestletUtils;
  11 import org.restlet.Request;
  12 import org.restlet.Response;
  13 import org.restlet.data.ClientInfo;
  14
  15 public class SubscriptionServiceProcessorTest {
  16   private SubscriptionServiceProcessor subscriptionProcessor;
  17   private Exchange mockExchange;
  18   private Message mockRequestMessage;
  19   private Message mockResponseMessage;
  20   private Request mockRestletRequest;
  21   private Response mockRestletResponse;
  22   private ClientInfo requestClientInfo;
  23   private RestletUtils mockRestletUtils;
  24   private SubscriptionService mockSubscriptionService;
  25
  26
  27   @Before
  28   public void init() throws Exception {
  29
  30     mockExchange = Mockito.mock(Exchange.class);
  31     mockRequestMessage = Mockito.mock(Message.class);
  32     mockResponseMessage = Mockito.mock(Message.class);
  33     mockRestletRequest = Mockito.mock(Request.class);
  34     mockRestletResponse = Mockito.mock(Response.class);
  35     mockRestletUtils = Mockito.mock(RestletUtils.class);
  36     mockSubscriptionService = Mockito.mock(SubscriptionService.class);
  37     subscriptionProcessor = new SubscriptionServiceProcessor(mockSubscriptionService);
  38
  39     requestClientInfo = new ClientInfo();
  40
  41     Mockito.when(mockExchange.getIn()).thenReturn(mockRequestMessage);
  42     Mockito.when(mockExchange.getOut()).thenReturn(mockResponseMessage);
  43
  44     Mockito.when(mockRequestMessage.getHeader(RestletConstants.RESTLET_REQUEST, Request.class))
  45         .thenReturn(mockRestletRequest);
  46
  47     Mockito.when(mockRestletRequest.getClientInfo()).thenReturn(requestClientInfo);
  48
  49
  50     Mockito.when(mockRequestMessage.getHeader(RestletConstants.RESTLET_RESPONSE, Response.class))
  51         .thenReturn(mockRestletResponse);
  52
  53
  54   }
  55
  56   @Test(expected = NullPointerException.class)
  57   public void testGetEntityCountHistory_success() {
  58
  59     subscriptionProcessor.getSubscription(mockExchange);
  60
  61   }
  62
  63 }