Application: gvSIG desktop

/**

 * 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.andami.messages;

import java.awt.Component;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.util.ArrayList;

import java.util.Vector;

import javax.swing.JOptionPane;

import javax.swing.Timer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.andami.PluginServices;

import org.gvsig.tools.exception.IBaseException;

/**

 * Clase que recibe los mensajes de error, warning e informaci?n y dispara los

 * eventos en los listeners que escuchan dichos eventos

 *

 * @version $Revision: 35350 $

 */

public class NotificationManager {

        private static int SIZE_MESSAGE=4;

    /** DOCUMENT ME! */

    private static Logger logger = LoggerFactory.getLogger(NotificationManager.class.getName());

    /** Timer de espera de nuevos mensajes */

    private static Timer timer;

    /** Indica si se han a?adido mensajes desde la ?ltima vez que se comprob? */

    private static boolean addedMessage = false;

    /** DOCUMENT ME! */

    private static ArrayList info = new ArrayList();

    private static ArrayList infoExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static ArrayList warnings = new ArrayList();

    private static ArrayList warningsExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static ArrayList errors = new ArrayList();

    private static ArrayList errorsExceptions = new ArrayList();

    /** DOCUMENT ME! */

    private static Vector listeners = new Vector();

    private static boolean isFirst = true;

    /**

     * A?ade un objeto que escucha los mensajes de error, warning e informaci?n

     *

     * @param nl objeto que recibir? los eventos

     */

    public static synchronized void addNotificationListener(NotificationListener nl) {

        logger.info("Se a?ade un listener al manager de notificaciones (" + nl.getClass().getName() +"/"+ nl.toString() + ")");

        listeners.add(nl);

    }

    /**

     * @see com.iver.mdiApp.Notification#addError(java.lang.String)

     */

    public static synchronized void addError(final String err, Throwable e) {

            logger.error(err, e);

        dispatchError(err, e);

    }

    public static synchronized void dispatchError(final String err, Throwable e) {

        errors.add(err);

        errorsExceptions.add(e);

        if (isFirst) {

            AddError((String[]) errors.toArray(new String[0]),

                (Throwable[]) errorsExceptions.toArray(new Throwable[0]));

            errors.clear();

            errorsExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /**

     * @see com.iver.mdiApp.Notification#addWarning(java.lang.String)

     */

    public static synchronized void addWarning(final String warn,

        final Throwable e) {

        logger.warn(warn, e);

        dispatchWarning(warn, e);

    }

    public static synchronized void dispatchWarning(final String warn,

        final Throwable e) {

        warnings.add(warn);

        warningsExceptions.add(e);

        if (isFirst) {

            AddWarning((String[]) warnings.toArray(new String[0]),

                (Throwable[]) warningsExceptions.toArray(new Throwable[0]));

            warnings.clear();

            warningsExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /*

     * @see com.iver.mdiApp.Notification#addWarning(java.lang.String)

     */

    public static synchronized void addWarning(final String warn) {

                addWarning(warn,null);

    }

    /*

     * @see com.iver.mdiApp.Consola#addInfo(java.lang.String)

     */

    public static synchronized void addInfo(final String inf, final Throwable e) {

                logger.info(inf, e);

        info.add(inf);

        infoExceptions.add(e);

        if (isFirst) {

            AddInfo((String[]) info.toArray(new String[0]),

                (Throwable[]) infoExceptions.toArray(new Throwable[0]));

            info.clear();

            infoExceptions.clear();

            isFirst = false;

        }

        dispatchMessages();

    }

    /*

     * @see com.iver.mdiApp.Consola#addInfo(java.lang.String)

     */

    public static synchronized void addInfo(final String inf) {

                addInfo(inf,null);

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de error a todos los listeners registrados

     *

     * @param error Mensaje de error

     * @param e s que van a recibir las notificaciones

     */

    private static void AddError(String[] error, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).errorEvent(new MessageEvent(

                    error, e));

        }

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de error a todos los listeners registrados

     *

     * @param warn Mensaje de warning

     * @param e objetos que van a recibir las notificaciones

     */

    private static void AddWarning(String[] warn, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).warningEvent(new MessageEvent(

                    warn, e));

        }

    }

    /**

     * M?todo que es ejecutado en el thread de la interfaz y que se encarga de

     * avisar del mensaje de informaci?n a todos los listeners registrados

     *

     * @param info Mensaje de informaci?n

     * @param e objetos que van a recibir las notificaciones

     */

    private static void AddInfo(String[] info, Throwable[] e) {

        for (int i = 0; i < listeners.size(); i++) {

            ((NotificationListener) listeners.get(i)).infoEvent(new MessageEvent(

                    info, e));

        }

    }

    /**

     * DOCUMENT ME!

     */

    private static void dispatchMessages() {

        addedMessage = true;

        if (timer == null) {

            timer = new Timer(1000, new ActionListener() {

                                public void actionPerformed(ActionEvent e) {

                                if (errors.size() > 0) {

                                    AddError((String[]) errors.toArray(new String[0]),

                                        (Throwable[]) errorsExceptions.toArray(new Throwable[0]));

                                    errors.clear();

                                    errorsExceptions.clear();

                                }

                                if (warnings.size() > 0) {

                                    AddWarning((String[]) warnings.toArray(new String[0]),

                                        (Throwable[]) warningsExceptions.toArray(new Throwable[0]));

                                    warnings.clear();

                                    warningsExceptions.clear();

                                }

                                if (info.size() > 0) {

                                    AddInfo((String[]) info.toArray(new String[0]),

                                        (Throwable[]) infoExceptions.toArray(new Throwable[0]));

                                    info.clear();

                                    infoExceptions.clear();

                                }

                                if (!addedMessage) {

                                    if (timer != null) {

                                        timer.stop();

                                    }

                                    timer = null;

                                }

                                addedMessage = false;

                                isFirst = true;

                                }

                        });

            timer.start();

        }

    }

        public static void addError(Throwable e1) {

            if( e1 instanceof IBaseException ) {

            IBaseException ex = (IBaseException) e1;

                String msg;

                try {

                    msg = ex.getLocalizedMessageStack();

                } catch(Exception ex1) {

                    try {

                        msg = ex.getMessageStack();

                    } catch(Exception ex2) {

                        msg = ex.getMessage();

                    }

                }

            addError(msg, e1);

            } else {

                addError(e1.toString(), e1);

            }

        }

        public static void showMessageError(String message,Exception e) {

                message=splitMessage(message);

                JOptionPane.showMessageDialog((Component)PluginServices.getMainFrame(),message,PluginServices.getText(NotificationManager.class,"error"),JOptionPane.ERROR_MESSAGE);

                NotificationManager.addWarning(message,e);

        }

        public static void showMessageWarning(String message,Exception e) {

                message=splitMessage(message);

                JOptionPane.showMessageDialog((Component)PluginServices.getMainFrame(),message,PluginServices.getText(NotificationManager.class,"warning"),JOptionPane.WARNING_MESSAGE);

                NotificationManager.addWarning(message,e);

        }

        public static void showMessageInfo(String message,Exception e) {

                message=splitMessage(message);

                JOptionPane.showMessageDialog((Component)PluginServices.getMainFrame(),message,PluginServices.getText(NotificationManager.class,"info"),JOptionPane.INFORMATION_MESSAGE);

                NotificationManager.addInfo(message,e);

        }

        private static String splitMessage(String message) {

                String[] messages=message.split("\n");

                String resultMessage="";

                for (int i=0;i<messages.length && i<=SIZE_MESSAGE;i++){

                        resultMessage+=(messages[i]);

                        resultMessage+=("\n");

                }

                return resultMessage;

        }

}