Application: gvSIG desktop

package org.gvsig.fmap.dal.feature.impl;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.collections4.CollectionUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DataServerExplorer.DataResource;

import org.gvsig.fmap.dal.exception.DataException;

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

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DynStruct;

import org.gvsig.tools.persistence.PersistenceManager;

import org.gvsig.tools.persistence.Persistent;

import org.gvsig.tools.persistence.PersistentState;

import org.gvsig.tools.persistence.exception.PersistenceException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@SuppressWarnings("UseSpecificCatch")

public class DALFile implements Persistent {

    private static final Logger LOGGER = LoggerFactory.getLogger(DALFile.class);

    private static final String DALFILE_PERSISTENCE_DEFINITION_NAME = "DALResources";

    public static DALFile getDALFile() {

        DALFile f = new DALFile();

        return f;

    }

    public static DALFile getDALFile(DataResource resource) {

        DALFile df = new DALFile();

        df.read(resource);

        return df;

    }

    public static void registerPersistenceDefinition() {

        PersistenceManager manager = ToolsLocator.getPersistenceManager();

        if (manager.getDefinition(DALFILE_PERSISTENCE_DEFINITION_NAME) == null) {

            DynStruct definition = manager.addDefinition(

                DALFile.class,

                DALFILE_PERSISTENCE_DEFINITION_NAME, 

                DALFILE_PERSISTENCE_DEFINITION_NAME + " Persistent definition", 

                null, 

                null

            );

            definition.addDynFieldString("defaultFeatureType");

            definition.addDynFieldList("featureTypes")

                .setClassOfItems(FeatureType.class)

                .setPersistent(true);

        }

    }

    private final List<FeatureType> featureTypes;

    private String defaultFeatureTypeId;

    public DALFile() {

        this.featureTypes = new ArrayList<>();

    }

    public boolean isEmpty() {

        if( CollectionUtils.isEmpty(this.featureTypes) ) {

            return true;

        }

        return false;

    }

    public void write(DataResource resource) {

        try {

            PersistenceManager manager = ToolsLocator.getPersistenceManager();

            PersistentState state = manager.getState(this);

            OutputStream out = resource.asOutputStream();

            manager.saveState(state, out);

        } catch(Throwable ex) {

            throw new RuntimeException("Can't write DAL resource.",ex);

        }

    }

    public void read(DataResource resource) {

        try {

            PersistenceManager manager = ToolsLocator.getPersistenceManager();

            InputStream in = resource.asInputStream();

            DALFile x = (DALFile) manager.getObject(in);

            this.featureTypes.clear();

            this.featureTypes.addAll(x.featureTypes);

        } catch(Throwable ex) {

            throw new RuntimeException("Can't read DAL resource.",ex);

        }

    }

    public void setStore(DefaultFeatureStore store) throws DataException {

        this.featureTypes.clear();

        List<FeatureType> theTypes = store.getFeatureTypes();

        for (FeatureType theType : theTypes) {

            this.featureTypes.add(theType.getCopy());

        }

        this.defaultFeatureTypeId = store.getDefaultFeatureType().getId();

    }

    public void updateStore(DefaultFeatureStore store) throws DataException {

        List<FeatureType> theTypes = new ArrayList<>();

        FeatureType defaultFeatureType = null;

        for (FeatureType type : this.featureTypes) {

            ((DefaultFeatureType)type).setStore(store);

            theTypes.add(type);

            if( StringUtils.equals(defaultFeatureTypeId, type.getId()) ) {

                defaultFeatureType = type;

            }

        }

        if( theTypes.isEmpty() ) {

            return;

        }

        if( defaultFeatureType==null ) {

            defaultFeatureType = theTypes.get(0);

        }

        store.setFeatureTypes(theTypes, defaultFeatureType);

    }

    @Override

    public void saveToState(PersistentState state) throws PersistenceException {

        state.set("defaultFeatureType", defaultFeatureTypeId);

        state.set("featureTypes", featureTypes);

    }

    @Override

    public void loadFromState(PersistentState state) throws PersistenceException {

        try {

            defaultFeatureTypeId = state.getString("defaultFeatureType");

            List<FeatureType> theTypes = state.getList("featureTypes");

            featureTypes.clear();

            for (FeatureType theType : theTypes) {

                this.featureTypes.add(theType);

            }

        } catch(Throwable th) {

            LOGGER.warn("Can't load DAL resource.", th);

            throw new PersistenceException(th);

        }

    }

}