[STEP2-4] Add Feature Blocking domains

.gitignore

@@ -142,4 +142,7 @@ gradle-app.setting
 # Java heap dump
 *.hprof
 
+# environment setting
+src/main/resources/*.yml
+
 # End of https://www.toptal.com/developers/gitignore/api/intellij+all,java,gradle

src/main/java/community/whatever/onembackendjava/api/controller/CsvController.java

@@ -0,0 +1,29 @@
+package community.whatever.onembackendjava.api.controller;
+
+import community.whatever.onembackendjava.api.service.CsvReaderService;
+import community.whatever.onembackendjava.common.util.ResponseFormatter;
+import community.whatever.onembackendjava.common.util.model.ResultJson;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+@Slf4j
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/csv")
+public class CsvController {
+
+    private final CsvReaderService csvReaderService;
+
+
+    // CSV 파일을 업로드하여 차단 도메인 목록 갱신
+    @PostMapping("/upload")
+    public ResponseEntity<ResultJson> uploadCsv(@RequestPart(name = "blockDomains") MultipartFile file) {
+        log.info("file >> {}", file);
+        csvReaderService.loadBlockedDomains(file);
+        return ResponseFormatter.ConvertResponse();
+    }
+
+}

src/main/java/community/whatever/onembackendjava/api/domain/BlockedDomainInterface.java

@@ -0,0 +1,11 @@
+package community.whatever.onembackendjava.api.domain;
+
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.Set;
+
+public interface BlockedDomainInterface {
+    void loadBlockedDomains(MultipartFile file);  // CSV 파일에서 차단 목록 로드
+    Set<String> getBlockedDomains();              // 차단된 도메인 목록 반환
+    boolean isBlocked(String url);                // 특정 URL이 차단된 도메인인지 확인
+}

src/main/java/community/whatever/onembackendjava/api/service/CsvReaderService.java

@@ -0,0 +1,57 @@
+package community.whatever.onembackendjava.api.service;
+
+import community.whatever.onembackendjava.api.domain.BlockedDomainInterface;
+import community.whatever.onembackendjava.common.error.BusinessExceptionGenerator;
+import community.whatever.onembackendjava.common.error.model.ErrorCode;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
+import java.util.HashSet;
+import java.util.Set;
+
+
+@Slf4j
+@Service
+public class CsvReaderService implements BlockedDomainInterface {
+
+    private Set<String> blockedDomains = new HashSet<>();
+
+    // CSV 파일을 읽어 BlockedDomains 리스트에 저장
+    public void loadBlockedDomains(MultipartFile file) {
+        if (file.isEmpty()) throw BusinessExceptionGenerator.createBusinessException(ErrorCode.DB001);
+
+        Set<String> domainSet = new HashSet<>();
+        try (BufferedReader br = new BufferedReader(
+                new InputStreamReader(file.getInputStream(), StandardCharsets.UTF_8))) {
+
+            String line;
+            while ((line = br.readLine()) != null) {
+                domainSet.add(line.trim());
+            }
+        } catch (Exception e) {
+            throw BusinessExceptionGenerator.createBusinessException("RU001", e.getMessage());
+        }
+
+        this.blockedDomains = domainSet; // 새로운 데이터로 업데이트
+    }
+
+    // 차단된 도메인 목록 반환
+    public Set<String> getBlockedDomains() {
+        return blockedDomains;
+    }
+
+    // URL이 차단된 도메인에 포함되는지 확인
+    public boolean isBlocked(String url) {
+        for (String domain : blockedDomains) {
+            if (url.contains(domain)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+}

src/main/java/community/whatever/onembackendjava/api/service/UrlShortenService.java

@@ -1,29 +1,34 @@
 package community.whatever.onembackendjava.api.service;
 
+import community.whatever.onembackendjava.api.domain.BlockedDomainInterface;
 import community.whatever.onembackendjava.api.dto.ShortenUrlDto;
-import community.whatever.onembackendjava.common.error.BusinessException;
 import community.whatever.onembackendjava.common.error.BusinessExceptionGenerator;
+import community.whatever.onembackendjava.common.error.model.ErrorCode;
+import community.whatever.onembackendjava.common.util.BlackListService;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StringUtils;
 
 import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
-import java.util.stream.Stream;
 
 @Slf4j
 @Service
+@RequiredArgsConstructor
 public class UrlShortenService {
 
+    private final BlockedDomainInterface blockedDomainInterface;
     private static final String UrlRegex = "https?://(?:www\\.)?[a-zA-Z0-9./]+";
     private static final Pattern URL_PATTERN = Pattern.compile(UrlRegex);
 
     private final Map<String, String> shortenUrls = new HashMap<>();
 
     public ShortenUrlDto.Get.Response shortenUrlSearch(ShortenUrlDto.Get.Request param){
         if (!shortenUrls.containsKey(param.getKey())) {
-            throw BusinessExceptionGenerator.createBusinessException("DB003");
+            throw BusinessExceptionGenerator.createBusinessException(ErrorCode.DB003);
         }
 
         return ShortenUrlDto.Get.Response.builder()
@@ -33,7 +38,10 @@ public ShortenUrlDto.Get.Response shortenUrlSearch(ShortenUrlDto.Get.Request par
 
     public ShortenUrlDto.Create.Response shortenUrlCreate(ShortenUrlDto.Create.Request param){
         if (validateOriginUrl(param.getOriginUrl())) {
-            throw BusinessExceptionGenerator.createBusinessException("DB001");
+            throw BusinessExceptionGenerator.createBusinessException(ErrorCode.DB001);
+        }
+        if(blockedDomainInterface.isBlocked(param.getOriginUrl())){
+            throw BusinessExceptionGenerator.createBusinessException(ErrorCode.DB004);
         }
 
         Random random = new Random();

src/main/java/community/whatever/onembackendjava/common/error/BusinessExceptionGenerator.java

@@ -16,6 +16,10 @@ public BusinessExceptionGenerator(RestControllerAdvice restControllerAdvice){
         this.restControllerAdvice = restControllerAdvice;
     }
 
+    public static BusinessException createBusinessException(ErrorCode errorCode) {
+        return new BusinessException(errorCode.getErrorCode(), errorCode.getMessage());
+    }
+
     public static BusinessException createBusinessException(String errorCode) {
         ErrorCode enumError = ErrorCode.valueOf(errorCode);
         return new BusinessException(enumError.getErrorCode(), enumError.getMessage());

src/main/java/community/whatever/onembackendjava/common/error/model/ErrorCode.java

@@ -8,7 +8,10 @@
 public enum ErrorCode {
     DB001("DB001","잘못된 요청입니다."),
     DB002("DB002","데이터를 찾을 수 없습니다."),
-    DB003("DB003","참조키를 찾을 수 없습니다.");
+    DB003("DB003","참조키를 찾을 수 없습니다."),
+    DB004("DB004","서비스를 이용할 수 없는 도메인입니다."),
+
+    RU001("RU001", "csv 파일 읽기에 실패했습니다.");
 
     private final String errorCode;
     private final String message;

src/main/java/community/whatever/onembackendjava/common/util/BlackListService.java

@@ -0,0 +1,23 @@
+package community.whatever.onembackendjava.common.util;
+
+import org.springframework.core.env.Environment;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+import java.util.List;
+
+@Component
+public class BlackListService {
+    private final List<String> blockedDomains;
+
+    public BlackListService(Environment env) {
+        String domains = env.getProperty("spring.blacklist.domains", ""); // 기본값 빈 문자열
+        this.blockedDomains = Arrays.stream(domains.split(","))
+                .filter(domain -> !domain.isEmpty())
+                .toList();
+    }
+
+    public List<String> getBlockedDomains() {
+        return blockedDomains;
+    }
+}