feat: 로컬 파일 업로드 로직 구현

.gitignore

@@ -75,3 +75,7 @@ $RECYCLE.BIN/
 
 ### 로그 디렉토리 ###
 .logs/
+
+### 로컬 업로드 파일 디렉토리 ###
+uploads/
+uploads-test/

src/main/java/com/codeit/team5/mopl/binarycontent/BinaryContentStorage.java

@@ -0,0 +1,24 @@
+package com.codeit.team5.mopl.binarycontent;
+
+import java.util.Locale;
+import java.util.Set;
+import java.util.UUID;
+import org.springframework.util.StringUtils;
+
+public interface BinaryContentStorage {
+
+    Set<String> ALLOWED_EXTENSIONS = Set.of("jpg", "jpeg", "png", "gif", "webp");
+
+    default String generateKey(UUID contentId, String originalFilename) {
+        String extension = StringUtils.getFilenameExtension(originalFilename);
+        String lowerExt = extension != null ? extension.toLowerCase(Locale.ROOT) : null;
+        String normalizedExt = (lowerExt != null && ALLOWED_EXTENSIONS.contains(lowerExt))
+                ? "." + lowerExt
+                : "";
+        return "thumbnails/" + contentId + "/" + UUID.randomUUID() + normalizedExt;
+    }
+
+    String toUrl(String key);
+
+    void store(String key, byte[] bytes);
+}

src/main/java/com/codeit/team5/mopl/binarycontent/entity/BinaryContent.java

@@ -0,0 +1,42 @@
+package com.codeit.team5.mopl.binarycontent.entity;
+
+import com.codeit.team5.mopl.global.entity.BaseUpdatableEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Table;
+import java.util.Objects;
+import com.codeit.team5.mopl.binarycontent.exception.InvalidBinaryContentUrlException;
+import org.springframework.util.StringUtils;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@Table(name = "binary_contents")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class BinaryContent extends BaseUpdatableEntity {
+
+    @Column(nullable = false, length = 512)
+    private String url;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "upload_status", nullable = false, length = 20)
+    private BinaryContentUploadStatus uploadStatus;
+
+    public static BinaryContent pending(String url) {
+        BinaryContent binaryContent = new BinaryContent();
+        if (!StringUtils.hasText(url)) {
+            throw new InvalidBinaryContentUrlException();
+        }
+        binaryContent.url = url;
+        binaryContent.uploadStatus = BinaryContentUploadStatus.PENDING;
+        return binaryContent;
+    }
+
+    public void updateUploadStatus(BinaryContentUploadStatus status) {
+        this.uploadStatus = Objects.requireNonNull(status, "status must not be null");
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/entity/BinaryContentUploadStatus.java

@@ -0,0 +1,7 @@
+package com.codeit.team5.mopl.binarycontent.entity;
+
+public enum BinaryContentUploadStatus {
+    PENDING,
+    COMPLETED,
+    FAILED
+}

src/main/java/com/codeit/team5/mopl/binarycontent/event/BinaryContentUploadEvent.java

@@ -0,0 +1,10 @@
+package com.codeit.team5.mopl.binarycontent.event;
+
+import java.util.UUID;
+
+public record BinaryContentUploadEvent(
+        UUID binaryContentId,
+        String key,
+        byte[] bytes
+) {
+}

src/main/java/com/codeit/team5/mopl/binarycontent/exception/BinaryContentNotFoundException.java

@@ -0,0 +1,12 @@
+package com.codeit.team5.mopl.binarycontent.exception;
+
+import com.codeit.team5.mopl.global.exception.suggestion.BusinessExceptionSuggestion;
+import java.util.UUID;
+import org.springframework.http.HttpStatus;
+
+public class BinaryContentNotFoundException extends BusinessExceptionSuggestion {
+
+    public BinaryContentNotFoundException(UUID id) {
+        super(HttpStatus.NOT_FOUND, "BinaryContent를 찾을 수 없습니다: " + id);
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/exception/BinaryContentStorageException.java

@@ -0,0 +1,16 @@
+package com.codeit.team5.mopl.binarycontent.exception;
+
+import com.codeit.team5.mopl.global.exception.suggestion.BusinessExceptionSuggestion;
+import org.springframework.http.HttpStatus;
+
+public class BinaryContentStorageException extends BusinessExceptionSuggestion {
+
+    public BinaryContentStorageException(HttpStatus status, String message) {
+        super(status, message);
+    }
+
+    public BinaryContentStorageException(HttpStatus status, String message, Throwable cause) {
+        super(status, message);
+        initCause(cause);
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/exception/FileStorageException.java

@@ -0,0 +1,14 @@
+package com.codeit.team5.mopl.binarycontent.exception;
+
+import org.springframework.http.HttpStatus;
+
+public class FileStorageException extends BinaryContentStorageException {
+
+    public FileStorageException(String key) {
+        super(HttpStatus.INTERNAL_SERVER_ERROR, "파일 저장 실패: " + key);
+    }
+
+    public FileStorageException(String key, Throwable cause) {
+        super(HttpStatus.INTERNAL_SERVER_ERROR, "파일 저장 실패: " + key, cause);
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/exception/InvalidBinaryContentUrlException.java

@@ -0,0 +1,11 @@
+package com.codeit.team5.mopl.binarycontent.exception;
+
+import com.codeit.team5.mopl.global.exception.suggestion.BusinessExceptionSuggestion;
+import org.springframework.http.HttpStatus;
+
+public class InvalidBinaryContentUrlException extends BusinessExceptionSuggestion {
+
+    public InvalidBinaryContentUrlException() {
+        super(HttpStatus.INTERNAL_SERVER_ERROR, "BinaryContent url은 비어있을 수 없습니다.");
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/exception/UploadDirectoryInitException.java

@@ -0,0 +1,15 @@
+package com.codeit.team5.mopl.binarycontent.exception;
+
+import java.nio.file.Path;
+import org.springframework.http.HttpStatus;
+
+public class UploadDirectoryInitException extends BinaryContentStorageException {
+
+    public UploadDirectoryInitException(Path uploadDir) {
+        super(HttpStatus.INTERNAL_SERVER_ERROR, "업로드 디렉토리 생성 실패: " + uploadDir);
+    }
+
+    public UploadDirectoryInitException(Path uploadDir, Throwable cause) {
+        super(HttpStatus.INTERNAL_SERVER_ERROR, "업로드 디렉토리 생성 실패: " + uploadDir, cause);
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/listener/BinaryContentUploadListener.java

@@ -0,0 +1,34 @@
+package com.codeit.team5.mopl.binarycontent.listener;
+
+import com.codeit.team5.mopl.binarycontent.BinaryContentStorage;
+import com.codeit.team5.mopl.binarycontent.entity.BinaryContentUploadStatus;
+import com.codeit.team5.mopl.binarycontent.event.BinaryContentUploadEvent;
+import com.codeit.team5.mopl.binarycontent.service.BinaryContentService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class BinaryContentUploadListener {
+
+    private final BinaryContentStorage binaryContentStorage;
+    private final BinaryContentService binaryContentService;
+
+    @Async("binaryContentUploadExecutor")
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handle(BinaryContentUploadEvent event) {
+        try {
+            binaryContentStorage.store(event.key(), event.bytes());
+            binaryContentService.updateUploadStatus(event.binaryContentId(), BinaryContentUploadStatus.COMPLETED);
+            log.debug("파일 업로드 완료 - binaryContentId: {}", event.binaryContentId());
+        } catch (Exception e) {
+            binaryContentService.updateUploadStatus(event.binaryContentId(), BinaryContentUploadStatus.FAILED);
+            log.error("파일 업로드 실패 - binaryContentId: {}", event.binaryContentId(), e);
+        }
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/repository/BinaryContentRepository.java

@@ -0,0 +1,8 @@
+package com.codeit.team5.mopl.binarycontent.repository;
+
+import com.codeit.team5.mopl.binarycontent.entity.BinaryContent;
+import java.util.UUID;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface BinaryContentRepository extends JpaRepository<BinaryContent, UUID> {
+}

src/main/java/com/codeit/team5/mopl/binarycontent/service/BinaryContentService.java

@@ -0,0 +1,25 @@
+package com.codeit.team5.mopl.binarycontent.service;
+
+import com.codeit.team5.mopl.binarycontent.entity.BinaryContentUploadStatus;
+import com.codeit.team5.mopl.binarycontent.exception.BinaryContentNotFoundException;
+import com.codeit.team5.mopl.binarycontent.repository.BinaryContentRepository;
+import java.util.UUID;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class BinaryContentService {
+
+    private final BinaryContentRepository binaryContentRepository;
+
+    @Transactional
+    public void updateUploadStatus(UUID binaryContentId, BinaryContentUploadStatus status) {
+        binaryContentRepository.findById(binaryContentId)
+                .orElseThrow(() -> new BinaryContentNotFoundException(binaryContentId))
+                .updateUploadStatus(status);
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/storage/local/LocalBinaryContentStorage.java

@@ -0,0 +1,52 @@
+package com.codeit.team5.mopl.binarycontent.storage.local;
+
+import com.codeit.team5.mopl.binarycontent.BinaryContentStorage;
+import com.codeit.team5.mopl.binarycontent.exception.FileStorageException;
+import com.codeit.team5.mopl.binarycontent.exception.UploadDirectoryInitException;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@ConditionalOnProperty(name = "mopl.storage.type", havingValue = "local", matchIfMissing = true)
+public class LocalBinaryContentStorage implements BinaryContentStorage {
+
+    private final Path uploadDir;
+    private final String baseUrl;
+
+    public LocalBinaryContentStorage(LocalStorageProperties properties) {
+        this.uploadDir = Paths.get(properties.uploadDir()).toAbsolutePath().normalize();
+        this.baseUrl = properties.baseUrl();
+        init();
+    }
+
+    @Override
+    public String toUrl(String key) {
+        return baseUrl + "/" + key;
+    }
+
+    @Override
+    public void store(String key, byte[] bytes) {
+        Path destination = uploadDir.resolve(key);
+        try {
+            Files.createDirectories(destination.getParent());
+            Files.write(destination, bytes);
+        } catch (IOException e) {
+            throw new FileStorageException(key, e);
+        }
+        log.debug("파일 저장 완료: {}", destination);
+    }
+
+    private void init() {
+        try {
+            Files.createDirectories(uploadDir);
+        } catch (IOException e) {
+            throw new UploadDirectoryInitException(uploadDir, e);
+        }
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/storage/local/LocalStorageProperties.java

@@ -0,0 +1,11 @@
+package com.codeit.team5.mopl.binarycontent.storage.local;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@ConfigurationProperties(prefix = "mopl.storage.local")
+public record LocalStorageProperties(
+        String baseUrl,
+        String uploadDir
+) {
+
+}

src/main/java/com/codeit/team5/mopl/binarycontent/storage/s3/S3BinaryContentStorage.java

@@ -0,0 +1,26 @@
+package com.codeit.team5.mopl.binarycontent.storage.s3;
+
+import com.codeit.team5.mopl.binarycontent.BinaryContentStorage;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Component;
+
+@Component
+@ConditionalOnProperty(name = "mopl.storage.type", havingValue = "s3")
+public class S3BinaryContentStorage implements BinaryContentStorage {
+
+    private final S3StorageProperties properties;
+
+    public S3BinaryContentStorage(S3StorageProperties properties) {
+        this.properties = properties;
+    }
+
+    @Override
+    public String toUrl(String key) {
+        return "https://" + properties.bucketName() + ".s3." + properties.region() + ".amazonaws.com/" + key;
+    }
+
+    @Override
+    public void store(String key, byte[] bytes) {
+        throw new UnsupportedOperationException("S3 스토리지가 아직 구현되지 않았습니다.");
+    }
+}

src/main/java/com/codeit/team5/mopl/binarycontent/storage/s3/S3StorageProperties.java

@@ -0,0 +1,13 @@
+package com.codeit.team5.mopl.binarycontent.storage.s3;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@ConfigurationProperties(prefix = "mopl.storage.s3")
+public record S3StorageProperties(
+        String accessKey,
+        String secretKey,
+        String bucketName,
+        String region
+) {
+
+}

src/main/java/com/codeit/team5/mopl/config/AsyncConfig.java

@@ -0,0 +1,29 @@
+package com.codeit.team5.mopl.config;
+
+import com.codeit.team5.mopl.global.async.CompositeTaskDecorator;
+import com.codeit.team5.mopl.global.async.MdcTaskDecorator;
+import com.codeit.team5.mopl.global.async.SecurityContextTaskDecorator;
+import java.util.List;
+import java.util.concurrent.Executor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+
+    @Bean(name = "binaryContentUploadExecutor")
+    public Executor binaryContentUploadExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(5);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("binary-upload-");
+        executor.setTaskDecorator(new CompositeTaskDecorator(
+                List.of(new MdcTaskDecorator(), new SecurityContextTaskDecorator())));
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/codeit/team5/mopl/config/StorageConfig.java

@@ -0,0 +1,12 @@
+package com.codeit.team5.mopl.config;
+
+import com.codeit.team5.mopl.binarycontent.storage.local.LocalStorageProperties;
+import com.codeit.team5.mopl.binarycontent.storage.s3.S3StorageProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableConfigurationProperties({LocalStorageProperties.class, S3StorageProperties.class})
+public class StorageConfig {
+
+}