Application: gvSIG desktop

package org.gvsig.fmap.dal.feature.spi.simpleprovider;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.net.URL;

import org.apache.commons.io.FilenameUtils;

import org.gvsig.fmap.dal.DALFileLocator;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.feature.FeatureStoreProviderFactory;

import org.gvsig.fmap.dal.feature.OpenFeatureStoreParameters;

import org.gvsig.fmap.dal.serverexplorer.filesystem.spi.FilesystemServerExplorerProviderFactory;

import org.gvsig.fmap.dal.spi.DataManagerProviderServices;

import org.gvsig.metadata.MetadataLocator;

import org.gvsig.metadata.MetadataManager;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DynStruct;

import org.gvsig.tools.persistence.PersistenceManager;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 *

 * @author jjdelcerro

 */

public abstract class AbstractSimpleReaderFactory implements SimpleReaderFactory {

    protected Logger LOGGER = LoggerFactory.getLogger(AbstractSimpleReaderFactory.class);

    private final String name;

    private final String description;

    private final String[] extensions;

    protected AbstractSimpleReaderFactory(

            String name,

            String description,

            String[] extensions

    ) {

        this.name = name;

        this.description = description;

        this.extensions = extensions;

    }

    @Override

    public String getName() {

        return name;

    }

    @Override

    public String getDescription() {

        return description;

    }

    @Override

    public String[] getExtensions() {

        return extensions;

    }

    @Override

    public boolean accept(File pathname) {

        return FilenameUtils.isExtension(pathname.getName(), this.getExtensions());

    }

    @Override

    public FeatureStoreProviderFactory createStoreProviderFactory() {

        return new BaseSimpleStoreProviderFactory(this);

    }

    @Override

    public FilesystemServerExplorerProviderFactory createFilesystemServerProviderFactory() {

        return new BaseSimpleFilesystemServerProviderFactory(this);

    }

    private InputStream openStream(URL url) {

        try {

            return url.openStream();

        } catch (IOException ex) {

            return null;

        }

    }

    @Override

    public void selfRegister(Class loader) {

        this.selfRegister(

                loader.getResource(this.getName() + "Parameters.xml"),

                loader.getResource(this.getName() + "Metadata.xml")

        );    

    }

    @SuppressWarnings("UseSpecificCatch")

    @Override

    public void selfRegister(URL parameters_xml, URL metadata_xml) {

        DynStruct definition;

        PersistenceManager persistenceManager = ToolsLocator.getPersistenceManager();

        definition = persistenceManager.getDefinition(this.getName());

        if (definition == null) {

            InputStream stream = this.openStream(parameters_xml);

            if (stream == null) {

                throw new RuntimeException("Can't access parameters definition in resource '" + parameters_xml.toString() + "'.");

            }

            persistenceManager.updateDefinition(

                    BaseSimpleStoreParameters.class,

                    this.getName(),

                    stream,

                    BaseSimpleStoreParameters.class.getClassLoader(),

                    null,

                    null

            );

        }

        if( metadata_xml!=null ) {

            MetadataManager metadataManager = MetadataLocator.getMetadataManager();

            try {

                definition = metadataManager.getDefinition(this.getName());

                if (definition == null) {

                    InputStream stream = this.openStream(metadata_xml);

                    metadataManager.addDefinition(

                            this.getName(),

                            stream,

                            BaseSimpleStoreParameters.class.getClassLoader()

                    );

                }

            } catch (Exception e) {

                LOGGER.warn(

                        "Can't access metadata definition in resource '" + metadata_xml.toString() + "'.",

                        e

                );

            }

        }

        DataManagerProviderServices dataman = (DataManagerProviderServices) DALLocator

                .getDataManager();

        if (!dataman.getStoreProviders().contains(this.getName())) {

            dataman.registerStoreProviderFactory(

                    new BaseSimpleStoreProviderFactory(this)

            );

        }

        try {

            DALFileLocator.getFilesystemServerExplorerManager()

                    .registerProviderFactory(

                            new BaseSimpleFilesystemServerProviderFactory(this)

                    );

        } catch (Exception e) {

            LOGGER.warn(

                "Can't register filesystem server provider factory ("+this.getName()+").",

                e

            );

        }

    }

    @Override

    public abstract SimpleReader createReader(OpenFeatureStoreParameters params);

}