Add JobWatcher unit tests

Author: alai8

operator/src/test/java/oracle/kubernetes/operator/JobWatcherTest.java

@@ -13,13 +13,17 @@
 import io.kubernetes.client.models.V1JobStatus;
 import io.kubernetes.client.models.V1ObjectMeta;
 import io.kubernetes.client.util.Watch;
+import java.util.function.Consumer;
 import oracle.kubernetes.operator.builders.StubWatchFactory;
 import oracle.kubernetes.operator.watcher.WatchListener;
+import oracle.kubernetes.operator.work.FiberTestSupport;
 import oracle.kubernetes.operator.work.NextAction;
 import oracle.kubernetes.operator.work.Packet;
 import oracle.kubernetes.operator.work.Step;
 import oracle.kubernetes.weblogic.domain.model.Domain;
 import org.hamcrest.Matchers;
+import static org.hamcrest.core.IsNull.nullValue;
+import org.joda.time.DateTime;
 import org.junit.Test;
 
 import static oracle.kubernetes.operator.LabelConstants.CREATEDBYOPERATOR_LABEL;
@@ -38,7 +42,8 @@ public class JobWatcherTest extends WatcherTestBase implements WatchListener<V1J
   private static final String NS = "ns1";
   private static final String VERSION = "123";
   private Packet packet;
-  private V1Job job = new V1Job().metadata(new V1ObjectMeta().name("test"));
+  private V1Job job = new V1Job().metadata(new V1ObjectMeta().name("test").creationTimestamp(new DateTime()));
+  private FiberTestSupport fiberTestSupport = new FiberTestSupport();
 
   public void setUp() throws Exception {
     super.setUp();
@@ -115,6 +120,12 @@ private void makeJobReady(V1Job job) {
     job.status(new V1JobStatus().conditions(conditions));
   }
 
+  private void makeJobFailed(V1Job job, String reason) {
+    List<V1JobCondition> conditions =
+        Collections.singletonList(new V1JobCondition().type("Failed").status("True").reason(reason));
+    job.status(new V1JobStatus().failed(1).conditions(conditions));
+  }
+
   @Test
   public void whenJobHasNoStatus_reportNotFailed() {
     assertThat(JobWatcher.isFailed(job), is(false));
@@ -127,6 +138,34 @@ public void whenJobHasFailedCount_reportFailed() {
     assertThat(JobWatcher.isFailed(job), is(true));
   }
 
+  @Test
+  public void whenJobHasFailedReason_getFailedReasonReturnsIt() {
+    makeJobFailed(job, "DeadlineExceeded");
+
+    assertThat(JobWatcher.getFailedReason(job), is("DeadlineExceeded"));
+  }
+
+  @Test
+  public void whenJobHasNoFailedReason_getFailedReasonReturnsNull() {
+    makeJobFailed(job, null);
+
+    assertThat(JobWatcher.getFailedReason(job), nullValue());
+  }
+
+  @Test
+  public void whenJobHasNoFailedCondition_getFailedReasonReturnsNull() {
+    job.status(new V1JobStatus().addConditionsItem(new V1JobCondition().type("Complete").status("True")));
+
+    assertThat(JobWatcher.getFailedReason(job), nullValue());
+  }
+
+  @Test
+  public void whenJobHasNoJobCondition_getFailedReasonReturnsNull() {
+    job.status(new V1JobStatus().conditions(Collections.EMPTY_LIST));
+
+    assertThat(JobWatcher.getFailedReason(job), nullValue());
+  }
+
   @Test
   public void waitForReady_returnsAStep() {
     AtomicBoolean stopping = new AtomicBoolean(true);
@@ -152,6 +191,38 @@ public void whenWaitForReadyAppliedToReadyJob_performNextStep() {
     assertThat(listeningStep.wasPerformed, is(true));
   }
 
+  @Test
+  public void whenReceivedDeadlineExceededResponse_doNotPerformNextStep() {
+    doReceivedResponseTest((j) -> makeJobFailed(j, "DeadlineExceeded"), false);
+  }
+
+  @Test
+  public void whenReceivedFailedWithNoReasonResponse_performNextStep() {
+    doReceivedResponseTest((j) -> makeJobFailed(j, null), true);
+  }
+
+  @Test
+  public void whenReceivedCompleteResponse_performNextStep() {
+    doReceivedResponseTest((j) -> makeJobReady(j), true);
+  }
+
+  private void doReceivedResponseTest(Consumer<V1Job> jobStatusUpdater, final boolean expectedResult) {
+    AtomicBoolean stopping = new AtomicBoolean(false);
+    JobWatcher watcher =
+        JobWatcher.create(this, "ns", Integer.toString(INITIAL_RESOURCE_VERSION), tuning, stopping);
+
+    ListeningTerminalStep listeningStep = new ListeningTerminalStep(stopping);
+    Step step = watcher.waitForReady(job, listeningStep);
+
+    // run WaitForReadyStep.apply() and the doSuspend() inside apply() to set up Complete callback
+    fiberTestSupport.runSteps(step);
+
+    jobStatusUpdater.accept(job);
+
+    watcher.receivedResponse(new Watch.Response<>("MODIFIED", job));
+    assertThat(listeningStep.wasPerformed, is(expectedResult));
+  }
+
   @Test
   public void afterFactoryDefined_createWatcherForDomain() {
     AtomicBoolean stopping = new AtomicBoolean(true);