EDIT

/**

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

 */

package eu.etaxonomy.taxeditor.store;

import org.eclipse.swt.widgets.Display;

import org.springframework.core.io.Resource;

import org.springframework.security.core.context.SecurityContextHolder;

import eu.etaxonomy.cdm.api.service.IClassificationService;

import eu.etaxonomy.cdm.api.service.IEntityConstraintViolationService;

import eu.etaxonomy.cdm.api.service.IEntityValidationService;

import eu.etaxonomy.cdm.api.service.IFeatureNodeService;

import eu.etaxonomy.cdm.api.service.IFeatureTreeService;

import eu.etaxonomy.cdm.api.service.IGrantedAuthorityService;

import eu.etaxonomy.cdm.api.service.IGroupService;

import eu.etaxonomy.cdm.api.service.IMarkerService;

import eu.etaxonomy.cdm.api.service.IMediaService;

import eu.etaxonomy.cdm.api.service.IOccurrenceService;

import eu.etaxonomy.cdm.api.service.IRightsService;

import eu.etaxonomy.cdm.api.service.molecular.IPrimerService;

import eu.etaxonomy.cdm.model.term.FeatureTree;

import eu.etaxonomy.cdm.model.molecular.Primer;

import eu.etaxonomy.cdm.model.validation.EntityValidation;

import eu.etaxonomy.taxeditor.io.ImportManager;

import eu.etaxonomy.taxeditor.session.mock.MockCdmEntitySessionManager;

/**

 * store the data correctly for the current session. No state is held in this

 * class.

 * class acts as a facade for the methods in cdmlib-service.

 * @created 17.03.2009

 * @version 1.0

 */

            "/eu/etaxonomy/cdm/editorApplicationContext.xml",

            TaxeditorStorePlugin.class);

    private static final DbSchemaValidation DEFAULT_DB_SCHEMA_VALIDATION = DbSchemaValidation.VALIDATE;

    private static UseObjectStore useObjectInitializer = new UseObjectStore();

    private ICdmSource cdmSource;

    private boolean isConnected;

    /**

     * <p>

     * getDefault

     * </p>

     *

     * @return a {@link eu.etaxonomy.taxeditor.store.CdmStore} object.

     */

            return instance;

        } else{// if (instance == null || !instance.isConnected) {

                MessagingUtils.dataSourceNotAvailableWarningDialog(instance);

            }else{

                MessagingUtils.noDataSourceWarningDialog(instance);

            }

            return null;

        }

    }

     * <p>

     * getDefault

     * </p>

     *

     * @return a {@link eu.etaxonomy.taxeditor.store.CdmStore} object.

     */

    protected static CdmStore getDefault(){

       return getDefault(false);

    }

    /**

     * Initialize the with the last edited datasource

     */

    public static void connect() {

        ICdmSource cdmSource;

        try {

            cdmSource = CdmDataSourceRepository.getCurrentCdmSource();

            connect(cdmSource);

        } catch (Exception e) {

            MessagingUtils.messageDialog("Connection to CDM Source Failed", CdmStore.class, "Could not connect to target CDM Source", e);

        }

    }

    /**

     * Initialize with a specific datasource

     *

     * @param datasource

     *            a {@link eu.etaxonomy.cdm.database.ICdmDataSource} object.

     */

    public static void connect(ICdmSource cdmSource) {

        connect(cdmSource, DEFAULT_DB_SCHEMA_VALIDATION,

                DEFAULT_APPLICATION_CONTEXT);

    }

    public static void connect(ICdmSource cdmSource, RemotingLoginDialog loginDialog) {

        connect(cdmSource,

                DEFAULT_DB_SCHEMA_VALIDATION,

                DEFAULT_APPLICATION_CONTEXT,

                loginDialog);

    }

    /**

     * Initialize and provide

     *

     * @param datasource

     * @param dbSchemaValidation

     * @param applicationContextBean

     */

    private static void connect(final ICdmSource cdmSource,

            final DbSchemaValidation dbSchemaValidation,

            final Resource applicationContextBean) {

        MessagingUtils.info("Connecting to datasource: " + cdmSource);

        job = new CdmStoreConnector(Display.getDefault(), cdmSource,

                dbSchemaValidation, applicationContextBean);

        job.setUser(true);

        job.setPriority(Job.BUILD);

        job.schedule();

    }

    private static void connect(final ICdmSource cdmSource,

            final DbSchemaValidation dbSchemaValidation,

            final Resource applicationContextBean,

        RemotingLoginDialog loginDialog = remotingLoginDialog;

            // before we connect we clear the entity caches and the sessions

                getCurrentSessionManager(true).disposeAll();

        }

        job = new CdmStoreConnector(Display.getDefault(),

                cdmSource,

                dbSchemaValidation,

                applicationContextBean);

        job.start(loginDialog);

    public static boolean isConnecting() {

        return job != null && job.getState() == Job.RUNNING;

    }

    /**

     * Closes the current application context

     *

     * @param monitor

     *            a {@link org.eclipse.core.runtime.IProgressMonitor} object.

     */

    public static void close(final IProgressMonitor monitor) {

        Display.getDefault().asyncExec(new Runnable() {

            public void run() {

                getContextManager().notifyContextAboutToStop(monitor);

                if ((monitor == null || (!monitor.isCanceled()) && isActive())) {

                    getContextManager().notifyContextStop(monitor);

                    instance.close();

                }

            }

        });

    }

    public static void close(IProgressMonitor monitor, boolean async) {

        if(async) {

            close(monitor);

        } else {

            getContextManager().notifyContextAboutToStop(monitor);

            if ((monitor == null || (!monitor.isCanceled()) && isActive())) {

                getContextManager().notifyContextStop(monitor);

                instance.close();

            }

        }

    }

    private void close() {

        isConnected = false;

        cdmSource = null;

        CdmApplicationState.dispose();

    }

        instance = new CdmStore(applicationController, cdmSource);

        this.cdmSource = cdmSource;

        isConnected = true;

    }

    /**

     * All calls to the datastore require

     *

     * @return

     */

            return CdmApplicationState.getCurrentAppConfig();

        } catch (Exception e) {

            MessagingUtils.error(CdmStore.class, e);

        }

        return null;

    }

    /**

     * <p>

     * getCurrentApplicationController

     * </p>

     *

     * @return a

     *         {@link eu.etaxonomy.cdm.remote.api.application.CdmApplicationController}

     *         object.

     */

            return getDefault().getApplicationConfiguration();

        }

        return null;

    }

    /*

     * CONVERSATIONS

     */

    /**

     * Creates a new conversation, binds resources to the conversation and start

     * a transaction for this conversation.

     *         object.

     */

    public static ConversationHolder createConversation() {

        ConversationHolder conversation = getCurrentApplicationConfiguration()

                .NewConversation();

        try {

            conversation.startTransaction();

        }catch(Exception e){

            MessagingUtils.messageDialog("No database connection", CdmStore.class, "No database connection available", e);

        }

        return conversation;

    }

    //FIXME:Remoting should be removed after moving completely to remoting

    private MockCdmEntitySessionManager mockCdmEntitySessionManager;

    private ICdmEntitySessionManager getSessionManager() {

        //FIXME:Remoting we should only have CdmApplicationRemoteConfiguration after move to remoting

        //               bad hack which should be finally removed

        if(getCurrentApplicationConfiguration() instanceof CdmApplicationRemoteController) {

            return ((CdmApplicationRemoteController)getCurrentApplicationConfiguration()).getCdmEntitySessionManager();

        } else {

            if(mockCdmEntitySessionManager == null) {

                mockCdmEntitySessionManager = new MockCdmEntitySessionManager();

            }

            return mockCdmEntitySessionManager;

        }

    }

    public static  ICdmEntitySessionManager getCurrentSessionManager() {

    }

    public static  ICdmEntitySessionManager getCurrentSessionManager(boolean connecting) {

        if (getDefault(connecting) != null) {

            return getDefault(connecting).getSessionManager();

        return null;

    }

    /**

     * invoking the getter otherwise the method returns <code>null</code>.

     *

     * @param <T>

     * @param serviceClass

     * @return the configured implementation of <code>serviceClass</code> or <code>null</code>

     */

    public static <T extends IService> T getService(Class<T> serviceClass) {

        T service = null;

        try {

            service = CdmApplicationState.getService(serviceClass);

        } catch (CdmApplicationException cae) {

            MessagingUtils.error(CdmStore.class, cae);

        }

        return service;

    }

    /**

     * @see #getService(Class)

     * As ICommonService is not extending IService we need a specific request here

     */

    public static ICommonService getCommonService() {

        return CdmApplicationState.getCommonService();

    }

    /**

     * <p>

     * getAuthenticationManager

     * </p>

     *

     * @return a

     *         {@link org.springframework.security.authentication.ProviderManager}

     *         object.

     */

    public static AuthenticationManager getAuthenticationManager() {

        return getCurrentApplicationConfiguration().getAuthenticationManager();

    }

    /**

     * <p>

     * getAuthenticationManager

     * </p>

     *

     * @return a

     *         {@link ICdmPermissionEvaluator} object.

     */

    public static ICdmPermissionEvaluator getPermissionEvaluator() {

        return getCurrentApplicationConfiguration().getPermissionEvaluator();

    }

    /*

     * SECURITY RELATED CONVENIENCE METHODS

     */

    /**

     * @see org.springframework.security.access.PermissionEvaluator#hasPermission(org.springframework.security.core.Authentication, java.lang.Object, java.lang.Object)

     *

     * @param targetDomainObject

     * @param permission

     * @return

     */

    public static boolean currentAuthentiationHasPermission(CdmBase targetDomainObject, EnumSet<CRUD> permission){

        //TODO use getCurrentApplicationConfiguration().currentAuthentiationHasPermission(CdmBase targetDomainObject, Operation permission) instead

        SecurityContext context = SecurityContextHolder.getContext();

        PermissionEvaluator pe = getPermissionEvaluator();

        boolean hasPermission = false;

        try {

                    permission);

        } catch (org.springframework.security.access.AccessDeniedException e) {

            /* IGNORE */

        }

        return hasPermission;

     * @see org.springframework.security.access.PermissionEvaluator#hasPermission(org.springframework.security.core.Authentication, java.lang.Object, java.lang.Object)

     * @param permission

     * @return

     */

    public static boolean currentAuthentiationHasPermission(Class<? extends CdmBase> targetType, EnumSet<CRUD> permission){

        boolean hasPermission = false;

            hasPermission = getPermissionEvaluator().hasPermission(getCurrentAuthentiation(), null, targetType.getName(), permission);

        } catch (org.springframework.security.access.AccessDeniedException e) {

            /* IGNORE */

        }

        return hasPermission;

        boolean hasPermission = false;

            hasPermission =  getPermissionEvaluator().hasOneOfRoles(getCurrentAuthentiation(), roles);

        } catch (org.springframework.security.access.AccessDeniedException e) {

            /* IGNORE */

        }

        return hasPermission;

    public static Authentication getCurrentAuthentiation() {

        SecurityContext context = SecurityContextHolder.getContext();

        return context.getAuthentication();

    }

    /*

     * LANGUAGE

     */

    /**

     * Provides access to the global default language set in the application preferences.

     *

     * @return a {@link eu.etaxonomy.cdm.model.common.Language} object.

     */

    public static Language getDefaultLanguage() {

        if (getDefault().getLanguage() == null) {

            getDefault().setLanguage(PreferencesUtil.getGlobalLanguage());

        }

        return getDefault().getLanguage();

    }

    /**

     * <p>

     * setDefaultLanguage

     * </p>

     *

     * @param language

     *            a {@link eu.etaxonomy.cdm.model.common.Language} object.

     */

    public static void setDefaultLanguage(Language language) {

        getDefault().setLanguage(language);

    }

    /**

     * @return the language

     */

    private Language getLanguage() {

        return language;

    }

    /**

     * @param language

     *            the language to set

     */

    private void setLanguage(Language language) {

        this.language = language;

    }

    /*

     * LOGIN

     */

    /**

     * <p>

     * Getter for the field <code>loginManager</code>.

     * </p>

     *

     * @return a {@link eu.etaxonomy.taxeditor.store.LoginManager} object.

     */

    public static LoginManager getLoginManager() {

        return loginManager;

    }

    /**

     * <p>

     * Getter for the field <code>contextManager</code>.

     * </p>

     *

     * @return a {@link eu.etaxonomy.taxeditor.store.ContextManager} object.

     */

    public static ContextManager getContextManager() {

        return contextManager;

    }

    public static TermManager getTermManager() {

        return termManager;

    }

    public static SearchManager getSearchManager() {

        return searchManager;

    }

    public static EditorManager getEditorManager() {

        return editorManager;

    }

        return progressMonitorClientManager;

    }

     * IMPORT/EXPORT FACTORIES

     */

    /**

     * <p>

     * Getter for the field <code>importHandler</code>.

     * </p>

     *

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

     */

    public static ImportManager getImportManager() {

        return ImportManager.NewInstance(getCurrentApplicationConfiguration());

    }

    /**

     * <p>

     * Getter for the field <code>exportHandler</code>.

     * </p>

     *

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

     */

    public static ExportManager getExportManager() {

        return ExportManager.NewInstance(getCurrentApplicationConfiguration());

    }

    /**

     * Whether this CdmStore is currently connected to a datasource

     *

     * @return a boolean.

     */

    public static boolean isActive() {

        return instance != null && instance.isConnected;

    }

    public static ICdmSource getActiveCdmSource() {

        if (isActive()) {

            return instance.getCdmSource();

        }

        return null;

    }

    /**

     * <p>

     * getDataSource

     * </p>

     *

     * @return a {@link eu.etaxonomy.cdm.database.ICdmDataSource} object.

     * @deprecated currently retained for backward compatibility - use {@link getActiveCdmSource()} instead

     */

    //	public static ICdmDataSource getDataSource() {

    //		if (isActive()) {

    //			return (ICdmDataSource)instance.getCdmSource();

    //		}

    //		return null;

    //	}

    /**

     * @return

     */

    private ICdmSource getCdmSource() {

        return cdmSource;

    }

        IService<T> service = null;

        if(cdmBase!=null){

            //get corresponding service

            if(cdmBase.isInstanceOf(Reference.class)){

                service = (IService<T>) getService(IReferenceService.class);

            }

            else if (cdmBase.isInstanceOf(AgentBase.class)){

                service = (IService<T>) getService(IAgentService.class);

            }

            }

                service = (IService<T>) getService(ITaxonService.class);

            }

                service = (IService<T>) getService(IOccurrenceService.class);

            }

                service = (IService<T>) getService(IMediaService.class);

            }

                service = (IService<T>) getService(ICollectionService.class);

            }

            }

            	service = (IService<T>) getService(IGroupService.class);

            }

            	service = (IService<T>) getService(IDescriptiveDataSetService.class);

            else if (cdmBase instanceof TermVocabulary<?>) {

            	service = (IService<T>) getService(IVocabularyService.class);

            }

            else if (cdmBase instanceof DefinedTermBase<?>) {

            	service = (IService<T>) getService(ITermService.class);

            }

                service = (IService<T>) getService(IPrimerService.class);

            }

            else if (cdmBase instanceof Amplification) {

                service = (IService<T>) getService(IAmplificationService.class);

                service = (IService<T>) getService(IPolytomousKeyNodeService.class);

            }

            else if (cdmBase instanceof Annotation) {

                service = (IService<T>) getService(IAnnotationService.class);

            }

            else if (cdmBase instanceof Classification) {

                service = (IService<T>) getService(IClassificationService.class);

            }

            else if (cdmBase instanceof DescriptionBase<?>) {

                service = (IService<T>) getService(IDescriptionService.class);

            }

            else if (cdmBase instanceof EntityConstraintViolation) {

                service = (IService<T>) getService(IEntityConstraintViolationService.class);

            }

            else if (cdmBase instanceof EntityValidation) {

                service = (IService<T>) getService(IEntityValidationService.class);

            }

            else if (cdmBase instanceof FeatureNode) {

                service = (IService<T>) getService(IFeatureNodeService.class);

            }

            else if (cdmBase instanceof FeatureTree) {

                service = (IService<T>) getService(IFeatureTreeService.class);