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
|
/*
* SonarQube
* Copyright (C) 2009-2025 SonarSource SA
* mailto:info AT sonarsource DOT com
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 3 of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program; if not, write to the Free Software Foundation,
* Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/
package org.sonar.application.config;
import com.google.common.collect.ImmutableMap;
import java.net.InetAddress;
import java.util.HashMap;
import java.util.Map;
import java.util.Optional;
import org.hamcrest.CoreMatchers;
import org.junit.Before;
import org.junit.Test;
import org.sonar.process.MessageException;
import org.sonar.process.NetworkUtils;
import org.sonar.process.NetworkUtilsImpl;
import org.sonar.process.Props;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assume.assumeThat;
import static org.mockito.Mockito.spy;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_ENABLED;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_ES_HOSTS;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_HZ_HOSTS;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_NODE_ES_HOST;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_NODE_HOST;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_NODE_SEARCH_HOST;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_NODE_TYPE;
import static org.sonar.process.ProcessProperties.Property.CLUSTER_SEARCH_HOSTS;
import static org.sonar.process.ProcessProperties.Property.JDBC_URL;
public class ClusterSettingsLoopbackTest {
private final InetAddress loopback = InetAddress.getLoopbackAddress();
private final NetworkUtils network = spy(NetworkUtilsImpl.INSTANCE);
private InetAddress nonLoopbackLocal;
@Before
public void setUp() {
Optional<InetAddress> opt = network.getLocalNonLoopbackIpv4Address();
assumeThat(opt.isPresent(), CoreMatchers.is(true));
nonLoopbackLocal = opt.get();
}
@Test
public void ClusterSettings_throws_MessageException_if_es_http_host_of_search_node_is_loopback() {
TestAppSettings settings = newSettingsForSearchNode(ImmutableMap.of(CLUSTER_NODE_SEARCH_HOST.getKey(), loopback.getHostAddress()));
Props props = settings.getProps();
ClusterSettings clusterSettings = new ClusterSettings(network);
assertThatThrownBy(() -> clusterSettings.accept(props))
.isInstanceOf(MessageException.class)
.hasMessage("Property " + CLUSTER_NODE_SEARCH_HOST.getKey() + " must be a local non-loopback address: " + loopback.getHostAddress());
}
@Test
public void ClusterSettings_throws_MessageException_if_es_transport_host_of_search_node_is_loopback() {
TestAppSettings settings = newSettingsForSearchNode(ImmutableMap.of(CLUSTER_NODE_ES_HOST.getKey(), loopback.getHostAddress()));
Props props = settings.getProps();
ClusterSettings clusterSettings = new ClusterSettings(network);
assertThatThrownBy(() -> clusterSettings.accept(props))
.isInstanceOf(MessageException.class)
.hasMessage("Property " + CLUSTER_NODE_ES_HOST.getKey() + " must be a local non-loopback address: " + loopback.getHostAddress());
}
@Test
public void ClusterSettings_throws_MessageException_if_host_of_app_node_is_loopback() {
TestAppSettings settings = newSettingsForAppNode(ImmutableMap.of(CLUSTER_NODE_HOST.getKey(), loopback.getHostAddress()));
Props props = settings.getProps();
ClusterSettings clusterSettings = new ClusterSettings(network);
assertThatThrownBy(() -> clusterSettings.accept(props))
.isInstanceOf(MessageException.class)
.hasMessage("Property " + CLUSTER_NODE_HOST.getKey() + " must be a local non-loopback address: " + loopback.getHostAddress());
}
private TestAppSettings newSettingsForAppNode(ImmutableMap<String, String> settings) {
Map<String, String> result = new HashMap<>();
result.put(CLUSTER_ENABLED.getKey(), "true");
result.put(CLUSTER_NODE_TYPE.getKey(), "application");
result.put(CLUSTER_NODE_HOST.getKey(), nonLoopbackLocal.getHostAddress());
result.put(CLUSTER_HZ_HOSTS.getKey(), nonLoopbackLocal.getHostAddress());
result.put(CLUSTER_SEARCH_HOSTS.getKey(), nonLoopbackLocal.getHostAddress());
result.put("sonar.auth.jwtBase64Hs256Secret", "abcde");
result.put(JDBC_URL.getKey(), "jdbc:postgresql://localhost:3306/sonar");
result.putAll(settings);
return new TestAppSettings(result);
}
private TestAppSettings newSettingsForSearchNode(ImmutableMap<String, String> settings) {
Map<String, String> result = new HashMap<>();
result.put(CLUSTER_ENABLED.getKey(), "true");
result.put(CLUSTER_NODE_TYPE.getKey(), "search");
result.put(CLUSTER_ES_HOSTS.getKey(), nonLoopbackLocal.getHostAddress());
result.put(CLUSTER_NODE_SEARCH_HOST.getKey(), nonLoopbackLocal.getHostAddress());
result.put(CLUSTER_NODE_ES_HOST.getKey(), nonLoopbackLocal.getHostAddress());
result.putAll(settings);
return new TestAppSettings(result);
}
}
|
