tabular-data-monitor-widget/src/main/java/org/gcube/portlets/user/td/monitorwidget/client/MonitorUpdater.java

package org.gcube.portlets.user.td.monitorwidget.client;

import java.util.ArrayList;

import org.gcube.portlets.user.td.gwtservice.client.rpc.TDGWTServiceAsync;
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitor;
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitorSession;
import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;

import com.allen_sauer.gwt.log.client.Log;
import com.google.gwt.user.client.Timer;
import com.google.gwt.user.client.rpc.AsyncCallback;


/**
 * 
 * @author "Giancarlo Panichi" 
 * <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a> 
 *
 */
public class MonitorUpdater extends Timer implements MonitorUpdaterListener {
	
	protected ArrayList<MonitorListener> listeners = new ArrayList<MonitorListener>();
	protected OperationMonitorSession operationMonitorSession;
	
	public MonitorUpdater(OperationMonitorSession operationMonitorSession){
		this.operationMonitorSession=operationMonitorSession;
	}
	
	/**
	 * {@inheritDoc}
	 */
	@Override
	public void run() {
		Log.debug("requesting operation progress");
		TDGWTServiceAsync.INSTANCE
				.getOperationMonitor(operationMonitorSession,new AsyncCallback<OperationMonitor>() {

					
					public void onFailure(Throwable caught) {
						cancel();
						Log.error("Error retrieving the operation state",
								caught);
						String message = getStack(caught);
						fireOperationFailed(caught,
								"Failed getting operation updates", message);
					}

					public void onSuccess(OperationMonitor result) {
						Log.info("retrieved OperationMonitor: "
								+ result.getTask().getState());
						switch (result.getTask().getState()) {
						case INITIALIZING:
							Log.info("Initializing...");
							fireOperationInitializing();
							break;
						case ABORTED:
							cancel();
							Log.info("Aborted");
							break;
						case IN_PROGRESS:
							fireOperationUpdate(result.getTask().getProgress());
							break;
						case VALIDATING_RULES:
							fireOperationValidate(result.getTask().getProgress());
							break;	
						case GENERATING_VIEW:
							Log.info("Generating View...");
							fireOperationGeneratingView();
							break;		
						case STOPPED:
							cancel();
							stopMessage(result);
							break;		
						case FAILED:
							cancel();
							errorMessage(result);
							break;
						case SUCCEDED:
							cancel();
							Log.info("Fisnish :"
									+ result.getTrId());
							fireOperationComplete(result.getTrId());
							break;
						default:
							Log.info("Unknow State");
							break;
						}

					}

					

				});

	}

	protected void errorMessage(OperationMonitor result) {
		Log.info("Opration Failed");
		Throwable th;
		String failure = null;
		String details = null;
		if (result.getTask().getErrorCause() != null) {
			th = result.getTask().getErrorCause();
			failure = "Failed Client Library";
			details = result.getTask().getErrorCause().getLocalizedMessage();
		} else {
			th = new Throwable("Failed");
			failure = "Failed Client Library";
			details = "Operation failed";
		}
		
		fireOperationFailed(th, failure, details);
	}
	
	protected void stopMessage(OperationMonitor result) {
		Log.info("Operation Stopped");
		String failure = null;
		String details = null;
		if (result.getTask().getErrorCause() != null) {	
			failure = "Stopped Operation";
			details = result.getTask().getErrorCause().getLocalizedMessage();
		} else {
			failure = "Stopped Operation";
			details = "Operation stopped";
		}
	
		fireOperationStopped(result.getTrId(),failure, details);
	}
	

	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 (MonitorListener listener : listeners)
			listener.operationInitializing();
	}
	
	protected void fireOperationGeneratingView() {
		for (MonitorListener listener : listeners)
			listener.operationGeneratingView();
	}

	protected void fireOperationUpdate(float elaborated) {
		for (MonitorListener listener : listeners)
			listener.operationUpdate(elaborated);
	}
	
	protected void fireOperationValidate(float elaborated) {
		for (MonitorListener listener : listeners)
			listener.operationValidate(elaborated);
	}

	protected void fireOperationComplete(TRId trId) {
		for (MonitorListener listener : listeners)
			listener.operationComplete(trId);
	}

	protected void fireOperationFailed(Throwable caught, String failure,
			String failureDetails) {
		for (MonitorListener listener : listeners)
			listener.operationFailed(caught, failure, failureDetails);
	}

	protected void fireOperationStopped(TRId trId, String reason, String details) {
		for (MonitorListener listener : listeners)
			listener.operationStopped(trId,reason, details);
	}
	
	
	/**
	 * Add a new {@link MonitorListener} to this
	 * {@link AddColumnProgressUpdater}.
	 * 
	 * @param listener
	 *            the listener to add.
	 */
	public void addListener(MonitorListener listener) {
		listeners.add(listener);
	}

	/**
	 * Removes the specified {@link MonitorListener} from this
	 * {@link AddColumnProgressUpdater}.
	 * 
	 * @param listener
	 *            the listener to remove.
	 */
	public void removeListener(MonitorListener listener) {
		listeners.remove(listener);
	}




	@Override
	public void operationAborted() {
		// TODO Auto-generated method stub
		
	}


	@Override
	public void operationPutInBackground() {
		// TODO Auto-generated method stub
		
	}
}