Source code

001package model.repository;
002
003import model.entity.Post;
004import model.entity.Section;
005import model.entity.User;
006
007import javax.persistence.EntityManager;
008import javax.persistence.PersistenceContext;
009import javax.persistence.TypedQuery;
010import javax.persistence.criteria.*;
011import java.io.Serializable;
012import java.time.Instant;
013import java.util.ArrayList;
014import java.util.Collections;
015import java.util.List;
016
017/**
018 * Classe che incapsula la logica per il recupero di entità di tipo {@link Post}
019 */
020public class PostRepository implements Serializable {
021
022    @PersistenceContext
023    protected EntityManager em;
024
025    /**
026     * Restituisce una nuova istanza di PostFinder
027     * @return nuova istanza di PostFinder
028     */
029    public PostFinder getFinder(){
030        return new PostFinder();
031    }
032
033    private enum SortCriteria {OLDEST, NEWEST, MOSTVOTED};
034
035    /**
036     *  Classe interna usata per specificare i parametri di ricerca di un post
037     */
038    public class PostFinder {
039        private User author;
040        private List<Section> sections;
041        private Instant before;
042        private Instant after;
043        private int offset = 0;
044        private int pageSize = 30;
045        private String content;
046        private boolean includeBody = false;
047        private User joinUserFollows;
048        private SortCriteria sortCriteria = PostRepository.SortCriteria.NEWEST;
049
050        protected PostFinder(){ }
051
052        /**
053         * Setta il campo author e restituisce l'istanza passata di PostFinder
054         * @param author entità User dell'autore dei post
055         * @return istanza passata di PostFinder
056         */
057        public PostFinder byAuthor(User author){
058            this.author = author;
059            return this;
060        }
061
062        /**
063         * Setta il campo content e restituisce l'istanza passata di PostFinder
064         * @param author text contenuto dei post
065         * @return istanza passata di PostFinder
066         */
067        public PostFinder byContent(String text){
068            this.content = text;
069            return this;
070        }
071
072        /**
073         * Setta il campo sections e restituisce l'istanza passata di PostFinder
074         * @param sections lista di sezioni
075         * @return istanza passata di PostFinder
076         */
077        public PostFinder bySections(List<Section> sections){
078            this.sections = sections;
079            return this;
080        }
081
082        /**
083         * Setta il campo sections e restituisce l'istanza passata di PostFinder
084         * @param sections sezione dei post
085         * @return istanza passata di PostFinder
086         */
087        public PostFinder bySection(Section section){
088            this.sections = Collections.singletonList(section);
089            return this;
090        }
091
092        /**
093         * Setta il campo postedAfter e restituisce l'istanza passata di PostFinder
094         * @param after data dopo la quale i post da trovare sono stati postati
095         * @return istanza passata di PostFinder
096         */
097        public PostFinder postedAfter(Instant after){
098            this.after = after;
099            return this;
100        }
101
102        /**
103         * Setta il campo postedBefore e restituisce l'istanza passata di PostFinder
104         * @param before data prima della quale i post da trovare sono stati postati
105         * @return istanza passata di PostFinder
106         */
107        public PostFinder postedBefore(Instant before){
108            this.before = before;
109            return this;
110        }
111
112        /**
113         * Setta il campo offset e restituisce l'istanza passata di PostFinder
114         * @param n offset per la paginazione
115         * @return istanza passata di PostFinder
116         */
117        public PostFinder offset(int n){
118            offset = n;
119            return this;
120        }
121
122        /**
123         * Setta il campo limit e restituisce l'istanza passata di PostFinder
124         * @param n limite di post da caricare
125         * @return istanza passata di PostFinder
126         */
127        public PostFinder limit(int n){
128            pageSize = n;
129            return this;
130        }
131
132        /**
133         * Setta il campo sortCriteria a oldest e restituisce l'istanza passata di PostFinder
134         * @return istanza passata di PostFinder
135         */
136        public PostFinder getOldest(){
137            sortCriteria = SortCriteria.OLDEST;
138            return this;
139        }
140
141        /**
142         * Setta il campo sortCriteria a newest e restituisce l'istanza passata di PostFinder
143         * @return istanza passata di PostFinder
144         */
145        public PostFinder getNewest(){
146            sortCriteria = SortCriteria.NEWEST;
147            return this;
148        }
149
150        /**
151         * Setta il campo sortCriteria a most voted e restituisce l'istanza passata di PostFinder
152         * @return istanza passata di PostFinder
153         */
154        public PostFinder getMostVoted(){
155            sortCriteria = SortCriteria.MOSTVOTED;
156            return this;
157        }
158
159        /**
160         * Setta il campo includeBody a true e restituisce l'istanza passata di PostFinder
161         * @return istanza passata di PostFinder
162         */
163        public PostFinder includeBody(){
164            includeBody = true;
165            return this;
166        }
167
168        /**
169         * Setta il campo joinUserFollows e restituisce l'istanza passata di PostFinder
170         * @param user entita utente da cui ottenere le sezioni seguite
171         * @return istanza passata di PostFinder
172         */
173        public PostFinder joinUserFollows(User user){
174            joinUserFollows = user;
175            return this;
176        }
177
178        /**
179         * Restituisce tutti i post che rispettano i criteri di ricerca
180         * @return lista di entità Post
181         */
182        public List<Post> getResults(){
183            CriteriaBuilder cb = em.getCriteriaBuilder();
184            CriteriaQuery<Post> cq = cb.createQuery(Post.class);
185            Root<Post> root = cq.from(Post.class);
186
187            List<Predicate> predicates = new ArrayList<>();
188
189            if(author != null) {
190                predicates.add(cb.equal(root.get("author"), author));
191            }
192
193            if(sections != null && !sections.isEmpty()) {
194                predicates.add(root.get("section").in(sections));
195            }
196
197            if(after != null) {
198                predicates.add(cb.greaterThanOrEqualTo(root.get("creationDate"), after));
199            }
200
201            if(before != null) {
202                predicates.add(cb.lessThanOrEqualTo(root.get("creationDate"), before));
203            }
204
205            if(content != null) {
206                if(includeBody) {
207                    predicates.add(
208                            cb.or(
209                                    cb.like(root.get("title"), '%' + content + '%'),
210                                    cb.and(
211                                            cb.notEqual(root.get("type"), Post.Type.IMG),
212                                            cb.like(root.get("content"), '%' + content + '%')
213                                    )));
214                } else {
215                    predicates.add(cb.like(root.get("title"), '%' + content + '%'));
216                }
217            }
218
219            if(joinUserFollows != null){
220                Join<Object, Object> joinFollow = root.join("section").join("follows");
221                predicates.add(cb.equal(joinFollow.get("user"), joinUserFollows));
222            }
223
224            cq.where(cb.and(predicates.toArray(Predicate[]::new)));
225
226            switch (sortCriteria) {
227                case MOSTVOTED:
228                    cq.orderBy(cb.desc(root.get("votesCount")));
229                    break;
230                case OLDEST:
231                    cq.orderBy(cb.asc(root.get("creationDate")));
232                    break;
233                case NEWEST:
234                default:
235                    cq.orderBy(cb.desc(root.get("creationDate")));
236                    break;
237            }
238
239
240            TypedQuery<Post> tq = em.createQuery(cq);
241            if(offset >= 0)
242                tq.setFirstResult(offset);
243            if(pageSize>=0)
244                tq.setMaxResults(pageSize);
245
246            return tq.getResultList();
247        }
248    }
249}