Feature/js develop/private course query controller 1

job-seeker-service/js-data-access/src/main/java/az/rock/flyjob/js/dataaccess/adapter/query/CourseQueryRepositoryAdapter.java

@@ -64,7 +64,8 @@ public Boolean isInLimit(Long limit,ResumeID resumeId) {
 
     @Override
     public List<CourseRoot> fetchAllCourses(CourseCriteria criteria, SimplePageableRequest pageableRequest) {
-        var courseComposeExample = CourseComposeExample.of(criteria,"order_number",pageableDataAccessMapper.toBatisPageable(pageableRequest));
+        var pageable = pageableDataAccessMapper.toBatisPageable(pageableRequest).changeLimit(pageableRequest.getSize()+1);
+        var courseComposeExample = CourseComposeExample.of(criteria,"order_number",pageable);
         return courseQueryBatisRepository.selectByExample(courseComposeExample)
                 .stream()
                 .map(courseDataAccessMapper::toRoot)

job-seeker-service/js-domain/js-domain-presentation/src/main/java/az/rock/flyjob/js/domain/presentation/handler/concretes/CourseQueryHandler.java

@@ -1,6 +1,7 @@
 package az.rock.flyjob.js.domain.presentation.handler.concretes;
 
 import az.rock.flyjob.js.domain.core.exception.course.CourseNotFoundException;
+import az.rock.flyjob.js.domain.core.root.detail.CourseRoot;
 import az.rock.flyjob.js.domain.presentation.dto.criteria.CourseCriteria;
 import az.rock.flyjob.js.domain.presentation.dto.response.resume.course.AnyCourseResponseModel;
 import az.rock.flyjob.js.domain.presentation.dto.response.resume.course.MyCourseResponseModel;
@@ -18,8 +19,10 @@
 import com.intellibucket.lib.payload.payload.query.CourseFetchPayload;
 import org.springframework.stereotype.Component;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
+import java.util.stream.Collectors;
 
 
 @Component
@@ -44,8 +47,8 @@ public SimplePageableResponse<MyCourseResponseModel> allMyCourses(SimplePageable
         var courses = courseQueryRepositoryAdapter.fetchAllCourses(criteria,pageableRequest)
                 .stream()
                 .map(MyCourseResponseModel::of)
-                .toList();
-        var payload = SimplePageableResponse.ofNoMore(pageableRequest.getSize(), pageableRequest.getPage(),courses);
+                .collect(Collectors.toList());
+        var payload = convertSimplePageableResponse(courses,pageableRequest);
         return payload;
 
     }
@@ -56,11 +59,10 @@ public SimplePageableResponse<AnyCourseResponseModel> allAnyCourses(UUID targetR
         var courses = courseQueryRepositoryAdapter.fetchAllCourses(criteria,pageableRequest)
                 .stream()
                 .map(AnyCourseResponseModel::of)
-                .toList();
-        var payload =  SimplePageableResponse.ofNoMore(pageableRequest.getSize(), pageableRequest.getPage(),courses);
+                .collect(Collectors.toList());
+        var payload =  convertSimplePageableResponse(courses,pageableRequest);
         return payload;
     }
-
     @Override
     public MyCourseResponseModel myCourseById(UUID id) throws CourseNotFoundException {
         var resumeId = securityContextHolder.availableResumeID();
@@ -87,8 +89,8 @@ public SimplePageableResponse<SimpleMyCourseResponseModel> allMySimpleCourses(Si
         var courses = courseQueryRepositoryAdapter.fetchAllCourses(criteria,simplePageableRequest)
                 .stream()
                 .map(SimpleMyCourseResponseModel::of)
-                .toList();
-        var payload = SimplePageableResponse.ofNoMore(simplePageableRequest.getSize(), simplePageableRequest.getPage(),courses);
+                .collect(Collectors.toList());
+        var payload = convertSimplePageableResponse(courses,simplePageableRequest);
         return payload;
     }
 
@@ -98,8 +100,15 @@ public SimplePageableResponse<SimpleAnyCourseResponseModel> allAnySimpleCourses(
         var courses = courseQueryRepositoryAdapter.fetchAllCourses(criteria,pageableRequest)
                 .stream()
                 .map(SimpleAnyCourseResponseModel::of)
-                .toList();
-        var payload =  SimplePageableResponse.ofNoMore(pageableRequest.getSize(), pageableRequest.getPage(),courses);
+                .collect(Collectors.toList());
+        var payload =  convertSimplePageableResponse(courses,pageableRequest);
         return payload;
     }
+
+    private SimplePageableResponse convertSimplePageableResponse(List courses,SimplePageableRequest simplePageableRequest){
+        Boolean hasMore = courses.size()  > simplePageableRequest.getSize();
+        if(hasMore)courses.remove(courses.size()-1);
+        return SimplePageableResponse.of(simplePageableRequest.getSize(), simplePageableRequest.getPage(),hasMore,courses);
+    }
 }
+

library/ib-data-access/src/main/java/com/intellibucket/lib/fj/dataaccess/BatisPageable.java

@@ -27,4 +27,7 @@ public Integer getOffset() {
         return offset;
     }
 
+    public BatisPageable changeLimit(Integer limit){
+        return new BatisPageable(limit,this.offset);
+    }
 }