EDIT

// $Id$

/**

* Copyright (C) 2007 EDIT

* European Distributed Institute of Taxonomy 

* http://www.e-taxonomy.eu

* 

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.taxeditor.io;

import org.apache.log4j.Logger;

import org.eclipse.core.runtime.Assert;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.core.runtime.jobs.Job;

import org.eclipse.swt.widgets.Display;

import org.eclipse.ui.IWorkbenchPart;

import eu.etaxonomy.cdm.api.application.CdmApplicationController;

import eu.etaxonomy.cdm.api.conversation.IConversationEnabled;

import eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportConfigurator;

import eu.etaxonomy.cdm.io.common.CdmDefaultImport;

import eu.etaxonomy.cdm.io.common.IImportConfigurator;

import eu.etaxonomy.cdm.io.excel.taxa.NormalExplicitImportConfigurator;

import eu.etaxonomy.cdm.io.jaxb.JaxbImportConfigurator;

import eu.etaxonomy.cdm.io.reference.endnote.in.EndnoteImportConfigurator;

import eu.etaxonomy.cdm.io.sdd.in.SDDImportConfigurator;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportConfigurator;

import eu.etaxonomy.cdm.io.tcsxml.in.TcsXmlImportConfigurator;

import eu.etaxonomy.taxeditor.model.CdmProgressMonitorAdapter;

import eu.etaxonomy.taxeditor.store.StoreUtil;

/**

 * <p>ImportHandler class.</p>

 *

 * @author n.hoffmann

 * @created Sep 11, 2009

 * @version 1.0

 */

public class ImportHandler extends AbstractIOHandler<IImportConfigurator> {

	private static final Logger logger = Logger

			.getLogger(ImportHandler.class);

	/**

	 * @param applicationController

	 */

	private ImportHandler(

			CdmApplicationController applicationController) {

		super(applicationController);

	}

	/**

	 * <p>NewInstance</p>

	 *

	 * @param applicationController a {@link eu.etaxonomy.cdm.api.application.CdmApplicationController} object.

	 * @return a {@link eu.etaxonomy.taxeditor.io.ImportHandler} object.

	 */

	public static ImportHandler NewInstance(CdmApplicationController applicationController){

		return new ImportHandler(applicationController);

	}

	/**

	 * Use when importing data into the current application context

	 *

	 * @param configurator a {@link eu.etaxonomy.cdm.io.common.IImportConfigurator} object.

	 * @return a {@link org.eclipse.core.runtime.jobs.Job} object.

	 */

	protected Job createIOJob(final IImportConfigurator configurator){

		Assert.isNotNull(configurator, "Configuration may not be null");

		final Display display = Display.getDefault();

		Job job = new Job("Import: " + configurator.getClass().getSimpleName()){

			@Override

			protected IStatus run(IProgressMonitor monitor) {

				monitor.beginTask("Importing data", 100);

				configurator.setProgressMonitor(CdmProgressMonitorAdapter.CreateMonitor(monitor));

				monitor.worked(10);

				display.asyncExec(new Runnable() {

					@Override

					public void run() {

						// terminate any open transactions

						IWorkbenchPart activePart = StoreUtil.getActivePage().getActivePart();

						if(activePart instanceof IConversationEnabled){

							IConversationEnabled conversationEnabled = (IConversationEnabled) activePart;

							conversationEnabled.getConversationHolder().commit(false);

						}

					}

				});

				monitor.worked(10);

				CdmDefaultImport<IImportConfigurator> importer = new CdmDefaultImport<IImportConfigurator>();

				importer.setCdmAppController(applicationController);

				monitor.worked(10);		

				try{

					importer.invoke(configurator);

					monitor.worked(60);

				}catch(RuntimeException e){

					StoreUtil.errorDialog("Error importing data", this, "An error occured while" +

							"importing from source '" + configurator.getSourceNameString() + "'.\n" +

									"Please check error log for details.", e);

				}

				display.asyncExec(new Runnable() {

					@Override

					public void run() {

						// restarting transaction and committing it to trigger change listener

						// TODO verify correct behaviour

						IWorkbenchPart activePart = StoreUtil.getActivePage().getActivePart();

						if(activePart instanceof IConversationEnabled){

							IConversationEnabled conversationEnabled = (IConversationEnabled) activePart;

							conversationEnabled.getConversationHolder().startTransaction();

							conversationEnabled.getConversationHolder().commit();

						}

					}

				});

				monitor.worked(10);

				return Status.OK_STATUS;

			}

		};

		return job;

	}

	private IImportConfigurator getConfigurator(TYPE type){

		Assert.isNotNull(type, "Type should not be null");

		switch(type){

			case BerlinModel:

				return BerlinModelImportConfigurator.NewInstance(null, null);	

			case Jaxb:

				return JaxbImportConfigurator.NewInstance(null, null);

			case Tcs:

				return TcsXmlImportConfigurator.NewInstance(null, null);

			case Endnote:

				return EndnoteImportConfigurator.NewInstance(null, null);

			case Excel_Taxa:

				return NormalExplicitImportConfigurator.NewInstance(null, null, null);

			case Abcd:

				return Abcd206ImportConfigurator.NewInstance(null, null);

			case Sdd:

				return SDDImportConfigurator.NewInstance(null, null);

			default:

				StoreUtil.notImplementedMessage(this);

				throw new IllegalArgumentException("Import not supported yet");

		}

	}

	/**

	 * <p>BerlinModelConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportConfigurator} object.

	 */

	public final BerlinModelImportConfigurator BerlinModelConfigurator() { return (BerlinModelImportConfigurator) getConfigurator(TYPE.BerlinModel);	}

	/**

	 * <p>JaxbConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.jaxb.JaxbImportConfigurator} object.

	 */

	public final JaxbImportConfigurator JaxbConfigurator() { return (JaxbImportConfigurator) getConfigurator(TYPE.Jaxb);	}

	/**

	 * <p>TcsConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.tcsxml.in.TcsXmlImportConfigurator} object.

	 */

	public final TcsXmlImportConfigurator TcsConfigurator() { return (TcsXmlImportConfigurator) getConfigurator(TYPE.Tcs);	}

	/**

	 * <p>EndnoteConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.reference.endnote.in.EndnoteImportConfigurator} object.

	 */

	public final EndnoteImportConfigurator EndnoteConfigurator() { return (EndnoteImportConfigurator) getConfigurator(TYPE.Endnote);   }

	/**

	 * <p>NormalExplicitConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.excel.taxa.NormalExplicitImportConfigurator} object.

	 */

	public final NormalExplicitImportConfigurator NormalExplicitConfigurator() { return (NormalExplicitImportConfigurator) getConfigurator(TYPE.Excel_Taxa); }

	/**

	 * <p>SddConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.sdd.in.SDDImportConfigurator} object.

	 */

	public final SDDImportConfigurator SddConfigurator() { return (SDDImportConfigurator) getConfigurator(TYPE.Sdd); }

	/**

	 * <p>AbcdConfigurator</p>

	 *

	 * @return a {@link eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportConfigurator} object.

	 */

	public final Abcd206ImportConfigurator AbcdConfigurator() { return (Abcd206ImportConfigurator) getConfigurator(TYPE.Abcd); }

}