BlobStorageServiceImpl

BlobStorageServiceImpl.java

@Service
@RequiredArgsConstructor
@ConditionalOnProperty(value = "mock.azure.blobstorage.service.enabled", havingValue = "false", matchIfMissing = true)
public class BlobStorageServiceImpl implements BlobStorageService {

    private final Logger LOGGER = LoggerFactory.getLogger(BlobStorageServiceImpl.class);
    private final CloudBlobContainer cloudBlobContainer;

    @Override
    public URI uploadPicture(MultipartFile multipartFile) {
        URI uri;
        String multipartName = multipartFile.getName().replaceAll("[\n|\r|\t]", "_");
        LOGGER.info("Profile image uploading, image name: {}", multipartName);

        try {
            String extension = FilenameUtils.getExtension(multipartFile.getOriginalFilename());
            String fileName = String.join(".", UUID.randomUUID().toString(), extension);
            CloudBlockBlob  blob = cloudBlobContainer.getBlockBlobReference(fileName);
            blob.upload(multipartFile.getInputStream(), -1);
            uri = blob.getUri();
        } catch (URISyntaxException | StorageException | IOException e) {
            throw new UploadPictureFailedException();
        }
        return Optional.ofNullable(uri).orElseThrow(UploadPictureFailedException::new);
    }
}