Skip to content

Commit

Permalink
Deleted unit tests for connection testing.
Browse files Browse the repository at this point in the history
Unit testing connection testing now does not work anymore because having made ConnectionTester an actor eliminated possibilities for mocking.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
  • Loading branch information
Juergen Fickel committed Jun 22, 2022
1 parent db66e00 commit 0715c57
Showing 1 changed file with 0 additions and 45 deletions.
Expand Up @@ -236,51 +236,6 @@ private DittoHeaders getDittoHeadersWithCorrelationId() {
return DittoHeaders.newBuilder().correlationId(testNameCorrelationId.getCorrelationId()).build();
}

@Test
public void testConnectionIsSuccessful() {
final var connection = ConnectivityModelFactory.newConnectionBuilder(getConnection(false))
.connectionStatus(ConnectivityStatus.CLOSED)
.build();
final var testKit = actorSystemResource.newTestKit();
final var underTest = testKit.watch(TestActorRef.apply(
createClientActor(proxyActor.getRef(), connection),
actorSystemResource.getActorSystem()
));

underTest.tell(TestConnection.of(connection, getDittoHeadersWithCorrelationId()), testKit.getRef());

testKit.expectMsg(new Status.Success("successfully connected + initialized mapper"));
Mockito.verify(genericMqttClient).disconnect();
testKit.expectTerminated(Duration.ofSeconds(5L), underTest);
Mockito.verify(genericMqttClient).disconnect();
}

@Test
public void testConnectionFails() {
final var mqttClientConnectException = new MqttClientConnectException("Failed to connect.", null);
Mockito.when(genericMqttClient.connect(Mockito.any())).thenThrow(mqttClientConnectException);
final var connection = ConnectivityModelFactory.newConnectionBuilder(getConnection(false))
.connectionStatus(ConnectivityStatus.CLOSED)
.build();
final var testKit = actorSystemResource.newTestKit();
final var underTest = testKit.watch(TestActorRef.apply(
createClientActor(proxyActor.getRef(), connection),
actorSystemResource.getActorSystem()
));

underTest.tell(TestConnection.of(connection, getDittoHeadersWithCorrelationId()), testKit.getRef());

final var failure = testKit.expectMsgClass(Status.Failure.class);
assertThat(failure.cause())
.isInstanceOfSatisfying(ConnectionFailedException.class, connectionFailedException -> {
assertThat(connectionFailedException.getDescription())
.hasValue("Cause: " + mqttClientConnectException.getMessage());
assertThat(connectionFailedException).hasCause(mqttClientConnectException);
});
testKit.expectTerminated(Duration.ofSeconds(5L), underTest);
Mockito.verify(genericMqttClient, Mockito.never()).disconnect();
}

@Test
public void subscribeFails() {
final var mqttSubscribeException = new MqttSubscribeException("Quisquam omnis in quia hic et libero.", null);
Expand Down

0 comments on commit 0715c57

Please sign in to comment.