877246e2aa9436266016f52b83eda76e5275da28
[policy/common.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * policy-endpoints
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.assertj.core.api.Assertions.assertThatIllegalArgumentException;
24 import static org.junit.Assert.assertEquals;
25 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_EP_CONN_TIMEOUT_SUFFIX;
26 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_EP_READ_TIMEOUT_MS_SUFFIX;
27 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_ROUNDTRIP_TIMEOUT_MS_SUFFIX;
28 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_ROUTE_OFFER_SUFFIX;
29 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_SESSION_STICKINESS_REQUIRED_SUFFIX;
30 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_SUB_CONTEXT_PATH_SUFFIX;
31 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_VERSION_SUFFIX;
32
33 import java.util.Map;
34 import org.onap.policy.common.endpoints.event.comm.Topic;
35 import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams;
36
37 /**
38  * Base class for DmaapTopicXxxFactory tests.
39  *
40  * @param <T> type of topic managed by the factory
41  */
42 public abstract class DmaapTopicFactoryTestBase<T extends Topic> extends BusTopicFactoryTestBase<T> {
43
44     public static final String MY_CONN_TIMEOUT = "200";
45     public static final String MY_READ_TIMEOUT = "201";
46     public static final String MY_ROUNDTRIP_TIMEOUT = "202";
47     public static final String MY_STICKINESS = "true";
48     public static final String MY_SUBCONTEXT = "my-subcontext";
49     public static final String MY_DME_VERSION = "my-version";
50
51     @Override
52     public void testBuildProperties() {
53         
54         super.testBuildProperties();
55         
56         // check properties specific to DMaaP/DME2
57         initFactory();
58
59         assertEquals(1, buildTopics(makePropBuilder().makeTopic(MY_TOPIC).build()).size());
60
61         BusTopicParams params = getLastParams();
62         assertEquals(MY_ENV, params.getEnvironment());
63         assertEquals(MY_LAT, params.getLatitude());
64         assertEquals(MY_LONG, params.getLongitude());
65         assertEquals(MY_PARTNER, params.getPartner());
66
67         Map<String, String> add = params.getAdditionalProps();
68         assertEquals(MY_CONN_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_EP_CONN_TIMEOUT_PROPERTY));
69         assertEquals(MY_READ_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_READ_TIMEOUT_PROPERTY));
70         assertEquals(MY_ROUNDTRIP_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_ROUNDTRIP_TIMEOUT_PROPERTY));
71         assertEquals(MY_ROUTE, add.get(DmaapTopicSinkFactory.DME2_ROUTE_OFFER_PROPERTY));
72         assertEquals(MY_STICKINESS, add.get(DmaapTopicSinkFactory.DME2_SESSION_STICKINESS_REQUIRED_PROPERTY));
73         assertEquals(MY_SUBCONTEXT, add.get(DmaapTopicSinkFactory.DME2_SUBCONTEXT_PATH_PROPERTY));
74         assertEquals(MY_DME_VERSION, add.get(DmaapTopicSinkFactory.DME2_VERSION_PROPERTY));
75     }
76
77     @Override
78     public void testBuildProperties_Variations() {
79         super.testBuildProperties_Variations();
80
81         // check "additional" properties
82         expectNullAddProp(PROPERTY_DMAAP_DME2_EP_CONN_TIMEOUT_SUFFIX,
83                         DmaapTopicSinkFactory.DME2_EP_CONN_TIMEOUT_PROPERTY);
84
85         expectNullAddProp(PROPERTY_DMAAP_DME2_EP_READ_TIMEOUT_MS_SUFFIX,
86                         DmaapTopicSinkFactory.DME2_READ_TIMEOUT_PROPERTY);
87
88         expectNullAddProp(PROPERTY_DMAAP_DME2_ROUNDTRIP_TIMEOUT_MS_SUFFIX,
89                         DmaapTopicSinkFactory.DME2_ROUNDTRIP_TIMEOUT_PROPERTY);
90
91         expectNullAddProp(PROPERTY_DMAAP_DME2_ROUTE_OFFER_SUFFIX, DmaapTopicSinkFactory.DME2_ROUTE_OFFER_PROPERTY);
92
93         expectNullAddProp(PROPERTY_DMAAP_DME2_SESSION_STICKINESS_REQUIRED_SUFFIX,
94                         DmaapTopicSinkFactory.DME2_SESSION_STICKINESS_REQUIRED_PROPERTY);
95
96         expectNullAddProp(PROPERTY_DMAAP_DME2_SUB_CONTEXT_PATH_SUFFIX,
97                         DmaapTopicSinkFactory.DME2_SUBCONTEXT_PATH_PROPERTY);
98
99         expectNullAddProp(PROPERTY_DMAAP_DME2_VERSION_SUFFIX, DmaapTopicSinkFactory.DME2_VERSION_PROPERTY);
100     }
101
102     @Override
103     public void testBuildListOfStringString() {
104         super.testBuildListOfStringString();
105
106         // check parameters that were used
107         BusTopicParams params = getLastParams();
108         assertEquals(false, params.isAllowSelfSignedCerts());
109     }
110
111     /**
112      * Tests exception cases with get(topic).  DMaaP topics are special in that they
113      * throw IllegalArgumentException, even for an unknown topic name; all of the
114      * other Topic Factory classes throw IllegalStateException, thus we override
115      * the default test method.
116      */
117     @Override
118     public void testGet_Ex() {
119         // null topic
120         assertThatIllegalArgumentException().as("null topic").isThrownBy(() -> getTopic(null));
121
122         // empty topic
123         assertThatIllegalArgumentException().as("empty topic").isThrownBy(() -> getTopic(""));
124
125         // unknown topic
126         initFactory();
127         buildTopics(makePropBuilder().makeTopic(MY_TOPIC).build());
128
129         assertThatIllegalArgumentException().as("unknown topic").isThrownBy(() -> getTopic(TOPIC2));
130     }
131 }