Only process new posts and replies if the notifications changed.
[Sone.git] / src / main / java / net / pterodactylus / sone / web / ajax / GetStatusAjaxPage.java
1 /*
2  * Sone - GetStatusAjaxPage.java - Copyright © 2010–2012 David Roden
3  *
4  * This program is free software: you can redistribute it and/or modify
5  * it under the terms of the GNU General Public License as published by
6  * the Free Software Foundation, either version 3 of the License, or
7  * (at your option) any later version.
8  *
9  * This program is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
16  */
17
18 package net.pterodactylus.sone.web.ajax;
19
20 import java.text.DateFormat;
21 import java.text.SimpleDateFormat;
22 import java.util.Collections;
23 import java.util.Date;
24 import java.util.HashSet;
25 import java.util.List;
26 import java.util.Set;
27
28 import net.pterodactylus.sone.data.Post;
29 import net.pterodactylus.sone.data.PostReply;
30 import net.pterodactylus.sone.data.Sone;
31 import net.pterodactylus.sone.notify.ListNotificationFilters;
32 import net.pterodactylus.sone.template.SoneAccessor;
33 import net.pterodactylus.sone.web.WebInterface;
34 import net.pterodactylus.sone.web.page.FreenetRequest;
35 import net.pterodactylus.util.collection.filter.Filter;
36 import net.pterodactylus.util.collection.filter.Filters;
37 import net.pterodactylus.util.json.JsonArray;
38 import net.pterodactylus.util.json.JsonObject;
39 import net.pterodactylus.util.notify.Notification;
40 import net.pterodactylus.util.object.HashCode;
41
42 /**
43  * The “get status” AJAX handler returns all information that is necessary to
44  * update the web interface in real-time.
45  *
46  * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
47  */
48 public class GetStatusAjaxPage extends JsonPage {
49
50         /** Date formatter. */
51         private static final DateFormat dateFormat = new SimpleDateFormat("MMM d, yyyy, HH:mm:ss");
52
53         /**
54          * Creates a new “get status” AJAX handler.
55          *
56          * @param webInterface
57          *            The Sone web interface
58          */
59         public GetStatusAjaxPage(WebInterface webInterface) {
60                 super("getStatus.ajax", webInterface);
61         }
62
63         /**
64          * {@inheritDoc}
65          */
66         @Override
67         protected JsonObject createJsonObject(FreenetRequest request) {
68                 final Sone currentSone = getCurrentSone(request.getToadletContext(), false);
69                 /* load Sones. */
70                 boolean loadAllSones = Boolean.parseBoolean(request.getHttpRequest().getParam("loadAllSones", "false"));
71                 Set<Sone> sones = new HashSet<Sone>(Collections.singleton(getCurrentSone(request.getToadletContext(), false)));
72                 if (loadAllSones) {
73                         sones.addAll(webInterface.getCore().getSones());
74                 } else {
75                         String loadSoneIds = request.getHttpRequest().getParam("soneIds");
76                         if (loadSoneIds.length() > 0) {
77                                 String[] soneIds = loadSoneIds.split(",");
78                                 for (String soneId : soneIds) {
79                                         /* just add it, we skip null further down. */
80                                         sones.add(webInterface.getCore().getSone(soneId, false));
81                                 }
82                         }
83                 }
84                 JsonArray jsonSones = new JsonArray();
85                 for (Sone sone : sones) {
86                         if (sone == null) {
87                                 continue;
88                         }
89                         JsonObject jsonSone = createJsonSone(sone);
90                         jsonSones.add(jsonSone);
91                 }
92                 /* load notifications. */
93                 List<Notification> notifications = ListNotificationFilters.filterNotifications(webInterface.getNotifications().getNotifications(), currentSone);
94                 Collections.sort(notifications, Notification.CREATED_TIME_SORTER);
95                 int notificationHash = HashCode.hashCode(notifications);
96                 /* load new posts. */
97                 Set<Post> newPosts = webInterface.getNewPosts();
98                 if (currentSone != null) {
99                         newPosts = Filters.filteredSet(newPosts, new Filter<Post>() {
100
101                                 @Override
102                                 public boolean filterObject(Post post) {
103                                         return ListNotificationFilters.isPostVisible(currentSone, post);
104                                 }
105
106                         });
107                 }
108                 JsonArray jsonPosts = new JsonArray();
109                 for (Post post : newPosts) {
110                         JsonObject jsonPost = new JsonObject();
111                         jsonPost.put("id", post.getId());
112                         jsonPost.put("sone", post.getSone().getId());
113                         jsonPost.put("recipient", (post.getRecipient() != null) ? post.getRecipient().getId() : null);
114                         jsonPost.put("time", post.getTime());
115                         jsonPosts.add(jsonPost);
116                 }
117                 /* load new replies. */
118                 Set<PostReply> newReplies = webInterface.getNewReplies();
119                 if (currentSone != null) {
120                         newReplies = Filters.filteredSet(newReplies, new Filter<PostReply>() {
121
122                                 @Override
123                                 public boolean filterObject(PostReply reply) {
124                                         return ListNotificationFilters.isReplyVisible(currentSone, reply);
125                                 }
126
127                         });
128                 }
129                 /* remove replies to unknown posts. */
130                 newReplies = Filters.filteredSet(newReplies, new Filter<PostReply>() {
131
132                         @Override
133                         public boolean filterObject(PostReply reply) {
134                                 return (reply.getPost() != null) && (reply.getPost().getSone() != null);
135                         }
136                 });
137                 JsonArray jsonReplies = new JsonArray();
138                 for (PostReply reply : newReplies) {
139                         JsonObject jsonReply = new JsonObject();
140                         jsonReply.put("id", reply.getId());
141                         jsonReply.put("sone", reply.getSone().getId());
142                         jsonReply.put("post", reply.getPost().getId());
143                         jsonReply.put("postSone", reply.getPost().getSone().getId());
144                         jsonReplies.add(jsonReply);
145                 }
146                 return createSuccessJsonObject().put("loggedIn", currentSone != null).put("options", createJsonOptions(currentSone)).put("sones", jsonSones).put("notificationHash", notificationHash).put("newPosts", jsonPosts).put("newReplies", jsonReplies);
147         }
148
149         /**
150          * {@inheritDoc}
151          */
152         @Override
153         protected boolean needsFormPassword() {
154                 return false;
155         }
156
157         /**
158          * {@inheritDoc}
159          */
160         @Override
161         protected boolean requiresLogin() {
162                 return false;
163         }
164
165         //
166         // PRIVATE METHODS
167         //
168
169         /**
170          * Creates a JSON object from the given Sone.
171          *
172          * @param sone
173          *            The Sone to convert to a JSON object
174          * @return The JSON representation of the given Sone
175          */
176         private JsonObject createJsonSone(Sone sone) {
177                 JsonObject jsonSone = new JsonObject();
178                 jsonSone.put("id", sone.getId());
179                 jsonSone.put("name", SoneAccessor.getNiceName(sone));
180                 jsonSone.put("local", sone.getInsertUri() != null);
181                 jsonSone.put("status", sone.getStatus().name());
182                 jsonSone.put("modified", webInterface.getCore().isModifiedSone(sone));
183                 jsonSone.put("locked", webInterface.getCore().isLocked(sone));
184                 jsonSone.put("lastUpdatedUnknown", sone.getTime() == 0);
185                 synchronized (dateFormat) {
186                         jsonSone.put("lastUpdated", dateFormat.format(new Date(sone.getTime())));
187                 }
188                 jsonSone.put("lastUpdatedText", GetTimesAjaxPage.getTime(webInterface, sone.getTime()).getText());
189                 return jsonSone;
190         }
191
192         /**
193          * Creates a JSON object that contains all options that are currently in
194          * effect for the given Sone (or overall, if the given Sone is {@code null}
195          * ).
196          *
197          * @param currentSone
198          *            The current Sone (may be {@code null})
199          * @return The current options
200          */
201         private JsonObject createJsonOptions(Sone currentSone) {
202                 JsonObject options = new JsonObject();
203                 if (currentSone != null) {
204                         options.put("ShowNotification/NewSones", currentSone.getOptions().getBooleanOption("ShowNotification/NewSones").get());
205                         options.put("ShowNotification/NewPosts", currentSone.getOptions().getBooleanOption("ShowNotification/NewPosts").get());
206                         options.put("ShowNotification/NewReplies", currentSone.getOptions().getBooleanOption("ShowNotification/NewReplies").get());
207                 }
208                 return options;
209         }
210
211 }