[feat] 이미지 업로드 기능을 구현한다.

build.gradle

@@ -1,59 +1,67 @@
 plugins {
-	id 'java'
-	id 'org.springframework.boot' version '3.2.0'
-	id 'io.spring.dependency-management' version '1.1.4'
+    id 'java'
+    id 'org.springframework.boot' version '3.2.0'
+    id 'io.spring.dependency-management' version '1.1.4'
 }
 
 group = 'kr.co'
 version = '0.0.1-SNAPSHOT'
 
 java {
-	sourceCompatibility = '17'
+    sourceCompatibility = '17'
 }
 
 configurations {
-	compileOnly {
-		extendsFrom annotationProcessor
-	}
+    compileOnly {
+        extendsFrom annotationProcessor
+    }
 }
 
 repositories {
-	mavenCentral()
+    mavenCentral()
 }
 
 dependencies {
-	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
-	implementation 'org.springframework.boot:spring-boot-starter-web'
-	implementation 'org.springframework.boot:spring-boot-starter-webflux'
-	implementation 'org.springframework.boot:spring-boot-starter-validation'
+    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
+    implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-webflux'
+    implementation 'org.springframework.boot:spring-boot-starter-validation'
 
-	implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
-	runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
-	runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
+    implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
+    runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
+    runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
 
-	compileOnly 'org.projectlombok:lombok'
+    compileOnly 'org.projectlombok:lombok'
 
-	runtimeOnly 'com.mysql:mysql-connector-j'
-	runtimeOnly 'com.h2database:h2'
+    runtimeOnly 'com.mysql:mysql-connector-j'
+    runtimeOnly 'com.h2database:h2'
 
-	annotationProcessor 'org.projectlombok:lombok'
-	testImplementation 'org.springframework.boot:spring-boot-starter-test'
-	testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.9.0'
+    annotationProcessor 'org.projectlombok:lombok'
+    testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.9.0'
 
-	implementation 'com.querydsl:querydsl-jpa:5.0.0:jakarta'
-	annotationProcessor "com.querydsl:querydsl-apt:5.0.0:jakarta"
-	annotationProcessor "jakarta.annotation:jakarta.annotation-api"
-	annotationProcessor "jakarta.persistence:jakarta.persistence-api"
-	annotationProcessor "jakarta.annotation:jakarta.annotation-api"
-	annotationProcessor "jakarta.persistence:jakarta.persistence-api" // Query DSL
+    implementation 'com.querydsl:querydsl-jpa:5.0.0:jakarta'
+    annotationProcessor "com.querydsl:querydsl-apt:5.0.0:jakarta"
+    annotationProcessor "jakarta.annotation:jakarta.annotation-api"
+    annotationProcessor "jakarta.persistence:jakarta.persistence-api"
+    annotationProcessor "jakarta.annotation:jakarta.annotation-api"
+    annotationProcessor "jakarta.persistence:jakarta.persistence-api" // Query DSL
 
-	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.3.0'
+    // S3
+    implementation platform('com.amazonaws:aws-java-sdk-bom:1.11.1000')
+    implementation 'com.amazonaws:aws-java-sdk-s3'
+
+    implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.3.0'
 }
 
 def generatedDir = "src/main/generated"
 
 clean {
-	delete file(generatedDir)
+    delete file(generatedDir)
+}
+
+bootJar {
+    archiveFileName = 'conceptbe.jar'
 }
 
 //tasks.named('test') {

src/main/java/kr/co/conceptbe/common/config/S3Config.java

@@ -0,0 +1,26 @@
+package kr.co.conceptbe.common.config;
+
+import com.amazonaws.auth.InstanceProfileCredentialsProvider;
+import com.amazonaws.regions.Regions;
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class S3Config {
+
+    @Bean
+    public InstanceProfileCredentialsProvider instanceProfileCredentialsProvider() {
+        return InstanceProfileCredentialsProvider.getInstance();
+    }
+
+    @Bean
+    public AmazonS3 amazonS3() {
+        return AmazonS3ClientBuilder.standard()
+            .withRegion(Regions.AP_NORTHEAST_2)
+            .withCredentials(instanceProfileCredentialsProvider())
+            .build();
+    }
+
+}

src/main/java/kr/co/conceptbe/idea/application/IdeaService.java

@@ -27,6 +27,8 @@
 import kr.co.conceptbe.idea.dto.IdeaHitResponse;
 import kr.co.conceptbe.idea.exception.AlreadyIdeaLikeException;
 import kr.co.conceptbe.idea.exception.NotFoundIdeaLikeException;
+import kr.co.conceptbe.image.domain.Image;
+import kr.co.conceptbe.image.domain.ImageRepository;
 import kr.co.conceptbe.member.domain.Member;
 import kr.co.conceptbe.member.exception.UnAuthorizedMemberException;
 import kr.co.conceptbe.member.persistence.MemberRepository;
@@ -52,6 +54,7 @@ public class IdeaService {
     private final HitRepository hitRepository;
     private final SkillCategoryRepository skillCategoryRepository;
     private final CommentRepository commentRepository;
+    private final ImageRepository imageRepository;
 
     public Long save(AuthCredentials authCredentials, IdeaRequest request) {
         validateMember(authCredentials);
@@ -122,11 +125,13 @@ private Set<Idea> getIdeasBookmarkedByMember(Member member) {
 
     public IdeaDetailResponse getDetailIdeaResponse(Long tokenMemberId, Long ideaId) {
         Idea idea = ideaRepository.getById(ideaId);
-        IdeaDetailResponse ideaDetailResponse = IdeaDetailResponse.of(tokenMemberId, idea);
+        List<Image> images = imageRepository.findAllByIdeaId(ideaId);
+        IdeaDetailResponse ideaDetailResponse = IdeaDetailResponse.of(tokenMemberId, idea, images);
 
         Member member = memberRepository.getById(tokenMemberId);
 
-        Optional<Hit> hitOptional = hitRepository.findFirstByMemberAndIdeaOrderByCreatedAtDesc(member, idea);
+        Optional<Hit> hitOptional = hitRepository.findFirstByMemberAndIdeaOrderByCreatedAtDesc(
+            member, idea);
         if (hitOptional.isEmpty() || hitOptional.get().isBeforeLocalDate()) {
             Hit.ofIdeaAndMember(idea, member);
         }

src/main/java/kr/co/conceptbe/idea/domain/IdeaValidatorImpl.java

@@ -0,0 +1,26 @@
+package kr.co.conceptbe.idea.domain;
+
+import kr.co.conceptbe.idea.domain.persistence.IdeaRepository;
+import kr.co.conceptbe.image.domain.IdeaValidator;
+import kr.co.conceptbe.member.exception.NotOwnerException;
+import org.springframework.stereotype.Component;
+
+@Component
+public class IdeaValidatorImpl implements IdeaValidator {
+
+    private final IdeaRepository ideaRepository;
+
+    public IdeaValidatorImpl(IdeaRepository ideaRepository) {
+        this.ideaRepository = ideaRepository;
+    }
+
+    @Override
+    public void validateIdea(Long ideaId, Long memberId) {
+        Idea savedIdea = ideaRepository.getById(ideaId);
+        if (savedIdea.isOwner(memberId)) {
+            return;
+        }
+        throw new NotOwnerException(memberId);
+    }
+
+}

src/main/java/kr/co/conceptbe/idea/dto/IdeaDetailResponse.java

@@ -4,6 +4,8 @@
 import java.util.List;
 import kr.co.conceptbe.comment.Comment;
 import kr.co.conceptbe.idea.domain.Idea;
+import kr.co.conceptbe.image.application.response.ImageResponse;
+import kr.co.conceptbe.image.domain.Image;
 
 public record IdeaDetailResponse(
     Long memberId,
@@ -24,10 +26,11 @@ public record IdeaDetailResponse(
     Integer hits,
     Boolean owner,
     Boolean ownerLike,
-    Boolean ownerScrap
+    Boolean ownerScrap,
+    List<ImageResponse> imageResponses
 ) {
 
-    public static IdeaDetailResponse of(Long tokenMemberId, Idea idea) {
+    public static IdeaDetailResponse of(Long tokenMemberId, Idea idea, List<Image> images) {
         return new IdeaDetailResponse(
             idea.getCreator().getId(),
             idea.getCreator().getProfileImageUrl(),
@@ -48,7 +51,8 @@ public static IdeaDetailResponse of(Long tokenMemberId, Idea idea) {
             idea.getHitsCount(),
             idea.isOwner(tokenMemberId),
             idea.isOwnerLike(tokenMemberId),
-            idea.isOwnerScrap(tokenMemberId)
+            idea.isOwnerScrap(tokenMemberId),
+            images.stream().map(ImageResponse::from).toList()
         );
     }
 }

src/main/java/kr/co/conceptbe/image/application/ImageService.java

@@ -0,0 +1,124 @@
+package kr.co.conceptbe.image.application;
+
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.model.DeleteObjectRequest;
+import com.amazonaws.services.s3.model.PutObjectRequest;
+import java.io.File;
+import java.io.IOException;
+import java.util.List;
+import java.util.Objects;
+import kr.co.conceptbe.auth.presentation.dto.AuthCredentials;
+import kr.co.conceptbe.image.domain.IdeaValidator;
+import kr.co.conceptbe.image.domain.Image;
+import kr.co.conceptbe.image.domain.ImageChecker;
+import kr.co.conceptbe.image.domain.ImageRepository;
+import kr.co.conceptbe.image.domain.UploadFile;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class ImageService {
+
+    @Value("${s3.bucket}")
+    private String bucket;
+    private final AmazonS3 amazonS3;
+    private final ImageRepository imageRepository;
+    private final IdeaValidator ideaValidator;
+    private final ImageChecker imageChecker;
+
+    public void save(Long ideaId, AuthCredentials authCredentials, List<MultipartFile> files) {
+        ideaValidator.validateIdea(ideaId, authCredentials.id());
+        imageChecker.validateAdditionImagesSize(files.size());
+        uploadImages(ideaId, files);
+    }
+
+    private void uploadImages(Long ideaId, List<MultipartFile> files) {
+        files.stream()
+            .map(this::upload)
+            .map(imageUrl -> new Image(ideaId, imageUrl))
+            .forEach(imageRepository::save);
+    }
+
+    private String upload(MultipartFile multipartFile) {
+        try {
+            UploadFile uploadFile = UploadFile.from(multipartFile);
+            fileUpload(uploadFile);
+            return uploadFile.getOriginalFilename();
+        } catch (IOException exception) {
+            throw new RuntimeException(exception);
+        }
+    }
+
+    private void fileUpload(MultipartFile multipartFile) throws IOException {
+        File tempFile = null;
+
+        try {
+            tempFile = File.createTempFile("upload_", ".tmp");
+            multipartFile.transferTo(tempFile);
+            amazonS3.putObject(new PutObjectRequest(
+                bucket,
+                multipartFile.getOriginalFilename(),
+                tempFile
+            ));
+        } catch (IOException exception) {
+            throw new IOException(exception);
+        } finally {
+            removeTempFileIfExists(tempFile);
+        }
+    }
+
+    private void removeTempFileIfExists(File tempFile) {
+        if (Objects.nonNull(tempFile) && tempFile.exists()) {
+            tempFile.delete();
+        }
+    }
+
+    public void update(
+        Long ideaId,
+        AuthCredentials authCredentials,
+        List<Long> imageIds,
+        List<MultipartFile> additionFiles
+    ) {
+        ideaValidator.validateIdea(ideaId, authCredentials.id());
+        List<Image> imagesToDeleted = getImagesToDeleted(ideaId, imageIds, additionFiles.size());
+        imagesToDeleted.forEach(this::deleteImage);
+        additionFiles.forEach(this::upload);
+    }
+
+    private List<Image> getImagesToDeleted(
+        Long ideaId,
+        List<Long> imageIds,
+        int additionFilesSize
+    ) {
+        List<Image> savedImages = imageRepository.findAllByIdeaId(ideaId);
+        List<Long> imageIdsToDeleted = imageChecker.getImageIdsToDeleted(
+            extractIds(savedImages),
+            imageIds
+        );
+        imageChecker.validateTotalImageSize(
+            savedImages.size(),
+            imageIdsToDeleted.size(),
+            additionFilesSize
+        );
+        return savedImages.stream()
+            .filter(image -> imageIdsToDeleted.contains(image.getId()))
+            .toList();
+    }
+
+    private List<Long> extractIds(List<Image> savedImages) {
+        return savedImages.stream()
+            .map(Image::getId)
+            .toList();
+    }
+
+    private void deleteImage(Image image) {
+        amazonS3.deleteObject(new DeleteObjectRequest(bucket, image.getImageUrl()));
+        imageRepository.delete(image);
+    }
+
+}

src/main/java/kr/co/conceptbe/image/application/response/ImageResponse.java

@@ -0,0 +1,22 @@
+package kr.co.conceptbe.image.application.response;
+
+import kr.co.conceptbe.image.domain.Image;
+import org.springframework.beans.factory.annotation.Value;
+
+public record ImageResponse(
+    Long id,
+    Long ideaId,
+    String imageUrl
+) {
+
+    @Value("${cloud-front-url}")
+    private static String cloudFrontUrl;
+
+    public static ImageResponse from(Image image) {
+        return new ImageResponse(
+            image.getId(),
+            image.getIdeaId(),
+            String.join("/", cloudFrontUrl, image.getImageUrl())
+        );
+    }
+}

src/main/java/kr/co/conceptbe/image/domain/IdeaValidator.java

@@ -0,0 +1,10 @@
+package kr.co.conceptbe.image.domain;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public interface IdeaValidator {
+
+    void validateIdea(Long ideaId, Long memberId);
+
+}