[refactor] 나만의 bar 페이지네이션을 커서 기반으로 리팩토링 #49 (#51)

* refactor: MyBar 목록 API 페이징 방식을 오프셋에서 커서 기반으로 변경

- 응답 DTO인 `MyBarListResponseDto`에서 `nextPage` 필드를 제거하고, 대신 `nextCursor` 필드를 추가

* feat: MyBarRepository에 커서 기반 페이징 메서드 추가

- `MyBarRepository`에 커서 기반 페이징을 위한 새로운 쿼리 메서드 `findSliceByCursor`를 추가

* refactor: MyBarService에 커서 기반 페이징 로직 구현 및 적용

- MyBar 목록 조회 API의 페이징 방식을 기존의 오프셋(offset) 기반에서 커서(cursor) 기반으로 변경
- `getMyBar` 메서드의 파라미터를 `page`, `pageSize`에서 `cursor`, `limit`로 수정하여 커서 기반 페이징에 적합하게 변경
- `Cursor` 클래스를 새로 추가하여 커서의 인코딩/디코딩 로직을 구현 커서는 `epochMillis`와 `id`를 조합하여 Base64로 인코딩
- 첫 페이지 요청(`cursor`가 null 또는 빈 문자열)과 다음 페이지 요청(`cursor`가 존재)을 분리하여 처리하는 로직을 추가

* refactor: MyBarController의 목록 조회 API 페이징 방식 변경

- 마이바(MyBar) 목록을 조회하는 GET API의 페이징 방식을 오프셋(offset) 기반에서 커서(cursor) 기반으로 리팩토링
- 기존의 `@RequestParam`인 `page`와 `pageSize`를 `cursor`와 `limit`로 변경
- `cursor`는 `String` 타입으로, 다음 페이지를 식별하는 데 사용

* refactor: MyBarListResponseDto의 커서 필드를 분리하여 재구성

- `MyBarListResponseDto`의 `nextCursor` 필드를 제거하고, `nextKeptAt`과 `nextId` 두 개의 필드로 분리
- 기존의 Base64로 인코딩된 문자열 커서 대신, 서버 내부에서 직접 사용할 수 있는 `LocalDateTime`과 `Long` 타입의 필드를 제공

* refactor: MyBarService의 커서 기반 페이징 로직 재구성 (간소화)

- `MyBarService`의 `getMyBar` 메서드에서 커서 기반 페이징 로직을 간소화
- 기존의 Base64 인코딩/디코딩 방식을 제거하고, 커서 값을 `lastKeptAt` (LocalDateTime)과 `lastId` (Long) 두 개의 파라미터로 직접 받도록 변경

* refactor: MyBar 목록 조회 API 파라미터를 커서 값으로 직접 변경

- MyBar 목록 조회 API의 `@GetMapping` 메서드 파라미터를 커서 기반 페이징에 맞게 변경
- 기존의 단일 `cursor` 문자열 필드 대신, `lastKeptAt` (LocalDateTime)과 `lastId` (Long)를 직접 받도록 수정
- `lastKeptAt` 파라미터에 `@DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)`을 적용하여 ISO 8601 형식의 시간 데이터를 자동으로 변환

Author: MEOHIN

src/main/java/com/back/domain/mybar/controller/MyBarController.java

@@ -9,6 +9,8 @@
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.format.annotation.DateTimeFormat;
+import java.time.LocalDateTime;
 
 @RestController
 @RequestMapping("/me/bar")
@@ -21,10 +23,12 @@ public class MyBarController {
     @GetMapping
     public RsData<MyBarListResponseDto> getMyBarList(
             @AuthenticationPrincipal(expression = "id") Long userId,
-            @RequestParam(defaultValue = "0") @Min(0) int page,
-            @RequestParam(defaultValue = "20") @Min(1) @Max(100) int pageSize
+            @RequestParam(required = false)
+            @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime lastKeptAt,
+            @RequestParam(required = false) Long lastId,
+            @RequestParam(defaultValue = "20") @Min(1) @Max(100) int limit
     ) {
-        MyBarListResponseDto body = myBarService.getMyBar(userId, page, pageSize);
+        MyBarListResponseDto body = myBarService.getMyBar(userId, lastKeptAt, lastId, limit);
         return RsData.successOf(body);  // code=200, message="success"
     }
 

src/main/java/com/back/domain/mybar/dto/MyBarListResponseDto.java

@@ -3,12 +3,14 @@
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
+import java.time.LocalDateTime;
 import java.util.List;
 
 @Getter
 @AllArgsConstructor
 public class MyBarListResponseDto {
     private List<MyBarItemResponseDto> items;
-    private boolean hasNext;   // 다음 페이지 존재 여부
-    private Integer nextPage;  // 다음 페이지 번호(없으면 null)
-}
+    private boolean hasNext;        // 다음 페이지 존재 여부
+    private LocalDateTime nextKeptAt; // 다음 페이지 시작용 keptAt
+    private Long nextId;              // 다음 페이지 시작용 id
+}

src/main/java/com/back/domain/mybar/repository/MyBarRepository.java

@@ -10,12 +10,23 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.Optional;
+import java.util.List;
+import java.time.LocalDateTime;
 
 @Repository
 public interface MyBarRepository extends JpaRepository<MyBar, Long> {
     /** 나만의 bar(킵) 목록: ACTIVE만, id desc */
     Page<MyBar> findByUser_IdAndStatusOrderByKeptAtDescIdDesc(Long userId, KeepStatus status, Pageable pageable);
 
+    @Query("""
+        select m from MyBar m
+         where m.user.id = :userId
+           and m.status = :status
+           and (m.keptAt < :keptAt or (m.keptAt = :keptAt and m.id < :id))
+         order by m.keptAt desc, m.id desc
+    """)
+    List<MyBar> findSliceByCursor(Long userId, KeepStatus status, LocalDateTime keptAt, Long id, Pageable pageable);
+
     /** 프로필/요약용: ACTIVE 개수 */
     long countByUser_IdAndStatus(Long userId, KeepStatus status);
 

src/main/java/com/back/domain/mybar/service/MyBarService.java

@@ -10,6 +10,7 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -26,18 +27,38 @@ public class MyBarService {
     private final UserRepository userRepository;
     private final CocktailRepository cocktailRepository;
 
+    // 커서: lastKeptAt + lastId를 그대로 파라미터로 사용
     @Transactional(readOnly = true)
-    public MyBarListResponseDto getMyBar(Long userId, int page, int pageSize) {
-        Page<MyBar> myBarPage = myBarRepository.findByUser_IdAndStatusOrderByKeptAtDescIdDesc(userId, KeepStatus.ACTIVE, PageRequest.of(page, pageSize));
+    public MyBarListResponseDto getMyBar(Long userId, LocalDateTime lastKeptAt, Long lastId, int limit) {
+        int safeLimit = Math.max(1, Math.min(limit, 100));
+        int fetchSize = safeLimit + 1; // 다음 페이지 여부 판단용으로 1개 더 조회
+
+        List<MyBar> rows;
+        Pageable pageable = PageRequest.of(0, fetchSize);
+
+        if (lastKeptAt == null || lastId == null) {
+            Page<MyBar> page0 = myBarRepository
+                    .findByUser_IdAndStatusOrderByKeptAtDescIdDesc(userId, KeepStatus.ACTIVE, pageable);
+            rows = page0.getContent();
+        } else {
+            rows = myBarRepository.findSliceByCursor(userId, KeepStatus.ACTIVE, lastKeptAt, lastId, pageable);
+        }
+
+        boolean hasNext = rows.size() > safeLimit;
+        if (hasNext) rows = rows.subList(0, safeLimit);
 
-        List<MyBar> myBars = myBarPage.getContent();
         List<MyBarItemResponseDto> items = new ArrayList<>();
-        for (MyBar myBar : myBars) items.add(MyBarItemResponseDto.from(myBar));
+        for (MyBar myBar : rows) items.add(MyBarItemResponseDto.from(myBar));
 
-        boolean hasNext = myBarPage.hasNext();
-        Integer nextPage = hasNext ? myBarPage.getNumber() + 1 : null;
+        LocalDateTime nextKeptAt = null;
+        Long nextId = null;
+        if (hasNext && !rows.isEmpty()) {
+            MyBar last = rows.get(rows.size() - 1);
+            nextKeptAt = last.getKeptAt();
+            nextId = last.getId();
+        }
 
-        return new MyBarListResponseDto(items, hasNext, nextPage);
+        return new MyBarListResponseDto(items, hasNext, nextKeptAt, nextId);
     }
 
     @Transactional
@@ -75,3 +96,4 @@ public void unkeep(Long userId, Long cocktailId) {
         myBarRepository.softDeleteByUserAndCocktail(userId, cocktailId);
     }
 }
+