From f60081c4edfdbd26eedf846959b96862e42e53ae Mon Sep 17 00:00:00 2001 From: Loganathan Sekar Date: Thu, 22 Feb 2024 20:31:08 +0530 Subject: [PATCH] Fixed test Signed-off-by: Loganathan Sekar --- .../stage/test/OpencrvsStageTest.java | 27 +++++++++++++++---- 1 file changed, 22 insertions(+), 5 deletions(-) diff --git a/registration-processor-opencrvs-stage/src/test/java/io/mosip/registration/processor/opencrvs/stage/test/OpencrvsStageTest.java b/registration-processor-opencrvs-stage/src/test/java/io/mosip/registration/processor/opencrvs/stage/test/OpencrvsStageTest.java index fe62e0a..bca76dd 100644 --- a/registration-processor-opencrvs-stage/src/test/java/io/mosip/registration/processor/opencrvs/stage/test/OpencrvsStageTest.java +++ b/registration-processor-opencrvs-stage/src/test/java/io/mosip/registration/processor/opencrvs/stage/test/OpencrvsStageTest.java @@ -8,10 +8,12 @@ import java.io.IOException; import java.lang.reflect.Field; -import java.util.*; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Map; -import io.mosip.kernel.core.exception.ExceptionUtils; -import io.mosip.registration.processor.opencrvs.stage.OpencrvsStage; import org.json.simple.JSONObject; import org.junit.Before; import org.junit.Test; @@ -31,8 +33,10 @@ import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.ObjectMapper; +import io.mosip.kernel.core.exception.ExceptionUtils; import io.mosip.kernel.core.exception.ServiceError; import io.mosip.registration.processor.core.abstractverticle.EventDTO; +import io.mosip.registration.processor.core.abstractverticle.HealthCheckDTO; import io.mosip.registration.processor.core.abstractverticle.MessageBusAddress; import io.mosip.registration.processor.core.abstractverticle.MessageDTO; import io.mosip.registration.processor.core.abstractverticle.MosipEventBus; @@ -53,6 +57,7 @@ import io.mosip.registration.processor.core.spi.eventbus.EventHandler; import io.mosip.registration.processor.core.spi.restclient.RegistrationProcessorRestClientService; import io.mosip.registration.processor.core.util.PropertiesUtil; +import io.mosip.registration.processor.opencrvs.stage.OpencrvsStage; import io.mosip.registration.processor.packet.storage.utils.Utilities; import io.mosip.registration.processor.rest.client.audit.builder.AuditLogRequestBuilder; import io.mosip.registration.processor.rest.client.audit.dto.AuditResponseDto; @@ -134,6 +139,18 @@ public void consumeAndSend(MessageBusAddress fromAddress, MessageBusAddress toAd public void send(MessageBusAddress toAddress, MessageDTO message) { } + + @Override + public void consumerHealthCheck(Handler eventHandler, String address) { + // TODO Auto-generated method stub + + } + + @Override + public void senderHealthCheck(Handler eventHandler, String address) { + // TODO Auto-generated method stub + + } }; } @@ -216,7 +233,7 @@ public void setup() throws Exception { Map map1 = new HashMap<>(); map1.put("UIN", "4238135072"); JSONObject jsonObject = new JSONObject(map1); - Mockito.when(utitilites.retrieveUIN(any())).thenReturn(jsonObject); + Mockito.when(utitilites.retrieveIdrepoJson(any())).thenReturn(jsonObject); @@ -352,7 +369,7 @@ public void testUINNotavailable() Map map1 = new HashMap<>(); JSONObject jsonObject = new JSONObject(map1); - Mockito.when(utitilites.retrieveUIN(any())).thenReturn(jsonObject); + Mockito.when(utitilites.retrieveIdrepoJson(any())).thenReturn(jsonObject); MessageDTO result = stage.process(dto); assertFalse(result.getIsValid());