updating files in a MinIO storage system

java/registry/src/main/java/dev/sunbirdrc/registry/controller/FileStorageController.java

@@ -3,6 +3,10 @@
 import dev.sunbirdrc.registry.helper.RegistryHelper;
 import dev.sunbirdrc.registry.model.dto.DocumentsResponse;
 import dev.sunbirdrc.registry.service.FileStorageService;
+import io.minio.errors.*;
+import org.apache.commons.lang3.exception.ExceptionUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
@@ -11,6 +15,10 @@
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
+import java.rmi.ServerException;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
 import java.util.List;
 
 // TODO: Get should be viewed by both attestor and reviewer
@@ -19,6 +27,7 @@ public class FileStorageController {
     private final FileStorageService fileStorageService;
     private final RegistryHelper registryHelper;
 
+    private static final Logger logger = LoggerFactory.getLogger(FileStorageController.class);
     FileStorageController(FileStorageService fileStorageService, RegistryHelper registryHelper) {
         this.fileStorageService = fileStorageService;
         this.registryHelper = registryHelper;
@@ -56,6 +65,23 @@ public ResponseEntity<DocumentsResponse> deleteMultipleFiles(@PathVariable Strin
         return new ResponseEntity<>(documentsResponse, HttpStatus.OK);
     }
 
+    @PutMapping("/api/v1/{entityName}/{entityId}/{property}/documents/{documentId}")
+    public ResponseEntity<DocumentsResponse> update(@RequestParam MultipartFile[] files,
+                                                    @PathVariable String entityName,
+                                                    @PathVariable String entityId,
+                                                    @PathVariable String documentId,
+                                                    @PathVariable String property,
+                                                    HttpServletRequest httpServletRequest) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
+        try {
+            registryHelper.authorize(entityName, entityId, httpServletRequest);
+        } catch (Exception e) {
+            logger.error("An error occurred during authorization: {}", ExceptionUtils.getStackTrace(e));
+            return new ResponseEntity<>(HttpStatus.FORBIDDEN);
+        }
+        DocumentsResponse documentsResponse = fileStorageService.updateFiles(files, httpServletRequest.getRequestURI());
+        return new ResponseEntity<>(documentsResponse, HttpStatus.OK);
+    }
+
     @DeleteMapping(value = "/api/v1/{entity}/{entityId}/{property}/documents/{documentId}")
     public ResponseEntity deleteAFile(@PathVariable String entity,
                               @PathVariable String entityId,

java/registry/src/main/java/dev/sunbirdrc/registry/service/FileStorageService.java

@@ -9,6 +9,7 @@
 import io.minio.messages.Bucket;
 import io.minio.messages.DeleteError;
 import io.minio.messages.DeleteObject;
+import org.apache.commons.lang3.exception.ExceptionUtils;
 import org.apache.poi.util.IOUtils;
 import org.jetbrains.annotations.NotNull;
 import org.slf4j.Logger;
@@ -139,4 +140,27 @@ public ComponentHealthInfo getHealthInfo() {
 			return new ComponentHealthInfo(getServiceName(), false, CONNECTION_FAILURE, e.getMessage());
 		}
 	}
+	public DocumentsResponse updateFiles(MultipartFile[] files, String requestedURI) {
+		String objectPath = getDirectoryPath(requestedURI);
+		DocumentsResponse documentsResponse = new DocumentsResponse();
+		for (MultipartFile file : files) {
+			String fileName = getFileName(file.getOriginalFilename());
+			try {
+				boolean objectExists = minioClient.statObject(
+						StatObjectArgs.builder().bucket(bucketName).object(objectPath).build()
+				) != null;
+
+				if (objectExists) {
+					save(file.getInputStream(),objectPath);
+					documentsResponse.addDocumentLocation(objectPath);
+					return documentsResponse;
+				}
+			} catch (Exception e) {
+				documentsResponse.addError(file.getOriginalFilename());
+				logger.error("Error has occurred while trying to update the file {}: {}", fileName, ExceptionUtils.getStackTrace(e));
+
+			}
+		}
+		return documentsResponse;
+	}
 }