--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingapp/msgui/appengine/src/conversationsengine_p.cpp Fri Jun 04 10:25:39 2010 +0100
@@ -0,0 +1,343 @@
+/*
+* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:
+*
+*/
+#include "conversationsengine_p.h"
+
+//SYSTEM INCLUDES
+#include <ccsconversationentry.h>
+#include <ccsclientconversation.h>
+//USER INCLUDES
+#include "conversationsenginedefines.h"
+#include "conversationmsgstorehandler.h"
+#include "conversationssummarymodel.h"
+#include "conversationsmodel.h"
+#include "conversationchangehandler.h"
+#include "conversationlistchangehandler.h"
+#include "debugtraces.h"
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::ConversationsEnginePrivate
+// @see header
+//---------------------------------------------------------------
+ConversationsEnginePrivate::ConversationsEnginePrivate(
+ ConversationMsgStoreHandler* conversationMsgStoreHandler,
+ ConversationsSummaryModel *conversationsSummaryModel,
+ ConversationsModel *conversationsModel
+ ):mServer(NULL),
+ mClientConv(NULL),
+ mConversationMsgStoreHandler(conversationMsgStoreHandler),
+ mConversationsSummaryModel(conversationsSummaryModel),
+ mConversationsModel(conversationsModel)
+{
+ TRAP_IGNORE(initL());
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::~ConversationsEnginePrivate
+// @see header
+//---------------------------------------------------------------
+ConversationsEnginePrivate::~ConversationsEnginePrivate()
+{
+ delete mConvChangeHandler;
+
+ delete mConvListChangeHandler;
+
+ if( mClientConv )
+ {
+ if(mServer)
+ {
+ TRAP_IGNORE(mServer->RemoveConversationChangeEventL(
+ mConvChangeHandler,mClientConv));
+ }
+ delete mClientConv;
+ mClientConv = NULL;
+ }
+ if(mServer)
+ {
+ TRAP_IGNORE(mServer->RemoveConversationListChangeEventL(
+ mConvListChangeHandler));
+ TRAP_IGNORE(mServer->RemoveResultsEventL ( this ));
+ mServer->Cancel();
+ delete mServer;
+ mServer = NULL;
+ }
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::initL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::initL()
+{
+ mServer = CCSRequestHandler::NewL();
+
+ //Add results observer to the server
+ mServer->RequestResultsEventL(this);
+
+ //Fetch the conversation list from server
+ mServer->GetConversationListL();
+
+ mConvChangeHandler = new ConversationsChangeHandler(this,
+ mConversationsModel);
+
+ mConvListChangeHandler = new ConversationsListChangeHandler(this,
+ mConversationsSummaryModel);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::registerForConversationListUpdatesL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::registerForConversationListUpdatesL()
+{
+ //Add ConversationListChange Observer
+ mServer->RequestConversationListChangeEventL (mConvListChangeHandler);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::getConversationsL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::getConversationsL( TInt aConversationId)
+{
+ if(!mClientConv)
+ {
+ QCRITICAL_WRITE("ConversationsEnginePrivate::getConversationsL start.");
+ //Clear the model before issueing fetch
+ mConversationsModel->clear();
+ //create a client conversation
+ mClientConv = CCsClientConversation::NewL();
+ mClientConv->SetConversationEntryId(aConversationId);
+ //set dummy entry
+ CCsConversationEntry *entry = CCsConversationEntry::NewL();
+ CleanupStack::PushL(entry);
+ mClientConv->SetConversationEntryL(entry);
+ CleanupStack::PopAndDestroy(entry);
+ //Get the conversations for new conversationId
+ mServer->GetConversationsL(mClientConv);
+
+ QCRITICAL_WRITE("ConversationsEnginePrivate::getConversationsL end.");
+ }
+
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::deleteConversationL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::deleteConversationL(TInt aConversationId)
+{
+ mServer->DeleteConversationL(aConversationId);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::deleteMessages
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::deleteMessages(RArray<TInt>& aIdArray)
+{
+ mConversationMsgStoreHandler->DeleteMessages(aIdArray);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::deleteallDraftMessages
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::deleteAllDraftMessagesL()
+{
+ mConversationMsgStoreHandler->DeleteAllDraftMessagesL();
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::markConversationReadL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::markConversationReadL(TInt aConversationId)
+{
+ mServer->MarkConversationReadL(aConversationId);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::markMessagesReadL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::markMessagesReadL(RArray<TInt>& aIdArray)
+{
+ mConversationMsgStoreHandler->MarkMessagesReadL(aIdArray);
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::getConversationCurrentId
+// @see header
+//---------------------------------------------------------------
+TInt ConversationsEnginePrivate::getConversationCurrentId()
+{
+ TInt convId = -1;
+ if(mClientConv)
+ {
+ convId = mClientConv->GetConversationEntryId();
+ }
+ return convId;
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::getConversationIdFromContactId
+// @see header
+//---------------------------------------------------------------
+TInt ConversationsEnginePrivate::getConversationIdFromContactIdL(TInt contactId)
+{
+ TInt convId = -1;
+
+ convId = mServer->GetConversationIdL(contactId);
+
+ return convId;
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::getConversationIdFromAddress
+// @see header
+//---------------------------------------------------------------
+TInt ConversationsEnginePrivate::getConversationIdFromAddressL(TDesC& contactAddress)
+{
+ TInt convId = -1;
+
+ convId = mServer->GetConversationIdFromAddressL(contactAddress);
+
+ return convId;
+}
+
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::clearConversationsL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::clearConversationsL()
+{
+ QCRITICAL_WRITE("ConversationsEnginePrivate::clearConversationsL start.");
+
+ mConvChangeHandler->Cancel();
+ //Clear conversations model before populating with new data
+ mConversationsModel->clear();
+
+ // Delete old CCsClientConversation object
+ // Remove the old Conversation change observer
+ if(mClientConv)
+ {
+ mServer->RemoveConversationChangeEventL (mConvChangeHandler ,mClientConv);
+ delete mClientConv;
+ mClientConv = NULL;
+ }
+
+ QCRITICAL_WRITE("ConversationsEnginePrivate::clearConversationsL end.");
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::registerForConversationUpdatesL
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::registerForConversationUpdatesL()
+{
+ //Add the Conversation Change for new conversationId
+ if(mClientConv)
+ {
+ mServer->RequestConversationChangeEventL (mConvChangeHandler ,mClientConv);
+ }
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::ConversationList
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::ConversationList(
+ RPointerArray<CCsClientConversation>& aClientConversationList)
+{
+ int error;
+ TRAP(error,
+ mConvListChangeHandler->ConversationListL(aClientConversationList));
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::Conversations
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::Conversations(
+ RPointerArray<CCsConversationEntry>& aConversationEntryList)
+{
+ int error;
+ if (mClientConv)
+ {
+ QCRITICAL_WRITE("ConversationsEnginePrivate::Conversations start.");
+
+ TRAP(error,mConvChangeHandler->ConversationsL(aConversationEntryList));
+
+ QCRITICAL_WRITE("ConversationsEnginePrivate::Conversations end.");
+ }
+}
+
+
+//---------------------------------------------------------------
+// ConversationsEngine::fetchMoreConversations
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::fetchMoreConversations()
+{
+ if (mClientConv)
+ {
+ mConvChangeHandler->restartHandleConversations();
+ }
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::resendMessage()
+// @see header
+//---------------------------------------------------------------
+bool ConversationsEnginePrivate::resendMessage(TMsvId messageId)
+{
+ TInt err = KErrNone;
+ bool retval = true;
+ TRAP(err, retval = mConversationMsgStoreHandler->ResendMessageL(messageId));
+ return ((err == KErrNone) && (retval == true))?true:false;
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::downloadMessage
+// @see header
+//---------------------------------------------------------------
+TInt ConversationsEnginePrivate::downloadMessage(TMsvId messageId)
+{
+ TInt err = KErrNone;
+ TInt retval = KErrNone;
+ TRAP(err, retval =
+ mConversationMsgStoreHandler->DownloadMessageL(messageId));
+
+ if( err!=KErrNone)
+ {
+ retval = KErrGeneral;
+ }
+
+ return retval;
+}
+
+//---------------------------------------------------------------
+// ConversationsEnginePrivate::downloadOperationSupported()
+// @see header
+//---------------------------------------------------------------
+bool ConversationsEnginePrivate::downloadOperationSupported(TMsvId messageId)
+{
+ return mConversationMsgStoreHandler->DownloadOperationSupported(messageId);
+}
+//EOF
+