117 lines
3.1 KiB
Java
117 lines
3.1 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.portlets.user.td.codelistmappingimportwidget.client.progress;
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import org.gcube.portlets.user.td.gwtservice.client.rpc.TDGWTServiceAsync;
|
|
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
|
|
|
import com.allen_sauer.gwt.log.client.Log;
|
|
import com.google.gwt.core.client.GWT;
|
|
import com.google.gwt.user.client.Timer;
|
|
import com.google.gwt.user.client.rpc.AsyncCallback;
|
|
|
|
/**
|
|
*
|
|
* @author Giancarlo Panichi
|
|
*
|
|
*
|
|
*/
|
|
public class FileUploadProgressUpdater extends Timer {
|
|
|
|
private ArrayList<FileUploadProgressListener> listeners = new ArrayList<FileUploadProgressListener>();
|
|
private static FileUploadProgressMessages msgs = GWT
|
|
.create(FileUploadProgressMessages.class);
|
|
|
|
|
|
@Override
|
|
public void run() {
|
|
Log.debug("requesting operation progress");
|
|
TDGWTServiceAsync.INSTANCE
|
|
.getFileUploadMonitor(new AsyncCallback<FileUploadMonitor>() {
|
|
|
|
public void onFailure(Throwable caught) {
|
|
cancel();
|
|
Log.error("Error retrieving the operation state",
|
|
caught);
|
|
String message = getStack(caught);
|
|
fireOperationFailed(caught,
|
|
msgs.failedGettingOperarionUpdateds(), message);
|
|
}
|
|
|
|
public void onSuccess(FileUploadMonitor result) {
|
|
Log.info("retrieved FileUploadMonitor: "
|
|
+ result.getState());
|
|
switch (result.getState()) {
|
|
case STARTED:
|
|
Log.debug("File Upload Started");
|
|
break;
|
|
case INPROGRESS:
|
|
Log.debug("Progress: "
|
|
+ result.getElaboratedLenght() + " of "
|
|
+ result.getTotalLenght());
|
|
fireOperationUpdate(result.getPercentDone());
|
|
break;
|
|
case FAILED:
|
|
Log.debug("File Upload Failed");
|
|
cancel();
|
|
fireOperationFailed(
|
|
new Throwable(msgs.fileUploadFailedHead()),
|
|
result.getFailureReason(),
|
|
result.getFailureDetails());
|
|
break;
|
|
case COMPLETED:
|
|
cancel();
|
|
Log.debug("File Upload Completed");
|
|
fireOperationComplete();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
protected String getStack(Throwable e) {
|
|
String message = e.getLocalizedMessage() + " -> <br>";
|
|
Throwable c = e.getCause();
|
|
if (c != null)
|
|
message += getStack(c);
|
|
return message;
|
|
}
|
|
|
|
protected void fireOperationInitializing() {
|
|
for (FileUploadProgressListener listener : listeners)
|
|
listener.operationInitializing();
|
|
}
|
|
|
|
protected void fireOperationUpdate(float elaborated) {
|
|
for (FileUploadProgressListener listener : listeners)
|
|
listener.operationUpdate(elaborated);
|
|
}
|
|
|
|
protected void fireOperationComplete() {
|
|
for (FileUploadProgressListener listener : listeners)
|
|
listener.operationComplete();
|
|
}
|
|
|
|
protected void fireOperationFailed(Throwable caught, String failure,
|
|
String failureDetails) {
|
|
for (FileUploadProgressListener listener : listeners)
|
|
listener.operationFailed(caught, failure, failureDetails);
|
|
}
|
|
|
|
public void addListener(FileUploadProgressListener listener) {
|
|
listeners.add(listener);
|
|
}
|
|
|
|
public void removeListener(FileUploadProgressListener listener) {
|
|
listeners.remove(listener);
|
|
}
|
|
}
|