statistical-algorithms-importer/src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/client/project/ProjectManager.java

package org.gcube.portlets.user.statisticalalgorithmsimporter.client.project;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.gcube.portlets.user.statisticalalgorithmsimporter.client.event.ProjectStatusEvent;
import org.gcube.portlets.user.statisticalalgorithmsimporter.client.event.SessionExpiredEvent;
import org.gcube.portlets.user.statisticalalgorithmsimporter.client.rpc.StatAlgoImporterServiceAsync;
import org.gcube.portlets.user.statisticalalgorithmsimporter.client.type.ProjectStatusEventType;
import org.gcube.portlets.user.statisticalalgorithmsimporter.client.type.SessionExpiredType;
import org.gcube.portlets.user.statisticalalgorithmsimporter.client.utils.UtilsGXT3;
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.exception.StatAlgoImporterSessionExpiredException;
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.project.InputVariables;
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.workspace.ItemDescription;
import org.gcube.portlets.widgets.wsexplorer.client.notification.WorkspaceExplorerSelectNotification.WorskpaceExplorerSelectNotificationListener;
import org.gcube.portlets.widgets.wsexplorer.client.select.WorkspaceExplorerSelectDialog;
import org.gcube.portlets.widgets.wsexplorer.shared.Item;
import org.gcube.portlets.widgets.wsexplorer.shared.ItemType;

import com.allen_sauer.gwt.log.client.Log;
import com.google.gwt.event.shared.EventBus;
import com.google.gwt.user.client.rpc.AsyncCallback;
import com.sencha.gxt.core.client.dom.XDOM;

/**
 * 
 * @author Giancarlo Panichi email: <a
 *         href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
 *
 */
public class ProjectManager {
	private EventBus eventBus;
	private ItemDescription projectFolder;
	@SuppressWarnings("unused")
	private ItemDescription mainCodeDescription;

	public ProjectManager(EventBus eventBus) {
		this.eventBus = eventBus;
	}

	public void createProject() {

		WorkspaceExplorerSelectDialog wselectDialog = new WorkspaceExplorerSelectDialog(
				"Select Project Folder", true);

		WorskpaceExplorerSelectNotificationListener handler = new WorskpaceExplorerSelectNotificationListener() {

			@Override
			public void onSelectedItem(Item item) {

				if (item.getType() == ItemType.FOLDER) {
					createProjectOnServer(item);

				} else {
					UtilsGXT3.info("Attention",
							"Select a valid project folder!");
				}

			}

			@Override
			public void onFailed(Throwable throwable) {
				Log.error("Error in create project: "
						+ throwable.getLocalizedMessage());
				UtilsGXT3.alert("Error", throwable.getLocalizedMessage());
				throwable.printStackTrace();
			}

			@Override
			public void onAborted() {

			}

			@Override
			public void onNotValidSelection() {
				UtilsGXT3.info("Attention", "Select a valid project folder!");
			}
		};

		wselectDialog.addWorkspaceExplorerSelectNotificationListener(handler);
		wselectDialog.setZIndex(XDOM.getTopZIndex());
		wselectDialog.show();
	}

	public void addResource() {
		List<ItemType> selectableTypes = new ArrayList<ItemType>();
		selectableTypes.add(ItemType.EXTERNAL_FILE);
		selectableTypes.add(ItemType.EXTERNAL_IMAGE);
		selectableTypes.add(ItemType.IMAGE_DOCUMENT);
		selectableTypes.add(ItemType.DOCUMENT);
		selectableTypes.add(ItemType.PDF_DOCUMENT);

		List<ItemType> showableTypes = new ArrayList<ItemType>();
		showableTypes.addAll(Arrays.asList(ItemType.values()));

		WorkspaceExplorerSelectDialog wselectDialog = new WorkspaceExplorerSelectDialog(
				"Select a Resource", selectableTypes, showableTypes);

		WorskpaceExplorerSelectNotificationListener handler = new WorskpaceExplorerSelectNotificationListener() {

			@Override
			public void onSelectedItem(Item item) {
				if (item.getType() == ItemType.EXTERNAL_FILE
						|| item.getType() == ItemType.EXTERNAL_IMAGE
						|| item.getType() == ItemType.IMAGE_DOCUMENT
						|| item.getType() == ItemType.DOCUMENT
						|| item.getType() == ItemType.PDF_DOCUMENT) {
					String filename = item.getName();
					if (filename != null && !filename.isEmpty()) {
						addResourceToProject(item);
					} else {
						UtilsGXT3.info("Attention", "Select a valid resource!");
					}

				} else {
					UtilsGXT3.info("Attention", "Select a valid resource!");
				}

			}

			@Override
			public void onFailed(Throwable throwable) {
				Log.error("Error in add resource: "
						+ throwable.getLocalizedMessage());
				UtilsGXT3.alert("Error", throwable.getLocalizedMessage());
				throwable.printStackTrace();
			}

			@Override
			public void onAborted() {

			}

			@Override
			public void onNotValidSelection() {
				UtilsGXT3.info("Attention", "Select a valid resource!");
			}
		};

		wselectDialog.addWorkspaceExplorerSelectNotificationListener(handler);
		wselectDialog.setZIndex(XDOM.getTopZIndex());
		wselectDialog.show();
	}

	protected void addResourceToProject(Item item) {
		Log.debug("Add Resource To Project Item selected: " + item);
		ItemDescription itemDescription = new ItemDescription(item.getId(),
				item.getName(), item.getOwner(), item.getPath(), item.getType()
						.name());
		StatAlgoImporterServiceAsync.INSTANCE.addResourceToProject(
				itemDescription, new AsyncCallback<Void>() {

					@Override
					public void onSuccess(Void result) {
						fireProjectStatusAddResourceEvent();
					}

					@Override
					public void onFailure(Throwable caught) {
						if (caught instanceof StatAlgoImporterSessionExpiredException) {
							eventBus.fireEvent(new SessionExpiredEvent(
									SessionExpiredType.EXPIREDONSERVER));
						} else {
							Log.error("Error in add resource to project: "
									+ caught.getLocalizedMessage());
							UtilsGXT3.alert("Error",
									caught.getLocalizedMessage());
						}
						caught.printStackTrace();

					}
				});

	}

	protected void createProjectOnServer(Item item) {
		Log.debug("Create Project Item selected: " + item);
		projectFolder = new ItemDescription(item.getId(), item.getName(),
				item.getOwner(), item.getPath(), item.getType().name());
		StatAlgoImporterServiceAsync.INSTANCE.createProjectOnWorkspace(
				projectFolder, new AsyncCallback<Void>() {

					@Override
					public void onSuccess(Void result) {
						fireProjectStatusOpenEvent();

					}

					@Override
					public void onFailure(Throwable caught) {
						if (caught instanceof StatAlgoImporterSessionExpiredException) {
							eventBus.fireEvent(new SessionExpiredEvent(
									SessionExpiredType.EXPIREDONSERVER));
						} else {
							Log.error("Error in create project: "
									+ caught.getLocalizedMessage());
							UtilsGXT3.alert("Error",
									caught.getLocalizedMessage());
						}
						caught.printStackTrace();

					}
				});
	}

	public void saveProject(InputVariables inputVariables) {
		Log.debug("Save Project: " + inputVariables);

		StatAlgoImporterServiceAsync.INSTANCE.saveProject(inputVariables,
				new AsyncCallback<Void>() {

					@Override
					public void onSuccess(Void result) {
						UtilsGXT3.info("Save",
								"Project saved!");
					}

					@Override
					public void onFailure(Throwable caught) {
						if (caught instanceof StatAlgoImporterSessionExpiredException) {
							eventBus.fireEvent(new SessionExpiredEvent(
									SessionExpiredType.EXPIREDONSERVER));
						} else {
							Log.error("Error on save project: "
									+ caught.getLocalizedMessage());
							UtilsGXT3.alert("Error",
									caught.getLocalizedMessage());
						}
						caught.printStackTrace();

					}
				});
	}

	public void setMainCode(ItemDescription itemDescription) {
		this.mainCodeDescription = itemDescription;
		Log.debug("Set Main Code: " + itemDescription);
		StatAlgoImporterServiceAsync.INSTANCE.setMainCode(itemDescription,
				new AsyncCallback<Void>() {

					@Override
					public void onFailure(Throwable caught) {
						if (caught instanceof StatAlgoImporterSessionExpiredException) {
							eventBus.fireEvent(new SessionExpiredEvent(
									SessionExpiredType.EXPIREDONSERVER));
						} else {
							Log.error("Error setting main code: "
									+ caught.getLocalizedMessage());
							UtilsGXT3.alert("Error",
									caught.getLocalizedMessage());
						}
						caught.printStackTrace();

					}

					@Override
					public void onSuccess(Void result) {
						fireProjectStatusUpdateEvent();
					}
				});

	}

	public void deleteItem(ItemDescription itemDescription) {
		StatAlgoImporterServiceAsync.INSTANCE.deleteResourceOnProject(itemDescription,
				new AsyncCallback<Void>() {

					@Override
					public void onFailure(Throwable caught) {
						if (caught instanceof StatAlgoImporterSessionExpiredException) {
							eventBus.fireEvent(new SessionExpiredEvent(
									SessionExpiredType.EXPIREDONSERVER));
						} else {
							Log.error("Error deleting resourse: "
									+ caught.getLocalizedMessage());
							UtilsGXT3.alert("Error",
									caught.getLocalizedMessage());
						}
						caught.printStackTrace();

					}

					@Override
					public void onSuccess(Void result) {
						fireProjectStatusDeleteEvent();
					}
				});

	}

	

	protected void fireProjectStatusOpenEvent() {
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.OPEN, projectFolder);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired! "+projectStatusEvent);

	}
	
	protected void fireProjectStatusSaveProjectEvent() {
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.SAVE, projectFolder);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired! "+projectStatusEvent);
	}
	

	protected void fireProjectStatusAddResourceEvent() {
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.ADD_RESOURCE, projectFolder);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired! "+projectStatusEvent);
	}
	
	protected void fireProjectStatusDeleteEvent() {
		// TODO Auto-generated method stub
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.DELETE_RESOURCE, projectFolder);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired! "+projectStatusEvent);
	}
	
	protected void fireProjectStatusUpdateEvent() {
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.UPDATE, projectFolder);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired! "+projectStatusEvent);
	}

}