message-router/consumer/provider/src/test/java/org/onap/ccsdk/sli/adaptors/messagerouter/consumer/provider/impl/AbstractBaseConsumerTest.java

   1 package org.onap.ccsdk.sli.adaptors.messagerouter.consumer.provider.impl;\r
   2 \r
   3 import static org.junit.Assert.assertEquals;\r
   4 import static org.junit.Assert.assertNotNull;\r
   5 \r
   6 import java.net.HttpURLConnection;\r
   7 import java.net.URL;\r
   8 \r
   9 import org.junit.Test;\r
  10 import org.onap.ccsdk.sli.adaptors.messagerouter.consumer.api.RequestHandler;\r
  11 \r
  12 public class AbstractBaseConsumerTest {\r
  13     private class DummyConsumer extends AbstractBaseConsumer {\r
  14 \r
  15         public DummyConsumer(String username, String password, String host, String authentication, Integer connectTimeout, Integer readTimeout, String group, String id, String filter, Integer limit, Integer timeoutQueryParamValue) {\r
  16             super(username, password, host, authentication, connectTimeout, readTimeout, group, id, filter, limit, timeoutQueryParamValue);\r
  17         }\r
  18 \r
  19     }\r
  20 \r
  21     public DummyConsumer getAuthDummy() {\r
  22         String username = "deadpool";\r
  23         String password = "notSECURE";\r
  24         String host = "http://localhost:7001";\r
  25         String group = "myCluster";\r
  26         String id = "node1";\r
  27         Integer connectTimeout = 10000;\r
  28         Integer readTimeout = 20000;\r
  29         String authentication = "basic";\r
  30         String filter = null;\r
  31         Integer limit = 3;\r
  32         Integer timeoutQueryParamValue = 5000;\r
  33         return new DummyConsumer(username, password, host, authentication, connectTimeout, readTimeout, group, id, filter, limit, timeoutQueryParamValue);\r
  34     }\r
  35 \r
  36     @Test\r
  37     public void createDummyWithAuth() {\r
  38         assertNotNull(getAuthDummy());\r
  39     }\r
  40 \r
  41     @Test\r
  42     public void createDummyNohAuth() {\r
  43         String username = null;\r
  44         String password = null;\r
  45         String host = "http://localhost:7001";\r
  46         String group = "myCluster";\r
  47         String id = "node1";\r
  48         Integer connectTimeout = 10000;\r
  49         Integer readTimeout = 20000;\r
  50         String authentication = "noauth";\r
  51         String filter = null;\r
  52         Integer limit = 3;\r
  53         Integer timeoutQueryParamValue = 5000;\r
  54         assertNotNull(new DummyConsumer(username, password, host, authentication, connectTimeout, readTimeout, group, id, filter, limit, timeoutQueryParamValue));\r
  55     }\r
  56 \r
  57     @Test\r
  58     public void callClose() throws Exception {\r
  59         DummyConsumer dummy = getAuthDummy();\r
  60         dummy.close();\r
  61     }\r
  62 \r
  63     @Test\r
  64     public void registerDummyHandler() throws Exception {\r
  65         DummyConsumer dummy = getAuthDummy();\r
  66         String topic = "politics";\r
  67         RequestHandler requestHandler = new RequestHandler() {\r
  68 \r
  69             @Override\r
  70             public void handleRequest(String topic, String requestBody) {\r
  71                 // TODO Auto-generated method stub\r
  72 \r
  73             };\r
  74 \r
  75         };\r
  76         dummy.registerHandler(topic, requestHandler);\r
  77         assertEquals(new URL("http://localhost:7001/events/politics/myCluster/node1?timeout=5000&limit=3"), dummy.url);\r
  78         assertEquals(topic, dummy.topic);\r
  79 \r
  80     }\r
  81 \r
  82     @Test\r
  83     public void buildURL() throws Exception {\r
  84         DummyConsumer dummy = getAuthDummy();\r
  85         HttpURLConnection connection = dummy.buildHttpURLConnection(new URL("http://localhost:7001/events/politics/myCluster/node1?timeout=5000&limit=3"));\r
  86         assertNotNull(connection);\r
  87         assertEquals("application/json", connection.getRequestProperty("Accept"));\r
  88     }\r
  89 \r
  90 }\r