You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdenetwork/kopete/libkopete/kopetemessagehandlerchain.cpp

185 lines
4.7 KiB

/*
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 <tqmap.h>
#include <tqtimer.h>
#include <tqvaluelist.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 TQValueList<MessageHandler*> HandlerList;
typedef TQMap<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()
: TQObject( 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) )
{
TQTimer::singleShot( 0, this, TQ_SLOT( slotStart() ) );
connect( event, TQ_SIGNAL( done( Kopete::MessageEvent* ) ), this, TQ_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"