--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingapp/msgui/appengine/src/conversationsengine_p.cpp Fri Apr 16 14:56:15 2010 +0300
@@ -0,0 +1,281 @@
+/*
+* 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"
+
+//---------------------------------------------------------------
+// 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)
+ {
+ mServer->RemoveConversationChangeEventL (mConvChangeHandler,
+ mClientConv);
+ }
+ delete mClientConv;
+ mClientConv = NULL;
+ }
+ if(mServer)
+ {
+ mServer->RemoveConversationListChangeEventL (mConvListChangeHandler);
+ 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)
+ {
+ //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 );
+ }
+}
+
+//---------------------------------------------------------------
+// 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::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()
+{
+ 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;
+ }
+}
+
+//---------------------------------------------------------------
+// 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)
+ {
+ TRAP(error,mConvChangeHandler->ConversationsL(aConversationEntryList));
+ }
+}
+
+
+//---------------------------------------------------------------
+// ConversationsEngine::fetchMoreConversations
+// @see header
+//---------------------------------------------------------------
+void ConversationsEnginePrivate::fetchMoreConversations()
+{
+ if(mClientConv)
+ {
+ mConvChangeHandler->restartHandleConversations();
+ }
+}
+
+//EOF
+