Fixed bug in restore-from-trash where very deep trees were not restored
[pithos-web-client] / src / gr / grnet / pithos / web / client / commands / ToTrashCommand.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 package gr.grnet.pithos.web.client.commands;
36
37 import gr.grnet.pithos.web.client.Pithos;
38 import gr.grnet.pithos.web.client.foldertree.File;
39 import gr.grnet.pithos.web.client.foldertree.Folder;
40 import gr.grnet.pithos.web.client.foldertree.Resource;
41 import gr.grnet.pithos.web.client.rest.DeleteRequest;
42 import gr.grnet.pithos.web.client.rest.GetRequest;
43 import gr.grnet.pithos.web.client.rest.PutRequest;
44 import gr.grnet.pithos.web.client.rest.RestException;
45
46 import java.util.Iterator;
47 import java.util.List;
48
49 import com.google.gwt.core.client.GWT;
50 import com.google.gwt.core.client.Scheduler;
51 import com.google.gwt.http.client.Response;
52 import com.google.gwt.http.client.URL;
53 import com.google.gwt.user.client.Command;
54 import com.google.gwt.user.client.ui.PopupPanel;
55
56 /**
57  *
58  * Move file or folder to trash.
59  *
60  *
61  */
62 public class ToTrashCommand implements Command{
63         private PopupPanel containerPanel;
64         protected Pithos app;
65         protected Object resource;
66
67         public ToTrashCommand(Pithos _app, PopupPanel _containerPanel, Object _resource){
68                 containerPanel = _containerPanel;
69         app = _app;
70         resource = _resource;
71         }
72
73         @Override
74         public void execute() {
75         if (containerPanel != null)
76                 containerPanel.hide();
77         if (resource instanceof List) {
78             @SuppressWarnings("unchecked")
79                         Iterator<File> iter = ((List<File>) resource).iterator();
80             trashFiles(iter, new Command() {
81                 @SuppressWarnings("unchecked")
82                                 @Override
83                 public void execute() {
84                     app.updateFolder(((List<File>) resource).get(0).getParent(), true, null);
85                 }
86             });
87         }
88         else if (resource instanceof Folder) {
89             final Folder toBeTrashed = (Folder) resource;
90             trashFolder(toBeTrashed, new Command() {
91                 @Override
92                 public void execute() {
93                     app.updateFolder(toBeTrashed.getParent(), true, null);
94                 }
95             });
96
97         }
98         }
99
100     private void trashFolder(final Folder f, final Command callback) {
101         String path = "/" + Pithos.TRASH_CONTAINER + "/" + f.getPrefix();
102         PutRequest createFolder = new PutRequest(app.getApiPath(), app.getUsername(), path) {
103             @Override
104             public void onSuccess(@SuppressWarnings("unused") Resource result) {
105                 GetRequest<Folder> getFolder = new GetRequest<Folder>(Folder.class, app.getApiPath(), f.getOwner(), "/" + f.getContainer() + "?format=json&delimiter=/&prefix=" + URL.encodeQueryString(f.getPrefix()), f) {
106
107                                         @Override
108                                         public void onSuccess(final Folder _f) {
109                                             Iterator<File> iter = _f.getFiles().iterator();
110                                             trashFiles(iter, new Command() {
111                                                 @Override
112                                                 public void execute() {
113                                                     Iterator<Folder> iterf = _f.getSubfolders().iterator();
114                                                     trashSubfolders(iterf, new Command() {
115                                                                         
116                                                                         @Override
117                                                                         public void execute() {
118                                                                                 DeleteRequest deleteFolder = new DeleteRequest(app.getApiPath(), _f.getOwner(), _f.getUri()) {
119                                                                                         
120                                                                                         @Override
121                                                                                         public void onSuccess(@SuppressWarnings("unused") Resource _result) {
122                                                                                                 if (callback != null)
123                                                                                                         callback.execute();
124                                                                                         }
125                                                                                         
126                                                                                         @Override
127                                                                                         public void onError(Throwable t) {
128                                                                             GWT.log("", t);
129                                                                             if (t instanceof RestException) {
130                                                                                 if (((RestException) t).getHttpStatusCode() == Response.SC_NOT_FOUND)
131                                                                                         onSuccess(null);
132                                                                                 else
133                                                                                         app.displayError("Unable to delete folder: " + ((RestException) t).getHttpStatusText());
134                                                                             }
135                                                                             else
136                                                                                 app.displayError("System error unable to delete folder: "+t.getMessage());
137                                                                                         }
138
139                                                                                         @Override
140                                                                                         protected void onUnauthorized(Response response) {
141                                                                                                 app.sessionExpired();
142                                                                                         }
143                                                                                 };
144                                                                                 deleteFolder.setHeader("X-Auth-Token", app.getToken());
145                                                                                 Scheduler.get().scheduleDeferred(deleteFolder);
146                                                                         }
147                                                                 });
148                                                 }
149                                             });
150                                         }
151
152                                         @Override
153                                         public void onError(Throwable t) {
154                                 GWT.log("", t);
155                                 if (t instanceof RestException) {
156                                     app.displayError("Unable to get folder: " + ((RestException) t).getHttpStatusText());
157                                 }
158                                 else
159                                     app.displayError("System error getting folder: " + t.getMessage());
160                                         }
161
162                                         @Override
163                                         protected void onUnauthorized(Response response) {
164                                                 app.sessionExpired();
165                                         }
166                                 };
167                                 getFolder.setHeader("X-Auth-Token", app.getToken());
168                                 Scheduler.get().scheduleDeferred(getFolder);
169             }
170
171             @Override
172             public void onError(Throwable t) {
173                 GWT.log("", t);
174                 if (t instanceof RestException) {
175                     app.displayError("Unable to create folder:" + ((RestException) t).getHttpStatusText());
176                 }
177                 else
178                     app.displayError("System error creating folder:" + t.getMessage());
179             }
180
181                         @Override
182                         protected void onUnauthorized(Response response) {
183                                 app.sessionExpired();
184                         }
185         };
186         createFolder.setHeader("X-Auth-Token", app.getToken());
187         createFolder.setHeader("Accept", "*/*");
188         createFolder.setHeader("Content-Length", "0");
189         createFolder.setHeader("Content-Type", "application/folder");
190         Scheduler.get().scheduleDeferred(createFolder);
191     }
192
193
194     
195     protected void trashFiles(final Iterator<File> iter, final Command callback) {
196         if (iter.hasNext()) {
197             File file = iter.next();
198             String path = "/" + Pithos.TRASH_CONTAINER + "/" + file.getPath();
199             PutRequest trashFile = new PutRequest(app.getApiPath(), app.getUsername(), path) {
200                 @Override
201                 public void onSuccess(@SuppressWarnings("unused") Resource result) {
202                     trashFiles(iter, callback);
203                 }
204
205                 @Override
206                 public void onError(Throwable t) {
207                     GWT.log("", t);
208                     if (t instanceof RestException) {
209                         app.displayError("Unable to copy file: " + ((RestException) t).getHttpStatusText());
210                     }
211                     else
212                         app.displayError("System error unable to copy file: "+t.getMessage());
213                 }
214
215                                 @Override
216                                 protected void onUnauthorized(Response response) {
217                                         app.sessionExpired();
218                                 }
219             };
220             trashFile.setHeader("X-Auth-Token", app.getToken());
221             trashFile.setHeader("X-Move-From", file.getUri());
222             Scheduler.get().scheduleDeferred(trashFile);
223         }
224         else if (callback != null) {
225             callback.execute();
226         }
227     }
228
229     protected void trashSubfolders(final Iterator<Folder> iter, final Command callback) {
230         if (iter.hasNext()) {
231             final Folder f = iter.next();
232             trashFolder(f, new Command() {
233                                 
234                                 @Override
235                                 public void execute() {
236                                         trashSubfolders(iter, callback);
237                                 }
238                         });
239         }
240         else  {
241                 app.updateTrash(false, callback);
242         }
243     }
244 }