diff -r 4697dfb2d7ad -r 238255e8b033 messagingapp/msgui/appengine/src/conversationchangehandler.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingapp/msgui/appengine/src/conversationchangehandler.cpp	Fri Apr 16 14:56:15 2010 +0300
@@ -0,0 +1,223 @@
+/*
+ * 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:  ?Description
+ *
+ */
+
+#include "conversationchangehandler.h"
+// SYSTEM INCLUDES
+#include <ccsconversationentry.h>
+
+// USER INCLUDES
+#include "conversationsengine.h"
+#include "conversationsengine_p.h"
+#include "conversationsmodel.h"
+
+const TInt WindowSize = 7;
+
+// ---------------------------------------------------------------------------
+// Constructor
+// ---------------------------------------------------------------------------
+//
+ConversationsChangeHandler::ConversationsChangeHandler(
+    ConversationsEnginePrivate* convEnginePrivate,
+    ConversationsModel* conversationsModel) :
+    CActive(EPriorityStandard), 
+    mCurrentState(EInit),
+    mFirstWindowCached(EFalse),
+    mCurrentIndex(-1), 
+    mConversationsModel(conversationsModel), 
+    mConvEnginePrivate(convEnginePrivate)
+
+{
+    CActiveScheduler::Add(this);
+}
+
+// ---------------------------------------------------------------------------
+// Destructor
+// ---------------------------------------------------------------------------
+//
+ConversationsChangeHandler::~ConversationsChangeHandler()
+{
+    mConversationEntryList.ResetAndDestroy();
+    // Cancel the active object
+    Cancel();
+}
+
+// ---------------------------------------------------------------------------
+// This is for handling GetConversation results asynchronusly
+// from the server.
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::ConversationsL(RPointerArray<
+        CCsConversationEntry>& aConversationEntryList)
+{
+    mConversationEntryList.ResetAndDestroy();
+
+    for (TInt i = 0; i < aConversationEntryList.Count(); ++i)
+    {
+        CCsConversationEntry *entry = aConversationEntryList[i]->CloneL();
+        mConversationEntryList.AppendL(entry);
+    }
+    if (aConversationEntryList.Count() > 0)
+    {
+        mFirstWindowCached = EFalse;
+        mCurrentIndex = 0;
+        mCurrentState = EInitialCache;
+        IssueRequest();
+    }
+    else
+    {
+        //This is done for safety
+        mConvEnginePrivate->registerForConversationUpdatesL();
+        mCurrentState = EListenToEvents;
+    }
+}
+
+// ---------------------------------------------------------------------------
+// Handling addition of new conversation entry from the server
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::AddConversation(
+    const CCsConversationEntry& aConvEntry)
+{
+    mConversationsModel->addRow(aConvEntry, true);
+    ConversationsEngine::instance()->emitConversationModelUpdated();
+}
+
+// ---------------------------------------------------------------------------
+// Handling modification of existing conversation entry from the server
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::ModifyConversation(
+    const CCsConversationEntry& aConvEntry)
+{
+    mConversationsModel->addRow(aConvEntry, true);
+    ConversationsEngine::instance()->emitConversationModelUpdated();
+}
+
+// ---------------------------------------------------------------------------
+// Handling deletion of conversation entry from the server
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::DeleteConversation(
+    const CCsConversationEntry& aConvEntry)
+{
+    mConversationsModel->deleteRow(aConvEntry.EntryId());
+    ConversationsEngine::instance()->emitConversationModelUpdated();
+}
+
+//-----------------------------------------------------------------------
+// This is for handling modify conversation event asynchronusly from the server
+//-----------------------------------------------------------------------
+//
+void ConversationsChangeHandler::RefreshConversation()
+{
+}
+
+// ---------------------------------------------------------------------------
+// RunL
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::RunL()
+{
+    if (iStatus != KErrNone)
+    {
+        return;
+    }
+    //process
+    switch (mCurrentState)
+    {
+        case EInitialCache:
+            HandleConversationsL();
+            break;
+    }
+}
+
+// ---------------------------------------------------------------------------
+// DoCancel
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::DoCancel()
+{
+    mCurrentState = EListenToEvents;
+}
+
+// ---------------------------------------------------------------------------
+// Make the active object alive.
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::IssueRequest()
+{
+    if (!IsActive())
+    {
+        iStatus = KRequestPending;
+        TRequestStatus* status = &iStatus;
+        SetActive();
+        User::RequestComplete(status, KErrNone);
+    }
+}
+
+// ---------------------------------------------------------------------------
+//  Handles Conversations received from server and updates into model
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::HandleConversationsL()
+{
+    for (int i = 0; i < WindowSize; ++i)
+    {
+        if (mCurrentIndex < mConversationEntryList.Count())
+        {
+            mConversationsModel->addRow(
+                * (mConversationEntryList[mCurrentIndex]));
+            mCurrentIndex++;
+        }
+        else
+        {
+            break;
+        }
+    }
+    if (mCurrentIndex < mConversationEntryList.Count())
+    {
+        if (!mFirstWindowCached)
+        {
+            ConversationsEngine::instance()->emitConversationModelPopulated();
+            mFirstWindowCached = ETrue;
+            return;
+        }
+        IssueRequest();
+    }
+    else
+    {
+        if (!mFirstWindowCached)
+        {
+            ConversationsEngine::instance()->emitConversationModelPopulated();
+            mFirstWindowCached = ETrue;
+        }
+        mConversationEntryList.ResetAndDestroy();
+        mConvEnginePrivate->registerForConversationUpdatesL();
+        mCurrentState = EListenToEvents;
+    }
+}
+
+// ---------------------------------------------------------------------------
+//  Starts fetching remaining conversations
+// ---------------------------------------------------------------------------
+//
+void ConversationsChangeHandler::restartHandleConversations()
+{
+    IssueRequest();
+}
+
+//EOF