feat: 파일 지연 삭제 구현

Author: larama-C

src/main/java/com/back/web7_9_codecrete_be/global/storage/FileDeleteQueue.java

@@ -0,0 +1,28 @@
+package com.back.web7_9_codecrete_be.global.storage;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Entity
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class FileDeleteQueue {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private String fileUrl;
+
+    private LocalDateTime deleteAt;
+}

src/main/java/com/back/web7_9_codecrete_be/global/storage/FileDeleteQueueRepository.java

@@ -0,0 +1,10 @@
+package com.back.web7_9_codecrete_be.global.storage;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public interface FileDeleteQueueRepository extends JpaRepository<FileDeleteQueue, Long> {
+    List<FileDeleteQueue> findAllByDeleteAtBefore(LocalDateTime now);
+}

src/main/java/com/back/web7_9_codecrete_be/global/storage/FileDeleteScheduler.java

@@ -0,0 +1,52 @@
+package com.back.web7_9_codecrete_be.global.storage;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import software.amazon.awssdk.services.s3.S3Client;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class FileDeleteScheduler {
+
+    private final FileDeleteQueueRepository repository;
+    private final S3Client s3Client;
+
+    @Value("${cloud.aws.s3.bucket}")
+    private String bucket;
+
+    @Value("${cloud.aws.region.static}")
+    private String region;
+
+    @Scheduled(fixedDelay = 600000) // 10분마다 실행
+    public void deleteFiles() {
+
+        List<FileDeleteQueue> targets =
+                repository.findAllByDeleteAtBefore(LocalDateTime.now());
+
+        for (FileDeleteQueue file : targets) {
+            try {
+                String key = extractKey(file.getFileUrl());
+
+                s3Client.deleteObject(builder -> builder
+                        .bucket(bucket)
+                        .key(key)
+                );
+
+            } catch (Exception e) {
+                // 실패해도 계속 진행
+            }
+        }
+
+        repository.deleteAll(targets);
+    }
+
+    private String extractKey(String fileUrl) {
+        String prefix = "https://" + bucket + ".s3." + region + ".amazonaws.com/";
+        return fileUrl.substring(prefix.length());
+    }
+}