gerrit.onap Code Review - ccsdk/sli.git/blob

   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         assertNotNull(dummy);\r
  62     }\r
  63 \r
  64     @Test\r
  65     public void registerDummyHandler() throws Exception {\r
  66         DummyConsumer dummy = getAuthDummy();\r
  67         String topic = "politics";\r
  68         RequestHandler requestHandler = new RequestHandler() {\r
  69 \r
  70             @Override\r
  71             public void handleRequest(String topic, String requestBody) {\r
  72                 // TODO Auto-generated method stub\r
  73 \r
  74             };\r
  75 \r
  76         };\r
  77         dummy.registerHandler(topic, requestHandler);\r
  78         assertEquals(new URL("http://localhost:7001/events/politics/myCluster/node1?timeout=5000&limit=3"), dummy.url);\r
  79         assertEquals(topic, dummy.topic);\r
  80 \r
  81     }\r
  82 \r
  83     @Test\r
  84     public void buildURL() throws Exception {\r
  85         DummyConsumer dummy = getAuthDummy();\r
  86         HttpURLConnection connection = dummy.buildHttpURLConnection(new URL("http://localhost:7001/events/politics/myCluster/node1?timeout=5000&limit=3"));\r
  87         assertNotNull(connection);\r
  88         assertEquals("application/json", connection.getRequestProperty("Accept"));\r
  89     }\r
  90 \r
  91 }\r