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

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

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.maindata.ItemDescription;
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.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 String projectFolderId;
	@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) {
				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();
	}

	protected void createProjectOnServer(Item item) {
		Log.debug("Item selected: " + item);
		projectFolderId = item.getId();
		StatAlgoImporterServiceAsync.INSTANCE.createProjectOnWorkspace(
				item.getId(), new AsyncCallback<Void>() {

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

					}

					@Override
					public void onFailure(Throwable caught) {
						Log.debug(caught.getLocalizedMessage());
						caught.printStackTrace();

					}
				});
	}

	public void setMainCode(ItemDescription mainCodeDescription) {
		this.mainCodeDescription = mainCodeDescription;
		Log.debug("Main: " + mainCodeDescription);
		StatAlgoImporterServiceAsync.INSTANCE.setMainCode(
				mainCodeDescription.getId(), 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) {
						fireProjectStatusEventUpdate();
					}
				});

	}

	public void deleteItem(ItemDescription itemDescription) {
		
	}

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

	}

	protected void fireProjectStatusEventUpdate() {
		ProjectStatusEvent projectStatusEvent = new ProjectStatusEvent(
				ProjectStatusEventType.UPDATE, projectFolderId);
		eventBus.fireEvent(projectStatusEvent);
		Log.debug("ProjectStatusEvent fired");
	}

}