summaryrefslogtreecommitdiffstats
path: root/kopete/libkopete/kopetemessagehandlerchain.cpp
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commitbcb704366cb5e333a626c18c308c7e0448a8e69f (patch)
treef0d6ab7d78ecdd9207cf46536376b44b91a1ca71 /kopete/libkopete/kopetemessagehandlerchain.cpp
downloadtdenetwork-bcb704366cb5e333a626c18c308c7e0448a8e69f.tar.gz
tdenetwork-bcb704366cb5e333a626c18c308c7e0448a8e69f.zip
Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.
BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdenetwork@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'kopete/libkopete/kopetemessagehandlerchain.cpp')
-rw-r--r--kopete/libkopete/kopetemessagehandlerchain.cpp186
1 files changed, 186 insertions, 0 deletions
diff --git a/kopete/libkopete/kopetemessagehandlerchain.cpp b/kopete/libkopete/kopetemessagehandlerchain.cpp
new file mode 100644
index 00000000..fe1e96ab
--- /dev/null
+++ b/kopete/libkopete/kopetemessagehandlerchain.cpp
@@ -0,0 +1,186 @@
+/*
+ kopetemessagehandlerchain.h - Kopete Message Handler Chain
+
+ Copyright (c) 2004 by Richard Smith <kde@metafoo.co.uk>
+ Kopete (c) 2002-2004 by the Kopete developers <kopete-devel@kde.org>
+
+ *************************************************************************
+ * *
+ * This library is free software; you can redistribute it and/or *
+ * modify it under the terms of the GNU Lesser General Public *
+ * License as published by the Free Software Foundation; either *
+ * version 2 of the License, or (at your option) any later version. *
+ * *
+ *************************************************************************
+*/
+
+#include "kopetemessagehandlerchain.h"
+#include "kopetemessagehandler.h"
+#include "kopetemessageevent.h"
+#include "kopetechatsession.h"
+
+#include <kdebug.h>
+
+#include <qmap.h>
+#include <qtimer.h>
+#include <qvaluelist.h>
+
+namespace Kopete
+{
+
+class MessageHandlerChainTerminator : public MessageHandler
+{
+public:
+ void handleMessage( MessageEvent *event )
+ {
+ kdError( 14010 ) << k_funcinfo << "message got to end of chain!" << endl;
+ event->discard();
+ }
+ int capabilities()
+ {
+ kdError( 14010 ) << k_funcinfo << "request got to end of chain!" << endl;
+ return 0;
+ }
+};
+
+// BEGIN MessageHandlerChain
+
+class MessageHandlerChain::Private
+{
+public:
+ Private() : first(0) {}
+ MessageHandler *first;
+};
+
+MessageHandlerChain::Ptr MessageHandlerChain::create( ChatSession *manager, Message::MessageDirection direction )
+{
+ // create the handler chain
+ MessageHandlerChain *chain = new MessageHandlerChain;
+
+ // grab the list of handler factories
+ typedef MessageHandlerFactory::FactoryList FactoryList;
+ FactoryList factories = MessageHandlerFactory::messageHandlerFactories();
+
+ // create a sorted list of handlers
+ typedef QValueList<MessageHandler*> HandlerList;
+ typedef QMap<int,HandlerList> HandlerMap;
+ HandlerMap handlers;
+ uint count = 0;
+ for( FactoryList::Iterator it = factories.begin(); it != factories.end(); ++it )
+ {
+ int position = (*it)->filterPosition( manager, direction );
+ if ( position == MessageHandlerFactory::StageDoNotCreate )
+ continue;
+ MessageHandler *handler = (*it)->create( manager, direction );
+ if ( handler )
+ {
+ ++count;
+ handlers[ position ].append( handler );
+ }
+ }
+
+ kdDebug(14010) << k_funcinfo << "got " << count << " handlers for chain" << endl;
+
+ // add the handlers to the chain
+ MessageHandler *curr = 0;
+ for( HandlerMap::Iterator it = handlers.begin(); it != handlers.end(); ++it )
+ {
+ for ( HandlerList::Iterator handlerIt = (*it).begin(); handlerIt != (*it).end(); ++handlerIt )
+ {
+ if ( curr )
+ curr->setNext( *handlerIt );
+ else
+ chain->d->first = *handlerIt;
+ curr = *handlerIt;
+ }
+ }
+
+ // add a terminator to avoid crashes if the message somehow manages to get to the
+ // end of the chain. maybe we should use a MessageHandlerFactory for this too?
+ MessageHandler *terminator = new MessageHandlerChainTerminator;
+ if ( curr )
+ curr->setNext( terminator );
+ else // empty chain: might happen for dir == Internal
+ chain->d->first = terminator;
+
+ return chain;
+}
+
+MessageHandlerChain::MessageHandlerChain()
+ : QObject( 0 ), d( new Private )
+{
+}
+
+MessageHandlerChain::~MessageHandlerChain()
+{
+ kdDebug(14010) << k_funcinfo << endl;
+ MessageHandler *handler = d->first;
+ while( handler )
+ {
+ MessageHandler *next = handler->next();
+ delete handler;
+ handler = next;
+ }
+ delete d;
+}
+
+
+ProcessMessageTask *MessageHandlerChain::processMessage( const Message &message )
+{
+ MessageEvent *event = new MessageEvent( message );
+ return new ProcessMessageTask( this, event );
+}
+
+int MessageHandlerChain::capabilities()
+{
+ return d->first->capabilities();
+}
+
+// END MessageHandlerChain
+
+// BEGIN ProcessMessageTask
+
+class ProcessMessageTask::Private
+{
+public:
+ Private( MessageHandlerChain::Ptr chain, MessageEvent *event ) : chain(chain), event(event) {}
+ MessageHandlerChain::Ptr chain;
+ MessageEvent *event;
+};
+
+ProcessMessageTask::ProcessMessageTask( MessageHandlerChain::Ptr chain, MessageEvent *event )
+ : d( new Private(chain, event) )
+{
+ QTimer::singleShot( 0, this, SLOT( slotStart() ) );
+ connect( event, SIGNAL( done( Kopete::MessageEvent* ) ), this, SLOT( slotDone() ) );
+ event->message().manager()->ref();
+}
+
+ProcessMessageTask::~ProcessMessageTask()
+{
+ delete d;
+}
+
+void ProcessMessageTask::slotStart()
+{
+ d->chain->d->first->handleMessageInternal( d->event );
+}
+
+void ProcessMessageTask::slotDone()
+{
+ d->event->message().manager()->deref();
+ emitResult();
+}
+
+MessageEvent *ProcessMessageTask::event()
+{
+ return d->event;
+}
+
+//END ProcessMessageTask
+
+}
+
+#include "kopetemessagehandlerchain.moc"
+
+// vim: set noet ts=4 sts=4 sw=4: