feat: PresignedUrl을 사용하여 이미지 업로드 기능 구현

src/main/java/com/depromeet/domain/image/api/ImageController.java

@@ -0,0 +1,36 @@
+package com.depromeet.domain.image.api;
+
+import com.depromeet.domain.image.application.ImageService;
+import com.depromeet.domain.image.dto.request.MissionRecordImageCreateRequest;
+import com.depromeet.domain.image.dto.request.MissionRecordImageUploadCompleteRequest;
+import com.depromeet.domain.image.dto.response.PresignedUrlResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+@Tag(name = "4. [이미지]", description = "이미지 관련 API입니다.")
+@RestController
+@RequiredArgsConstructor
+public class ImageController {
+    private final ImageService imageService;
+
+    @Operation(
+            summary = "미션 기록 이미지 Presigned URL 생성",
+            description = "미션 기록 이미지 Presigned URL를 생성합니다.")
+    @PostMapping("/records/upload-url")
+    public PresignedUrlResponse missionRecordPresignedUrlCreate(
+            @Valid @RequestBody MissionRecordImageCreateRequest request) {
+        return imageService.createMissionRecordPresignedUrl(request);
+    }
+
+    @Operation(summary = "미션 기록 이미지 업로드 완료처리", description = "미션 기록 이미지 업로드 완료 시 호출하시면 됩니다.")
+    @PostMapping("/records/upload-complete")
+    public void missionRecordUploaded(
+            @Valid @RequestBody MissionRecordImageUploadCompleteRequest request) {
+        imageService.uploadCompleteMissionRecord(request);
+    }
+}

src/main/java/com/depromeet/domain/image/application/ImageService.java

@@ -0,0 +1,123 @@
+package com.depromeet.domain.image.application;
+
+import com.amazonaws.HttpMethod;
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.Headers;
+import com.amazonaws.services.s3.model.CannedAccessControlList;
+import com.amazonaws.services.s3.model.GeneratePresignedUrlRequest;
+import com.depromeet.domain.image.domain.ImageFileExtension;
+import com.depromeet.domain.image.domain.ImageType;
+import com.depromeet.domain.image.dto.request.MissionRecordImageCreateRequest;
+import com.depromeet.domain.image.dto.request.MissionRecordImageUploadCompleteRequest;
+import com.depromeet.domain.image.dto.response.PresignedUrlResponse;
+import com.depromeet.domain.member.domain.Member;
+import com.depromeet.domain.mission.domain.Mission;
+import com.depromeet.domain.missionRecord.dao.MissionRecordRepository;
+import com.depromeet.domain.missionRecord.domain.MissionRecord;
+import com.depromeet.global.error.exception.CustomException;
+import com.depromeet.global.error.exception.ErrorCode;
+import com.depromeet.global.util.MemberUtil;
+import com.depromeet.global.util.SpringEnvironmentUtil;
+import com.depromeet.infra.config.storage.StorageProperties;
+import java.util.Date;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional
+public class ImageService {
+    private final MemberUtil memberUtil;
+    private final SpringEnvironmentUtil springEnvironmentUtil;
+    private final StorageProperties storageProperties;
+    private final AmazonS3 amazonS3;
+    private final MissionRecordRepository missionRecordRepository;
+
+    public PresignedUrlResponse createMissionRecordPresignedUrl(
+            MissionRecordImageCreateRequest request) {
+        final Member currentMember = memberUtil.getCurrentMember();
+
+        MissionRecord missionRecord = findMissionRecordByMissionRecordId(request.missionRecordId());
+
+        Mission mission = missionRecord.getMission();
+        mission.validateUserMismatch(currentMember);
+
+        String fileName =
+                createFileName(
+                        ImageType.MISSION_RECORD,
+                        request.missionRecordId(),
+                        request.imageFileExtension());
+        GeneratePresignedUrlRequest generatePresignedUrlRequest =
+                createGeneratePreSignedUrlRequest(
+                        storageProperties.bucket(),
+                        fileName,
+                        request.imageFileExtension().getUploadExtension());
+
+        String presignedUrl = amazonS3.generatePresignedUrl(generatePresignedUrlRequest).toString();
+
+        missionRecord.updateUploadStatusPending();
+        return PresignedUrlResponse.from(presignedUrl);
+    }
+
+    private MissionRecord findMissionRecordByMissionRecordId(Long request) {
+        return missionRecordRepository
+                .findById(request)
+                .orElseThrow(() -> new CustomException(ErrorCode.MISSION_RECORD_NOT_FOUND));
+    }
+
+    public void uploadCompleteMissionRecord(MissionRecordImageUploadCompleteRequest request) {
+        final Member currentMember = memberUtil.getCurrentMember();
+        MissionRecord missionRecord = findMissionRecordByMissionRecordId(request.missionRecordId());
+
+        Mission mission = missionRecord.getMission();
+        mission.validateUserMismatch(currentMember);
+
+        String imageUrl =
+                storageProperties.endpoint()
+                        + "/"
+                        + storageProperties.bucket()
+                        + "/"
+                        + springEnvironmentUtil.getCurrentProfile()
+                        + "/"
+                        + ImageType.MISSION_RECORD.getValue()
+                        + "/"
+                        + request.missionRecordId()
+                        + "/image."
+                        + request.imageFileExtension().getUploadExtension();
+        missionRecord.updateUploadStatusComplete(request.remark(), imageUrl);
+    }
+
+    private String createFileName(
+            ImageType imageType, Long targetId, ImageFileExtension imageFileExtension) {
+        return springEnvironmentUtil.getCurrentProfile()
+                + "/"
+                + imageType.getValue()
+                + "/"
+                + targetId
+                + "/image."
+                + imageFileExtension.getUploadExtension();
+    }
+
+    private GeneratePresignedUrlRequest createGeneratePreSignedUrlRequest(
+            String bucket, String fileName, String fileExtension) {
+        GeneratePresignedUrlRequest generatePresignedUrlRequest =
+                new GeneratePresignedUrlRequest(bucket, fileName, HttpMethod.PUT)
+                        .withKey(fileName)
+                        .withContentType("image/" + fileExtension)
+                        .withExpiration(getPreSignedUrlExpiration());
+
+        generatePresignedUrlRequest.addRequestParameter(
+                Headers.S3_CANNED_ACL, CannedAccessControlList.PublicRead.toString());
+
+        return generatePresignedUrlRequest;
+    }
+
+    private Date getPreSignedUrlExpiration() {
+        Date expiration = new Date();
+        var expTimeMillis = expiration.getTime();
+        expTimeMillis += 1000 * 60 * 30;
+        expiration.setTime(expTimeMillis);
+        return expiration;
+    }
+}

src/main/java/com/depromeet/domain/image/domain/ImageFileExtension.java

@@ -0,0 +1,15 @@
+package com.depromeet.domain.image.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum ImageFileExtension {
+    JPEG("jpeg"),
+    JPG("jpg"),
+    PNG("png"),
+    ;
+
+    private final String uploadExtension;
+}

src/main/java/com/depromeet/domain/image/domain/ImageType.java

@@ -0,0 +1,14 @@
+package com.depromeet.domain.image.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum ImageType {
+    MISSION_RECORD("mission_record"),
+    MEMBER_PROFILE("member_profile"),
+    MEMBER_BACKGROUND("member_background"),
+    ;
+    private final String value;
+}

src/main/java/com/depromeet/domain/image/dto/request/MissionRecordImageCreateRequest.java

@@ -0,0 +1,13 @@
+package com.depromeet.domain.image.dto.request;
+
+import com.depromeet.domain.image.domain.ImageFileExtension;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+
+public record MissionRecordImageCreateRequest(
+        @NotNull(message = "미션 기록 ID는 비워둘 수 없습니다.")
+                @Schema(description = "미션 기록 ID", defaultValue = "1")
+                Long missionRecordId,
+        @NotNull(message = "이미지 파일의 확장자는 비워둘 수 없습니다.")
+                @Schema(description = "이미지 파일의 확장자", defaultValue = "JPEG")
+                ImageFileExtension imageFileExtension) {}

src/main/java/com/depromeet/domain/image/dto/request/MissionRecordImageUploadCompleteRequest.java

@@ -0,0 +1,15 @@
+package com.depromeet.domain.image.dto.request;
+
+import com.depromeet.domain.image.domain.ImageFileExtension;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+
+public record MissionRecordImageUploadCompleteRequest(
+        @NotNull(message = "미션 기록 ID는 비워둘 수 없습니다.")
+                @Schema(description = "미션 기록 ID", defaultValue = "1")
+                Long missionRecordId,
+        @NotNull(message = "이미지 파일의 확장자는 비워둘 수 없습니다.")
+                @Schema(description = "이미지 파일의 확장자", defaultValue = "JPEG")
+                ImageFileExtension imageFileExtension,
+        @Size(max = 200, message = "미션 일지는 20자 이하까지만 입력 가능합니다.") String remark) {}

src/main/java/com/depromeet/domain/image/dto/response/PresignedUrlResponse.java

@@ -0,0 +1,9 @@
+package com.depromeet.domain.image.dto.response;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+public record PresignedUrlResponse(@Schema(description = "Presigned URL") String presignedUrl) {
+    public static PresignedUrlResponse from(String presignedUrl) {
+        return new PresignedUrlResponse(presignedUrl);
+    }
+}

src/main/java/com/depromeet/domain/mission/domain/Mission.java

@@ -3,6 +3,8 @@
 import com.depromeet.domain.common.model.BaseTimeEntity;
 import com.depromeet.domain.member.domain.Member;
 import com.depromeet.domain.missionRecord.domain.MissionRecord;
+import com.depromeet.global.error.exception.CustomException;
+import com.depromeet.global.error.exception.ErrorCode;
 import jakarta.persistence.CascadeType;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
@@ -115,4 +117,10 @@ public void updateMission(String name, String content, MissionVisibility visibil
         this.content = content;
         this.visibility = visibility;
     }
+
+    public void validateUserMismatch(Member member) {
+        if (!member.getId().equals(this.member.getId())) {
+            throw new CustomException(ErrorCode.MISSION_RECORD_USER_MISMATCH);
+        }
+    }
 }

src/main/java/com/depromeet/domain/missionRecord/domain/MissionRecord.java

@@ -2,6 +2,8 @@
 
 import com.depromeet.domain.common.model.BaseTimeEntity;
 import com.depromeet.domain.mission.domain.Mission;
+import com.depromeet.global.error.exception.CustomException;
+import com.depromeet.global.error.exception.ErrorCode;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
@@ -77,4 +79,20 @@ public static MissionRecord createMissionRecord(
                 .mission(mission)
                 .build();
     }
+
+    public void updateUploadStatusPending() {
+        if (this.uploadStatus != ImageUploadStatus.NONE) {
+            throw new CustomException(ErrorCode.MISSION_RECORD_UPLOAD_STATUS_IS_NOT_NONE);
+        }
+        this.uploadStatus = ImageUploadStatus.PENDING;
+    }
+
+    public void updateUploadStatusComplete(String remark, String imageUrl) {
+        if (this.uploadStatus != ImageUploadStatus.PENDING) {
+            throw new CustomException(ErrorCode.MISSION_RECORD_UPLOAD_STATUS_IS_NOT_PENDING);
+        }
+        this.uploadStatus = ImageUploadStatus.COMPLETE;
+        this.remark = remark;
+        this.imageUrl = imageUrl;
+    }
 }

src/main/java/com/depromeet/domain/missionRecord/service/MissionRecordService.java

@@ -23,13 +23,13 @@ public class MissionRecordService {
     private final MissionRecordRepository missionRecordRepository;
 
     public Long createMissionRecord(MissionRecordCreateRequest request) {
-        final Mission mission = findMission(request);
+        final Mission mission = findMissionByMissionId(request.missionId());
         final Member member = memberUtil.getCurrentMember();
 
         Duration duration =
                 Duration.ofMinutes(request.durationMin()).plusSeconds(request.durationSec());
 
-        validateMissionRecordUserMismatch(mission, member);
+        mission.validateUserMismatch(member);
         validateMissionRecordDuration(duration);
 
         MissionRecord missionRecord =
@@ -38,18 +38,12 @@ public Long createMissionRecord(MissionRecordCreateRequest request) {
         return missionRecordRepository.save(missionRecord).getId();
     }
 
-    private Mission findMission(MissionRecordCreateRequest request) {
+    private Mission findMissionByMissionId(Long missionId) {
         return missionRepository
-                .findByMissionId(request.missionId())
+                .findByMissionId(missionId)
                 .orElseThrow(() -> new CustomException(ErrorCode.MISSION_NOT_FOUND));
     }
 
-    private void validateMissionRecordUserMismatch(Mission mission, Member member) {
-        if (!member.getId().equals(mission.getMember().getId())) {
-            throw new CustomException(ErrorCode.MISSION_RECORD_USER_MISMATCH);
-        }
-    }
-
     private void validateMissionRecordDuration(Duration duration) {
         if (duration.getSeconds() > 3600L) {
             throw new CustomException(ErrorCode.MISSION_RECORD_DURATION_OVERBALANCE);

src/main/java/com/depromeet/global/error/exception/ErrorCode.java

@@ -26,8 +26,13 @@ public enum ErrorCode {
     MISSION_VISIBILITY_NULL(HttpStatus.BAD_REQUEST, "미션 공개 여부가 null입니다."),
 
     // MissionRecord
+    MISSION_RECORD_NOT_FOUND(HttpStatus.NOT_FOUND, "해당 미션 기록을 찾을 수 없습니다."),
     MISSION_RECORD_USER_MISMATCH(HttpStatus.BAD_REQUEST, "미션을 생성한 유저와 로그인된 계정이 일치하지 않습니다"),
     MISSION_RECORD_DURATION_OVERBALANCE(HttpStatus.BAD_REQUEST, "미션 참여 시간이 지정 된 시간보다 초과하였습니다"),
+    MISSION_RECORD_UPLOAD_STATUS_IS_NOT_NONE(
+            HttpStatus.BAD_REQUEST, "미션 기록의 이미지 업로드 상태가 NONE이 아닙니다."),
+    MISSION_RECORD_UPLOAD_STATUS_IS_NOT_PENDING(
+            HttpStatus.BAD_REQUEST, "미션 기록의 이미지 업로드 상태가 PENDING이 아닙니다."),
     ;
 
     private final HttpStatus status;

src/main/java/com/depromeet/infra/config/storage/StorageConfig.java

@@ -3,6 +3,7 @@
 import com.amazonaws.auth.AWSCredentials;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
 import lombok.RequiredArgsConstructor;
@@ -19,9 +20,13 @@ public AmazonS3 amazonS3() {
         AWSCredentials credentials =
                 new BasicAWSCredentials(
                         storageProperties.accessKey(), storageProperties.secretKey());
+        AwsClientBuilder.EndpointConfiguration endpointConfiguration =
+                new AwsClientBuilder.EndpointConfiguration(
+                        storageProperties.endpoint(), storageProperties.region());
+
         return AmazonS3ClientBuilder.standard()
+                .withEndpointConfiguration(endpointConfiguration)
                 .withCredentials(new AWSStaticCredentialsProvider(credentials))
-                .withRegion(storageProperties.region())
                 .build();
     }
 }

src/main/java/com/depromeet/infra/config/storage/StorageProperties.java

@@ -3,4 +3,5 @@
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 @ConfigurationProperties(prefix = "storage")
-public record StorageProperties(String accessKey, String secretKey, String region, String bucket) {}
+public record StorageProperties(
+        String accessKey, String secretKey, String region, String bucket, String endpoint) {}

src/main/resources/application-storage.yml

@@ -5,5 +5,6 @@ spring:
 storage:
   accessKey: ${STORAGE_ACCESS_KEY:}
   secretKey: ${STORAGE_SECRET_KEY:}
-  region: ${STORAGE_REGION:}
   bucket: ${STORAGE_BUCKET:}
+  region: ${STORAGE_REGION:}
+  endpoint: ${STORAGE_ENDPOINT:https://kr.object.ncloudstorage.com}