gvSIG projects pool

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (c) 2007-2020 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 2

 * 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.swing.impl.initworkspace;

import java.awt.event.ActionEvent;

import java.awt.event.FocusEvent;

import java.awt.event.FocusListener;

import java.io.File;

import java.io.IOException;

import java.net.URL;

import java.util.ArrayList;

import java.util.List;

import javax.swing.DefaultComboBoxModel;

import javax.swing.ImageIcon;

import javax.swing.JComponent;

import javax.swing.SwingUtilities;

import javax.swing.event.ChangeEvent;

import javax.swing.event.ChangeListener;

import javax.swing.event.TableModelEvent;

import javax.swing.event.TableModelListener;

import org.apache.commons.collections4.CollectionUtils;

import org.apache.commons.lang3.StringUtils;

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

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

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

import org.gvsig.fmap.dal.swing.DALSwingLocator;

import org.gvsig.fmap.dal.swing.DataSwingManager;

import org.gvsig.fmap.mapcontrol.MapControl;

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

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

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

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

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

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

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

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

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.swing.api.OnlineJInitWorkingcopy;

import org.gvsig.online.swing.api.OnlineSwingLocator;

import org.gvsig.online.swing.api.OnlineSwingServices;

import org.gvsig.online.swing.impl.OnlineSwingCommons;

import static org.gvsig.online.swing.impl.OnlineSwingCommons.notInSwingThreadInvokeLater;

import org.gvsig.online.swing.impl.workingarea.WorkingAreaPickerControllerImpl;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dataTypes.CoercionException;

import org.gvsig.tools.dataTypes.DataTypes;

import org.gvsig.tools.dataTypes.DataTypesManager;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.i18n.I18nManager;

import org.gvsig.tools.swing.api.Component;

import org.gvsig.tools.swing.api.ToolsSwingLocator;

import org.gvsig.tools.swing.api.ToolsSwingManager;

import org.gvsig.tools.swing.api.ToolsSwingUtils;

import org.gvsig.tools.swing.api.bookmarkshistory.TextFieldWithHistoryAndBookmarkController;

import org.gvsig.tools.swing.api.pickercontroller.FilePickerController;

import org.gvsig.tools.swing.api.pickercontroller.PickerController;

import org.gvsig.tools.swing.api.task.TaskStatusController;

import org.gvsig.tools.swing.api.task.TaskStatusSwingManager;

import org.gvsig.tools.swing.api.windowmanager.Dialog;

import org.gvsig.tools.swing.api.windowmanager.WindowManager_v2;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.tools.task.UserCancelTaskException;

import org.gvsig.tools.util.LabeledValue;

import org.gvsig.tools.util.LabeledValueImpl;

import org.slf4j.LoggerFactory;

/**

 *

 * @author gvSIG Team

 */

@SuppressWarnings("UseSpecificCatch")

public class OnlineJInitWorkingcopyImpl extends OnlineJInitWorkingcopyView

        implements Component, OnlineJInitWorkingcopy  {

    private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(OnlineJInitWorkingcopyImpl.class);

    private Dialog dialog;

    private OnlineSite site;

    private JDBCServerExplorer workspaceServer;

    private FilePickerController workspaceFilePicker;

    private PickerController<JDBCServerExplorerParameters> workspaceServerPicker;

    private TextFieldWithHistoryAndBookmarkController siteURLController;

    private WorkingAreaPickerControllerImpl workingAreaPicker;

    private TaskStatusController taskStatusController;

    public OnlineJInitWorkingcopyImpl() {

        translate();

        initComponents();

    }

    private void initComponents() {

        ToolsSwingManager toolsSwingManager = ToolsSwingLocator.getToolsSwingManager();

        TaskStatusSwingManager taskStatusManager = ToolsSwingLocator.getTaskStatusSwingManager();

        OnlineSwingServices onlineservices = OnlineSwingLocator.getOnlineSwingManager().getDefaultServices();

        this.taskStatusController = taskStatusManager.createTaskStatusController(

                null,

                this.lblStatusTitle,

                this.lblStatusMessages,

                this.pbStatus,

                this.btnStatusCancel,

                null

        );

        this.taskStatusController.setShowCancelButton(false);

        this.taskStatusController.setShowRemoveTaskButton(false);

//        this.taskStatusController.bind(ToolsLocator.getTaskStatusManager());

        SwingUtilities.invokeLater(() -> {this.setVisibleStatus(false); });        

        this.workspaceFilePicker = toolsSwingManager.createFilePickerController(

                txtWorkspaceFile, 

                btnWorkspaceFile

        );

        this.workspaceFilePicker.addChangeListener((ChangeEvent e) -> {

            if (StringUtils.isBlank(this.txtWorkspaceName.getText())) {

                File file = this.workspaceFilePicker.get();

                if(file != null){

                    this.txtWorkspaceName.setText(H2SpatialUtils.removeH2FileNameExtension(file.getName()));

                }

            }

            doUpdateComponents();

        });

        this.txtWorkspaceFile.addFocusListener(new FocusListener() {

            @Override

            public void focusGained(FocusEvent e) {

                //DO NOTHING

            }

            @Override

            public void focusLost(FocusEvent e) {

                doUpdateComponents();

            }

        });

        this.txtWorkspaceName.addActionListener((ActionEvent e) -> {

            doUpdateComponents();

        });

        this.txtWorkspaceName.addFocusListener(new FocusListener() {

            @Override

            public void focusGained(FocusEvent e) {

                //DO NOTHING

            }

            @Override

            public void focusLost(FocusEvent e) {

                doUpdateComponents();

            }

        });

        this.siteURLController = toolsSwingManager.createTextFieldWithHistoryAndBookmarkController(

                OnlineSwingCommons.BOOKMARKSANDHISTORY_SITE_URL,

                txtSiteURL,

                btnSiteURLRefresh,

                btnSiteURLHistory,

                btnSiteURLBookmarks

        );

        this.siteURLController.setEnabled(true);

        this.siteURLController.addActionListener((ActionEvent e) -> {

            doChangeSiteURL();

        });

        this.cboProjects.addActionListener((ActionEvent e) -> {

            SwingUtilities.invokeLater(() -> {doChangeProject();});

        });

        this.workingAreaPicker = new WorkingAreaPickerControllerImpl(

            () -> {return getSite();},

            txtWorkingAreaLabel,

            txtWorkingArea,

            btnWorkingAreaFromView,

            btnWorkingAreaDialog,

            btnWorkingAreaHistory,

            btnWorkingAreaBookmarks,

            () -> {

                LabeledValue<MapControl> n = onlineservices.getActiveMapControl();

                return (n == null) ? null : n.getValue();

            },

            () -> {

                List<OnlineLayer> selectedLayers = getLayersModel().getSelectedLayers();

                if (selectedLayers.isEmpty()) {

                    return null;

                }

                return selectedLayers;

            }

        );

        this.workingAreaPicker.addChangeListener((ChangeEvent e) -> {

            doUpdateComponents();

        });

        SwingUtilities.invokeLater(() -> { clearMessage(); });

        ToolsSwingUtils.ensureRowsCols(this, 15, 40, 25, 100);

    }

    @Override

    public void setDialog(Dialog dialog) {

        this.dialog = dialog;

        this.doUpdateComponents();

    }

    private void doUpdateComponents() {

        message("");

        boolean enableAll = true;

        boolean isThereURL = false;

        boolean isThereProject = false;

        boolean isThereDbfile = false;

        boolean isThereWsName = false;

        boolean isThereSelectedsLayers = false;

        boolean isThereWorkingArea = false;

        // 0. Check is processing

        enableAll = !this.isProcessing();

        // 1. Check Site URL

        if( enableAll ) {

            URL url = this.getSiteURL();

            isThereURL = (url != null);

            if( !isThereURL ) {

                if( StringUtils.isBlank(this.txtSiteURL.getText()) ) {

                    message2(enableAll, "_The_site_url_is_blank");

                } else {

                    message2(enableAll, "_Invalid_site_url");

                }

            }

            enableAll = enableAll && isThereURL;

        }

        // 2. Check online project

        if( enableAll ) {

            OnlineProject project = this.getProject();

            isThereProject = (project != null);

            if( !isThereProject ) {

                message2(enableAll, "_Select_a_Online_project");

            }

            enableAll = enableAll && isThereProject;

        }

        // 3. Check workspace file

        if( enableAll ) {

            File f = this.getWorkspaceFile();

            isThereDbfile = (f!=null);

            if( !isThereDbfile ) {

                message2(enableAll, "_Selected_working_copy_file_is_not_valid");

            } else {

                f = H2SpatialUtils.normalizeH2File(f);

                if( f.exists() ) {

                    message2(enableAll, "_Selected_working_copy_file_already_exists");

                    isThereDbfile = false;

                }

            }

            enableAll = enableAll && isThereDbfile;

        }

        // 4. Check workspace name        

        if( enableAll ) {

            String wsname = this.getWorkspaceName();

            isThereWsName = StringUtils.isNotBlank(wsname);

            if( !isThereWsName ) {

                message2(enableAll, "_Need_a_working_copy_name");

            } else {

                OnlineManager manager = OnlineLocator.getOnlineManager();

                OnlineWorkingcopyDescriptor ws = manager.getWorkingcopyDescriptor(wsname);

                if( ws!=null ) {

                    message2(enableAll, "_A_working_copy_with_that_name_already_exists");

                    isThereWsName = false;

                }

            }

            enableAll = isThereURL && isThereWsName;

        }

        // 5. Check layers selected

        if( enableAll || isThereProject ) {

            isThereSelectedsLayers = !this.getLayersModel().isSelectionEmpty();

            if( !isThereSelectedsLayers ) {

                message2(enableAll, "_You_must_select_some_layer");

            }

            enableAll = isThereURL && isThereSelectedsLayers;

        }

        // 6. Check selected working area

        if( enableAll || isThereProject ) {

            WorkingArea workingArea = this.workingAreaPicker.getWithoutAddHistory();

            isThereWorkingArea = (workingArea != null && workingArea.getValue() != null);

            if( !isThereWorkingArea ) {

                message2(enableAll, "_You_must_select_a_working_area");

            }

            enableAll = isThereURL && isThereWorkingArea;

        }

        this.siteURLController.setEnabled(!this.isProcessing());

        this.cboProjects.setEnabled(isThereURL && this.cboProjects.getModel().getSize()>0 );

        this.workspaceFilePicker.setEnabled(isThereProject);

        this.chkCreateConnectionToDatabase.setEnabled(isThereProject && isThereDbfile);

        this.txtWorkspaceName.setEnabled(isThereProject && isThereDbfile);

        this.tblLayers.setEnabled(isThereURL && isThereProject);

        this.txtWorkingAreaLabel.setEnabled(isThereProject);

        this.txtWorkingArea.setEnabled(isThereProject);

        this.btnWorkingAreaFromView.setEnabled(isThereProject);

        this.btnWorkingAreaDialog.setEnabled(isThereSelectedsLayers);

        if (this.dialog != null) {

            this.dialog.setButtonEnabled(WindowManager_v2.BUTTON_OK,enableAll);

        }

    }

    @Override

    public JComponent asJComponent() {

        return this;

    }

    private void translate() {

        ToolsSwingManager swingManager = ToolsSwingLocator.getToolsSwingManager();

        swingManager.translate(this.chkCreateConnectionToDatabase);

        swingManager.translate(this.lblWorkspaceName);

        swingManager.translate(this.lblSiteUrl);

        swingManager.translate(this.lblProjects);

        swingManager.translate(this.lblWorkspaceFile);

        swingManager.translate(this.lblLayers);

        swingManager.translate(this.lblWorkspaceFile);

        swingManager.translate(this.lblWorkingArea);

        swingManager.translate(this.btnWorkingAreaFromView);

        swingManager.translate(this.btnWorkingAreaDialog);

    }

    private URL getSiteURL() {

        if(siteURLController.isEnabled()){

            String value = this.siteURLController.getText();

            URL url;

            DataTypesManager manager = ToolsLocator.getDataTypesManager();

            try {

                 url = (URL) manager.coerce(DataTypes.URL, value);

            } catch (CoercionException ex) {

                String s = (value==null)? "null":StringUtils.abbreviate(value, 100);

                LOGGER.warn("Can't coerce value ("+s+") to "+DataTypes.URL_NAME+".", ex);

                return null;

            }

            return url;

        }

        return null;

    }

    private File getWorkspaceFile() {

        File file = this.workspaceFilePicker.get();

        return file;

    }

    @Override

    public int actionPerformed() {

        I18nManager i18n = ToolsLocator.getI18nManager();

        OnlineManager manager = OnlineLocator.getOnlineManager();

        OnlineProject theProject = this.getProject();

        WorkingArea workingArea = this.workingAreaPicker.get();

        if (theProject == null ) {

            return ERR_PROJECT_REQUIRED;

        }

        if (workingArea==null ) {

            return ERR_WORKINGAREA_REQUIRED;

        }

        int err = ERR_NO_ERROR;

        SimpleTaskStatus status = this.getTaskStatus();

        try {

            File file = this.getWorkspaceFile();

            if (file != null) {

                status.setTitle(i18n.getTranslation("_Initializing_workspace"));

                err = manager.initWorkingcopy(file, theProject, getWorkspaceName(), getTaskStatus());

                if (err == ERR_NO_ERROR ) {

                    OnlineWorkingcopy ws = manager.openWorkingcopy(file);

                    if( this.chkCreateConnectionToDatabase.isSelected() ) {

                        ws.addToConnectionPool();

                    }

                    ws.download_config(true, status);

                    ws.download_resources(true, status);

                    ws.setCurrentWorkingArea(workingArea);

                    LayersTableModel model = (LayersTableModel) this.tblLayers.getModel();

                    List<OnlineLayer> selectedLayers = model.getSelectedLayers();

                    if( !CollectionUtils.isEmpty(selectedLayers) ) {

                        status.setRangeOfValues(0, selectedLayers.size());

                        status.setCurValue(0);

                        for (OnlineLayer layer : selectedLayers) {

                            status.incrementCurrentValue();

                            status.setTitle(i18n.getTranslation("_Adding_layer")+" "+layer.getName());

                            if( status.isCancellationRequested() ) {

                                status.cancel();

                                throw new UserCancelTaskException();

                            }

                            String fieldForLabel = "ogc_fid"; // FIXME: Pedir en el GUI

                            String label = layer.getName(); // FIXME: Pedir en el GUI

                            int tileSize = layer.calculateTileSize(5000, status);

                            ws.addEntity(

                                    layer.getFeatureType(), 

                                    layer.getName(), 

                                    layer.getTitle(), 

                                    fieldForLabel, 

                                    label, 

                                    layer.getPkName(),

                                    tileSize

                            );

                        }

                        status.setRangeOfValues(0, selectedLayers.size());

                        status.setCurValue(0);

                        for (OnlineLayer layer : selectedLayers) {

                            status.incrementCurrentValue();

                            status.setTitle(i18n.getTranslation("_Downloading_layer")+" "+layer.getName());

                            if( status.isCancellationRequested() ) {

                                status.cancel();

                                throw new UserCancelTaskException();

                            }

                            err = ws.download(layer.getName(),workingArea.getValue(), status);

                            if (err != ERR_NO_ERROR ) {

                                // TODO: Que hacer aqui si da error

                            }

                        }

                    }

                }

            }

        } catch (UserCancelTaskException ex) {

            LOGGER.info("Cancelled by user.");

            err = OnlineManager.ERR_CANCELLED_BY_USER;

        } catch (Exception ex) {

            LOGGER.info("Can't initialize workspace", ex);

            err = OnlineManager.ERR_EXCEPTION;

        }

        if( err==ERR_NO_ERROR || err == OnlineManager.ERR_CANCELLED_BY_USER) {

            URL siteurl = getSiteURL();

            if( siteurl != null ) {

                this.siteURLController.addHistory(siteurl.toString());

            }

        }

        return err;

    }

    private OnlineSite getSite() {

        if (site == null){

            try {

                OnlineManager manager = OnlineLocator.getOnlineManager();

                URL url = getSiteURL();

                if (url != null){

                    site = manager.connectSite(url);

                }

            } catch (IOException ex) {

                LOGGER.warn("Can't connect to site '"+this.txtSiteURL.getText()+"'", ex);

            }

        }

        return site;

    }

    private OnlineProject getProject() {

        OnlineSite theSite = this.getSite();

        if( theSite == null ) {

            return null;

        }

        LabeledValue<Integer> item = (LabeledValue<Integer>) this.cboProjects.getSelectedItem();

        if( item == null ) {

            return null;

        }

        return theSite.getProject(item.getValue());

    }

    @Override

    public String getWorkspaceName() {

        return txtWorkspaceName.getText();

    }

    public static void selfRegister() {

    }

    @Override

    public boolean isProcessing() {

        return false;

    }

    private void message2(boolean doMessage, String s) {

        if( doMessage ) {

            message(s);

        }

    }

    private void message(String message) {

        if( notInSwingThreadInvokeLater(() -> {message(message);}) ) {

            return;

        }

        String s = message;

        if( StringUtils.startsWith(s, "_") ) {

            I18nManager i18n = ToolsLocator.getI18nManager();

            s = i18n.getTranslation(s);

        }

        this.lblStatusMessages.setText(s);

//        this.lblStatusMessages.setToolTipText(toolTipText);        

    }

    @Override

    public ImageIcon loadImage(String imageName) {

        return OnlineSwingCommons.loadImage(imageName);

    }

    private void doChangeSiteURL() {

        String url_s = null;

        try {

            OnlineManager onlineManager = OnlineLocator.getOnlineManager();

            url_s = this.siteURLController.getText();

            if( StringUtils.isBlank(url_s) ) {

                DisposeUtils.dispose(this.site);

                this.site = null;

                return;

            }

            URL url = new URL(url_s);

            this.site = onlineManager.connectSite(url);

            this.siteURLController.addHistory(url_s);

            doFillProjects();

            doUpdateComponents();

        } catch (Exception ex) {

            LOGGER.warn("Can't chage site url ("+url_s+").",ex);

        }        

    }

    private void doFillProjects() {

        OnlineSite theSite = this.getSite();

        if( theSite == null ) {

            return;

        }

        List<LabeledValue<Integer>> projects = new ArrayList<>();

        for (OnlineProject project : theSite.projects()) {

            projects.add(new LabeledValueImpl<>(project.getTitle(),project.getId()));

        }

        projects.sort((LabeledValue<Integer> o1, LabeledValue<Integer> o2) -> o1.getLabel().compareTo(o2.getLabel()));

        DefaultComboBoxModel<LabeledValue<Integer>> model = new DefaultComboBoxModel<>();

        for (LabeledValue<Integer> project : projects) {

            model.addElement(project);

        }

        this.cboProjects.setModel(model);

        this.cboProjects.setSelectedIndex(-1);

        this.workspaceFilePicker.set(null);

        this.txtWorkspaceName.setText("");

        this.clearLayers();

    }

    private void doChangeProject() {

        OnlineSite theSite = this.getSite();

        LabeledValue<Integer> selected = (LabeledValue<Integer>) this.cboProjects.getSelectedItem();

        if( selected == null || theSite == null ) {

            this.workspaceFilePicker.set(null);

            this.txtWorkspaceName.setText("");

            this.clearLayers();

            return;

        }

        int projectId = selected.getValue();

        OnlineProject project = theSite.getProject(projectId);

        List<OnlineLayer> layers = new ArrayList<>();

        for (OnlineLayer layer : project.layers()) {

            if( layer.isHidden() ) {

                continue;

            }

            layers.add(layer);

        }

        layers.sort((OnlineLayer o1, OnlineLayer o2) -> o1.getLabel().compareTo(o2.getLabel()));

        LayersTableModel model = new LayersTableModel(layers);

        model.addTableModelListener(new TableModelListener() {

            @Override

            public void tableChanged(TableModelEvent e) {

                doUpdateComponents();

            }

        });

        this.tblLayers.setModel(model);

        doUpdateComponents();

    }

    private void clearLayers() {

        LayersTableModel model = new LayersTableModel();

        this.tblLayers.setModel(model);

    }

    private LayersTableModel getLayersModel() {

        return (LayersTableModel) this.tblLayers.getModel();

    }

    private SimpleTaskStatus getTaskStatus() {

        SimpleTaskStatus taskStatus = ToolsLocator.getTaskStatusManager().createDefaultSimpleTaskStatus("_Create_workingcopy");

        taskStatus.setAutoremove(true);

        taskStatus.add();

        taskStatus.setIndeterminate();

        this.taskStatusController.bind(taskStatus);

        return taskStatus;

    }

    public void setVisibleStatus(boolean visible) {

        if( notInSwingThreadInvokeLater(() -> {setVisibleStatus(visible);}) ) {

            return;

        }

        this.lblStatusTitle.setVisible(visible);

        this.pbStatus.setVisible(visible);

        this.lblStatusMessages.setVisible(true);

    }

    private void clearMessage() {

        message(" ");

    }

}