Fixed initialization and display of shared trees
[pithos-web-client] / src / gr / grnet / pithos / web / client / othersharedtree / OtherSharedTreeViewModel.java
1 /*
2  * Copyright 2011 GRNET S.A. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or
5  * without modification, are permitted provided that the following
6  * conditions are met:
7  *
8  *   1. Redistributions of source code must retain the above
9  *      copyright notice, this list of conditions and the following
10  *      disclaimer.
11  *
12  *   2. Redistributions in binary form must reproduce the above
13  *      copyright notice, this list of conditions and the following
14  *      disclaimer in the documentation and/or other materials
15  *      provided with the distribution.
16  *
17  * THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
18  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
19  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
20  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
21  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
22  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
23  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
24  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
25  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
27  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
28  * POSSIBILITY OF SUCH DAMAGE.
29  *
30  * The views and conclusions contained in the software and
31  * documentation are those of the authors and should not be
32  * interpreted as representing official policies, either expressed
33  * or implied, of GRNET S.A.
34  */
35
36 package gr.grnet.pithos.web.client.othersharedtree;
37
38 import gr.grnet.pithos.web.client.FolderContextMenu;
39 import gr.grnet.pithos.web.client.Pithos;
40 import gr.grnet.pithos.web.client.SharingUsers;
41 import gr.grnet.pithos.web.client.foldertree.AccountResource;
42 import gr.grnet.pithos.web.client.foldertree.File;
43 import gr.grnet.pithos.web.client.foldertree.Folder;
44 import gr.grnet.pithos.web.client.othersharedtree.OtherSharedTreeView.Templates;
45 import gr.grnet.pithos.web.client.rest.GetRequest;
46 import gr.grnet.pithos.web.client.rest.RestException;
47
48 import java.util.HashMap;
49 import java.util.HashSet;
50 import java.util.Iterator;
51 import java.util.Map;
52 import java.util.Set;
53
54 import com.google.gwt.cell.client.AbstractCell;
55 import com.google.gwt.cell.client.Cell;
56 import com.google.gwt.cell.client.TextCell;
57 import com.google.gwt.cell.client.ValueUpdater;
58 import com.google.gwt.core.client.GWT;
59 import com.google.gwt.core.client.Scheduler;
60 import com.google.gwt.event.dom.client.ContextMenuEvent;
61 import com.google.gwt.http.client.Response;
62 import com.google.gwt.http.client.URL;
63 import com.google.gwt.safehtml.shared.SafeHtml;
64 import com.google.gwt.safehtml.shared.SafeHtmlBuilder;
65 import com.google.gwt.text.shared.SafeHtmlRenderer;
66 import com.google.gwt.user.client.Command;
67 import com.google.gwt.user.client.ui.AbstractImagePrototype;
68 import com.google.gwt.view.client.ListDataProvider;
69 import com.google.gwt.view.client.SelectionChangeEvent;
70 import com.google.gwt.view.client.SelectionChangeEvent.Handler;
71 import com.google.gwt.view.client.SingleSelectionModel;
72 import com.google.gwt.view.client.TreeViewModel;
73
74 public class OtherSharedTreeViewModel implements TreeViewModel {
75
76         private static final String treeTitle = "Other 's shared";
77     protected Pithos app;
78
79     private Cell<Folder> folderCell = new AbstractCell<Folder>(ContextMenuEvent.getType().getName()) {
80
81        @Override
82         public void render(@SuppressWarnings("unused") Context context, Folder folder, SafeHtmlBuilder safeHtmlBuilder) {
83             String html = AbstractImagePrototype.create(OtherSharedTreeView.images.folderYellow()).getHTML();
84             safeHtmlBuilder.appendHtmlConstant(html);
85             safeHtmlBuilder.append(Templates.INSTANCE.nameSpan(folder.getName()));
86         }
87
88         @Override
89         public void onBrowserEvent(@SuppressWarnings("unused") Context context, @SuppressWarnings("unused") com.google.gwt.dom.client.Element parent, Folder folder, com.google.gwt.dom.client.NativeEvent event, @SuppressWarnings("unused") ValueUpdater<Folder> valueUpdater) {
90             if (event.getType().equals(ContextMenuEvent.getType().getName())) {
91                 OtherSharedTreeViewModel.this.selectionModel.setSelected(folder, true);
92                 FolderContextMenu menu = new FolderContextMenu(app, OtherSharedTreeView.images, app.getSelectedTree(), folder);
93                 menu.setPopupPosition(event.getClientX(), event.getClientY());
94                 menu.show();
95             }
96         }
97     };
98
99     private ListDataProvider<String> rootDataProvider = new ListDataProvider<String>();
100     protected ListDataProvider<String> userLevelDataProvider = new ListDataProvider<String>();
101
102     protected Map<String, ListDataProvider<Folder>> userDataProviderMap = new HashMap<String, ListDataProvider<Folder>>();
103     private Map<Folder, ListDataProvider<Folder>> dataProviderMap = new HashMap<Folder, ListDataProvider<Folder>>();
104     
105     protected Map<String, Set<File>> sharedFiles = new HashMap<String, Set<File>>();
106
107     protected SingleSelectionModel<Folder> selectionModel;
108
109     public OtherSharedTreeViewModel(Pithos _app, SingleSelectionModel<Folder> selectionModel) {
110         app = _app;
111         this.selectionModel = selectionModel;
112     }
113
114     @Override
115     public <T> NodeInfo<?> getNodeInfo(T value) {
116         if (value == null) {
117             rootDataProvider.getList().add(treeTitle);
118             final SingleSelectionModel<String> selectionModel2 = new SingleSelectionModel<String>();
119             selectionModel2.addSelectionChangeHandler(new Handler() {
120
121                 @Override
122                 public void onSelectionChange(@SuppressWarnings("unused") SelectionChangeEvent event) {
123                     if (selectionModel2.getSelectedObject() != null) {
124                         app.deselectOthers(app.getOtherSharedTreeView(), selectionModel2);
125                         app.applyPermissions(null);
126                         app.showFiles(new HashSet<File>());
127                     }
128                 }
129             });
130             app.addSelectionModel(selectionModel2);
131             return new DefaultNodeInfo<String>(rootDataProvider, new TextCell(new SafeHtmlRenderer<String>() {
132                 @Override
133                 public SafeHtml render(String object) {
134                     SafeHtmlBuilder builder = new SafeHtmlBuilder();
135                     render(object, builder);
136                     return builder.toSafeHtml();
137                 }
138
139                 @Override
140                 public void render(String object, SafeHtmlBuilder builder) {
141                     String html = AbstractImagePrototype.create(OtherSharedTreeView.images.othersShared()).getHTML();
142                     builder.appendHtmlConstant(html);
143                     builder.append(OtherSharedTreeView.Templates.INSTANCE.nameSpan(object));
144                 }
145             }),  selectionModel2, null);
146         }
147         else if (value instanceof String) {
148                 if (value.equals(treeTitle)) {
149                         fetchSharingUsers(null);
150                     final SingleSelectionModel<String> selectionModel3 = new SingleSelectionModel<String>();
151                     selectionModel3.addSelectionChangeHandler(new Handler() {
152
153                         @Override
154                         public void onSelectionChange(@SuppressWarnings("unused") SelectionChangeEvent event) {
155                             if (selectionModel3.getSelectedObject() != null) {
156                                 app.deselectOthers(app.getOtherSharedTreeView(), selectionModel3);
157                                 app.applyPermissions(null);
158                                 String username = selectionModel3.getSelectedObject();
159                                         if (userDataProviderMap.get(username) == null) {
160                                                 userDataProviderMap.put(username, new ListDataProvider<Folder>());
161                                         }
162                                 fetchSharedFiles(username, userDataProviderMap.get(username));
163                             }
164                         }
165                     });
166                     app.addSelectionModel(selectionModel3);
167                     return new DefaultNodeInfo<String>(userLevelDataProvider, new TextCell(new SafeHtmlRenderer<String>() {
168
169                                         @Override
170                                         public SafeHtml render(String object) {
171                             SafeHtmlBuilder builder = new SafeHtmlBuilder();
172                             render(object, builder);
173                             return builder.toSafeHtml();
174                                         }
175
176                                         @Override
177                                         public void render(String object, SafeHtmlBuilder builder) {
178                             String html = AbstractImagePrototype.create(OtherSharedTreeView.images.user()).getHTML();
179                             builder.appendHtmlConstant(html);
180                             builder.append(OtherSharedTreeView.Templates.INSTANCE.nameSpan(object));
181                                         }
182                                 }), selectionModel3, null);
183                 }
184                         String username = (String) value;
185                         if (userDataProviderMap.get(username) == null) {
186                                 userDataProviderMap.put(username, new ListDataProvider<Folder>());
187                         }
188                         final ListDataProvider<Folder> dataProvider = userDataProviderMap.get(username);
189                         fetchSharedContainers(username, dataProvider, null);
190                         return new DefaultNodeInfo<Folder>(dataProvider, folderCell, selectionModel, null);
191         }
192         else {
193             final Folder f = (Folder) value;
194             if (dataProviderMap.get(f) == null) {
195                 dataProviderMap.put(f, new ListDataProvider<Folder>());
196             }
197             final ListDataProvider<Folder> dataProvider = dataProviderMap.get(f);
198             fetchFolder(f, dataProvider, false);
199             return new DefaultNodeInfo<Folder>(dataProvider, folderCell, selectionModel, null);
200         }
201     }
202
203     private void fetchSharingUsers(final Command callback) {
204         GetRequest<SharingUsers> getSharingUsers = new GetRequest<SharingUsers>(SharingUsers.class, app.getApiPath(), "", "?format=json") {
205             @Override
206             public void onSuccess(final SharingUsers _result) {
207                 userLevelDataProvider.getList().clear();
208                 userLevelDataProvider.getList().addAll(_result.getUsers());
209                 for (String name : _result.getUsers()) {
210                         sharedFiles.put(name, new HashSet<File>());
211                 }
212                 Iterator<String> iter = _result.getUsers().iterator();
213                 fetchSharedContainers(iter, callback);
214             }
215
216             @Override
217             public void onError(Throwable t) {
218                 GWT.log("Error getting folder", t);
219                 if (t instanceof RestException)
220                     app.displayError("Error getting folder: " + ((RestException) t).getHttpStatusText());
221                 else
222                     app.displayError("System error fetching folder: " + t.getMessage());
223             }
224
225                         @Override
226                         protected void onUnauthorized(Response response) {
227                                 app.sessionExpired();
228                         }
229         };
230         getSharingUsers.setHeader("X-Auth-Token", app.getToken());
231         Scheduler.get().scheduleDeferred(getSharingUsers);
232         }
233
234         protected void fetchSharedContainers(final Iterator<String> iter, final Command callback) {
235                 if (iter.hasNext()) {
236                         String username = iter.next();
237                         if (userDataProviderMap.get(username) == null) {
238                                 userDataProviderMap.put(username, new ListDataProvider<Folder>());
239                         }
240                         final ListDataProvider<Folder> dataProvider = userDataProviderMap.get(username);
241                         fetchSharedContainers(username, dataProvider, new Command() {
242                                 
243                                 @Override
244                                 public void execute() {
245                                         fetchSharedContainers(iter, callback);
246                                         
247                                 }
248                         });
249                 }
250                 else
251                         if (callback != null)
252                                 callback.execute();
253         }
254
255         @Override
256     public boolean isLeaf(Object o) {
257                 if (o == null)
258                         return false;
259                 else if (o instanceof Folder) {
260             Folder f = (Folder) o;
261             return f.getSubfolders().isEmpty();
262         }
263                 else {
264                         if (o.equals(treeTitle))
265                                 return userLevelDataProvider.getList().isEmpty();
266                         ListDataProvider<Folder> dp = userDataProviderMap.get(o);
267                         if (dp != null)
268                                 return dp.getList().isEmpty();
269                         return true;
270                 }
271     }
272
273         private void fetchSharedContainers(final String username, final ListDataProvider<Folder> dataProvider, final Command callback) {
274                 GetRequest<AccountResource> getUserSharedContainers = new GetRequest<AccountResource>(AccountResource.class, app.getApiPath(), username, "?format=json") {
275
276                         @Override
277                         public void onSuccess(AccountResource _result) {
278                         final ListDataProvider<Folder> tempProvider = new ListDataProvider<Folder>();
279                                 Iterator<Folder> iter = _result.getContainers().iterator();
280                                 fetchFolder(username, iter, tempProvider, new Command() {
281                                         
282                                         @Override
283                                         public void execute() {
284                                                 dataProvider.getList().clear();
285                                                 dataProvider.getList().addAll(tempProvider.getList());
286                                                 if (callback != null)
287                                                         callback.execute();
288                                         }
289                                 });
290                         }
291
292                         @Override
293                         public void onError(Throwable t) {
294                 GWT.log("Error getting account", t);
295                 if (t instanceof RestException)
296                     app.displayError("Error getting account: " + ((RestException) t).getHttpStatusText());
297                 else
298                     app.displayError("System error fetching user data: " + t.getMessage());
299                         }
300
301                         @Override
302                         protected void onUnauthorized(Response response) {
303                                 app.sessionExpired();
304                         }
305                 };
306                 getUserSharedContainers.setHeader("X-Auth-Token", app.getToken());
307                 Scheduler.get().scheduleDeferred(getUserSharedContainers);
308         }
309
310         protected void fetchSharedFiles(final String username, final ListDataProvider<Folder> dataProvider) {
311                 GetRequest<AccountResource> getUserSharedContainers = new GetRequest<AccountResource>(AccountResource.class, app.getApiPath(), username, "?format=json") {
312
313                         @Override
314                         public void onSuccess(AccountResource _result) {
315                         final ListDataProvider<Folder> tempProvider = new ListDataProvider<Folder>();
316                                 Iterator<Folder> iter = _result.getContainers().iterator();
317                                 fetchFolder(username, iter, tempProvider, new Command() {
318                                         
319                                         @Override
320                                         public void execute() {
321                                                 dataProvider.getList().clear();
322                                                 dataProvider.getList().addAll(tempProvider.getList());
323                                                 app.showFiles(sharedFiles.get(username));
324                                         }
325                                 });
326                         }
327
328                         @Override
329                         public void onError(Throwable t) {
330                 GWT.log("Error getting account", t);
331                 if (t instanceof RestException)
332                     app.displayError("Error getting account: " + ((RestException) t).getHttpStatusText());
333                 else
334                     app.displayError("System error fetching user data: " + t.getMessage());
335                         }
336
337                         @Override
338                         protected void onUnauthorized(Response response) {
339                                 app.sessionExpired();
340                         }
341                 };
342                 getUserSharedContainers.setHeader("X-Auth-Token", app.getToken());
343                 Scheduler.get().scheduleDeferred(getUserSharedContainers);
344         }
345
346         protected void fetchFolder(final String username, final Iterator<Folder> iter, final ListDataProvider<Folder> dataProvider, final Command callback) {
347         if (iter.hasNext()) {
348             final Folder f = iter.next();
349
350             String path = "/" + f.getContainer() + "?format=json&delimiter=/&prefix=" + URL.encodeQueryString(f.getPrefix());
351             GetRequest<Folder> getFolder = new GetRequest<Folder>(Folder.class, app.getApiPath(), username, path, f) {
352                 @Override
353                 public void onSuccess(Folder _result) {
354                         if (!_result.isShared()) {
355                                 for (File file : _result.getFiles()) {
356                                         if (file.isShared())
357                                                 sharedFiles.get(username).add(file);
358                                 }
359                                 Iterator<Folder> iter2 = _result.getSubfolders().iterator();
360                                 fetchFolder(username, iter2, dataProvider, new Command() {
361                                                         
362                                                         @Override
363                                                         public void execute() {
364                                             fetchFolder(username, iter, dataProvider, callback);
365                                                         }
366                                                 });
367                         }
368                         else {
369                                 dataProvider.getList().add(_result);
370                             fetchFolder(username, iter, dataProvider, callback);
371                         }
372                 }
373
374                 @Override
375                 public void onError(Throwable t) {
376                     GWT.log("Error getting folder", t);
377                     if (t instanceof RestException)
378                         app.displayError("Error getting folder: " + ((RestException) t).getHttpStatusText());
379                     else
380                         app.displayError("System error fetching folder: " + t.getMessage());
381                 }
382
383                                 @Override
384                                 protected void onUnauthorized(Response response) {
385                                         app.sessionExpired();
386                                 }
387             };
388             getFolder.setHeader("X-Auth-Token", app.getToken());
389             Scheduler.get().scheduleDeferred(getFolder);
390         }
391         else if (callback != null)
392             callback.execute();
393     }
394
395     public Folder getSelection() {
396         return selectionModel.getSelectedObject();
397     }
398
399     public void updateFolder(Folder folder, boolean showfiles) {
400         if (dataProviderMap.get(folder) == null) {
401             dataProviderMap.put(folder, new ListDataProvider<Folder>());
402         }
403         final ListDataProvider<Folder> dataProvider = dataProviderMap.get(folder);
404         fetchFolder(folder, dataProvider, showfiles);
405     }
406
407     public void fetchFolder(final Folder f, final ListDataProvider<Folder> dataProvider, final boolean showfiles) {
408         String path = "/" + f.getContainer() + "?format=json&delimiter=/&prefix=" + URL.encodeQueryString(f.getPrefix());
409         GetRequest<Folder> getFolder = new GetRequest<Folder>(Folder.class, app.getApiPath(), f.getOwner(), path, f) {
410             @Override
411             public void onSuccess(final Folder _result) {
412                 if (showfiles)
413                     app.showFiles(_result);
414                 Iterator<Folder> iter = _result.getSubfolders().iterator();
415                 fetchFolder(_result.getOwner(), iter, dataProvider, new Command() {
416                     @Override
417                     public void execute() {
418                         dataProvider.getList().clear();
419                         dataProvider.getList().addAll(_result.getSubfolders());
420                         app.getOtherSharedTreeView().updateChildren(f);
421                     }
422                 });
423             }
424
425             @Override
426             public void onError(Throwable t) {
427                 GWT.log("Error getting folder", t);
428                 if (t instanceof RestException)
429                     app.displayError("Error getting folder: " + ((RestException) t).getHttpStatusText());
430                 else
431                     app.displayError("System error fetching folder: " + t.getMessage());
432             }
433
434                         @Override
435                         protected void onUnauthorized(Response response) {
436                                 app.sessionExpired();
437                         }
438         };
439         getFolder.setHeader("X-Auth-Token", app.getToken());
440         Scheduler.get().scheduleDeferred(getFolder);
441     }
442     
443     public void initialize(Command callback) {
444         fetchSharingUsers(callback);
445     }
446 }