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
|
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
* Copyright (C) 2019 Nordix Foundation.
* Modifications Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
* Modifications Copyright (C) 2020 Nordix Foundation
* ================================================================================
* 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.distribution.main.rest;
import static org.assertj.core.api.Assertions.assertThatCode;
import static org.junit.Assert.assertEquals;
import java.io.IOException;
import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.Invocation;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.MediaType;
import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.client.authentication.HttpAuthenticationFeature;
import org.junit.Test;
import org.onap.policy.common.endpoints.http.server.RestServer;
import org.onap.policy.common.endpoints.parameters.RestServerParameters;
import org.onap.policy.common.utils.network.NetworkUtil;
import org.onap.policy.distribution.main.PolicyDistributionException;
import org.onap.policy.distribution.main.parameters.CommonTestData;
import org.onap.policy.distribution.main.startstop.Main;
import org.onap.policy.distribution.reception.statistics.DistributionStatisticsManager;
/**
* Class to perform unit test of {@link DistributionRestController}.
*
* @author Ram Krishna Verma (ram.krishna.verma@ericsson.com)
*/
public class TestDistributionStatistics {
@Test
public void testDistributionStatistics_200() {
assertThatCode(() -> {
final Main main = startDistributionService();
StatisticsReport report = getDistributionStatistics();
validateReport(report, 0, 200);
updateDistributionStatistics();
report = getDistributionStatistics();
validateReport(report, 1, 200);
stopDistributionService(main);
DistributionStatisticsManager.resetAllStatistics();
}).doesNotThrowAnyException();
}
@Test
public void testDistributionStatistics_500() throws InterruptedException {
final RestServerParameters restServerParams = new CommonTestData().getRestServerParameters(false);
restServerParams.setName(CommonTestData.DISTRIBUTION_GROUP_NAME);
final RestServer restServer = new RestServer(restServerParams, null, DistributionRestController.class);
assertThatCode(() -> {
restServer.start();
final StatisticsReport report = getDistributionStatistics();
validateReport(report, 0, 500);
restServer.shutdown();
DistributionStatisticsManager.resetAllStatistics();
}).doesNotThrowAnyException();
}
private Main startDistributionService() {
final String[] distributionConfigParameters = { "-c", "parameters/DistributionConfigParameters.json" };
return new Main(distributionConfigParameters);
}
private void stopDistributionService(final Main main) throws PolicyDistributionException {
main.shutdown();
}
private StatisticsReport getDistributionStatistics() throws InterruptedException, IOException {
final ClientConfig clientConfig = new ClientConfig();
final HttpAuthenticationFeature feature = HttpAuthenticationFeature.basic("healthcheck", "zb!XztG34");
clientConfig.register(feature);
final Client client = ClientBuilder.newClient(clientConfig);
final WebTarget webTarget = client.target("http://localhost:6969/statistics");
final Invocation.Builder invocationBuilder = webTarget.request(MediaType.APPLICATION_JSON);
if (!NetworkUtil.isTcpPortOpen("localhost", 6969, 6, 10000L)) {
throw new IllegalStateException("cannot connect to port 6969");
}
return invocationBuilder.get(StatisticsReport.class);
}
private void updateDistributionStatistics() {
DistributionStatisticsManager.updateTotalDistributionCount();
DistributionStatisticsManager.updateDistributionSuccessCount();
DistributionStatisticsManager.updateDistributionFailureCount();
DistributionStatisticsManager.updateTotalDownloadCount();
DistributionStatisticsManager.updateDownloadSuccessCount();
DistributionStatisticsManager.updateDownloadFailureCount();
}
private void validateReport(final StatisticsReport report, final int count, final int code) {
assertEquals(code, report.getCode());
assertEquals(count, report.getTotalDistributionCount());
assertEquals(count, report.getDistributionSuccessCount());
assertEquals(count, report.getDistributionFailureCount());
assertEquals(count, report.getTotalDownloadCount());
assertEquals(count, report.getDownloadSuccessCount());
assertEquals(count, report.getDownloadFailureCount());
}
}
|
