X-Git-Url: http://git.maemo.org/git/?a=blobdiff_plain;f=src%2FIO%2FCommunication%2FCommunicationManager.cpp;h=32d6ed9dcad4b906dc65256d04d9f684dffd38c5;hb=663a2fc8ce3a0b8b987655fe709a831a3db9b315;hp=4212f68c76c700f5f23a865553a81fc31c91fa43;hpb=9ee999fe4a7de48abc3b4f950699cd4564d16562;p=qtmeetings

diff --git a/src/IO/Communication/CommunicationManager.cpp b/src/IO/Communication/CommunicationManager.cpp
index 4212f68..32d6ed9 100644
--- a/src/IO/Communication/CommunicationManager.cpp
+++ b/src/IO/Communication/CommunicationManager.cpp
@@ -6,14 +6,17 @@
 #include <QDateTime>
 #include <QDomDocument>
 #include <QDebug>
+#include "../../Domain/Configuration/Configuration.h";
 
 static const int ERROR_BASE=100;
 
-CommunicationManager::CommunicationManager( const ConnectionSettings &aConnection )
+
+CommunicationManager::CommunicationManager()
 {
-	iConnectionSettings = new ConnectionSettings( aConnection );
+
 	iModifyingCommunication = NULL;
-	iFetchingCommunication = new Communication( aConnection );
+
+	iFetchingCommunication = new Communication();
 
 	if ( iFetchingCommunication )
 	{
@@ -23,27 +26,48 @@ CommunicationManager::CommunicationManager( const ConnectionSettings &aConnectio
 				 SLOT( readProgress( int, int, int ) )
 				);
 		connect( iFetchingCommunication,
-				 SIGNAL( requestFinished( int, QHttp::Error ) ),
+				 SIGNAL( requestFinished( int, int ) ),
 				 this,
-				 SLOT( requestFinished( int, QHttp::Error ) )
+				 SLOT( requestFinished( int, int ) )
 				);
 	}
+
 }
 
 CommunicationManager::~CommunicationManager()
 {
-	delete iConnectionSettings;
+	//delete iConnectionSettings;
 	delete iModifyingCommunication;
 	delete iFetchingCommunication;
 	while ( !iMeetings.isEmpty() )
 		delete iMeetings.takeFirst();
 }
 
-void CommunicationManager::fetchMeetings( const QDateTime &aFrom, const QDateTime &aUntil, const Room &aIn )
+void CommunicationManager::fetchMeetings( const int aWeek, const int aYear, const Room &aIn )
 {
+	//prevent making multiple simultaneous user availibility requests
+	//TODO: Would be nice to queue these requests instead of just aborting 
+	const RequestData* rd = findRequest( GetUserAvailability );
+	if( rd )
+		return;
+	
+	// Set from to beginning, 00:00 of the requested week
+	QDateTime from = QDateTime::currentDateTime();
+	from = from.addYears( aYear - from.date().year() );
+	from = from.addDays( -1*(from.date().dayOfWeek()-1) );
+	from = from.addDays( (aWeek - from.date().weekNumber())*7 );
+	QTime midnight = from.time();
+	midnight.setHMS( 0,0,0 );
+	from.setTime( midnight );
+	qDebug() << "CommunicationManager::fetchMeetings from: " << from.toString();
+	
+	QDateTime until = from.addDays(7);
+	qDebug() << "CommunicationManager::fetchMeetings until: " << until.toString();
+	
+	
 	ReqMsgGetUserAvailability msg;
 	msg.setTimeZone();
-	msg.setTimeWindow( aFrom, aUntil );
+	msg.setTimeWindow( from, until );
 	msg.addUser( aIn.address() );
 		
 	int id = iFetchingCommunication->request( msg.getContentTypeForHeader(), msg.getMessage() );
@@ -87,6 +111,15 @@ void CommunicationManager::fetchMeetingDetails( Meeting& aMeeting )
 	}
 }
 
+void CommunicationManager::cancelFetchMeetingDetails()
+{
+	const RequestData *rd = findRequest( GetCalendarItem );
+	if( rd != NULL ) {
+		int id = rd->requestId;
+		iCancelledRequests.append( id );
+	}
+}
+
 void CommunicationManager::getMeetingDetails( Meeting &aMeeting )
 {
 	ReqMsgGetCalendarItem msg( aMeeting.secondaryId() );
@@ -102,42 +135,58 @@ void CommunicationManager::getMeetingDetails( Meeting &aMeeting )
 	}
 }
 
-void CommunicationManager::requestFinished( int aRequestId, QHttp::Error aError )
+void CommunicationManager::requestFinished( int aRequestId, int aError )
 {
 	RequestData* rd = takeRequest( aRequestId );
-	qDebug() << "CommunicationManager::requestFinished: id: " << aRequestId << " error: " << (int)aError;
+	if( iCancelledRequests.contains( rd->requestId ) )
+	{
+		iCancelledRequests.removeAll( rd->requestId );
+		delete rd;
+		return;
+	}
+	QByteArray* response = iFetchingCommunication->response( aRequestId );
+	qDebug() << "CommunicationManager::requestFinished: id: " << aRequestId << " error: " << aError;
 
-	if( aError != QHttp::NoError || rd == NULL )
+	if( aError != (int)(QHttp::NoError) || rd == NULL || response == NULL )
 	{
-		int err = (int)aError;
-		if( rd == NULL )
+		int err = aError;
+		if( rd == NULL || response == NULL )
 			err = 10;
 		delete rd;
 		emit error( ERROR_BASE+(int)err, CommunicationManager::FetchingCommunication );
+		while ( !iMeetings.isEmpty() )
+					delete iMeetings.takeFirst();
+		emit meetingsFetched( iMeetings );
 		return;
 	}
 
-	const QByteArray& response = iFetchingCommunication->response( aRequestId );
-
 	switch( rd->type )
 	{
 	case GetUserAvailability:
 		{
-		ResMsgGetUserAvailability msg( response );
+		ResMsgGetUserAvailability msg( *response );
 	
 		while ( !iMeetings.isEmpty() )
 			delete iMeetings.takeFirst();
 	
 		int err = msg.getMeetingsFromResponse( iMeetings, *(rd->room) );
 		if( err )
+			{
 			emit error( ERROR_BASE+8, CommunicationManager::FetchingCommunication );
+			while ( !iMeetings.isEmpty() )
+								delete iMeetings.takeFirst();
+					emit meetingsFetched( iMeetings );
+			}
 		else
+			{
+			qDebug("*** COMMUNICATIONMANAGER ::: Meetings fetched!");
 			emit meetingsFetched( iMeetings );
+			}
 		break;
 		}
 	case ConvertId:
 		{
-		ResponseMessage msg( response );
+		ResponseMessage msg( *response );
 		QString id = msg.getNodeValue( QString( "Id" ),
 									   QDomNode::AttributeNode,
 									   QString( "AlternateId" ) );
@@ -148,15 +197,22 @@ void CommunicationManager::requestFinished( int aRequestId, QHttp::Error aError
 		}
 	case GetCalendarItem:
 		{
-		ResMsgGetCalendarItem msg( response );
+		ResMsgGetCalendarItem msg( *response );
 		int err = msg.getMeetingDetailsFromResponse( *(rd->meeting) );
 		if( err )
+			{
 			emit error( ERROR_BASE+9, CommunicationManager::FetchingCommunication );
+			while ( !iMeetings.isEmpty() )
+								delete iMeetings.takeFirst();
+					emit meetingsFetched( iMeetings );
+			}
+
 		else
 			emit meetingDetailsFetched( *(rd->meeting) );
 		break;
 		}
 	}
+	delete response;
 	delete rd;
 }
 
@@ -188,5 +244,16 @@ CommunicationManager::RequestData* CommunicationManager::takeRequest( int aReque
 	return NULL;
 }
 
-
+const CommunicationManager::RequestData* CommunicationManager::findRequest( RequestType aRequestType ) const
+{
+	for( int i = iRequestInfos.count() - 1; i >= 0 ; i-- )
+	{
+		struct RequestData* rd = iRequestInfos[i];
+		if( rd->type == aRequestType )
+		{
+			return rd;
+		}
+	}
+	return NULL;
+}