aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java
diff options
context:
space:
mode:
authorGravatar lberki <lberki@google.com>2017-05-30 12:35:33 +0200
committerGravatar László Csomor <laszlocsomor@google.com>2017-05-30 12:51:57 +0200
commitaea56b36af994b269800602e36000c293cabd00b (patch)
tree794f6b3b2528353cc39bd383730d408d4ff25233 /src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java
parent229f393bf460700594ae032a551879e026bd0b91 (diff)
Migrate Java tests to Truth.
RELNOTES: None. PiperOrigin-RevId: 157446717
Diffstat (limited to 'src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java')
-rw-r--r--src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java127
1 files changed, 62 insertions, 65 deletions
diff --git a/src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java b/src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java
index 96dd01276f..76272294fa 100644
--- a/src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java
+++ b/src/test/java/com/google/devtools/build/lib/runtime/BuildEventStreamerTest.java
@@ -14,9 +14,7 @@
package com.google.devtools.build.lib.runtime;
import static com.google.common.truth.Truth.assertThat;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
+import static com.google.common.truth.Truth.assertWithMessage;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
@@ -275,7 +273,7 @@ public class BuildEventStreamerTest extends FoundationTestCase {
EventBusHandler handler = new EventBusHandler();
eventBus.register(handler);
- assertNull(handler.transportSet);
+ assertThat(handler.transportSet).isNull();
RecordingBuildEventTransport transport = new RecordingBuildEventTransport();
BuildEventStreamer streamer =
@@ -290,15 +288,15 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> afterFirstEvent = transport.getEvents();
assertThat(afterFirstEvent).hasSize(1);
- assertEquals(startEvent.getEventId(), afterFirstEvent.get(0).getEventId());
- assertEquals(1, handler.transportSet.size());
+ assertThat(afterFirstEvent.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(handler.transportSet).hasSize(1);
streamer.buildEvent(new BuildCompleteEvent(new BuildResult(0)));
List<BuildEvent> finalStream = transport.getEvents();
assertThat(finalStream).hasSize(3);
- assertEquals(BuildEventId.buildFinished(), finalStream.get(1).getEventId());
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, finalStream.get(2).getEventId());
+ assertThat(finalStream.get(1).getEventId()).isEqualTo(BuildEventId.buildFinished());
+ assertThat(finalStream.get(2).getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
while (!handler.transportSet.isEmpty()) {
LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(100));
@@ -325,13 +323,13 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> eventsSeen = transport.getEvents();
assertThat(eventsSeen).hasSize(3);
- assertEquals(startEvent.getEventId(), eventsSeen.get(0).getEventId());
- assertEquals(unexpectedEvent.getEventId(), eventsSeen.get(2).getEventId());
+ assertThat(eventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(eventsSeen.get(2).getEventId()).isEqualTo(unexpectedEvent.getEventId());
BuildEvent linkEvent = eventsSeen.get(1);
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, linkEvent.getEventId());
- assertTrue(
- "Unexpected events should be linked",
- linkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()));
+ assertThat(linkEvent.getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertWithMessage("Unexpected events should be linked")
+ .that(linkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()))
+ .isTrue();
}
@Test
@@ -351,12 +349,12 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> eventsSeen = transport.getEvents();
assertThat(eventsSeen).hasSize(2);
- assertEquals(unexpectedStartEvent.getEventId(), eventsSeen.get(1).getEventId());
+ assertThat(eventsSeen.get(1).getEventId()).isEqualTo(unexpectedStartEvent.getEventId());
BuildEvent initial = eventsSeen.get(0);
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, initial.getEventId());
- assertTrue(
- "Event should be linked",
- initial.getChildrenEvents().contains(unexpectedStartEvent.getEventId()));
+ assertThat(initial.getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertWithMessage("Event should be linked")
+ .that(initial.getChildrenEvents().contains(unexpectedStartEvent.getEventId()))
+ .isTrue();
// The initial event should also announce a new progress event; we test this
// by streaming another unannounced event.
@@ -367,14 +365,14 @@ public class BuildEventStreamerTest extends FoundationTestCase {
streamer.buildEvent(unexpectedEvent);
List<BuildEvent> allEventsSeen = transport.getEvents();
assertThat(allEventsSeen).hasSize(4);
- assertEquals(unexpectedEvent.getEventId(), allEventsSeen.get(3).getEventId());
+ assertThat(allEventsSeen.get(3).getEventId()).isEqualTo(unexpectedEvent.getEventId());
BuildEvent secondLinkEvent = allEventsSeen.get(2);
- assertTrue(
- "Progress should have been announced",
- initial.getChildrenEvents().contains(secondLinkEvent.getEventId()));
- assertTrue(
- "Second event should be linked",
- secondLinkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()));
+ assertWithMessage("Progress should have been announced")
+ .that(initial.getChildrenEvents().contains(secondLinkEvent.getEventId()))
+ .isTrue();
+ assertWithMessage("Second event should be linked")
+ .that(secondLinkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()))
+ .isTrue();
}
@Test
@@ -408,7 +406,7 @@ public class BuildEventStreamerTest extends FoundationTestCase {
}
}
// The early event should be reported precisely once.
- assertEquals(1, earlyEventCount);
+ assertThat(earlyEventCount).isEqualTo(1);
}
@Test
@@ -435,11 +433,11 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> allEventsSeen = transport.getEvents();
assertThat(allEventsSeen).hasSize(4);
- assertEquals(startEvent.getEventId(), allEventsSeen.get(0).getEventId());
+ assertThat(allEventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
BuildEvent linkEvent = allEventsSeen.get(1);
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, linkEvent.getEventId());
- assertEquals(rootCause.getEventId(), allEventsSeen.get(2).getEventId());
- assertEquals(failedTarget.getEventId(), allEventsSeen.get(3).getEventId());
+ assertThat(linkEvent.getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertThat(allEventsSeen.get(2).getEventId()).isEqualTo(rootCause.getEventId());
+ assertThat(allEventsSeen.get(3).getEventId()).isEqualTo(failedTarget.getEventId());
}
@Test
@@ -467,12 +465,12 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> allEventsSeen = transport.getEvents();
assertThat(allEventsSeen).hasSize(6);
- assertEquals(startEvent.getEventId(), allEventsSeen.get(0).getEventId());
- assertEquals(BuildEventId.buildFinished(), allEventsSeen.get(1).getEventId());
+ assertThat(allEventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(allEventsSeen.get(1).getEventId()).isEqualTo(BuildEventId.buildFinished());
BuildEvent linkEvent = allEventsSeen.get(2);
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, linkEvent.getEventId());
- assertEquals(rootCauseId, allEventsSeen.get(3).getEventId());
- assertEquals(failedTarget.getEventId(), allEventsSeen.get(4).getEventId());
+ assertThat(linkEvent.getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertThat(allEventsSeen.get(3).getEventId()).isEqualTo(rootCauseId);
+ assertThat(allEventsSeen.get(4).getEventId()).isEqualTo(failedTarget.getEventId());
}
@Test
@@ -496,8 +494,8 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> allEventsSeen = transport.getEvents();
assertThat(allEventsSeen).hasSize(2);
- assertEquals(startEvent.getEventId(), allEventsSeen.get(0).getEventId());
- assertEquals(waitingForStart.getEventId(), allEventsSeen.get(1).getEventId());
+ assertThat(allEventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(allEventsSeen.get(1).getEventId()).isEqualTo(waitingForStart.getEventId());
}
private Artifact makeArtifact(String pathString) {
@@ -531,23 +529,22 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> allEventsSeen = transport.getEvents();
List<BuildEventStreamProtos.BuildEvent> eventProtos = transport.getEventProtos();
- assertEquals(7, allEventsSeen.size());
- assertEquals(startEvent.getEventId(), allEventsSeen.get(0).getEventId());
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, allEventsSeen.get(1).getEventId());
+ assertThat(allEventsSeen).hasSize(7);
+ assertThat(allEventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(allEventsSeen.get(1).getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
List<BuildEventStreamProtos.File> firstSetDirects =
eventProtos.get(2).getNamedSetOfFiles().getFilesList();
- assertEquals(2, firstSetDirects.size());
- assertEquals(
- ImmutableSet.of(a.getPath().toString(), b.getPath().toString()),
- ImmutableSet.of(firstSetDirects.get(0).getUri(), firstSetDirects.get(1).getUri()));
+ assertThat(firstSetDirects).hasSize(2);
+ assertThat(ImmutableSet.of(firstSetDirects.get(0).getUri(), firstSetDirects.get(1).getUri()))
+ .isEqualTo(ImmutableSet.of(a.getPath().toString(), b.getPath().toString()));
List<NamedSetOfFilesId> secondSetTransitives =
eventProtos.get(4).getNamedSetOfFiles().getFileSetsList();
- assertEquals(1, secondSetTransitives.size());
- assertEquals(eventProtos.get(2).getId().getNamedSet(), secondSetTransitives.get(0));
+ assertThat(secondSetTransitives).hasSize(1);
+ assertThat(secondSetTransitives.get(0)).isEqualTo(eventProtos.get(2).getId().getNamedSet());
List<NamedSetOfFilesId> reportedArtifactSets =
eventProtos.get(6).getNamedSetOfFiles().getFileSetsList();
- assertEquals(1, reportedArtifactSets.size());
- assertEquals(eventProtos.get(4).getId().getNamedSet(), reportedArtifactSets.get(0));
+ assertThat(reportedArtifactSets).hasSize(1);
+ assertThat(reportedArtifactSets.get(0)).isEqualTo(eventProtos.get(4).getId().getNamedSet());
}
@Test
@@ -576,16 +573,16 @@ public class BuildEventStreamerTest extends FoundationTestCase {
List<BuildEvent> eventsSeen = transport.getEvents();
assertThat(eventsSeen).hasSize(3);
- assertEquals(startEvent.getEventId(), eventsSeen.get(0).getEventId());
- assertEquals(unexpectedEvent.getEventId(), eventsSeen.get(2).getEventId());
+ assertThat(eventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(eventsSeen.get(2).getEventId()).isEqualTo(unexpectedEvent.getEventId());
BuildEvent linkEvent = eventsSeen.get(1);
BuildEventStreamProtos.BuildEvent linkEventProto = transport.getEventProtos().get(1);
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, linkEvent.getEventId());
- assertTrue(
- "Unexpected events should be linked",
- linkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()));
- assertEquals(stdoutMsg, linkEventProto.getProgress().getStdout());
- assertEquals(stderrMsg, linkEventProto.getProgress().getStderr());
+ assertThat(linkEvent.getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertWithMessage("Unexpected events should be linked")
+ .that(linkEvent.getChildrenEvents().contains(unexpectedEvent.getEventId()))
+ .isTrue();
+ assertThat(linkEventProto.getProgress().getStdout()).isEqualTo(stdoutMsg);
+ assertThat(linkEventProto.getProgress().getStderr()).isEqualTo(stderrMsg);
// As there is only one progress event, the OutErrProvider should be queried
// only once for stdout and stderr.
@@ -622,13 +619,13 @@ public class BuildEventStreamerTest extends FoundationTestCase {
streamer.buildEvent(secondWithConfiguration);
List<BuildEvent> allEventsSeen = transport.getEvents();
- assertEquals(7, allEventsSeen.size());
- assertEquals(startEvent.getEventId(), allEventsSeen.get(0).getEventId());
- assertEquals(ProgressEvent.INITIAL_PROGRESS_UPDATE, allEventsSeen.get(1).getEventId());
- assertEquals(configuration, allEventsSeen.get(2));
- assertEquals(BuildEventId.progressId(1), allEventsSeen.get(3).getEventId());
- assertEquals(firstWithConfiguration, allEventsSeen.get(4));
- assertEquals(BuildEventId.progressId(2), allEventsSeen.get(5).getEventId());
- assertEquals(secondWithConfiguration, allEventsSeen.get(6));
+ assertThat(allEventsSeen).hasSize(7);
+ assertThat(allEventsSeen.get(0).getEventId()).isEqualTo(startEvent.getEventId());
+ assertThat(allEventsSeen.get(1).getEventId()).isEqualTo(ProgressEvent.INITIAL_PROGRESS_UPDATE);
+ assertThat(allEventsSeen.get(2)).isEqualTo(configuration);
+ assertThat(allEventsSeen.get(3).getEventId()).isEqualTo(BuildEventId.progressId(1));
+ assertThat(allEventsSeen.get(4)).isEqualTo(firstWithConfiguration);
+ assertThat(allEventsSeen.get(5).getEventId()).isEqualTo(BuildEventId.progressId(2));
+ assertThat(allEventsSeen.get(6)).isEqualTo(secondWithConfiguration);
}
}