fix: add status check to TimerEventSource and update tests

Signed-off-by: David Sondermann <[email protected]>

Author: Donnerbart

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/timer/TimerEventSource.java

@@ -10,6 +10,7 @@
 import org.slf4j.LoggerFactory;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.health.Status;
 import io.javaoperatorsdk.operator.processing.event.Event;
 import io.javaoperatorsdk.operator.processing.event.ResourceID;
 import io.javaoperatorsdk.operator.processing.event.source.AbstractEventSource;
@@ -77,6 +78,11 @@ public void stop() {
     }
   }
 
+  @Override
+  public Status getStatus() {
+    return isRunning() ? Status.HEALTHY : Status.UNHEALTHY;
+  }
+
   @Override
   public Set<Void> getSecondaryResources(HasMetadata primary) {
     return Set.of();

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/timer/TimerEventSourceTest.java

@@ -11,6 +11,7 @@
 import org.junit.jupiter.api.Test;
 
 import io.javaoperatorsdk.operator.TestUtils;
+import io.javaoperatorsdk.operator.health.Status;
 import io.javaoperatorsdk.operator.processing.event.Event;
 import io.javaoperatorsdk.operator.processing.event.EventHandler;
 import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -41,6 +42,7 @@ public void schedulesOnce() {
 
     untilAsserted(() -> assertThat(eventHandler.events).hasSize(1));
     untilAsserted(PERIOD * 2, 0, () -> assertThat(eventHandler.events).hasSize(1));
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
   }
 
   @Test
@@ -51,6 +53,7 @@ public void canCancelOnce() {
     source.cancelOnceSchedule(resourceID);
 
     untilAsserted(() -> assertThat(eventHandler.events).isEmpty());
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
   }
 
   @Test
@@ -61,6 +64,7 @@ public void canRescheduleOnceEvent() {
     source.scheduleOnce(resourceID, 2 * PERIOD);
 
     untilAsserted(PERIOD * 2, PERIOD, () -> assertThat(eventHandler.events).hasSize(1));
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
   }
 
   @Test
@@ -71,23 +75,29 @@ public void deRegistersOnceEventSources() {
     source.onResourceDeleted(customResource);
 
     untilAsserted(() -> assertThat(eventHandler.events).isEmpty());
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
   }
 
   @Test
   public void eventNotRegisteredIfStopped() {
     var resourceID = ResourceID.fromResource(TestUtils.testCustomResource());
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
 
     source.stop();
     assertThatExceptionOfType(IllegalStateException.class)
         .isThrownBy(() -> source.scheduleOnce(resourceID, PERIOD));
+    assertThat(source.getStatus()).isEqualTo(Status.UNHEALTHY);
   }
 
   @Test
   public void eventNotFiredIfStopped() {
     source.scheduleOnce(ResourceID.fromResource(TestUtils.testCustomResource()), PERIOD);
+    assertThat(source.getStatus()).isEqualTo(Status.HEALTHY);
+
     source.stop();
 
     untilAsserted(() -> assertThat(eventHandler.events).isEmpty());
+    assertThat(source.getStatus()).isEqualTo(Status.UNHEALTHY);
   }
 
   private void untilAsserted(ThrowingRunnable assertion) {