gerrit.onap Code Review - policy/common.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP Policy Engine - Common Modules
   4  * ================================================================================
   5  * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.common.endpoints.event.comm.bus;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.junit.Assert.assertTrue;
  26 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_SOURCE_TOPICS;
  27 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX;
  28 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX;
  29
  30 import java.util.Deque;
  31 import java.util.LinkedList;
  32 import java.util.List;
  33 import java.util.Properties;
  34 import org.junit.After;
  35 import org.junit.Before;
  36 import org.junit.Test;
  37 import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams;
  38
  39 public class DmaapTopicSourceFactoryTest extends DmaapTopicFactoryTestBase<DmaapTopicSource> {
  40
  41     private SourceFactory factory;
  42
  43     /**
  44      * Creates the object to be tested.
  45      */
  46     @Before
  47     @Override
  48     public void setUp() {
  49         super.setUp();
  50
  51         factory = new SourceFactory();
  52     }
  53
  54     @After
  55     public void tearDown() {
  56         factory.destroy();
  57     }
  58
  59     @Test
  60     @Override
  61     public void testBuildBusTopicParams() {
  62         super.testBuildBusTopicParams();
  63         super.testBuildBusTopicParams_Ex();
  64     }
  65
  66     @Test
  67     @Override
  68     public void testBuildProperties() {
  69         super.testBuildProperties();
  70
  71         // check source-specific parameters that were used
  72         BusTopicParams params = factory.params.getFirst();
  73         assertEquals(MY_CONS_GROUP, params.getConsumerGroup());
  74         assertEquals(MY_CONS_INST, params.getConsumerInstance());
  75         assertEquals(MY_FETCH_LIMIT, params.getFetchLimit());
  76         assertEquals(MY_FETCH_TIMEOUT, params.getFetchTimeout());
  77
  78         super.testBuildProperties_Variations();
  79         super.testBuildProperties_Multiple();
  80
  81         // check default values for source-specific parameters
  82         checkDefault(PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX,
  83             params2 -> params2.getFetchLimit() == DmaapTopicSource.DEFAULT_LIMIT_FETCH,
  84             null, "", "invalid-limit-number");
  85
  86         checkDefault(PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX,
  87             params2 -> params2.getFetchTimeout() == DmaapTopicSource.DEFAULT_TIMEOUT_MS_FETCH,
  88             null, "", "invalid-timeout-number");
  89     }
  90
  91     @Test
  92     public void testBuildListOfStringStringStringString() {
  93         DmaapTopicSource source1 = factory.build(servers, MY_TOPIC, MY_API_KEY, MY_API_SECRET);
  94         assertNotNull(source1);
  95
  96         // check source-specific parameters that were used
  97         BusTopicParams params = factory.params.getFirst();
  98         assertEquals(MY_API_KEY, params.getApiKey());
  99         assertEquals(MY_API_SECRET, params.getApiSecret());
 100         assertEquals(DmaapTopicSource.DEFAULT_LIMIT_FETCH, params.getFetchLimit());
 101         assertEquals(DmaapTopicSource.DEFAULT_TIMEOUT_MS_FETCH, params.getFetchTimeout());
 102     }
 103
 104     @Test
 105     @Override
 106     public void testBuildListOfStringString() {
 107         super.testBuildListOfStringString();
 108
 109         // check source-specific parameters that were used
 110         BusTopicParams params = factory.params.getFirst();
 111         assertEquals(null, params.getApiKey());
 112         assertEquals(null, params.getApiSecret());
 113         assertEquals(DmaapTopicSource.DEFAULT_LIMIT_FETCH, params.getFetchLimit());
 114         assertEquals(DmaapTopicSource.DEFAULT_TIMEOUT_MS_FETCH, params.getFetchTimeout());
 115     }
 116
 117     @Test
 118     @Override
 119     public void testDestroyString_testGet_testInventory() {
 120         super.testDestroyString_testGet_testInventory();
 121         super.testDestroyString_Ex();
 122     }
 123
 124     @Test
 125     @Override
 126     public void testDestroy() {
 127         super.testDestroy();
 128     }
 129
 130     @Test
 131     public void testGet() {
 132         super.testGet_Ex();
 133     }
 134
 135     @Test
 136     public void testToString() {
 137         assertTrue(factory.toString().startsWith("IndexedDmaapTopicSourceFactory ["));
 138     }
 139
 140     @Override
 141     protected void initFactory() {
 142         if (factory != null) {
 143             factory.destroy();
 144         }
 145
 146         factory = new SourceFactory();
 147     }
 148
 149     @Override
 150     protected List<DmaapTopicSource> buildTopics(Properties properties) {
 151         return factory.build(properties);
 152     }
 153
 154     @Override
 155     protected DmaapTopicSource buildTopic(BusTopicParams params) {
 156         return factory.build(params);
 157     }
 158
 159     @Override
 160     protected DmaapTopicSource buildTopic(List<String> servers, String topic) {
 161         return factory.build(servers, topic);
 162     }
 163
 164     @Override
 165     protected void destroyFactory() {
 166         factory.destroy();
 167     }
 168
 169     @Override
 170     protected void destroyTopic(String topic) {
 171         factory.destroy(topic);
 172     }
 173
 174     @Override
 175     protected List<DmaapTopicSource> getInventory() {
 176         return factory.inventory();
 177     }
 178
 179     @Override
 180     protected DmaapTopicSource getTopic(String topic) {
 181         return factory.get(topic);
 182     }
 183
 184     @Override
 185     protected BusTopicParams getLastParams() {
 186         return factory.params.getLast();
 187     }
 188
 189     @Override
 190     protected TopicPropertyBuilder makePropBuilder() {
 191         return new DmaapTopicPropertyBuilder(PROPERTY_DMAAP_SOURCE_TOPICS);
 192     }
 193
 194     /**
 195      * Factory that records the parameters of all of the sources it creates.
 196      */
 197     private static class SourceFactory extends IndexedDmaapTopicSourceFactory {
 198         private Deque<BusTopicParams> params = new LinkedList<>();
 199
 200         @Override
 201         protected DmaapTopicSource makeSource(BusTopicParams busTopicParams) {
 202             params.add(busTopicParams);
 203             return super.makeSource(busTopicParams);
 204         }
 205     }
 206 }