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

1 files changed, 230 insertions, 0 deletions

diff --git a/kopete/protocols/groupwise/libgroupwise/tasks/conferencetask.cpp b/kopete/protocols/groupwise/libgroupwise/tasks/conferencetask.cpp
new file mode 100644
index 00000000..9773a622
--- /dev/null
+++ b/kopete/protocols/groupwise/libgroupwise/tasks/conferencetask.cpp
@@ -0,0 +1,230 @@
+/*
+    Kopete Groupwise Protocol
+    conferencetask.cpp - Event Handling task responsible for all conference related events
+
+    Copyright (c) 2004      SUSE Linux AG	 	 http://www.suse.com
+    
+    Based on Iris, Copyright (C) 2003  Justin Karneges
+
+    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 "client.h"
+#include "userdetailsmanager.h"
+
+#include "conferencetask.h"
+
+ConferenceTask::ConferenceTask( Task* parent )
+ : EventTask( parent )
+{
+	// register all the events that this task monitors
+	registerEvent( GroupWise::ConferenceClosed );
+	registerEvent( GroupWise::ConferenceJoined );
+	registerEvent( GroupWise::ConferenceLeft );
+	registerEvent( GroupWise::ReceiveMessage );
+	registerEvent( GroupWise::UserTyping );
+	registerEvent( GroupWise::UserNotTyping );
+	registerEvent( GroupWise::ConferenceInvite );
+	registerEvent( GroupWise::ConferenceInviteNotify );
+	registerEvent( GroupWise::ConferenceReject );
+	registerEvent( GroupWise::ReceiveAutoReply );
+	// GW7
+	registerEvent( GroupWise::ReceivedBroadcast );
+	registerEvent( GroupWise::ReceivedSystemBroadcast );
+
+	// listen to the UserDetailsManager telling us that user details are available
+	connect( client()->userDetailsManager(), SIGNAL( gotContactDetails( const GroupWise::ContactDetails & ) ), 
+		SLOT( slotReceiveUserDetails( const GroupWise::ContactDetails & ) ) );
+}
+
+
+ConferenceTask::~ConferenceTask()
+{
+}
+
+void ConferenceTask::dumpConferenceEvent( ConferenceEvent & evt )
+{
+	client()->debug( QString( "Conference Event - guid: %1 user: %2 timestamp: %3:%4:%5" ).arg
+			( evt.guid ).arg( evt.user.ascii() ).arg( evt.timeStamp.time().hour() ).arg
+			( evt.timeStamp.time().minute() ).arg( evt.timeStamp.time().second() ) ); 
+ 	client()->debug( QString( "                  flags: %1" ).arg( evt.flags, 8 ) );
+}
+
+bool ConferenceTask::take( Transfer * transfer )
+{
+	EventTransfer * incomingEvent;
+	if ( forMe( transfer, incomingEvent ) )
+	{
+		client()->debug( "Got a conference event:" );
+		ConferenceEvent event;
+		event.type = (GroupWise::Event)( incomingEvent->eventType() );
+		event.timeStamp = incomingEvent->timeStamp();
+		event.user = incomingEvent->source();
+		event.flags = 0;
+		Q_ASSERT( incomingEvent->hasGuid() );
+		event.guid = incomingEvent->guid();
+		
+		switch ( event.type )
+		{
+			case GroupWise::ConferenceClosed:
+				// extra debug - we never see these events, against spec.
+				client()->debug( "********************" );
+				client()->debug( "* ConferenceClosed *" );
+				client()->debug( "* ConferenceClosed *" );
+				client()->debug( "* ConferenceClosed *" );
+				client()->debug( "********************" );
+				emit closed( event );
+				break;
+			case GroupWise::ConferenceJoined:
+				Q_ASSERT( incomingEvent->hasFlags() );
+				event.flags = incomingEvent->flags();
+				client()->debug( "ConferenceJoined" );
+				if ( !queueWhileAwaitingData( event ) )
+					emit joined( event );
+				break;
+			case GroupWise::ConferenceLeft:
+				Q_ASSERT( incomingEvent->hasFlags() );
+				event.flags = incomingEvent->flags();
+				client()->debug( "ConferenceLeft" );
+				emit left( event );
+				break;
+			case GroupWise::ReceiveMessage:
+				Q_ASSERT( incomingEvent->hasFlags() );
+				event.flags = incomingEvent->flags();
+				Q_ASSERT( incomingEvent->hasMessage() );
+				event.message = incomingEvent->message();
+				client()->debug( "ReceiveMessage" );
+				client()->debug( QString( "message: %1" ).arg( event.message ) );
+				if ( !queueWhileAwaitingData( event ) )
+					emit message( event );
+				break;
+			case GroupWise::UserTyping:
+				client()->debug( "UserTyping" );
+				emit typing( event );
+				break;
+			case GroupWise::UserNotTyping:
+				client()->debug( "UserNotTyping" );
+				emit notTyping( event );
+				break;
+			case GroupWise::ConferenceInvite:
+				Q_ASSERT( incomingEvent->hasMessage() );
+				event.message = incomingEvent->message();
+				client()->debug( "ConferenceInvite" );
+				client()->debug( QString( "message: %1" ).arg( event.message ) );
+				if ( !queueWhileAwaitingData( event ) )
+					emit invited( event );
+				break;
+			case GroupWise::ConferenceInviteNotify:
+				client()->debug( "ConferenceInviteNotify" );
+				if ( !queueWhileAwaitingData( event ) )
+					emit otherInvited( event );
+				break;
+			case GroupWise::ConferenceReject:
+				client()->debug( "ConferenceReject" );
+				if ( !queueWhileAwaitingData( event ) )
+					emit invitationDeclined( event );
+				break;
+			case GroupWise::ReceiveAutoReply:
+				Q_ASSERT( incomingEvent->hasFlags() );
+				event.flags = incomingEvent->flags();
+				Q_ASSERT( incomingEvent->hasMessage() );
+				event.message = incomingEvent->message();
+				client()->debug( "ReceiveAutoReply" );
+				client()->debug( QString( "message: %1" ).arg( event.message.ascii() ) );
+				emit autoReply( event );
+				break;
+			case GroupWise::ReceivedBroadcast:
+				Q_ASSERT( incomingEvent->hasMessage() );
+				event.message = incomingEvent->message();
+				client()->debug( "ReceivedBroadCast" );
+				client()->debug( QString( "message: %1" ).arg( event.message ) );
+				if ( !queueWhileAwaitingData( event ) )
+					emit broadcast( event );
+				break;
+			case GroupWise::ReceivedSystemBroadcast:
+				Q_ASSERT( incomingEvent->hasMessage() );
+				event.message = incomingEvent->message();
+				client()->debug( "ReceivedSystemBroadCast" );
+				client()->debug( QString( "message: %1" ).arg( event.message ) );
+				emit systemBroadcast( event );
+				break;
+			default:
+				client()->debug( QString( "WARNING: didn't handle registered event %1, on conference %2" ).arg( incomingEvent->eventType() ).arg( event.guid.ascii() ) );
+		}
+		dumpConferenceEvent( event );
+
+		return true;
+	}
+	return false;
+}
+
+void ConferenceTask::slotReceiveUserDetails( const GroupWise::ContactDetails & details )
+{
+	client()->debug( "ConferenceTask::slotReceiveUserDetails()" );
+	
+	// dequeue any events which are deliverable now we have these details 
+	QValueListIterator< ConferenceEvent > end = m_pendingEvents.end();
+	QValueListIterator< ConferenceEvent > it = m_pendingEvents.begin();
+	while ( it != end )
+	{
+		QValueListIterator< ConferenceEvent > current = it;
+		++it;
+		// if the details relate to event, try again to handle it
+		if ( details.dn == (*current).user )
+		{
+			client()->debug( QString( " - got details for event involving %1" ).arg( (*current).user ) );
+			switch ( (*current).type )
+			{
+				case GroupWise::ConferenceJoined:
+					client()->debug( "ConferenceJoined" );
+					emit joined( *current );
+					break;
+				case GroupWise::ReceiveMessage:
+					client()->debug( "ReceiveMessage" );
+					emit message( *current );
+					break;
+				case GroupWise::ConferenceInvite:
+					client()->debug( "ConferenceInvite" );
+					emit invited( *current );
+					break;
+				case GroupWise::ConferenceInviteNotify:
+					client()->debug( "ConferenceInviteNotify" );
+					emit otherInvited( *current );
+					break;
+				default:
+					client()->debug( "Queued an event while waiting for more data, but didn't write a handler for the dequeue!" );
+			}
+			m_pendingEvents.remove( current );
+			client()->debug( QString( "Event handled - now %1 pending events" ).arg
+			( (uint)m_pendingEvents.count() ) );
+		}
+	}
+}
+
+
+bool ConferenceTask::queueWhileAwaitingData( const ConferenceEvent & event )
+{
+	if ( client()->userDetailsManager()->known( event.user ) )
+	{
+		client()->debug( "ConferenceTask::queueWhileAwaitingData() - source is known!" );
+		return false;
+	}
+	else
+	{
+		client()->debug( QString( "ConferenceTask::queueWhileAwaitingData() - queueing event involving %1" ).arg( event.user ) );
+		client()->userDetailsManager()->requestDetails( event.user );
+		m_pendingEvents.append( event );
+		return true;
+	}
+}
+
+#include "conferencetask.moc"