EDIT

/**

* Copyright (C) 2017 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.wizard;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.io.IOUtils;

import org.apache.log4j.Logger;

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

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.ui.IWorkbench;

import eu.etaxonomy.cdm.common.URI;

import eu.etaxonomy.cdm.database.DbSchemaValidation;

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

import eu.etaxonomy.cdm.io.reference.ris.in.RisReferenceImportConfigurator;

import eu.etaxonomy.taxeditor.store.CdmStore;

/**

 * @author k.luther

 * @date 12.05.2017

 */

public class RISImportWizard extends AbstractImportWizard<RisReferenceImportConfigurator>{

    private RisReferenceImportConfigurator configurator;

    private ImportFromFileDataSourceWizardPage dataSourcePage;

    private static final Logger logger = Logger.getLogger(ExcelDistributionUpdateWizard.class);

    @Override

    public RisReferenceImportConfigurator getConfigurator() {

        return configurator;

    }

    @Override

    public boolean performFinish() {

        URI source = dataSourcePage.getUri();

       // configurator.setSource(source);

//        try {

//            configurator = RisReferenceImportConfigurator.NewInstance(source, null);

//        } catch (MalformedURLException e1) {

//            // TODO Auto-generated catch block

//            e1.printStackTrace();

//        } catch (IOException e1) {

//            // TODO Auto-generated catch block

//            e1.printStackTrace();

//        }

        configurator.setDbSchemaValidation(DbSchemaValidation.CREATE);

        File file = source.toFile();

       FileInputStream fis;

        try {

            fis = new FileInputStream(file);

            byte[] data;

            data = IOUtils.toByteArray(fis);

            configurator.setStream(data);

//TODO: workaround, needs to be changed to source as byte array

            Job job = CdmStore.getImportManager().createIOServiceJob(configurator, data, SOURCE_TYPE.INPUTSTREAM);

            CdmStore.getImportManager().run(job);

        } catch (FileNotFoundException e) {

            logger.error("Error while reading file" + source.toString());

        } catch (IOException e){

        }

        //CdmStore.getImportManager().runMoniteredOperation(configurator, new File(source), SOURCE_TYPE.INPUTSTREAM);

        return true;

    }

    @Override

    public void init(IWorkbench workbench, IStructuredSelection selection) {

        super.init(workbench, selection);

        configurator = RisReferenceImportConfigurator.NewInstance();

    }

    @Override

    public void addPages() {

        //addConfiguratorPage();

        addDataSourcePage();

    }

    @Override

    protected void addConfiguratorPage(){

        List<String> ignoreMethods = new ArrayList<>();

        ignoreMethods.add("setIgnoreNull");

        ignoreMethods.add("setInteractWithUser");

        ignoreMethods.add("setUseClassification");

        pageConfiguration = GenericConfiguratorWizardPage.Import(CONFIGURATION_PAGE, getConfigurator(), ignoreMethods, "Ris Import");

        addPage(pageConfiguration);

    }

    private void addDataSourcePage(){

        dataSourcePage = new ImportFromFileDataSourceWizardPage("Choose Ris File",

                "Please choose an xls file in the Distribution Update format.", new String[]{"*.txt"});

        addPage(dataSourcePage);

    }

}