SONAR-9741 fix types of fields in response of WS

This commit is contained in:
Sébastien Lesaint 2017-09-12 16:59:06 +02:00
parent b49a62254e
commit 58678f9db7
17 changed files with 63 additions and 64 deletions

View File

@ -37,7 +37,7 @@ public class NodeDetails implements Externalizable {
private String name;
private String host;
private int port;
private long started;
private long startedAt;
/**
* Required for Serialization
@ -50,7 +50,7 @@ public class NodeDetails implements Externalizable {
this.name = builder.name;
this.host = builder.host;
this.port = builder.port;
this.started = builder.started;
this.startedAt = builder.startedAt;
}
public static Builder newNodeDetailsBuilder() {
@ -73,8 +73,8 @@ public class NodeDetails implements Externalizable {
return port;
}
public long getStarted() {
return started;
public long getStartedAt() {
return startedAt;
}
@Override
@ -84,7 +84,7 @@ public class NodeDetails implements Externalizable {
", name='" + name + '\'' +
", host='" + host + '\'' +
", port=" + port +
", started=" + started +
", startedAt=" + startedAt +
'}';
}
@ -94,7 +94,7 @@ public class NodeDetails implements Externalizable {
out.writeUTF(name);
out.writeUTF(host);
out.writeInt(port);
out.writeLong(started);
out.writeLong(startedAt);
}
@Override
@ -103,7 +103,7 @@ public class NodeDetails implements Externalizable {
this.name = in.readUTF();
this.host = in.readUTF();
this.port = in.readInt();
this.started = in.readLong();
this.startedAt = in.readLong();
}
@Override
@ -116,7 +116,7 @@ public class NodeDetails implements Externalizable {
}
NodeDetails that = (NodeDetails) o;
return port == that.port &&
started == that.started &&
startedAt == that.startedAt &&
type == that.type &&
name.equals(that.name) &&
host.equals(that.host);
@ -124,7 +124,7 @@ public class NodeDetails implements Externalizable {
@Override
public int hashCode() {
return Objects.hash(type, name, host, port, started);
return Objects.hash(type, name, host, port, startedAt);
}
public static class Builder {
@ -132,7 +132,7 @@ public class NodeDetails implements Externalizable {
private String name;
private String host;
private int port;
private long started;
private long startedAt;
private Builder() {
// use static factory method
@ -159,9 +159,9 @@ public class NodeDetails implements Externalizable {
return this;
}
public Builder setStarted(long started) {
checkStarted(started);
this.started = started;
public Builder setStartedAt(long startedAt) {
checkStartedAt(startedAt);
this.startedAt = startedAt;
return this;
}
@ -170,7 +170,7 @@ public class NodeDetails implements Externalizable {
checkString(name, "name");
checkString(host, "host");
checkPort(port);
checkStarted(started);
checkStartedAt(startedAt);
return new NodeDetails(this);
}
@ -189,8 +189,8 @@ public class NodeDetails implements Externalizable {
checkArgument(port > 0, "port must be > 0");
}
private static void checkStarted(long started) {
checkArgument(started > 0, "started must be > 0");
private static void checkStartedAt(long startedAt) {
checkArgument(startedAt > 0, "startedAt must be > 0");
}
}

View File

@ -107,9 +107,9 @@ public class NodeDetailsTest {
@Test
public void setStarted_throws_IAE_if_arg_is_less_than_1() {
expectedException.expect(IllegalArgumentException.class);
expectedException.expectMessage("started must be > 0");
expectedException.expectMessage("startedAt must be > 0");
builderUnderTest.setStarted(-random.nextInt(5));
builderUnderTest.setStartedAt(-random.nextInt(5));
}
@Test
@ -165,7 +165,7 @@ public class NodeDetailsTest {
.setPort(1 + random.nextInt(33));
expectedException.expect(IllegalArgumentException.class);
expectedException.expectMessage("started must be > 0");
expectedException.expectMessage("startedAt must be > 0");
builderUnderTest.build();
}
@ -209,18 +209,18 @@ public class NodeDetailsTest {
String name = randomAlphanumeric(3);
String host = randomAlphanumeric(10);
int port = 1 + random.nextInt(10);
int started = 1 + random.nextInt(666);
long startedAt = 1 + random.nextInt(666);
NodeDetails underTest = builderUnderTest
.setType(randomType)
.setName(name)
.setHost(host)
.setPort(port)
.setStarted(started)
.setStartedAt(startedAt)
.build();
assertThat(underTest.toString())
.isEqualTo("NodeDetails{type=" + randomType + ", name='" + name + "', host='" + host + "', port=" + port + ", started=" + started + "}");
.isEqualTo("NodeDetails{type=" + randomType + ", name='" + name + "', host='" + host + "', port=" + port + ", startedAt=" + startedAt + "}");
}
@Test
@ -228,20 +228,20 @@ public class NodeDetailsTest {
String name = randomAlphanumeric(3);
String host = randomAlphanumeric(10);
int port = 1 + random.nextInt(10);
int started = 1 + random.nextInt(666);
long startedAt = 1 + random.nextInt(666);
NodeDetails underTest = builderUnderTest
.setType(randomType)
.setName(name)
.setHost(host)
.setPort(port)
.setStarted(started)
.setStartedAt(startedAt)
.build();
assertThat(underTest.getType()).isEqualTo(randomType);
assertThat(underTest.getName()).isEqualTo(name);
assertThat(underTest.getHost()).isEqualTo(host);
assertThat(underTest.getPort()).isEqualTo(port);
assertThat(underTest.getStarted()).isEqualTo(started);
assertThat(underTest.getStartedAt()).isEqualTo(startedAt);
}
}

View File

@ -71,7 +71,7 @@ public class NodeDetailsTestSupport {
.setName(randomAlphanumeric(3))
.setHost(randomAlphanumeric(10))
.setPort(1 + random.nextInt(10))
.setStarted(1 + random.nextInt(666));
.setStartedAt(1 + random.nextInt(666));
}
NodeDetails.Type randomType() {

View File

@ -245,7 +245,7 @@ public class SharedHealthStateImplTest {
.setName(randomAlphanumeric(30))
.setHost(randomAlphanumeric(10))
.setPort(1 + random.nextInt(666))
.setStarted(1 + random.nextInt(852))
.setStartedAt(1 + random.nextInt(852))
.build())
.build();
}

View File

@ -43,7 +43,7 @@ public class SearchNodeHealthProvider implements NodeHealthProvider {
.setName(props.nonNullValue(CLUSTER_NODE_NAME))
.setHost(getHost(props, networkUtils))
.setPort(Integer.valueOf(props.nonNullValue(CLUSTER_NODE_PORT)))
.setStarted(system2.now())
.setStartedAt(system2.now())
.build();
}

View File

@ -190,14 +190,14 @@ public class SearchNodeHealthProviderTest {
NodeHealth nodeHealth = underTest.get();
assertThat(nodeHealth.getDetails().getStarted()).isEqualTo(now);
assertThat(nodeHealth.getDetails().getStartedAt()).isEqualTo(now);
// change now
when(system2.now()).thenReturn(now);
NodeHealth newNodeHealth = underTest.get();
assertThat(newNodeHealth.getDetails().getStarted()).isEqualTo(now);
assertThat(newNodeHealth.getDetails().getStartedAt()).isEqualTo(now);
}
@Test

View File

@ -47,7 +47,7 @@ public class NodeHealthProviderImpl implements NodeHealthProvider {
.setType(NodeDetails.Type.APPLICATION)
.setHost(computeHost(configuration, networkUtils))
.setPort(computePort(configuration))
.setStarted(server.getStartedAt().getTime())
.setStartedAt(server.getStartedAt().getTime())
.build();
}

View File

@ -29,7 +29,6 @@ import org.sonar.server.health.Health;
import org.sonar.server.health.HealthChecker;
import org.sonarqube.ws.WsSystem;
import static java.lang.String.valueOf;
import static org.sonar.api.utils.DateUtils.formatDateTime;
public class HealthActionSupport {
@ -102,8 +101,8 @@ public class HealthActionSupport {
.setType(WsSystem.NodeType.valueOf(details.getType().name()))
.setName(details.getName())
.setHost(details.getHost())
.setPort(valueOf(details.getPort()))
.setStarted(formatDateTime(details.getStarted()));
.setPort(details.getPort())
.setStartedAt(formatDateTime(details.getStartedAt()));
return nodeBuilder.build();
}

View File

@ -10,8 +10,8 @@
"name": "app-1",
"type": "APPLICATION",
"host": "192.168.1.1",
"port": "999",
"started": "2015-08-13T23:34:59+0200",
"port": 999,
"startedAt": "2015-08-13T23:34:59+0200",
"health": "RED",
"causes": [
{
@ -23,8 +23,8 @@
"name": "app-2",
"type": "APPLICATION",
"host": "192.168.1.2",
"port": "999",
"started": "2015-08-13T23:34:59+0200",
"port": 999,
"startedAt": "2015-08-13T23:34:59+0200",
"health": "YELLOW",
"causes": [
{
@ -36,8 +36,8 @@
"name": "es-1",
"type": "SEARCH",
"host": "192.168.1.3",
"port": "999",
"started": "2015-08-13T23:34:59+0200",
"port": 999,
"startedAt": "2015-08-13T23:34:59+0200",
"health": "GREEN",
"causes": []
},
@ -45,8 +45,8 @@
"name": "es-2",
"type": "SEARCH",
"host": "192.168.1.4",
"port": "999",
"started": "2015-08-13T23:34:59+0200",
"port": 999,
"startedAt": "2015-08-13T23:34:59+0200",
"health": "GREEN",
"causes": []
},
@ -54,8 +54,8 @@
"name": "es-3",
"type": "SEARCH",
"host": "192.168.1.5",
"port": "999",
"started": "2015-08-13T23:34:59+0200",
"port": 999,
"startedAt": "2015-08-13T23:34:59+0200",
"health": "GREEN",
"causes": []
}

View File

@ -277,7 +277,7 @@ public class AppNodeClusterCheckTest {
.setHost(randomAlphanumeric(32))
.setName(randomAlphanumeric(32))
.setPort(1 + random.nextInt(88))
.setStarted(1 + random.nextInt(54))
.setStartedAt(1 + random.nextInt(54))
.build())
.build();
}

View File

@ -116,7 +116,7 @@ public class ClusterHealthTest {
.setName(randomAlphanumeric(3))
.setHost(randomAlphanumeric(4))
.setPort(1 + random.nextInt(344))
.setStarted(1 + random.nextInt(999))
.setStartedAt(1 + random.nextInt(999))
.build())
.build()).collect(Collectors.toSet());
}

View File

@ -50,7 +50,7 @@ public class EsStatusClusterCheckTest {
.setName(randomAlphanumeric(23))
.setHost(randomAlphanumeric(23))
.setPort(1 + random.nextInt(96))
.setStarted(1 + random.nextInt(966))
.setStartedAt(1 + random.nextInt(966))
.build())
.build())
.collect(Collectors.toSet());

View File

@ -249,7 +249,7 @@ public class HealthCheckerImplTest {
.setName(randomAlphanumeric(10))
.setHost(randomAlphanumeric(5))
.setPort(1 + random.nextInt(333))
.setStarted(1 + random.nextInt(444))
.setStartedAt(1 + random.nextInt(444))
.build())
.build();
}

View File

@ -221,14 +221,14 @@ public class NodeHealthProviderImplTest {
NodeHealth nodeHealth = underTest.get();
assertThat(nodeHealth.getDetails().getStarted()).isEqualTo(date.getTime());
assertThat(nodeHealth.getDetails().getStartedAt()).isEqualTo(date.getTime());
// change startedAt value
setStartedAt();
NodeHealth newNodeHealth = underTest.get();
assertThat(newNodeHealth.getDetails().getStarted()).isEqualTo(date.getTime());
assertThat(newNodeHealth.getDetails().getStartedAt()).isEqualTo(date.getTime());
}
private void setStartedAt() {

View File

@ -513,7 +513,7 @@ public class SearchNodeClusterCheckTest {
.setHost(randomAlphanumeric(32))
.setName(randomAlphanumeric(32))
.setPort(1 + random.nextInt(88))
.setStarted(1 + random.nextInt(54))
.setStartedAt(1 + random.nextInt(54))
.build())
.build();
}

View File

@ -96,7 +96,7 @@ public class HealthActionTest {
.setType(NodeDetails.Type.APPLICATION)
.setHost("192.168.1.1")
.setPort(999)
.setStarted(time)
.setStartedAt(time)
.build())
.build(),
newNodeHealthBuilder()
@ -108,7 +108,7 @@ public class HealthActionTest {
.setType(NodeDetails.Type.APPLICATION)
.setHost("192.168.1.2")
.setPort(999)
.setStarted(time)
.setStartedAt(time)
.build())
.build(),
newNodeHealthBuilder()
@ -119,7 +119,7 @@ public class HealthActionTest {
.setType(NodeDetails.Type.SEARCH)
.setHost("192.168.1.3")
.setPort(999)
.setStarted(time)
.setStartedAt(time)
.build())
.build(),
newNodeHealthBuilder()
@ -130,7 +130,7 @@ public class HealthActionTest {
.setType(NodeDetails.Type.SEARCH)
.setHost("192.168.1.4")
.setPort(999)
.setStarted(time)
.setStartedAt(time)
.build())
.build(),
newNodeHealthBuilder()
@ -141,7 +141,7 @@ public class HealthActionTest {
.setType(NodeDetails.Type.SEARCH)
.setHost("192.168.1.5")
.setPort(999)
.setStarted(time)
.setStartedAt(time)
.build())
.build())));
@ -201,8 +201,8 @@ public class HealthActionTest {
.containsOnly(nodeHealth.getCauses().stream().toArray(String[]::new));
assertThat(node.getName()).isEqualTo(nodeHealth.getDetails().getName());
assertThat(node.getHost()).isEqualTo(nodeHealth.getDetails().getHost());
assertThat(node.getPort()).isEqualTo(String.valueOf(nodeHealth.getDetails().getPort()));
assertThat(node.getStarted()).isEqualTo(formatDateTime(nodeHealth.getDetails().getStarted()));
assertThat(node.getPort()).isEqualTo(nodeHealth.getDetails().getPort());
assertThat(node.getStartedAt()).isEqualTo(formatDateTime(nodeHealth.getDetails().getStartedAt()));
assertThat(node.getType().name()).isEqualTo(nodeHealth.getDetails().getType().name());
}
@ -225,7 +225,7 @@ public class HealthActionTest {
randomNodeHealth(NodeDetails.Type.SEARCH, "2_name", "1_host", 2, 28),
randomNodeHealth(NodeDetails.Type.SEARCH, "2_name", "2_host", 1, 66),
randomNodeHealth(NodeDetails.Type.SEARCH, "2_name", "2_host", 2, 77)));
String[] expected = nodeHealths.stream().map(s -> formatDateTime(new Date(s.getDetails().getStarted()))).toArray(String[]::new);
String[] expected = nodeHealths.stream().map(s -> formatDateTime(new Date(s.getDetails().getStartedAt()))).toArray(String[]::new);
Collections.shuffle(nodeHealths);
when(webServer.isStandalone()).thenReturn(false);
@ -234,7 +234,7 @@ public class HealthActionTest {
WsSystem.HealthResponse response = underTest.newRequest().executeProtobuf(WsSystem.HealthResponse.class);
assertThat(response.getNodes().getNodesList())
.extracting(WsSystem.Node::getStarted)
.extracting(WsSystem.Node::getStartedAt)
.containsExactly(expected);
}
@ -248,7 +248,7 @@ public class HealthActionTest {
.setName(randomAlphanumeric(3))
.setHost(randomAlphanumeric(4))
.setPort(1 + random.nextInt(3))
.setStarted(1 + random.nextInt(23))
.setStartedAt(1 + random.nextInt(23))
.build())
.build();
}
@ -263,7 +263,7 @@ public class HealthActionTest {
.setName(name)
.setHost(host)
.setPort(port)
.setStarted(started)
.setStartedAt(started)
.build())
.build();
}

View File

@ -65,8 +65,8 @@ message Node {
optional string name = 1;
optional NodeType type = 2;
optional string host = 3;
optional string port = 4;
optional string started = 5;
optional int32 port = 4;
optional string startedAt = 5;
optional Health health = 6;
repeated Cause causes = 7;
}