이미지 S3 업로드 기능 구현

backend/ddang/build.gradle

@@ -67,6 +67,11 @@ dependencies {
     implementation 'ch.qos.logback.contrib:logback-json-classic:0.1.5'
     implementation 'net.logstash.logback:logstash-logback-encoder:6.1'
 
+    // aws
+    implementation platform('software.amazon.awssdk:bom:2.20.56')
+    implementation 'software.amazon.awssdk:s3'
+    implementation 'software.amazon.awssdk:cloudfront'
+
     implementation 'org.springframework.boot:spring-boot-starter-validation'
     implementation 'org.springframework.boot:spring-boot-starter-web'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'

backend/ddang/src/main/java/com/ddang/ddang/auction/configuration/AwsConfiguration.java

@@ -0,0 +1,25 @@
+package com.ddang.ddang.auction.configuration;
+
+import com.google.api.client.util.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import software.amazon.awssdk.auth.credentials.InstanceProfileCredentialsProvider;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.s3.S3Client;
+
+@Profile("!local && !test")
+@Configuration
+public class AwsConfiguration {
+
+    @Value("${aws.s3.region}")
+    private String s3Region;
+
+    @Bean
+    public S3Client s3Client() {
+        return S3Client.builder()
+                       .region(Region.of(s3Region))
+                       .credentialsProvider(InstanceProfileCredentialsProvider.create())
+                       .build();
+    }
+}

backend/ddang/src/main/java/com/ddang/ddang/image/domain/StoreImageProcessor.java

@@ -7,7 +7,10 @@
 
 public interface StoreImageProcessor {
 
-    StoreImageDto storeImageFile(MultipartFile imageFile);
+    List<String> WHITE_IMAGE_EXTENSION = List.of("jpg", "jpeg", "png");
+    String EXTENSION_FILE_CHARACTER = ".";
 
-    List<StoreImageDto> storeImageFiles(List<MultipartFile> imageFiles);
+    StoreImageDto storeImageFile(final MultipartFile imageFile);
+
+    List<StoreImageDto> storeImageFiles(final List<MultipartFile> imageFiles);
 }

backend/ddang/src/main/java/com/ddang/ddang/image/infrastructure/local/LocalStoreImageProcessor.java

@@ -5,21 +5,21 @@
 import com.ddang.ddang.image.infrastructure.local.exception.EmptyImageException;
 import com.ddang.ddang.image.infrastructure.local.exception.StoreImageFailureException;
 import com.ddang.ddang.image.infrastructure.local.exception.UnsupportedImageFileExtensionException;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
 import java.io.File;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Component;
-import org.springframework.web.multipart.MultipartFile;
 
 @Component
+@Profile("local || test")
 public class LocalStoreImageProcessor implements StoreImageProcessor {
 
-    private static final List<String> WHITE_IMAGE_EXTENSION = List.of("jpg", "jpeg", "png");
-    private static final String EXTENSION_FILE_CHARACTER = ".";
-
     @Value("${image.store.dir}")
     private String imageStoreDir;
 
@@ -38,7 +38,8 @@ public List<StoreImageDto> storeImageFiles(final List<MultipartFile> imageFiles)
         return storeImageDtos;
     }
 
-    public StoreImageDto storeImageFile(MultipartFile imageFile) {
+    @Override
+    public StoreImageDto storeImageFile(final MultipartFile imageFile) {
         try {
             final String originalImageFileName = imageFile.getOriginalFilename();
             final String storeImageFileName = createStoreImageFileName(originalImageFileName);
@@ -47,16 +48,16 @@ public StoreImageDto storeImageFile(MultipartFile imageFile) {
             imageFile.transferTo(new File(fullPath));
 
             return new StoreImageDto(originalImageFileName, storeImageFileName);
-        } catch (IOException ex) {
+        } catch (final IOException ex) {
             throw new StoreImageFailureException("이미지 저장에 실패했습니다.", ex);
         }
     }
 
-    private String findFullPath(String storeImageFileName) {
+    private String findFullPath(final String storeImageFileName) {
         return imageStoreDir + storeImageFileName;
     }
 
-    private String createStoreImageFileName(String originalFilename) {
+    private String createStoreImageFileName(final String originalFilename) {
         final String extension = extractExtension(originalFilename);
 
         validateImageFileExtension(extension);
@@ -66,7 +67,7 @@ private String createStoreImageFileName(String originalFilename) {
         return uuid + EXTENSION_FILE_CHARACTER + extension;
     }
 
-    private String extractExtension(String originalFilename) {
+    private String extractExtension(final String originalFilename) {
         int position = originalFilename.lastIndexOf(EXTENSION_FILE_CHARACTER);
 
         return originalFilename.substring(position + 1);

backend/ddang/src/main/java/com/ddang/ddang/image/infrastructure/s3/S3StoreImageProcessor.java

@@ -0,0 +1,101 @@
+package com.ddang.ddang.image.infrastructure.s3;
+
+import com.ddang.ddang.image.domain.StoreImageProcessor;
+import com.ddang.ddang.image.domain.dto.StoreImageDto;
+import com.ddang.ddang.image.infrastructure.local.exception.EmptyImageException;
+import com.ddang.ddang.image.infrastructure.local.exception.StoreImageFailureException;
+import com.ddang.ddang.image.infrastructure.local.exception.UnsupportedImageFileExtensionException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+import software.amazon.awssdk.core.exception.SdkException;
+import software.amazon.awssdk.core.sync.RequestBody;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.model.PutObjectRequest;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+
+@Component
+@Profile("!local && !test")
+@RequiredArgsConstructor
+public class S3StoreImageProcessor implements StoreImageProcessor {
+
+    @Value("${aws.s3.bucket-name}")
+    private String bucketName;
+
+    @Value("${aws.s3.image-path}")
+    private String path;
+
+    private final S3Client s3Client;
+
+    @Override
+    public List<StoreImageDto> storeImageFiles(final List<MultipartFile> imageFiles) {
+        final List<StoreImageDto> storeImageDtos = new ArrayList<>();
+
+        for (final MultipartFile imageFile : imageFiles) {
+            if (imageFile.isEmpty()) {
+                throw new EmptyImageException("이미지 파일의 데이터가 비어 있습니다.");
+            }
+
+            storeImageDtos.add(storeImageFile(imageFile));
+        }
+
+        return storeImageDtos;
+    }
+
+    @Override
+    public StoreImageDto storeImageFile(final MultipartFile imageFile) {
+        try {
+            final String originalImageFileName = imageFile.getOriginalFilename();
+            final String storeImageFileName = createStoreImageFileName(originalImageFileName);
+            final String fullPath = findFullPath(storeImageFileName);
+            final PutObjectRequest putObjectRequest = PutObjectRequest.builder()
+                                                                      .key(fullPath)
+                                                                      .bucket(bucketName)
+                                                                      .contentType(imageFile.getContentType())
+                                                                      .build();
+
+            s3Client.putObject(
+                    putObjectRequest,
+                    RequestBody.fromInputStream(imageFile.getInputStream(), imageFile.getSize())
+            );
+
+            return new StoreImageDto(originalImageFileName, storeImageFileName);
+        } catch (final IOException ex) {
+            throw new StoreImageFailureException("이미지 저장에 실패했습니다.", ex);
+        } catch (final SdkException ex) {
+            throw new StoreImageFailureException("AWS 이미지 저장에 실패했습니다.", ex);
+        }
+    }
+
+    private String findFullPath(final String storeImageFileName) {
+        return path + storeImageFileName;
+    }
+
+    private String createStoreImageFileName(final String originalFilename) {
+        final String extension = extractExtension(originalFilename);
+
+        validateImageFileExtension(extension);
+
+        final String uuid = UUID.randomUUID().toString();
+
+        return uuid + EXTENSION_FILE_CHARACTER + extension;
+    }
+
+    private String extractExtension(final String originalFilename) {
+        int position = originalFilename.lastIndexOf(EXTENSION_FILE_CHARACTER);
+
+        return originalFilename.substring(position + 1);
+    }
+
+    private void validateImageFileExtension(final String extension) {
+        if (!WHITE_IMAGE_EXTENSION.contains(extension)) {
+            throw new UnsupportedImageFileExtensionException("지원하지 않는 확장자입니다. : " + extension);
+        }
+    }
+}