source: 3thparty/jmessenger/src/nu/fw/jeti/backend/Handlers.java @ 3952

package nu.fw.jeti.backend;

import java.util.HashMap;
import java.util.Map;

import nu.fw.jeti.jabber.handlers.*;
import nu.fw.jeti.plugins.PluginsInfo;

/**
 * @author E.S. de Boer
 */

public class Handlers
{
        private Map handlers;
        private Map xmppHandlers;
        private InfoQueryHandler iqHandler;
        private PresenceHandler presenceHandler;
        private MessageHandler messageHandler;
        private StreamErrorHandler streamErrorHandler;

    public Handlers()
    {
                handlers = new HashMap(10);
                iqHandler = new InfoQueryHandler();
                presenceHandler  = new PresenceHandler();
                messageHandler = new MessageHandler();
                streamErrorHandler = new StreamErrorHandler();
                handlers.put("jabber:iq:auth",new IQAuthHandler());
                handlers.put("jabber:iq:roster",new RosterHandler());
                handlers.put("jabber:iq:time",new IQTimeHandler());
                handlers.put("jabber:iq:version",new IQVersionHandler());
                handlers.put("jabber:iq:register",new IQRegisterHandler());
                handlers.put("j2m:prefs",new JetiPrivateHandler());
                handlers.put("jeti:rosterprefs",new JetiPrivateRosterHandler());
                handlers.put("jabber:iq:private",new IQPrivateHandler());
                handlers.put("jabber:x:event",new XMessageEventHandler());
                handlers.put("jabber:x:delay",new XDelayHandler());
                handlers.put("jabber:iq:browse",new IQBrowseHandler());
                handlers.put("jabber:iq:last",new IQLastHandler());
                handlers.put("jabber:iq:oob",new IQXOOBHandler());
                handlers.put("jabber:x:data",new XDataHandler());
                handlers.put("http://jabber.org/protocol/disco#info",new IQDiscoInfoHandler());
                handlers.put("http://jabber.org/protocol/disco#items",new IQDiscoItemsHandler());
                handlers.put("http://jabber.org/protocol/caps",new IQXCapsHandler());
                handlers.put("urn:ietf:params:xml:ns:xmpp-stanzas",new XMPPErrorHandler());
                handlers.put("urn:ietf:params:xml:ns:xmpp-streams",new XMPPErrorHandler());
                handlers.put("unknown",new UnknownExtensionHandler());
    }
    
    public void loadExtraHandlers(Map extraHandlers)
    {
        if(PluginsInfo.isPluginLoaded("xmpp"))xmppHandlers = extraHandlers;
    }

        public PacketHandler getPacketHandler(String namespace)
        {//iq message & presence
                if ("iq".equals(namespace)) return iqHandler;
                else if ("presence".equals(namespace)) return presenceHandler;
                else if("message".equals(namespace)) return messageHandler;
                else if ("stream:error".equals(namespace)) return streamErrorHandler;
                else if(xmppHandlers!=null)
                {
                        return (PacketHandler)xmppHandlers.get(namespace);
                }
                else return null;
        }

        public synchronized ExtensionHandler getExtensionHandler(String namespace)
        {
                return (ExtensionHandler) handlers.get(namespace);
        }
        
        public synchronized void addExtensionHandler(String namespace,ExtensionHandler handler)
        {
                handlers.put(namespace,handler);
        }
        
        public synchronized void removeExtensionHandler(String namespace)
        {
                handlers.remove(namespace);
        }
}

/*
 * Overrides for emacs
 * Local variables:
 * tab-width: 4
 * End:
 */