Application: gvSIG desktop » gvSIG tools: Catalog

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2004 IVER T.I. and Generalitat Valenciana.

 *

 * 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., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package org.gvsig.catalog.ui.serverconnect;

import java.awt.BorderLayout;

import java.awt.Cursor;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.FileReader;

import java.io.IOException;

import java.net.URL;

import java.util.Iterator;

import java.util.TreeMap;

import javax.swing.Icon;

import javax.swing.ImageIcon;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JPanel;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.catalog.CatalogClient;

import org.gvsig.catalog.CatalogLocator;

import org.gvsig.catalog.CatalogManager;

import org.gvsig.catalog.drivers.DiscoveryServiceCapabilities;

import org.gvsig.catalog.drivers.ICatalogServiceDriver;

import org.gvsig.catalog.ui.search.SearchDialog;

import org.gvsig.catalog.ui.serverproperties.ServerPropertiesDialog;

import org.gvsig.catalog.utils.CatalogConstants;

import org.gvsig.i18n.Messages;

import org.gvsig.utils.swing.jcomboServer.ServerData;

/**

 * 

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public class ServerConnectDialogPanel extends JPanel implements ActionListener {

    private static Logger logger =

        LoggerFactory.getLogger(ServerConnectDialogPanel.class);

        private static final CatalogManager catalogManager = CatalogLocator.getCatalogManager();

        private static final long serialVersionUID = 1224880378648403038L;

        private static TreeMap serverList = new TreeMap();

        private ServerConnectPanel controlsPanel = null;

        private JFrame parent = null;

        protected CatalogClient client = null;

        protected String serversFile = "servers"

            + File.separator+ "CatalogServers.txt";

        protected String currentServer = "";

        private ConnectThread connectThread = null;

        /**

         * Constructor

         * @param parent 

         */

        public  ServerConnectDialogPanel(JFrame parent) {

                this.parent = parent;

                this.setLayout(new BorderLayout());

                add(getControlsPanel(),BorderLayout.CENTER);

                //Loads the servers

                int n_servers = loadServerList(serversFile);

              //Load the protocols

        controlsPanel.loadDrivers(

                catalogManager.getDrivers());

        getControlsPanel().setPropertiesIcon(getPropertiesIcon());

                if (n_servers == 0) {

                    return;

                }

                //Load the first protocol

                controlsPanel.setProtocol(controlsPanel.getServer().getServiceSubType());

                enableServerPropertiesButton();

        } 

        /**

         * @return the main panel

         */

        public ServerConnectPanel getControlsPanel() {        

                if (controlsPanel == null) {

                        controlsPanel = new ServerConnectPanel();

                        controlsPanel.addActionListener(this);

                        controlsPanel.enableSearchButton(false);

                }

                return controlsPanel;

        } 

        /**

         * It adds a server in the TreeMap Object

         * @param server 

         */

        protected static void addTreeMapServer(ServerData server) {        

                if (ServerConnectDialogPanel.serverList == null) {

                        ServerConnectDialogPanel.serverList = new TreeMap();

                }

                serverList.put(server.getServerAddress(), server);

        } 

        /**

         * This method loads a server list in the combo

         * @param sfile 

         */

        private int loadServerList(String sfile) {

                int n = loadServersFromFile(sfile);

                if (n == 0) {

                    return 0;

                }

                Iterator iter = serverList.keySet().iterator();

                while (iter.hasNext()) {

                        ServerData server = (ServerData) serverList.get((String) iter.next());

                        controlsPanel.addServer(server);

                }

                return n;

        } 

        /**

         * It loads a server list from a text file

         * @param sfile 

         * File that contains the rervers

         */

        private int loadServersFromFile(String sfile) {

            int servers_loaded = 0;

                File file = null;

                try {

                    URL uf = getClass().getClassLoader().getResource(sfile);

                        if (uf != null) {

                            file = new File(uf.getFile());

                            if (!file.exists()) {

                                throw new FileNotFoundException(file.getAbsolutePath());

                            }

                            FileReader _fr = new FileReader(file);

                                BufferedReader _br = new BufferedReader(_fr);

                                String s;

                                while ((s = _br.readLine()) != null) {

                                        addTreeMapServer(new ServerData(s,"",""));

                                        servers_loaded++;

                                }

                                _br.close();

                                _fr.close();

                        } else {

                            throw new FileNotFoundException(sfile);

                        }

                } catch (Exception e) {

                    logger.info("Error while loading server list file: " + e.getMessage());

            String tit = Messages.getText("_Loading_servers");

            String msg = Messages.getText("_Unable_to_load_server_list_file")

                + ": " + sfile;

            JOptionPane.showMessageDialog(

                this,

                msg, tit, JOptionPane.ERROR_MESSAGE);

                }

                return servers_loaded;

        } 

        /*

         * (non-Javadoc)

         * @see java.awt.event.ActionListener#actionPerformed(java.awt.event.ActionEvent)

         */

        public void actionPerformed(ActionEvent e) {        

                if (e.getActionCommand().compareTo(CatalogConstants.CONNECT_BUTTON_ACTION_COMMAND)==0) {

                        connectButtonActionPerformed();

                }else if (e.getActionCommand().compareTo(CatalogConstants.SEARCH_BUTTON_ACTION_COMMAND)==0) {

                        searchButtonActionPerformed();

                }else if (e.getActionCommand().compareTo(CatalogConstants.CLOSE_BUTTON_ACTION_COMMAND)==0) {

                        closeButtonActionPerformed();

                }else if (e.getActionCommand().compareTo(CatalogConstants.PROTOCOL_COMBO_ACTION_COMMAND)==0){

                        enableServerPropertiesButton();

                }else if (e.getActionCommand().compareTo(CatalogConstants.SERVERPROPERTIES_BUTTON_ACTION_COMMAND)==0) {

                        serverPropertiesButtonActionPerformed();

                }else if (e.getActionCommand().compareTo(CatalogConstants.SERVER_COMBO_ACTION_COMMAND)==0) {

                        controlsPanel.updateProtocol();

                }

        }

        /**

         * Enable the server properties button

         */

        private void enableServerPropertiesButton(){

                if(((ICatalogServiceDriver)controlsPanel.getDriver()).getProfile() == null){

                        controlsPanel.enableServerPropertiesButton(false);

                }else{

                        controlsPanel.enableServerPropertiesButton(true);

                }

        }

        /**

         * Action when the search button is clicked

         */

        protected void searchButtonActionPerformed() {        

                setEnabled(false);

                new SearchDialog(client,parent);

        } 

        /**

         * It is thrown the the server properties button is clicked

         */

        protected void serverPropertiesButtonActionPerformed(){

                createClient();

                new ServerPropertiesDialog(

                                controlsPanel.getServer(),

                                client,

                                ((ICatalogServiceDriver)controlsPanel.getDriver()).getProfile());

        }

        /**

         * It is thrown the the connect button is clicked

         */

        protected void connectButtonActionPerformed() {        

                controlsPanel.enableSearchButton(false);                

                createClient();                

                if (connectThread != null){

                        connectThread.stop();

                }

                connectThread = new ConnectThread();

                setCursor(new Cursor(Cursor.WAIT_CURSOR));

        } 

        /**

         * Create the catalog client

         */

        protected void createClient(){

                ServerData serverData = null;

                if (client != null){

                        serverData = client.getServerData();

                }

                client = new CatalogClient(controlsPanel.getServerAddress(),

                                controlsPanel.getDatabase(),

                                (ICatalogServiceDriver)controlsPanel.getDriver());

                client.setServerData(serverData);

        }

        /**

         *  * It is thrown the the close button is clicked

         */

        protected void closeButtonActionPerformed() {        

                parent.setVisible(false);

                System.exit(0);

        } 

        /**

         * @return Returns the serversFile.

         */

        public String getServersFile() {        

                return serversFile;

        } 

        /**

         * @param serversFile The serversFile to set.

         */

        public void setServersFile(String srv_file) {        

                this.serversFile = srv_file;

        } 

        /**

         * @return Returns the currentServer.

         */

        public String getCurrentServer() {        

                return currentServer;

        } 

        /**

         * @return Returns the client.

         */

        public CatalogClient getClient() {        

                return client;

        } 

        protected Icon getPropertiesIcon(){

                return new ImageIcon("./gvSIG/extensiones/org.gvsig.catalog/images/serverProperties.png");

        }

        /**

         * This class is used to manage the searches.

         * It contains method to start and to stop a thread. It is

         * necessary to create because "stop" method (for the Thread class)

         * is deprecated.

         * 

         * 

         * @author Jorge Piera Llodra (piera_jor@gva.es)

         */

        private class ConnectThread implements Runnable {

                volatile Thread myThread = null;

                public  ConnectThread() {        

                        myThread = new Thread(this);

                        myThread.start();

                } 

                public void stop(){

                        myThread.stop();

                }

                /*

                 * (non-Javadoc)

                 * @see java.lang.Runnable#run()

                 */

                public void run() {        

                        try {

                                DiscoveryServiceCapabilities capabilities = client.getCapabilities();

                                if (capabilities.isAvailable()){

                                        controlsPanel.enableSearchButton(true);

                                        currentServer = controlsPanel.getServerAddress();

                                        searchButtonActionPerformed();                                

                                } 

                                controlsPanel.setServerReply(capabilities.getServerMessage());

                        } catch (Exception e) {

                                controlsPanel.setServerReply(Messages.getText(e.toString()));

                                logger.info("While connecting to server.", e);

                        }

            setCursor(new Cursor(Cursor.DEFAULT_CURSOR)); 

                }

        }        

}