Merge pull request #14 from TAMULib/sprint2-b03247-paginated-notes

Sprint2 b03247 paginated notes

Author: jcreel

src/main/java/edu/tamu/app/controller/NoteController.java

@@ -4,13 +4,25 @@
 import static edu.tamu.framework.enums.BusinessValidationType.CREATE;
 import static edu.tamu.framework.enums.BusinessValidationType.EXISTS;
 
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.domain.Sort.Direction;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.web.bind.annotation.RestController;
 
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+
 import edu.tamu.app.model.Note;
 import edu.tamu.app.model.repo.NoteRepo;
+import edu.tamu.app.model.request.FilteredPageRequest;
 import edu.tamu.framework.aspect.annotation.ApiCredentials;
+import edu.tamu.framework.aspect.annotation.ApiData;
 import edu.tamu.framework.aspect.annotation.ApiMapping;
 import edu.tamu.framework.aspect.annotation.ApiValidatedModel;
 import edu.tamu.framework.aspect.annotation.ApiValidation;
@@ -65,4 +77,33 @@ public ApiResponse remove(@ApiValidatedModel Note note) {
         simpMessagingTemplate.convertAndSend("/channel/note", new ApiResponse(SUCCESS, noteRepo.findAll()));
         return new ApiResponse(SUCCESS);
     }
+    
+    @ApiMapping("/page")
+    @Auth(role="ROLE_ANONYMOUS")
+    public ApiResponse page(@ApiData JsonNode dataNode) {
+        Direction sortDirection;
+        if (dataNode.get("direction").get("direction").asText().equals("ASC")) {
+            sortDirection = Sort.Direction.ASC;
+        } else {
+            sortDirection = Sort.Direction.DESC;
+        }
+        
+        Map<String, String[]> filters = new HashMap<String, String[]>();
+        System.out.println("dataNode: " + dataNode.get("filters").get("title"));
+        filters.put("title", arrayNodeToStringArray((ArrayNode) dataNode.get("filters").get("title")));
+        
+        FilteredPageRequest filteredPageRequest = new FilteredPageRequest(dataNode.get("page").get("number").asInt(), dataNode.get("page").get("size").asInt(), sortDirection, dataNode.get("direction").get("properties").asText(), filters);
+        Page<Note> notes = noteRepo.findAll(filteredPageRequest);
+        return new ApiResponse(SUCCESS, notes);
+    }
+    
+    private String[] arrayNodeToStringArray(ArrayNode arrayNode) {
+        String[] array = new String[arrayNode.size()];
+        Iterator<JsonNode> arrayIterator = arrayNode.elements();
+        int i = 0;
+        while (arrayIterator.hasNext()) {
+            array[i++] = arrayIterator.next().asText();
+        }
+        return array;
+    }
 }

src/main/java/edu/tamu/app/model/repo/NoteRepo.java

@@ -1,12 +1,18 @@
 package edu.tamu.app.model.repo;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 
 import edu.tamu.app.model.Note;
 import edu.tamu.app.model.repo.custom.NoteRepoCustom;
 
-public interface NoteRepo extends JpaRepository<Note, Long>, NoteRepoCustom {
+public interface NoteRepo extends JpaRepository<Note, Long>, NoteRepoCustom, JpaSpecificationExecutor<Note> {
 
-//    public void delete(Note note);
+    public Page<Note> findAll(Specification<Note> specification, Pageable pageable);
+    
+    public Page<Note> findAll(Pageable pageable);
 
 }

src/main/java/edu/tamu/app/model/repo/custom/NoteRepoCustom.java

@@ -6,7 +6,5 @@
 public interface NoteRepoCustom {
 
     public Note create(Note note, Credentials credentials);
-    
-//    public void delete(Note note);
 
 }

src/main/java/edu/tamu/app/model/repo/specification/NoteSpecification.java

@@ -0,0 +1,46 @@
+package edu.tamu.app.model.repo.specification;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+
+import org.springframework.data.jpa.domain.Specification;
+
+import edu.tamu.app.model.Note;
+
+public class NoteSpecification<E> implements Specification<E> {
+    
+    private Map<String, String[]> filters;
+    
+    public NoteSpecification(Map<String, String[]> filters) {
+        this.filters = filters;
+    }
+
+    @Override
+    public Predicate toPredicate(Root<E> root, CriteriaQuery<?> query, CriteriaBuilder cb){
+        
+        List<Predicate> datePredicates = new ArrayList<Predicate>();
+//        System.out.println("entry set is: " + filters);
+//        for (Map.Entry<String, String[]> entry : filters.entrySet()) {
+//            String key = entry.getKey();
+//            String[] values = entry.getValue();
+//            
+//            switch (key) {
+//                case "date":
+//                    for (String value : values) {
+//                        datePredicates.add(cb.like(cb.lower(root.get(key).as(String.class)), value.toLowerCase()));
+//                        break;
+//                    }
+//                default:
+//                    break;
+//            }
+//        }
+       
+        return cb.and(datePredicates.toArray(new Predicate[datePredicates.size()]));
+    }   
+}

src/main/java/edu/tamu/app/model/request/FilteredPageRequest.java

@@ -0,0 +1,29 @@
+package edu.tamu.app.model.request;
+
+import java.util.Map;
+
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+
+public class FilteredPageRequest extends PageRequest {
+
+    private static final long serialVersionUID = -190530029013941566L;
+    private Map<String, String[]> filters;
+    
+    public FilteredPageRequest() {
+        super(0, 2);
+    }
+    
+    public FilteredPageRequest(int page, int size, Sort.Direction direction, String properties, Map<String, String[]> filters) {
+        super(page, size, direction, properties);
+        setFilters(filters);
+    }
+
+    public Map<String, String[]> getFilters() {
+        return filters;
+    }
+
+    public void setFilters(Map<String, String[]> filters) {
+        this.filters = filters;
+    }
+}