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.io.InputStream;

import java.net.URI;

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 javax.json.JsonObject;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.lang3.mutable.Mutable;

import org.apache.commons.lang3.mutable.MutableInt;

import org.apache.commons.lang3.mutable.MutableObject;

import org.apache.http.HttpResponse;

import org.apache.http.NameValuePair;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.ResponseHandler;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClientBuilder;

import org.apache.http.message.BasicNameValuePair;

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.json.Json;

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 static org.gvsig.online.lib.api.OnlineUserIdentificationRequester.CONFIG_FACTORYNAME_NAME;

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

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.api.OnlineUserIdentificationRequester.OnlineUserIdentificationRequesterConfig;

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

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;

import org.gvsig.tools.util.Factory;

@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 Map<String,OnlineUserIdentificationRequesterFactory> userIdentificationRequesters;

    private Map<String,OnlineWorkingcopyDescriptor> workspaces;

    public OnlineManagerImpl() {

        this.workspaces = new HashMap<>();

        this.userIdentificationRequesters = new HashMap<>();

    }

    @Override

    public String getErrorMessage(int errcode) {

        return OnlineUtils.getErrorMessage(errcode);

    }

    @Override

    public void addUserIdentificationRequester(OnlineUserIdentificationRequesterFactory factory) {        

        this.userIdentificationRequesters.put(factory.getName(), factory);

    }

    @Override

    public OnlineUserIdentificationRequesterFactory getUserIdentificationRequester(String mode) {

        return this.userIdentificationRequesters.get(mode);

    }

    @Override

    public OnlineUserIdentificationRequesterConfig getUserIdentificationRequester(JsonObject json) {

        String factoryName = json.getString(CONFIG_FACTORYNAME_NAME, null);

        String urlOnline = json.getString(CONFIG_URLONLINE_NAME, null);

        OnlineUserIdentificationRequesterFactory factory = this.getUserIdentificationRequester(factoryName);

        OnlineUserIdentificationRequesterConfig config = factory.create(urlOnline);

        config.fromJson(json);

        return config;

    }

    @Override

    public Iterable<OnlineUserIdentificationRequesterFactory> getUserIdentificationRequesters() {

        return this.userIdentificationRequesters.values();

    }

    @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.userIdentificationRequesters = 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);

            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);

            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

                    dropExpiredCaches();

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

                    return workspace;

                }

            }

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

            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(OnlineUserIdentificationRequesterConfig userIdentificationRequesterConfig, URL siteurl) throws IOException {

        OnlineSiteImpl site = new OnlineSiteImpl();

        if( siteurl!=null) {

            site.connect(userIdentificationRequesterConfig, siteurl);

        }

        return site;

    }

    @SuppressWarnings("Convert2Lambda")

    @Override

    public String authenticate(String urlbase, String userId, String password) {

        try {

            MutableInt statusCode = new MutableInt();

            Mutable<String> token = new MutableObject<>();

            if( !StringUtils.endsWith("/", urlbase) ) {

                urlbase += "/";

            }                

            URI uri = new URI(urlbase+"auth/api-token-auth/");

            int numretries = 3;

            for (int retries = 0; retries < numretries; retries++) {            

                HttpPost request = new HttpPost(uri);

                List<NameValuePair> params = new ArrayList<>();

                params.add(new BasicNameValuePair("username", userId));

                params.add(new BasicNameValuePair("password", password));

                UrlEncodedFormEntity formdata = new UrlEncodedFormEntity(params);

                request.setEntity(formdata);

                request.setHeader("Content-type","application/x-www-form-urlencoded");

                CloseableHttpClient httpClient = HttpClientBuilder.create().build();                

                ResponseHandler responseHandler = new ResponseHandler() {

                    @Override

                    public Object handleResponse(HttpResponse response) throws ClientProtocolException, IOException {

                        statusCode.setValue(response.getStatusLine().getStatusCode());

                        InputStream content = response.getEntity().getContent();

                        JsonObject resp = Json.createObject(content);

                        token.setValue(resp.getString("token", null));

                        return null;

                    }

                };

                httpClient.execute(request,responseHandler);  

                if( statusCode.getValue()==200 ) {

                    break;

                }

            }

            if( statusCode.getValue()!=200 ) {

                LOGGER.warn("Toomany retries for authenticate (HTTP status "+statusCode.toString()+")");

                return null;

            }

            String authorization = "JWT " + token.getValue();

            return authorization;

        } catch (Exception ex) {

            LOGGER.warn("", ex);

            throw new RuntimeException("Can't get authorization from '"+urlbase+"' for user '"+userId+"'.", ex);

        }

    }

    @Override

    public WorkingArea createWorkingArea() {

        return new WorkingAreaImpl();

    }

    private OnlineCodeGenerator getCodeGenerator() {

        return new RandomCodeGenerator();

    }

}