Implement tests for EurekaReactiveDiscoveryClient and EurekaDiscoveryClientTests (#4508)

* Implement probe() and reactiveProbe() and tests for Reactive client

Signed-off-by: Mohamed Macow <[email protected]>

* Implement test for probe()

Signed-off-by: Mohamed Macow <[email protected]>

* Correct year in copyright

Signed-off-by: Mohamed Macow <[email protected]>

* remove function override and correct tests

Signed-off-by: Mohamed Macow <[email protected]>

* revert override in reactive client

Signed-off-by: Mohamed Macow <[email protected]>

* revert format

Signed-off-by: Mohamed Macow <[email protected]>

---------

Signed-off-by: Mohamed Macow <[email protected]>

Author: darth-raijin

spring-cloud-netflix-eureka-client/src/test/java/org/springframework/cloud/netflix/eureka/EurekaDiscoveryClientTests.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright 2025-present the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.netflix.eureka;
+
+import com.netflix.discovery.EurekaClient;
+import com.netflix.discovery.shared.Applications;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import static org.assertj.core.api.Assertions.assertThatCode;
+import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
+import static org.mockito.Mockito.when;
+
+
+/**
+ * @author Mohamed Macow
+ */
+@ExtendWith(MockitoExtension.class)
+class EurekaDiscoveryClientTests {
+
+	@Mock
+	private EurekaClient eurekaClient;
+
+	@InjectMocks
+	private EurekaDiscoveryClient client;
+
+	@Test
+	void shouldCompleteProbeWhenClientHealthy() {
+		when(eurekaClient.getApplications()).thenReturn(new Applications());
+
+		assertThatCode(() -> client.probe())
+				.doesNotThrowAnyException();
+	}
+
+	@Test
+	void shouldThrowProbeWhenClientThrows() {
+		RuntimeException eurekaException = new RuntimeException("exception");
+		when(eurekaClient.getApplications()).thenThrow(eurekaException);
+
+		assertThatExceptionOfType(eurekaException.getClass())
+				.isThrownBy(() -> client.probe())
+				.withMessage(eurekaException.getMessage());
+	}
+}

spring-cloud-netflix-eureka-client/src/test/java/org/springframework/cloud/netflix/eureka/reactive/EurekaReactiveDiscoveryClientTests.java

@@ -39,6 +39,7 @@
 
 /**
  * @author Tim Ysewyn
+ * @author Mohamed Macow
  */
 @ExtendWith(MockitoExtension.class)
 class EurekaReactiveDiscoveryClientTests {
@@ -109,4 +110,24 @@ void shouldReturnFluxOfServiceInstances() {
 		StepVerifier.create(instances).expectNextCount(1).expectComplete().verify();
 	}
 
+	@Test
+	void shouldCompleteReactiveProbeWhenClientHealthy() {
+		when(eurekaClient.getApplications()).thenReturn(new Applications());
+
+		StepVerifier.create(client.reactiveProbe())
+				.verifyComplete();
+	}
+
+	@Test
+	void shouldErrorReactiveProbeWhenClientThrows() {
+		RuntimeException eurekaException = new RuntimeException("exception");
+		when(eurekaClient.getApplications()).thenThrow(eurekaException);
+
+		StepVerifier.create(client.reactiveProbe())
+				.verifyErrorSatisfies(ex ->
+						assertThat(ex)
+								.isInstanceOf(RuntimeException.class)
+								.hasMessage(eurekaException.getMessage()));
+	}
+
 }