Fact 2634 csv creation for cron job

build.gradle

@@ -201,7 +201,7 @@ dependencies {
 
   implementation group: 'com.azure.spring', name: 'spring-cloud-azure-starter-storage-blob', version: '7.3.0'
 
-
+  implementation group: 'tools.jackson.dataformat', name: 'jackson-dataformat-csv'
   implementation group: 'tools.jackson.datatype', name: 'jackson-datatype-hibernate7'
 
   implementation group: 'com.github.hmcts.java-logging', name: 'logging', version: '8.0.0'

infrastructure/storage-account.tf

@@ -16,6 +16,10 @@ module "storage_account" {
     {
       name        = "photos",
       access_type = "container"
+    },
+    {
+      name        = "csv",
+      access_type = "container"
     }
   ]
 

src/functionalTest/java/uk/gov/hmcts/reform/fact/functional/controllers/CsvControllerFunctionalTest.java

@@ -0,0 +1,35 @@
+package uk.gov.hmcts.reform.fact.functional.controllers;
+
+import io.qameta.allure.Feature;
+import io.restassured.response.Response;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import uk.gov.hmcts.reform.fact.functional.http.HttpClient;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.springframework.http.HttpStatus.UNAUTHORIZED;
+
+@Feature("CSV Controller")
+@DisplayName("CSV Controller")
+class CsvControllerFunctionalTest {
+
+    private static final String CSV_ENDPOINT = "/csv/";
+    private static final String INVALID_TOKEN = "invalid-token";
+    private static final HttpClient http = new HttpClient();
+
+    @Test
+    @DisplayName("POST /csv/ without bearer token returns 401")
+    void shouldReturnUnauthorizedWithoutToken() {
+        final Response response = http.doPost(CSV_ENDPOINT, null, "");
+
+        assertThat(response.statusCode()).isEqualTo(UNAUTHORIZED.value());
+    }
+
+    @Test
+    @DisplayName("POST /csv/ with invalid bearer token returns 401")
+    void shouldReturnUnauthorizedWithInvalidToken() {
+        final Response response = http.doPost(CSV_ENDPOINT, null, INVALID_TOKEN);
+
+        assertThat(response.statusCode()).isEqualTo(UNAUTHORIZED.value());
+    }
+}

src/integrationTest/java/uk/gov/hmcts/reform/fact/data/api/config/AzureBlobConfigurationTestConfiguration.java

@@ -9,6 +9,8 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
 
+import uk.gov.hmcts.reform.fact.data.api.services.AzureBlobService;
+
 @Configuration
 @Profile("test")
 public class AzureBlobConfigurationTestConfiguration {
@@ -17,7 +19,10 @@ public class AzureBlobConfigurationTestConfiguration {
     private BlobServiceClient blobServiceClient;
 
     @Mock
-    private BlobContainerClient containerClient;
+    private BlobContainerClient photoContainerClient;
+
+    @Mock
+    private BlobContainerClient csvContainerClient;
 
     @Mock
     private BlobClient blobClient;
@@ -27,8 +32,13 @@ public AzureBlobConfigurationTestConfiguration() {
     }
 
     @Bean
-    public BlobContainerClient blobContainerClient() {
-        return containerClient;
+    public BlobContainerClient photoBlobContainerClient() {
+        return photoContainerClient;
+    }
+
+    @Bean
+    public BlobContainerClient csvBlobContainerClient() {
+        return csvContainerClient;
     }
 
     @Bean
@@ -40,4 +50,14 @@ public BlobClient blobClient() {
     public BlobServiceClient blobServiceClient() {
         return blobServiceClient;
     }
+
+    @Bean
+    public AzureBlobService photoAzureBlobService() {
+        return new AzureBlobService(photoContainerClient);
+    }
+
+    @Bean
+    public AzureBlobService csvAzureBlobService() {
+        return new AzureBlobService(csvContainerClient);
+    }
 }

src/integrationTest/java/uk/gov/hmcts/reform/fact/data/api/controllers/CsvControllerTest.java

@@ -0,0 +1,82 @@
+package uk.gov.hmcts.reform.fact.data.api.controllers;
+
+import io.qameta.allure.Feature;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.webmvc.test.autoconfigure.AutoConfigureMockMvc;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.bean.override.mockito.MockitoBean;
+import org.springframework.test.web.servlet.MockMvc;
+import uk.gov.hmcts.reform.fact.data.api.clients.SlackClient;
+import uk.gov.hmcts.reform.fact.data.api.services.AzureBlobService;
+import uk.gov.hmcts.reform.fact.data.api.services.CourtDetailsViewService;
+import uk.gov.hmcts.reform.fact.data.api.services.CourtService;
+
+import java.util.Collections;
+
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+@Feature("CSV Controller")
+@DisplayName("CSV Controller")
+@SpringBootTest
+@AutoConfigureMockMvc(addFilters = false)
+@ActiveProfiles("test")
+class CsvControllerTest {
+
+    @Autowired
+    private MockMvc mvc;
+
+    @MockitoBean(name = "csvAzureBlobService")
+    private AzureBlobService azureBlobService;
+
+    @MockitoBean
+    private CourtService courtService;
+
+    @MockitoBean
+    private CourtDetailsViewService courtDetailsViewService;
+
+    @MockitoBean
+    private SlackClient slackClient;
+
+    @Test
+    @DisplayName("POST /csv/ returns 200 when CSV is created and uploaded successfully")
+    void createAndUploadCsvReturns200() throws Exception {
+        when(courtService.getAllCourtDetails()).thenReturn(Collections.emptyList());
+        when(azureBlobService.uploadFile(anyString(), any())).thenReturn("http://example.com/blob");
+
+        mvc.perform(post("/csv/"))
+            .andExpect(status().isOk());
+
+        verify(azureBlobService, times(1)).uploadFile(anyString(), any());
+    }
+
+    @Test
+    @DisplayName("POST /csv/ returns 502 when Azure upload fails (e.g. container missing)")
+    void createAndUploadCsvReturns502OnAzureUploadException() throws Exception {
+        when(courtService.getAllCourtDetails()).thenReturn(Collections.emptyList());
+        when(azureBlobService.uploadFile(anyString(), any())).thenThrow(new RuntimeException("Container not found"));
+
+        mvc.perform(post("/csv/"))
+            .andExpect(status().isBadGateway())
+            .andExpect(jsonPath("$.message").value("Failed to upload CSV file to Azure Blob Storage"));
+    }
+
+    @Test
+    @DisplayName("POST /csv/ returns 500 when CSV creation fails")
+    void createAndUploadCsvReturns500OnCsvCreationException() throws Exception {
+        when(courtService.getAllCourtDetails()).thenThrow(new RuntimeException("DB error"));
+
+        mvc.perform(post("/csv/"))
+            .andExpect(status().isInternalServerError())
+            .andExpect(jsonPath("$.message").value("Failed to create CSV file"));
+    }
+}

src/main/java/uk/gov/hmcts/reform/fact/data/api/config/AzureBlobConfiguration.java

@@ -7,14 +7,36 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
 
+import uk.gov.hmcts.reform.fact.data.api.services.AzureBlobService;
+import org.springframework.beans.factory.annotation.Qualifier;
+
 @Configuration
 @Profile("!test")
 public class AzureBlobConfiguration {
 
     @Bean
-    public BlobContainerClient blobContainerClient(
+    public BlobContainerClient photoBlobContainerClient(
+        BlobServiceClient blobServiceClient,
+        @Value("${spring.cloud.azure.storage.blob.photo-container-name}") String containerName) {
+        return blobServiceClient.getBlobContainerClient(containerName);
+    }
+
+    @Bean
+    public BlobContainerClient csvBlobContainerClient(
         BlobServiceClient blobServiceClient,
-        @Value("${spring.cloud.azure.storage.blob.container-name}") String containerName) {
+        @Value("${spring.cloud.azure.storage.blob.csv-container-name}") String containerName) {
         return blobServiceClient.getBlobContainerClient(containerName);
     }
+
+    @Bean
+    public AzureBlobService photoAzureBlobService(
+        @Qualifier("photoBlobContainerClient") BlobContainerClient photoBlobContainerClient) {
+        return new AzureBlobService(photoBlobContainerClient);
+    }
+
+    @Bean
+    public AzureBlobService csvAzureBlobService(
+        @Qualifier("csvBlobContainerClient") BlobContainerClient csvBlobContainerClient) {
+        return new AzureBlobService(csvBlobContainerClient);
+    }
 }

src/main/java/uk/gov/hmcts/reform/fact/data/api/controllers/CsvController.java

@@ -0,0 +1,37 @@
+package uk.gov.hmcts.reform.fact.data.api.controllers;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.responses.ApiResponses;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import uk.gov.hmcts.reform.fact.data.api.security.SecuredFactRestController;
+import uk.gov.hmcts.reform.fact.data.api.services.CsvService;
+
+@SecuredFactRestController(
+    name = "CSV",
+    description = "Operations related to CSV file handling"
+)
+@RequestMapping("/csv")
+public class CsvController {
+
+    private final CsvService csvService;
+
+    public CsvController(CsvService csvService) {
+        this.csvService = csvService;
+    }
+
+    @PostMapping("/")
+    @Operation(
+        summary = "Create and upload CSV file",
+        description = "Generates a CSV file with court data and uploads it to the configured storage service."
+    )
+    @ApiResponses(value = {
+        @ApiResponse(responseCode = "200", description = "CSV file created and uploaded successfully"),
+        @ApiResponse(responseCode = "500", description = "Failed to create CSV file"),
+        @ApiResponse(responseCode = "502", description = "Failed to upload CSV file to storage")
+    })
+    public void createAndUploadCsv() {
+        csvService.createAndUploadCsv();
+    }
+}

src/main/java/uk/gov/hmcts/reform/fact/data/api/errorhandling/GlobalExceptionHandler.java

@@ -1,13 +1,17 @@
 package uk.gov.hmcts.reform.fact.data.api.errorhandling;
 
+import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.AzureUploadException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.CourtResourceNotFoundException;
+import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.CsvCreationException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.DuplicatedListItemException;
+import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.JsonConvertException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.InvalidAreaOfLawException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.InvalidDateRangeException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.InvalidFileException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.InvalidParameterCombinationException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.InvalidPostcodeException;
 import uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions.NotFoundException;
+
 import uk.gov.hmcts.reform.fact.data.api.validation.annotations.ValidUUID;
 
 import java.time.LocalDateTime;
@@ -206,6 +210,27 @@ public ExceptionResponse handle(InvalidAreaOfLawException ex) {
         return generateExceptionResponse(ex.getMessage());
     }
 
+    @ExceptionHandler(JsonConvertException.class)
+    @ResponseStatus(HttpStatus.BAD_REQUEST)
+    public ExceptionResponse handle(JsonConvertException ex) {
+        log.error("400, JSON conversion error. Details: {}", ex.getMessage());
+        return generateExceptionResponse(ex.getMessage());
+    }
+
+    @ExceptionHandler(AzureUploadException.class)
+    @ResponseStatus(HttpStatus.BAD_GATEWAY)
+    public ExceptionResponse handle(AzureUploadException ex) {
+        log.error("502, error while uploading CSV to Azure. Details: {}", ex.getMessage());
+        return generateExceptionResponse(ex.getMessage());
+    }
+
+    @ExceptionHandler(CsvCreationException.class)
+    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
+    public ExceptionResponse handle(CsvCreationException ex) {
+        log.error("500, error while creating CSV file. Details: {}", ex.getMessage());
+        return generateExceptionResponse(ex.getMessage());
+    }
+
     private ExceptionResponse generateExceptionResponse(String message) {
         ExceptionResponse response = new ExceptionResponse();
         response.setMessage(message);

src/main/java/uk/gov/hmcts/reform/fact/data/api/errorhandling/exceptions/CsvCreationException.java

@@ -0,0 +1,7 @@
+package uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions;
+
+import lombok.experimental.StandardException;
+
+@StandardException
+public class CsvCreationException extends RuntimeException {
+}

src/main/java/uk/gov/hmcts/reform/fact/data/api/errorhandling/exceptions/JsonConvertException.java

@@ -0,0 +1,7 @@
+package uk.gov.hmcts.reform.fact.data.api.errorhandling.exceptions;
+
+import lombok.experimental.StandardException;
+
+@StandardException
+public class JsonConvertException extends RuntimeException {
+}

src/main/java/uk/gov/hmcts/reform/fact/data/api/models/StringMultipartFile.java

@@ -0,0 +1,57 @@
+package uk.gov.hmcts.reform.fact.data.api.models;
+
+import lombok.Getter;
+import org.springframework.web.multipart.MultipartFile;
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+
+/**
+ * An implementation of the {@link MultipartFile} interface that wraps a {@link String} content.
+ *
+ * <p>This class is used to represent a file created from a string, which can be then treated as a standard
+ * multipart file for operations like uploading to cloud storage.</p>
+ */
+@Getter
+public class StringMultipartFile implements MultipartFile {
+
+    private final String name;
+    private final String originalFilename;
+    private final String contentType;
+    private final byte[] bytes;
+
+    /**
+     * Constructs a new StringMultipartFile.
+     *
+     * @param name the name of the file
+     * @param originalFilename the original filename
+     * @param contentType the content type of the file
+     * @param content the string content of the file
+     */
+    public StringMultipartFile(String name, String originalFilename, String contentType, String content) {
+        this.name = name;
+        this.originalFilename = originalFilename;
+        this.contentType = contentType;
+        this.bytes = content.getBytes();
+    }
+
+    @Override
+    public boolean isEmpty() {
+        return bytes.length == 0;
+    }
+
+    @Override
+    public long getSize() {
+        return bytes.length;
+    }
+
+    @Override
+    public InputStream getInputStream() {
+        return new ByteArrayInputStream(bytes);
+    }
+
+    @Override
+    public void transferTo(java.io.File dest) throws IllegalStateException {
+        // This implementation is currently empty as it's not required for current use cases,
+        // but the override is necessary for the interface.
+    }
+}