addition of case urn mapper service

Author: yashyashm

src/integrationTest/java/uk/gov/hmcts/cp/config/TestConfig.java

@@ -1,4 +1,15 @@
 package uk.gov.hmcts.cp.config;
 
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import uk.gov.hmcts.cp.services.CaseUrnMapperService;
+import uk.gov.hmcts.cp.services.InMemoryCaseUrnMapper;
+
+@Configuration
 public class TestConfig {
-}
+
+    @Bean
+    public CaseUrnMapperService caseUrnMapperService() {
+        return new InMemoryCaseUrnMapper();
+    }
+}

src/integrationTest/java/uk/gov/hmcts/cp/controllers/CourtScheduleControllerIT.java

@@ -2,16 +2,20 @@
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Import;
 import org.springframework.http.MediaType;
 import org.springframework.test.context.junit.jupiter.SpringExtension;
 import org.springframework.test.web.servlet.MockMvc;
+import uk.gov.hmcts.cp.config.TestConfig;
+import uk.gov.hmcts.cp.services.InMemoryCaseUrnMapper;
 
 import java.util.UUID;
 
@@ -22,12 +26,22 @@
 @ExtendWith(SpringExtension.class)
 @SpringBootTest
 @AutoConfigureMockMvc
+@Import(TestConfig.class)
 class CourtScheduleControllerIT {
     private static final Logger log = LoggerFactory.getLogger(CourtScheduleControllerIT.class);
 
     @Autowired
     private MockMvc mockMvc;
 
+    @Autowired
+    private InMemoryCaseUrnMapper inMemoryCaseUrnMapper;
+
+    @BeforeEach
+    void setUp() {
+        inMemoryCaseUrnMapper.clearAllMappings();
+        inMemoryCaseUrnMapper.saveCaseUrnMapping("test-case-urn", "test-case-id");
+    }
+
     @Test
     void shouldReturnOkWhenValidUrnIsProvided() throws Exception {
         String caseUrn = "test-case-urn";

src/main/java/uk/gov/hmcts/cp/config/OpenAPIConfiguration.java

@@ -3,6 +3,7 @@
 import io.swagger.v3.oas.models.OpenAPI;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
 
 @Configuration
 public class OpenAPIConfiguration {
@@ -13,4 +14,9 @@ public class OpenAPIConfiguration {
     public OpenAPI openAPI() {
         return openAPIConfigLoader.openAPI();
     }
+
+    @Bean
+    public RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
 }

src/main/java/uk/gov/hmcts/cp/controllers/CourtScheduleController.java

@@ -10,15 +10,19 @@
 import org.springframework.web.server.ResponseStatusException;
 import uk.gov.hmcts.cp.openapi.api.CourtScheduleApi;
 import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
+import uk.gov.hmcts.cp.services.CaseUrnMapperService;
 import uk.gov.hmcts.cp.services.CourtScheduleService;
 
 @RestController
 public class CourtScheduleController implements CourtScheduleApi {
     private static final Logger LOG = LoggerFactory.getLogger(CourtScheduleController.class);
     private final CourtScheduleService courtScheduleService;
+    private final CaseUrnMapperService caseUrnMapperService;
 
-    public CourtScheduleController(final CourtScheduleService courtScheduleService) {
+    public CourtScheduleController(final CourtScheduleService courtScheduleService,
+                                   final CaseUrnMapperService caseUrnMapperService) {
         this.courtScheduleService = courtScheduleService;
+        this.caseUrnMapperService = caseUrnMapperService;
     }
 
     @Override
@@ -27,7 +31,8 @@ public ResponseEntity<CourtScheduleResponse> getCourtScheduleByCaseUrn(final Str
         final CourtScheduleResponse courtScheduleResponse;
         try {
             sanitizedCaseUrn = sanitizeCaseUrn(caseUrn);
-            courtScheduleResponse = courtScheduleService.getCourtScheduleByCaseUrn(sanitizedCaseUrn);
+            courtScheduleResponse = courtScheduleService.getCourtScheduleByCaseUrn(
+                    caseUrnMapperService.getCaseId(sanitizedCaseUrn));
         } catch (ResponseStatusException e) {
             LOG.atError().log(e.getMessage());
             throw e;

src/main/java/uk/gov/hmcts/cp/services/CaseUrnMapperService.java

@@ -17,45 +17,7 @@
 import java.net.URI;
 import java.util.List;
 
-@Service
-@RequiredArgsConstructor
-public class CaseUrnMapperServiceImpl {
 
-    private static final Logger LOG = LoggerFactory.getLogger(CaseUrnMapperServiceImpl.class);
-
-    private final RestTemplate restTemplate;
-
-    @Value("${service.case-mapper-service.url}")
-    private String caseMapperServiceUrl;
-
-    private static final String CASEURN_ID = "caseurn/{caseurn}";
-
-    public String getCaseId(final String caseUrn) {
-        try {
-            ResponseEntity<String> responseEntity = restTemplate.exchange(
-                    getCaseIdUrl(caseUrn),
-                    HttpMethod.GET,
-                    getRequestEntity(),
-                    String.class
-            );
-            return responseEntity.hasBody() ? responseEntity.getBody(): Strings.EMPTY;
-        } catch (Exception e) {
-            LOG.atError().log("Error while getting case id from case urn", e);
-        }
-        return null;
-    }
-
-    private String getCaseIdUrl(String caseUrn) {
-        return UriComponentsBuilder
-                .fromUri(URI.create(caseMapperServiceUrl))
-                .pathSegment(caseUrn)
-                .buildAndExpand(caseUrn)
-                .toUriString();
-    }
-
-    private HttpEntity<String> getRequestEntity() {
-        HttpHeaders headers = new HttpHeaders();
-        headers.setAccept(List.of(MediaType.APPLICATION_JSON));
-        return new HttpEntity<>(headers);
-    }
+public interface CaseUrnMapperService {
+    public String getCaseId(final String caseUrn) ;
 }

src/main/java/uk/gov/hmcts/cp/services/CaseUrnMapperServiceImpl.java

@@ -19,9 +19,9 @@
 
 @Service
 @RequiredArgsConstructor
-public class CaseUrnMapperService {
+public class CaseUrnMapperServiceImpl implements CaseUrnMapperService {
 
-    private static final Logger LOG = LoggerFactory.getLogger(CaseUrnMapperService.class);
+    private static final Logger LOG = LoggerFactory.getLogger(CaseUrnMapperServiceImpl.class);
 
     private final RestTemplate restTemplate;
 
@@ -30,6 +30,7 @@ public class CaseUrnMapperService {
 
     private static final String CASEURN_ID = "caseurn/{caseurn}";
 
+    @Override
     public String getCaseId(final String caseUrn) {
         try {
             ResponseEntity<String> responseEntity = restTemplate.exchange(
@@ -45,15 +46,15 @@ public String getCaseId(final String caseUrn) {
         return null;
     }
 
-    protected String getCaseIdUrl(String caseUrn) {
+    private String getCaseIdUrl(String caseUrn) {
         return UriComponentsBuilder
                 .fromUri(URI.create(caseMapperServiceUrl))
                 .pathSegment(caseUrn)
                 .buildAndExpand(caseUrn)
                 .toUriString();
     }
 
-    protected HttpEntity<String> getRequestEntity() {
+    private HttpEntity<String> getRequestEntity() {
         HttpHeaders headers = new HttpHeaders();
         headers.setAccept(List.of(MediaType.APPLICATION_JSON));
         return new HttpEntity<>(headers);

src/main/java/uk/gov/hmcts/cp/services/InMemoryCaseUrnMapper.java

@@ -1,4 +1,25 @@
 package uk.gov.hmcts.cp.services;
 
-public class InMemoryCaseUrnMapper {
-}
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@Component
+public class InMemoryCaseUrnMapper implements CaseUrnMapperService {
+
+    private final Map<String, String> caseUrnToCaseIdMap = new ConcurrentHashMap<>();
+
+    public void saveCaseUrnMapping(final String caseUrn, final String caseId) {
+        caseUrnToCaseIdMap.put(caseUrn, caseId);
+    }
+
+    @Override
+    public String getCaseId(final String caseUrn) {
+        return caseUrnToCaseIdMap.getOrDefault(caseUrn, "default-case-id");
+    }
+
+    public void clearAllMappings() {
+        caseUrnToCaseIdMap.clear();
+    }
+}

src/main/resources/application.yaml

@@ -30,6 +30,10 @@ spring:
 #      key: ${COSMOSDB_KEY}
 #      database: ${COSMOSDB_DATABASE}
 
+service:
+  case-mapper-service:
+    url: https://virtserver.swaggerhub.com/HMCTS-DTS/api-cp-refdata-case-mapper
+
 azure:
   application-insights:
     instrumentation-key: ${rpe.AppInsightsInstrumentationKey:00000000-0000-0000-0000-000000000000}

src/test/java/uk/gov/hmcts/cp/controllers/CourtScheduleControllerTest.java

@@ -6,15 +6,18 @@
 import org.slf4j.LoggerFactory;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.client.RestTemplate;
 import org.springframework.web.server.ResponseStatusException;
 import uk.gov.hmcts.cp.openapi.model.CourtSchedule;
 import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
 
 import uk.gov.hmcts.cp.openapi.model.CourtSitting;
 import uk.gov.hmcts.cp.openapi.model.Hearing;
-import uk.gov.hmcts.cp.repositories.CourtScheduleRepository;
 import uk.gov.hmcts.cp.repositories.InMemoryCourtScheduleRepositoryImpl;
+import uk.gov.hmcts.cp.services.CaseUrnMapperService;
+import uk.gov.hmcts.cp.services.CaseUrnMapperServiceImpl;
 import uk.gov.hmcts.cp.services.CourtScheduleService;
+import uk.gov.hmcts.cp.services.InMemoryCaseUrnMapper;
 
 import java.util.UUID;
 
@@ -33,7 +36,8 @@ class CourtScheduleControllerTest {
     @BeforeEach
     void setUp() {
         CourtScheduleService courtScheduleService = new CourtScheduleService(new InMemoryCourtScheduleRepositoryImpl());
-        courtScheduleController = new CourtScheduleController(courtScheduleService);
+        CaseUrnMapperService caseUrnMapperService  = new InMemoryCaseUrnMapper();
+        courtScheduleController = new CourtScheduleController(courtScheduleService, caseUrnMapperService);
     }
 
     @Test