gvSIG projects pool

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 gvSIG Association.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 3

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.online.lib.impl;

import java.io.File;

import java.io.IOException;

import java.net.URL;

import java.nio.file.Files;

import java.nio.file.Path;

import java.util.ArrayList;

import java.util.Collections;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Objects;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorer;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DatabaseWorkspaceManager;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.CONFIG_NAME_STORESREPOSITORYID;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.TABLE_CONFIGURATION;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.TABLE_REPOSITORY;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.TABLE_RESOURCES;

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

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

import org.gvsig.fmap.dal.store.h2.H2SpatialUtils;

import org.gvsig.fmap.dal.store.jdbc.JDBCNewStoreParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

import org.gvsig.fmap.dal.store.jdbc2.JDBCServerExplorer;

import org.gvsig.online.lib.api.OnlineCodeGenerator;

import org.gvsig.online.lib.api.OnlineManager;

import org.gvsig.online.lib.api.OnlineProject;

import org.gvsig.online.lib.api.OnlineSite;

import org.gvsig.online.lib.api.OnlineUserIdentificationRequester;

import org.gvsig.online.lib.api.workingcopy.OnlineWorkingcopy;

import org.gvsig.online.lib.api.workingcopy.OnlineWorkingcopyDescriptor;

import org.gvsig.online.lib.api.workingcopy.WorkingArea;

import org.gvsig.online.lib.impl.workspace.OnlineWorkingcopyDescriptorImpl;

import org.gvsig.online.lib.impl.workspace.OnlineWorkspaceImpl;

import org.gvsig.online.lib.impl.workspace.StoreProperties;

import org.gvsig.online.lib.impl.workspace.WorkingAreaImpl;

import org.gvsig.online.lib.impl.workspace.tables.EntitiesTable;

import org.gvsig.online.lib.impl.workspace.tables.RemoteChangesTable;

import org.gvsig.online.lib.impl.workspace.tables.VarsTable;

import org.gvsig.online.lib.impl.workspace.tables.WorkspaceChangesTable;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.tools.task.UserCancelTaskException;

import org.gvsig.tools.util.HasAFile;

import org.gvsig.tools.util.ListBuilder;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@SuppressWarnings("UseSpecificCatch")

public class OnlineManagerImpl implements OnlineManager {

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

    public static final List<String> INTERNAL_WORKSPACE_TABLES = ListBuilder.create(

            EntitiesTable.TABLE_NAME,

            VarsTable.TABLE_NAME,

            RemoteChangesTable.TABLE_NAME,

            WorkspaceChangesTable.TABLE_NAME,

            DatabaseWorkspaceManager.TABLE_RESOURCES_NAME,

            DatabaseWorkspaceManager.TABLE_CONFIGURATION_NAME,

            DatabaseWorkspaceManager.TABLE_REPOSITORY_NAME

    );

    private OnlineUserIdentificationRequester userIdentificationRequester;

    private Map<String,OnlineWorkingcopyDescriptor> workspaces;

    public OnlineManagerImpl() {

        this.workspaces = new HashMap<>();

        this.userIdentificationRequester = null;

    }

    @Override

    public String getErrorMessage(int errcode) {

        return OnlineUtils.getErrorMessage(errcode);

    }

    @Override

    public void setUserIdentificationRequester(OnlineUserIdentificationRequester userIdentificationRequester) {

        this.userIdentificationRequester = userIdentificationRequester;

    }

    @Override

    public OnlineUserIdentificationRequester getUserIdentificationRequester() {

        return this.userIdentificationRequester;

    }

    @Override

    public OnlineWorkingcopyDescriptor getWorkingcopyDescriptor(String code) {

        OnlineWorkingcopyDescriptor descriptor = this.workspaces.get(code);

        if( descriptor!=null ) {

            DisposeUtils.bind(descriptor);

            return descriptor;

        }

        for (OnlineWorkingcopyDescriptor descriptor2 : this.workspaces.values()) {

            if( descriptor2==null ) {

                continue;

            }

            if( StringUtils.equalsIgnoreCase(descriptor2.getLabel(), code) ) {

                DisposeUtils.bind(descriptor2);

                return descriptor2;

            }

        }

        return null;

    }

    @Override

    public synchronized void clean() {

        for (OnlineWorkingcopyDescriptor workspace : workspaces.values()) {

            DisposeUtils.disposeQuietly(workspace);

        }

        this.workspaces = new HashMap<>();

        this.userIdentificationRequester = null;

    }

    public OnlineWorkingcopy openWorkingcopy(JDBCServerExplorer wsexplorer, String label) {

        // Abre la copia de trabajo cambiando su label y asignando un code nuevo.

        if (wsexplorer == null) {

            return null;

        }

        JDBCServerExplorerParameters params = null;

        try {

            OnlineWorkingcopy workspace;

            params = wsexplorer.getParameters();

            workspace = new OnlineWorkspaceImpl(wsexplorer, this.getCodeGenerator(), label);

            workspace.setUserIdentificationRequester(this.userIdentificationRequester);

            this.registerWorkingcopy(workspace);

            dropExpiredCaches();

            return workspace;

        } catch (Exception ex) {

            LOGGER.debug("Can't get workspace from "+Objects.toString(params)+".", ex);

            return null;

        }

    }

    @Override

    public void registerWorkingcopy(OnlineWorkingcopy workspace) {

        OnlineWorkingcopyDescriptor descriptor = this.workspaces.get(workspace.getCode());

        if( descriptor == null ) {

            descriptor = new OnlineWorkingcopyDescriptorImpl(workspace);

            this.workspaces.put(workspace.getCode(), descriptor);

        } else {

            ((OnlineWorkingcopyDescriptorImpl)descriptor).setWorkspace(workspace);            

        }

    }

    @Override

    public void deregisterWorkingcopy(File dbfile) {

        Path dbpath = dbfile.toPath();

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

        for (Iterator<OnlineWorkingcopyDescriptor> iterator = this.workspaces.values().iterator(); iterator.hasNext();) {

            OnlineWorkingcopyDescriptorImpl descriptor = (OnlineWorkingcopyDescriptorImpl) iterator.next();

            JDBCServerExplorerParameters explorerParams = descriptor.getExplorerParameters();

            if( explorerParams instanceof HasAFile ) {

                Path p = ((HasAFile) explorerParams).getFile().toPath();

                try {

                    if( Files.isSameFile(dbpath, p) ) {

                        wscodes.add(descriptor.getCode());

                    }

                } catch (IOException ex) {

                    LOGGER.debug("Can't deregister workspace '"+dbfile.getAbsolutePath()+"'.",ex);

                }

            }

        }        

        for (String wscode : wscodes) {

            deregisterWorkingcopy(wscode);

        }

    }

    @Override

    public void deregisterWorkingcopy(OnlineWorkingcopy workspace) {

        this.deregisterWorkingcopy(workspace.getCode());

    }

    @Override

    public void deregisterWorkingcopy(String workspaceCode) {

        DisposeUtils.disposeQuietly(this.workspaces.get(workspaceCode));

        this.workspaces.remove(workspaceCode);

        dropExpiredCaches();

    }

    private void dropExpiredCaches() {

        for (Iterator<OnlineWorkingcopyDescriptor> iterator = this.workspaces.values().iterator(); iterator.hasNext();) {

            OnlineWorkingcopyDescriptorImpl value = (OnlineWorkingcopyDescriptorImpl) iterator.next();

            if(DisposeUtils.getReferences(value)<=0){

                iterator.remove();

            } else {

                value.dropExpiredCaches();

            }

        }

    }

    @Override

    public OnlineWorkingcopy getWorkingcopy(FeatureStore store) {

        try {

            OnlineWorkspaceImpl workspace;

            switch(StoreProperties.getOnlineMode(store)) {

                case StoreProperties.MODE_NOT_ONLINE:

                    return null;

                case StoreProperties.MODE_ONLINE:

                    String workspace_code = StoreProperties.getWorkspaceCode(store);

                    OnlineWorkingcopyDescriptor workspaceDescriptor = this.workspaces.get(workspace_code);

                    if( workspaceDescriptor!=null ) {

                        workspace = (OnlineWorkspaceImpl) workspaceDescriptor.getWorkspace();

                        if (workspace != null) {

                            if( workspace.isInStoreIgnoreChanges(store) ) {

                                return workspace;

                            }

                            String entity_name = StoreProperties.getEntityName(store);

                            EntitiesTable.EntityRow entity = (EntitiesTable.EntityRow) workspace.getWorkspaceEntityByName(entity_name);

                            if (entity == null) {

                                StoreProperties.setNotOnlineMode(store);

                                DisposeUtils.dispose(workspace);

                                return null;

                            }

                            if( workspace.isCorrupt(entity,store,0) ) {

//                                return null; 

                            }

//                            LOGGER.debug("===: GET WORKSPACE "+ hexId(workspace)+ " from property (code='"+workspace.getCode()+"', label='"+workspace.getLabel()+"') for store '"+store.getName()+"'");        

                            return workspace;

                        }

                    }                

                case StoreProperties.MODE_UNKNOWN:

                default:

                    DataStoreParameters params = store.getParameters();

                    if(!(params instanceof JDBCStoreParameters)) {

                        StoreProperties.setNotOnlineMode(store);

                        return null;

                    }

                    String entity_name = ((JDBCStoreParameters) params).getTable();

                    if (INTERNAL_WORKSPACE_TABLES.contains(entity_name)  ) {

                        StoreProperties.setNotOnlineMode(store);

                        return null;

                    }

                    String storeUrl = ((JDBCStoreParameters)params).getUrl();

                    List<OnlineWorkingcopyDescriptor> descriptors = new ArrayList<>(this.workspaces.values());

                    for (OnlineWorkingcopyDescriptor value : descriptors) {

                        if( value == null ) {

                            continue;

                        }

                        JDBCServerExplorerParameters explorerParams = value.getExplorerParameters();    

                        if( explorerParams == null ) {

                            continue;

                        }

                        if (!StringUtils.equals(storeUrl, explorerParams.getUrl())) {

                            continue;

                        }

                        workspace = (OnlineWorkspaceImpl) value.getWorkspace();

                        if( workspace == null ) {

                            continue;

                        }

                        EntitiesTable.EntityRow entity = (EntitiesTable.EntityRow) workspace.getWorkspaceEntityByName(entity_name);

                        if (entity == null) {

                            StoreProperties.setNotOnlineMode(store);

                            DisposeUtils.dispose(workspace);

                            return null;

                        }

                        StoreProperties.set(store, workspace, entity_name);

                        if( workspace.isCorrupt(entity,store,0) ) {

//                                return null;

                        }

//                            LOGGER.debug("===: GET WORKSPACE "+ hexId(workspace)+ " from registry (code='"+workspace.getCode()+"', label='"+workspace.getLabel()+"') for store '"+store.getName()+"'");        

                        return workspace;

                    }

                    JDBCServerExplorer explorer = null;

                    try {

                        explorer = (JDBCServerExplorer)store.getExplorer();

                        if( !this.isWorkingcopy(explorer.getParameters()) ) {

                            StoreProperties.setNotOnlineMode(store);

                            return null;

                        }

                        workspace = (OnlineWorkspaceImpl) openWorkingcopy(explorer);

                    } catch (Exception e) {

                        workspace = null;

                    } finally {

                        DisposeUtils.disposeQuietly(explorer);

                    }

                    if (workspace == null) {

                        StoreProperties.setNotOnlineMode(store);

                        return null;

                    }

                    this.registerWorkingcopy(workspace);

                    EntitiesTable.EntityRow entity = (EntitiesTable.EntityRow) workspace.getWorkspaceEntityByName(entity_name);

                    if (entity == null) {

                        StoreProperties.setNotOnlineMode(store);

                        return null;

                    }

                    StoreProperties.set(store, workspace, entity_name);

                    return workspace;

            }

        } catch (Exception ex) {

            LOGGER.warn("Can't get '" +store.getName()+ "'store's workspace ", ex);

            StoreProperties.setUnknownOnlineMode(store);

            throw new RuntimeException("Can't get '" +store.getName()+ "'store's workspace ", ex);

        }

    }

    @Override

    public Map<String, OnlineWorkingcopyDescriptor> getWorkingcopy() {

        return Collections.unmodifiableMap(this.workspaces);

    }

    @Override

    public synchronized void restoreWorkingcopy(Map<String, OnlineWorkingcopyDescriptor> descriptors) {

        this.workspaces = new HashMap<>();

        if( descriptors != null ) {

            this.workspaces.putAll(descriptors);

        }

    }

    @Override

    public boolean isWorkingcopy(JDBCServerExplorerParameters params) {

        DataServerExplorer explorer = null;

        try {

            DataManager dataManager = DALLocator.getDataManager();

            explorer = dataManager.openServerExplorer(params.getProviderName(), params);

            DataStoreParameters x = explorer.get(VarsTable.TABLE_NAME);

            if(x==null) {

                return false;

            }

            return explorer.exists(x);

        } catch (Exception ex) {

            return false;

        } finally {

            DisposeUtils.disposeQuietly(explorer);

        }

    }

    @Override

    public boolean isWorkingcopy(File dbfile) {

        try {

            DataManager dataManager = DALLocator.getDataManager();

            JDBCServerExplorerParameters params = (JDBCServerExplorerParameters) dataManager.createServerExplorerParameters(DataStore.H2SPATIAL_PROVIDER_NAME);

            ((HasAFile)params).setFile(dbfile);

            return isWorkingcopy(params);

        } catch (Exception ex) {

            return false;

        }

    }    

    @Override

    public int initWorkingcopy(File wsfile, OnlineProject project, String label, SimpleTaskStatus status) {

        int err = ERR_NO_ERROR;

        if (wsfile == null) {

            return ERR_DBFILE_IS_NULL;

        }

        if (status == null) {

            status = ToolsLocator.getTaskStatusManager().createDefaultSimpleTaskStatus("Online init_workingcopy");

            status.setAutoremove(true);

            status.add();

        } else {

            status.push();

        }

        DataManager dataManager = DALLocator.getDataManager();

        JDBCServerExplorer explorer = null;

        try {

            wsfile = new File(H2SpatialUtils.removeH2FileNameExtension(wsfile.getAbsolutePath()));

            if (StringUtils.isBlank(label)) {

                label = wsfile.getName();

            }

            err = ERR_CANT_OPEN_WORKSPACE_SERVEREXPLORER;

            JDBCServerExplorerParameters explorerParams = (JDBCServerExplorerParameters) dataManager.createServerExplorerParameters(DataStore.H2SPATIAL_PROVIDER_NAME);

            ((HasAFile) explorerParams).setFile(wsfile);

            explorer = (JDBCServerExplorer) dataManager.openServerExplorer(

                    explorerParams.getProviderName(),

                    explorerParams

            );

            return this.initWorkingcopy(explorer, project, label, status);

        } catch (Exception ex) {

            status.abort();

            LOGGER.warn("Can't init workspace in '" + wsfile.getAbsolutePath() + "'.", ex);

            status.message(ex.getMessage());

            return err;

        } finally {

            status.pop();

            DisposeUtils.disposeQuietly(explorer);

        }

    }

    @Override

    public int initWorkingcopy(JDBCServerExplorer wsexplorer, OnlineProject project, String label, SimpleTaskStatus status) {

        int err = ERR_NO_ERROR;

        if (wsexplorer == null) {

            return ERR_WSEXPLORER_IS_NULL;

        }

        if (StringUtils.isBlank(label)) {

            return ERR_LABEL_IS_NULL;

        }

        if (status == null) {

            status = ToolsLocator.getTaskStatusManager().createDefaultSimpleTaskStatus("Online init_workingcopy");

            status.setAutoremove(true);

            status.add();

        } else {

            status.push();

        }

        LOGGER.info("Initializing workspace "+Objects.toString(wsexplorer.getParameters().toJson()).replace('\n', ' ').replaceAll("\"password\":\"[^\"]*\"", "\"password\":\"****\""));

        DataManager dataManager = DALLocator.getDataManager();

        OnlineWorkspaceImpl workspace = null;

        try {

            status.setTitle("Online init_workingcopy");

            DatabaseWorkspaceManager databaseWorkspaceManager = dataManager.createDatabaseWorkspaceManager(wsexplorer.getParameters());

            if(!databaseWorkspaceManager.existsTable(TABLE_CONFIGURATION)){

                databaseWorkspaceManager.createTable(TABLE_CONFIGURATION);

            }

            if(!databaseWorkspaceManager.existsTable(TABLE_RESOURCES)){

                databaseWorkspaceManager.createTable(TABLE_RESOURCES);

            }

            if(!databaseWorkspaceManager.existsTable(TABLE_REPOSITORY)){

                databaseWorkspaceManager.createTable(TABLE_REPOSITORY);

                databaseWorkspaceManager.set(CONFIG_NAME_STORESREPOSITORYID, "Online");

            }

            databaseWorkspaceManager.connect();

            FeatureType[] tables = new FeatureType[]{

                VarsTable.featureType(),

                EntitiesTable.featureType(),

                WorkspaceChangesTable.featureType(),

                RemoteChangesTable.featureType()

            };

            status.setRangeOfValues(0, tables.length);

            int step = 1;

            for (FeatureType table : tables) {

                status.message(table.getLabel());

                status.setCurValue(step++);

                err = ERR_CANT_CREATE_TABLE + step;

                JDBCNewStoreParameters table_params = wsexplorer.getAddParameters();

                table_params.setDefaultFeatureType(table.getEditable());

                String tableName = table.getTags().getString("ID");

                table_params.setTable(tableName);

                wsexplorer.add(wsexplorer.getProviderName(), table_params, false);

                JDBCStoreParameters openParams = wsexplorer.get(tableName);

                databaseWorkspaceManager.writeStoresRepositoryEntry(tableName, openParams);

            }

//            try {

//                wsexplorer.execute(OnlineUtils.getSqlTemplate(wsexplorer.getProviderName(), "createWorkspaceIndex1"));

//                wsexplorer.execute(OnlineUtils.getSqlTemplate(wsexplorer.getProviderName(), "createWorkspaceIndex2"));

//                wsexplorer.execute(OnlineUtils.getSqlTemplate(wsexplorer.getProviderName(), "createWorkspaceIndex3"));

//                

//            } catch (Exception ex) {

//                LOGGER.warn("Can't create index in workspace", ex);

//            }

//            

            status.setTitle("vcsgis retrieving entities");

            workspace = new OnlineWorkspaceImpl(wsexplorer, this.getCodeGenerator(), project, label);

            if (workspace.getUserIdentificationRequester() == null) {

                workspace.setUserIdentificationRequester(this.userIdentificationRequester);

            }

            workspace.initialize();

            LOGGER.info("Workspace initialized "+workspace.getCode());

            this.registerWorkingcopy(workspace);

            status.terminate();

            return ERR_NO_ERROR;

        } catch (UserCancelTaskException ex) {

            status.cancel();

            LOGGER.warn("Cancelled by user (" + getMessageLabel(wsexplorer) + ").", ex);

            status.message("Cancelled by user.");

            throw ex;

        } catch (Exception ex) {

            status.abort();

            LOGGER.warn("Can't init workspace in '" + getMessageLabel(wsexplorer) + "'.", ex);

            status.message(ex.getMessage());

            return err;

        } finally {

            status.pop();

            DisposeUtils.disposeQuietly(workspace);

        }

    }

    private String getMessageLabel(JDBCServerExplorer explorer) {

        return explorer.getParameters().getUrl();

    }

    @Override

    public OnlineWorkingcopy openWorkingcopy(File wsfile) {

        if (wsfile == null) {

            return null;

        }

        JDBCServerExplorer explorer = null;

        try {

            DataManager dataManager = DALLocator.getDataManager();

            JDBCServerExplorerParameters explorerParams = (JDBCServerExplorerParameters) dataManager.createServerExplorerParameters(DataStore.H2SPATIAL_PROVIDER_NAME);

            ((HasAFile) explorerParams).setFile(wsfile);

            explorer = (JDBCServerExplorer) dataManager.openServerExplorer(

                    explorerParams.getProviderName(),

                    explorerParams

            );

            OnlineWorkingcopy workspace = openWorkingcopy(explorer);

            return workspace;

        } catch (Exception ex) {

            return null;

        } finally {

            DisposeUtils.disposeQuietly(explorer);

        }

    }

    @Override

    public OnlineWorkingcopy openWorkingcopy(JDBCServerExplorer wsexplorer) {

        if (wsexplorer == null) {

            return null;

        }

        JDBCServerExplorerParameters params = null;

        try {

            OnlineWorkingcopy workspace;

            params = wsexplorer.getParameters();

            String url = params.getUrl();

            for (Iterator<OnlineWorkingcopyDescriptor> iterator = this.workspaces.values().iterator(); iterator.hasNext();) {

                OnlineWorkingcopyDescriptorImpl value = (OnlineWorkingcopyDescriptorImpl) iterator.next();

                if (DisposeUtils.getReferences(value)<=0) {

                    iterator.remove();

                    continue;

                }

                if (value.isWorkspaceInitialized() && StringUtils.equals(url, value.getExplorerParameters().getUrl())) {

                    workspace = value.getWorkspace();//FIXME: lo siguiente solo si es null

                    //workspace.getCode(); value.getCode();

                    if (workspace.getUserIdentificationRequester() == null) {

                        workspace.setUserIdentificationRequester(this.userIdentificationRequester);

                    }

                    dropExpiredCaches();

//                    LOGGER.debug("===: OPEN WORKSPACE "+ hexId(workspace)+ " from registry (code='"+workspace.getCode()+"', label='"+workspace.getLabel()+"')");        

                    return workspace;

                }

            }

            workspace = new OnlineWorkspaceImpl(wsexplorer, this.getCodeGenerator(), null);

            workspace.setUserIdentificationRequester(this.userIdentificationRequester);

            this.registerWorkingcopy(workspace);

            dropExpiredCaches();

            return workspace;

        } catch (Exception ex) {

            LOGGER.debug("Can't get workspace from "+Objects.toString(params)+".", ex);

            return null;

        }

    }

    public OnlineWorkingcopy openWorkingcopy(File wsfile, String label) {

        if (wsfile == null) {

            return null;

        }

        JDBCServerExplorer explorer = null;

        try {

            DataManager dataManager = DALLocator.getDataManager();

            JDBCServerExplorerParameters explorerParams = (JDBCServerExplorerParameters) dataManager.createServerExplorerParameters(DataStore.H2SPATIAL_PROVIDER_NAME);

            ((HasAFile) explorerParams).setFile(wsfile);

            explorer = (JDBCServerExplorer) dataManager.openServerExplorer(

                    explorerParams.getProviderName(),

                    explorerParams

            );

            OnlineWorkingcopy workspace = openWorkingcopy(explorer, label);

            return workspace;

        } catch (Exception ex) {

            return null;

        } finally {

            DisposeUtils.disposeQuietly(explorer);

        }

    }

    @Override

    public OnlineSite connectSite(URL siteurl) throws IOException {

        OnlineSiteImpl site = new OnlineSiteImpl();

        if( siteurl!=null) {

            site.connect(siteurl);

        }

        return site;

    }

    @Override

    public WorkingArea createWorkingArea() {

        return new WorkingAreaImpl();

    }

    private OnlineCodeGenerator getCodeGenerator() {

        return new RandomCodeGenerator();

    }

}