✨ feat/product/KIKI-61-Search : 검색관련 기능 고도화

.github/workflows/dev-ci-cd.yml

@@ -9,7 +9,7 @@ name: 키키하이 dev CI-CD 파이프라인
 
 on:
   push:
-    branches: [ "develop","feat/product/KIKI-61-ElasticSearch"]
+    branches: [ "develop"]
 
 jobs:
   #1. 개발 서버 CI, Build 용

src/main/java/site/kikihi/custom/global/response/ErrorCode.java

@@ -7,7 +7,7 @@
 /**
  * 애플리케이션 전역에서 사용하는 에러 코드 Enum입니다.
  * 각 에러는 고유 코드, HTTP 상태, 메시지를 포함합니다.
- *
+ * <p>
  * 400 : 잘못된 요청 에러
  * 401 : 로그인 관련 에러
  * 403 : 권한 부족 관련 에러
@@ -28,6 +28,8 @@ public enum ErrorCode {
         INVALID_INPUT(400_002, HttpStatus.BAD_REQUEST, "입력값이 올바르지 않습니다."),
         NULL_VALUE(400_003, HttpStatus.BAD_REQUEST, "Null 값이 들어왔습니다."),
         TEST_ERROR(400_004, HttpStatus.BAD_REQUEST, "테스트 에러입니다."),
+        ALREADY_ON(400_005, HttpStatus.BAD_REQUEST, "이미 검색어 저장 기능이 켜져있습니다"),
+        ALREADY_OFF(400_006, HttpStatus.BAD_REQUEST, "이미 검색어 저장 기능이 꺼져있습니다"),
 
 
         // ========================
@@ -48,7 +50,6 @@ public enum ErrorCode {
         TOKEN_NOT_FOUND_COOKIE(401_011, HttpStatus.UNAUTHORIZED, "쿠키에 리프레시 토큰이 존재하지 않습니다."),
 
 
-
         // ========================
         // 403 Forbidden
         // ========================
@@ -57,6 +58,7 @@ public enum ErrorCode {
         UNAUTHORIZED_POST_ACCESS(403_002, HttpStatus.FORBIDDEN, "해당 게시글에 접근할 권한이 없습니다."),
         UNAUTHORIZED_DELETE_BOOKMARK(403_003, HttpStatus.FORBIDDEN, "해당 북마크를 삭제할 권한이 없습니다."),
         UNAUTHORIZED_DELETE_CUSTOM(403_004, HttpStatus.FORBIDDEN, "해당 커스텀을 삭제할 권한이 없습니다."),
+        UNAUTHORIZED_DELETE_SEARCH(403_005, HttpStatus.FORBIDDEN, "검색기록을 삭제할 권한이 없습니다."),
 
 
         // ========================
@@ -69,20 +71,22 @@ public enum ErrorCode {
         POST_TYPE_NOT_FOUND(404_004, HttpStatus.NOT_FOUND, "게시글 타입을 찾을 수 없습니다."),
         COMMENT_NOT_FOUND(404_005, HttpStatus.NOT_FOUND, "요청한 댓글을 찾을 수 없습니다."),
         PRODUCT_NOT_FOUND(404_006, HttpStatus.NOT_FOUND, "요청한 상품을 찾을 수 없습니다."),
-        BOOKMARK_NOT_FOUND(404_007,HttpStatus.NOT_FOUND,"요청한 북마크를 찾을 수 없습니다."),
-        CUSTOM_NOT_FOUND(404_008,HttpStatus.NOT_FOUND,"요청한 커스텀 키보드를 찾을 수 없습니다."),
+        BOOKMARK_NOT_FOUND(404_007, HttpStatus.NOT_FOUND, "요청한 북마크를 찾을 수 없습니다."),
+        CUSTOM_NOT_FOUND(404_008, HttpStatus.NOT_FOUND, "요청한 커스텀 키보드를 찾을 수 없습니다."),
+        SEARCH_NOT_FOUND(404_009, HttpStatus.NOT_FOUND, "요청한 검색기록을 찾을 수 없습니다."),
 
         // ========================
         // 409 Conflict
         // ========================
         DUPLICATE_EMAIL(409_001, HttpStatus.CONFLICT, "이미 사용 중인 이메일입니다."),
-        BOOKMARK_ALREADY(409_003,HttpStatus.CONFLICT,"이미 해당 상품에 북마크를 등록했습니다"),
+        BOOKMARK_ALREADY(409_003, HttpStatus.CONFLICT, "이미 해당 상품에 북마크를 등록했습니다"),
 
 
         // ========================
         // 500 Internal Server Error
         // ========================
-        INTERNAL_SERVER_ERROR(500_000, HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부 오류입니다.");
+        INTERNAL_SERVER_ERROR(500_000, HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부 오류입니다."),
+        ;
 
         // 기타 공통
 

src/main/java/site/kikihi/custom/platform/adapter/in/web/DevAuthController.java

@@ -74,6 +74,7 @@ private User createDev() {
                 .provider(Provider.KAKAO) // 테스트용 값 (Enum)
                 .role(Role.ADMIN) // 관리자 권한 부여
                 .address(Address.of())
+                .isSearch(true)
                 .build();
     }
 

src/main/java/site/kikihi/custom/platform/adapter/in/web/SearchController.java

@@ -1,44 +1,130 @@
 package site.kikihi.custom.platform.adapter.in.web;
 
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import site.kikihi.custom.global.response.ApiResponse;
+import site.kikihi.custom.global.response.page.PageRequest;
 import site.kikihi.custom.platform.adapter.in.web.dto.response.product.ProductListResponse;
-import site.kikihi.custom.platform.application.service.ElasticSearchService;
+import site.kikihi.custom.platform.adapter.in.web.dto.response.search.SearchListResponse;
+import site.kikihi.custom.platform.adapter.in.web.swagger.SearchControllerSpec;
+import site.kikihi.custom.platform.application.in.search.SearchUseCase;
 import site.kikihi.custom.platform.domain.product.Product;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.*;
+import site.kikihi.custom.platform.domain.search.Search;
+import site.kikihi.custom.security.oauth2.domain.PrincipalDetails;
 
 import java.util.List;
+import java.util.UUID;
 
 @RestController
 @RequestMapping("/api/v1/search")
 @RequiredArgsConstructor
-public class SearchController {
+public class SearchController implements SearchControllerSpec {
 
-    private final ElasticSearchService searchService;
+    private final SearchUseCase service;
 
-    // 상품 검색
+    /// 상품 검색
     @GetMapping
     public ApiResponse<List<ProductListResponse>> searchProducts(
             @RequestParam("keyword") String keyword,
-            @RequestParam(defaultValue = "0") int page,
-            @RequestParam(defaultValue = "20") int size,
-            @RequestParam(defaultValue = "0.001") float minScore
+            PageRequest pageRequest,
+            @AuthenticationPrincipal PrincipalDetails principalDetails
     ) {
 
-        List<Product> productList = searchService.searchProducts(keyword, page, size, minScore);
+        /// 유저가 없다면 null 저장
+        UUID userId = principalDetails != null ? principalDetails.getId() : null;
+
+        /// 서비스 호출
+        List<Product> productList = service.searchProducts(keyword, pageRequest.getPage(), pageRequest.getSize(), userId);
+
+        /// DTO 수정
         List<ProductListResponse> responses = ProductListResponse.from(productList);
 
+        /// 응답
         return ApiResponse.ok(responses);
     }
 
-    // 상품 필터링
-//    @GetMapping("/filter")
-//    public ApiResponse<List<Product>> filterProducts(
-//            @RequestParam("keyword") String keyword,
-//            @RequestBody SearchRequest req,
-//            PageRequest pageRequest
-//    ) {
-//        List<Product> products = searchService.filterProducts(keyword, req.manufacturer(), req.minPrice(), req.maxPrice(), pageRequest.getPage(), pageRequest.getSize());
-//        return ApiResponse.ok(products);
-//    }
+    /// 나의 최근 검색어 조회
+    @GetMapping("/my")
+    public ApiResponse<List<SearchListResponse>> getMySearches(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ) {
+
+        /// 서비스 호출
+        List<Search> responses = service.getMySearches(principalDetails.getId());
+
+        /// 리턴
+        return ApiResponse.ok(SearchListResponse.from(responses));
+
+    }
+
+    /// 특정 검색어 삭제
+    @DeleteMapping("/{id}")
+    public ApiResponse<Void> deleteSearch(
+            @PathVariable Long id,
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ) {
+        /// 서비스 호출
+        service.deleteMySearchKeyword(id, principalDetails.getId());
+
+        /// 리턴
+        return ApiResponse.deleted();
+    }
+
+
+    /// 모든 검색어 삭제
+    @DeleteMapping()
+    public ApiResponse<Void> deleteAllSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ) {
+        /// 서비스 호출
+        service.deleteAllKeywords(principalDetails.getId());
+
+        /// 리턴
+        return ApiResponse.deleted();
+    }
+
+    /// 자동 저장 기능 조회
+    @GetMapping("/auto")
+    public ApiResponse<String> getMyAutoSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ) {
+
+        /// 서비스 호출
+        boolean checked = service.checkSearch(principalDetails.getId());
+
+        String autoSearch = checked ? "자동 저장이 활성화되었습니다." : "자동 저장이 꺼져있습니다.";
+
+        /// 리턴
+        return ApiResponse.ok(autoSearch);
+
+    }
+
+    /// 자동 저장 기능 켜기
+    @PutMapping("/auto/on")
+    public ApiResponse<Void> turnOnSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ){
+
+        /// 서비스 호출
+        service.turnOnMySearchKeyword(principalDetails.getId());
+
+        /// 리턴
+        return ApiResponse.updated();
+
+    }
+
+    /// 자동 저장 기능 끄기
+    @PutMapping("/auto/off")
+    public ApiResponse<Void> turnOffSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    ){
+
+        /// 서비스 호출
+        service.turnOffMySearchKeyword(principalDetails.getId());
+
+        /// 리턴
+        return ApiResponse.updated();
+    }
+
 }

src/main/java/site/kikihi/custom/platform/adapter/in/web/dto/response/search/SearchListResponse.java

@@ -0,0 +1,27 @@
+package site.kikihi.custom.platform.adapter.in.web.dto.response.search;
+
+import lombok.Builder;
+import site.kikihi.custom.platform.domain.search.Search;
+import java.util.List;
+
+@Builder
+public record SearchListResponse(
+        Long searchId,
+        String keyword
+) {
+
+    /// 정적 팩토리 메서드
+    public static SearchListResponse from(Search search) {
+        return SearchListResponse.builder()
+                .searchId(search.getId())
+                .keyword(search.getKeyword())
+                .build();
+    }
+
+    /// 정적 팩토리 메서드
+    public static List<SearchListResponse> from(List<Search> searches) {
+        return searches.stream()
+                .map(SearchListResponse::from)
+                .toList();
+    }
+}

src/main/java/site/kikihi/custom/platform/adapter/in/web/swagger/SearchControllerSpec.java

@@ -0,0 +1,88 @@
+package site.kikihi.custom.platform.adapter.in.web.swagger;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestParam;
+import site.kikihi.custom.global.response.ApiResponse;
+import site.kikihi.custom.global.response.page.PageRequest;
+import site.kikihi.custom.platform.adapter.in.web.dto.response.product.ProductListResponse;
+import site.kikihi.custom.platform.adapter.in.web.dto.response.search.SearchListResponse;
+import site.kikihi.custom.security.oauth2.domain.PrincipalDetails;
+
+import java.util.List;
+
+@Tag(name = "검색 API", description = "검색을 위한 API 입니다.")
+public interface SearchControllerSpec {
+
+    @Operation(
+            summary = "검색 API",
+            description = "키워드를 바탕으로 조회합니다."
+    )
+    ApiResponse<List<ProductListResponse>> searchProducts(
+            @Parameter(example = "하우징")
+            @RequestParam("keyword") String keyword,
+            PageRequest pageRequest,
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+
+    @Operation(
+            summary = "나의 최근 검색어 목록 API",
+            description = "JWT를 바탕으로 나의 최근 검색어를 조회합니다."
+    )
+    ApiResponse<List<SearchListResponse>> getMySearches(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+    @Operation(
+            summary = "특정 검색어 삭제 API",
+            description = "JWT를 바탕으로 특정 검색어를 삭제합니다."
+    )
+    ApiResponse<Void> deleteSearch(
+            @PathVariable Long id,
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+
+
+
+    @Operation(
+            summary = "모든 검색어 삭제 API",
+            description = "JWT를 바탕으로 모든 검색어를 삭제합니다."
+    )
+    ApiResponse<Void> deleteAllSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+
+    @Operation(
+            summary = "검색어 자동저장 여부 API",
+            description = "JWT를 바탕으로 자동저장을 확인합니다."
+    )
+    ApiResponse<String> getMyAutoSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+
+    @Operation(
+            summary = "검색어 자동저장 기능 ON API",
+            description = "JWT를 바탕으로 자동저장을 킵니다."
+    )
+    ApiResponse<Void> turnOnSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+
+
+
+
+    @Operation(
+            summary = "검색어 자동저장 기능 OFF API",
+            description = "JWT를 바탕으로 자동저장을 끕니다."
+    )
+    ApiResponse<Void> turnOffSearch(
+            @AuthenticationPrincipal PrincipalDetails principalDetails
+    );
+}

src/main/java/site/kikihi/custom/platform/adapter/out/SearchAdapter.java

@@ -0,0 +1,51 @@
+package site.kikihi.custom.platform.adapter.out;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import site.kikihi.custom.platform.adapter.out.jpa.search.SearchJpaEntity;
+import site.kikihi.custom.platform.adapter.out.jpa.search.SearchJpaRepository;
+import site.kikihi.custom.platform.application.out.search.SearchPort;
+import site.kikihi.custom.platform.domain.search.Search;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+@Component
+@RequiredArgsConstructor
+public class SearchAdapter implements SearchPort {
+
+    private final SearchJpaRepository repository;
+
+    @Override
+    public Search saveSearch(Search search) {
+
+        var entity = SearchJpaEntity.from(search);
+        return repository.save(entity)
+                .toDomain();
+    }
+
+    @Override
+    public Optional<Search> getSearch(Long id) {
+        return repository.findById(id)
+                .map(SearchJpaEntity::toDomain);
+    }
+
+    @Override
+    public List<Search> getSearches(UUID userId) {
+        return repository.findByUserIdOrderByCreatedAtDesc(userId).stream()
+                .map(SearchJpaEntity::toDomain)
+                .toList();
+    }
+
+    @Override
+    public void deleteSearch(Long searchId, UUID userId) {
+        repository.deleteByIdAndUserId(searchId, userId);
+    }
+
+
+    @Override
+    public void deleteALlSearch(UUID userId) {
+        repository.deleteAllByUserId(userId);
+    }
+}