1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
|
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2016-2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2019-2020 Nordix Foundation.
* Modifications Copyright (C) 2020 Bell Canada. All rights reserved.
* Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
package org.onap.policy.apex.service.engine.parameters;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import java.util.Arrays;
import org.junit.Test;
import org.onap.policy.apex.service.engine.main.ApexCommandLineArguments;
import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperCarrierTechnologyParameters;
import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperTokenDelimitedEventProtocolParameters;
import org.onap.policy.apex.service.parameters.ApexParameterHandler;
import org.onap.policy.apex.service.parameters.ApexParameters;
import org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters;
import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode;
import org.onap.policy.apex.service.parameters.eventprotocol.EventProtocolParameters;
import org.onap.policy.common.parameters.ParameterException;
/**
* Test for an empty parameter file.
*
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public class SyncParameterTests {
@Test
public void testSyncBadNoSyncWithPeer() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsNoSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsNoSyncWithPeer.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID")
.hasMessageContaining("peer is illegal");
}
@Test
public void testSyncBadNotSyncWithPeer() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsNotSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsNotSyncWithPeer.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID")
.hasMessageContaining("peer is illegal");
}
@Test
public void testSyncBadSyncBadPeers() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsBadPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsBadPeers.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer0\" INVALID")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID")
.hasMessageContaining("does not exist or is not defined");
}
@Test
public void testSyncBadSyncInvalidTimeout() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsInvalidTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsInvalidTimeout.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer0\" INVALID")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID")
.hasMessageContaining("timeout value \"-10\" is illegal")
.hasMessageContaining("timeout value \"-3\" is illegal")
.hasMessageContaining("timeout value \"-1\" is illegal")
.hasMessageContaining("timeout value \"-99999999\" is illegal");
}
@Test
public void testSyncBadSyncBadTimeout() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsBadTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsBadTimeout.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"MyOtherProducer\" INVALID, "
+ "specified peered mode \"SYNCHRONOUS\" timeout is illegal");
}
@Test
public void testSyncBadSyncUnpairedTimeout() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncBadParamsUnpairedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncBadParamsUnpairedTimeout.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID, peer \"SyncConsumer0\"")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID, peer \"SyncConsumer1\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer0\" INVALID, peer \"SyncProducer0\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID, peer \"SyncProducer1\"")
.hasMessageContaining("timeout 10 does not equal peer timeout 1")
.hasMessageContaining("timeout 3 does not equal peer timeout 99999999")
.hasMessageContaining("timeout 1 does not equal peer timeout 10")
.hasMessageContaining("timeout 99999999 does not equal peer timeout 3");
}
@Test
public void testSyncGoodSyncGoodTimeoutProducer() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsProducerTimeout.json");
}
@Test
public void testSyncGoodSyncGoodTimeoutConsumer() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsConsumerTimeout.json");
}
@Test
public void testSyncGoodSyncGoodTimeoutBoth() throws ParameterException {
verifySyncGoodSyncGoodTimeout("src/test/resources/parameters/syncGoodParamsBothTimeout.json");
}
private void verifySyncGoodSyncGoodTimeout(String fileName) throws ParameterException {
final String[] args = {"-p", fileName};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
final ApexParameters parameters = new ApexParameterHandler().getParameters(arguments);
assertEquals(fileName, 12345, parameters.getEventInputParameters().get("SyncConsumer0")
.getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
assertEquals(fileName, 1, parameters.getEventInputParameters().get("SyncConsumer1")
.getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
assertEquals(fileName, 12345, parameters.getEventOutputParameters().get("SyncProducer0")
.getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
assertEquals(fileName, 1, parameters.getEventOutputParameters().get("SyncProducer1")
.getPeerTimeout(EventHandlerPeeredMode.SYNCHRONOUS));
}
@Test
public void testSyncUnusedConsumerPeers() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncUnusedConsumerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncUnusedConsumerPeers.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID, peer \"SyncConsumer0\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID, peer \"SyncProducer1\"")
.hasMessageContaining("value \"SyncProducer0\" on peer does not equal event handler")
.hasMessageContaining("value \"SyncConsumer0\" on peer does not equal event handler");
}
@Test
public void testSyncMismatchedPeers() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncMismatchedPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncMismatchedPeers.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID, peer \"SyncConsumer1\"")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID, peer \"SyncConsumer0\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer0\" INVALID, peer \"SyncProducer0\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID, peer \"SyncProducer1\"")
.hasMessageContaining("value \"SyncProducer1\" on peer does not equal event handler")
.hasMessageContaining("value \"SyncProducer0\" on peer does not equal event handler")
.hasMessageContaining("value \"SyncConsumer1\" on peer does not equal event handler")
.hasMessageContaining("value \"SyncConsumer0\" on peer does not equal event handler");
}
@Test
public void testSyncUnusedProducerPeers() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncUnusedProducerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncUnusedProducerPeers.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer0\" INVALID, peer \"SyncConsumer0\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer0\" INVALID, peer \"SyncProducer1\"")
.hasMessageContaining("value \"SyncProducer1\" on peer does not equal event handler")
.hasMessageContaining("value \"SyncConsumer1\" on peer does not equal event handler");
}
@Test
public void testSyncMismatchedTimeout() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncMismatchedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
assertThatThrownBy(() -> new ApexParameterHandler().getParameters(arguments))
.hasMessageContaining("src/test/resources/parameters/syncMismatchedTimeout.json")
.hasMessageContaining("ApexParameters")
.hasMessageContaining("\"eventOutputParameters\" value \"SyncProducer1\" INVALID, peer \"SyncConsumer1\"")
.hasMessageContaining("\"eventInputParameters\" value \"SyncConsumer1\" INVALID, peer \"SyncProducer1\"")
.hasMessageContaining("timeout 123 does not equal peer timeout 456")
.hasMessageContaining("timeout 456 does not equal peer timeout 123");
}
@Test
public void testSyncGoodParametersTest() throws ParameterException {
final String[] args = {"-p", "src/test/resources/parameters/syncGoodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
final ApexParameters parameters = new ApexParameterHandler().getParameters(arguments);
assertEquals("MyApexEngine", parameters.getEngineServiceParameters().getName());
assertEquals("0.0.1", parameters.getEngineServiceParameters().getVersion());
assertEquals(45, parameters.getEngineServiceParameters().getId());
assertEquals(19, parameters.getEngineServiceParameters().getInstanceCount());
assertEquals(65522, parameters.getEngineServiceParameters().getDeploymentPort());
final CarrierTechnologyParameters prodCT0 =
parameters.getEventOutputParameters().get("SyncProducer0").getCarrierTechnologyParameters();
final EventProtocolParameters prodEP0 =
parameters.getEventOutputParameters().get("SyncProducer0").getEventProtocolParameters();
final CarrierTechnologyParameters consCT0 =
parameters.getEventInputParameters().get("SyncConsumer0").getCarrierTechnologyParameters();
final EventProtocolParameters consEP0 =
parameters.getEventInputParameters().get("SyncConsumer0").getEventProtocolParameters();
final CarrierTechnologyParameters prodCT1 =
parameters.getEventOutputParameters().get("SyncProducer1").getCarrierTechnologyParameters();
final EventProtocolParameters prodEP1 =
parameters.getEventOutputParameters().get("SyncProducer1").getEventProtocolParameters();
final CarrierTechnologyParameters consCT1 =
parameters.getEventInputParameters().get("SyncConsumer1").getCarrierTechnologyParameters();
final EventProtocolParameters consEP1 =
parameters.getEventInputParameters().get("SyncConsumer1").getEventProtocolParameters();
assertEquals("FILE", prodCT0.getLabel());
assertEquals("JSON", prodEP0.getLabel());
assertEquals("FILE", consCT0.getLabel());
assertEquals("JSON", consEP0.getLabel());
assertEquals("FILE", prodCT1.getLabel());
assertEquals("JSON", prodEP1.getLabel());
assertEquals("SUPER_DOOPER", consCT1.getLabel());
assertEquals("SUPER_TOK_DEL", consEP1.getLabel());
assertTrue(consCT1 instanceof SuperDooperCarrierTechnologyParameters);
assertTrue(consEP1 instanceof SuperTokenDelimitedEventProtocolParameters);
final SuperDooperCarrierTechnologyParameters superDooperParameters =
(SuperDooperCarrierTechnologyParameters) consCT1;
assertEquals("localhost:9092", superDooperParameters.getBootstrapServers());
assertEquals("all", superDooperParameters.getAcks());
assertEquals(0, superDooperParameters.getRetries());
assertEquals(16384, superDooperParameters.getBatchSize());
assertEquals(1, superDooperParameters.getLingerTime());
assertEquals(33554432, superDooperParameters.getBufferMemory());
assertEquals("default-group-id", superDooperParameters.getGroupId());
assertTrue(superDooperParameters.isEnableAutoCommit());
assertEquals(1000, superDooperParameters.getAutoCommitTime());
assertEquals(30000, superDooperParameters.getSessionTimeout());
assertEquals("apex-out", superDooperParameters.getProducerTopic());
assertEquals(100, superDooperParameters.getConsumerPollTime());
assertEquals("org.apache.superDooper.common.serialization.StringSerializer",
superDooperParameters.getKeySerializer());
assertEquals("org.apache.superDooper.common.serialization.StringSerializer",
superDooperParameters.getValueSerializer());
assertEquals("org.apache.superDooper.common.serialization.StringDeserializer",
superDooperParameters.getKeyDeserializer());
assertEquals("org.apache.superDooper.common.serialization.StringDeserializer",
superDooperParameters.getValueDeserializer());
final String[] consumerTopics = {"apex-in"};
assertEquals(Arrays.asList(consumerTopics), superDooperParameters.getConsumerTopicList());
}
}
|
