diff -r 4697dfb2d7ad -r 238255e8b033 messagingapp/msgappfw/server/src/ccsserver.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingapp/msgappfw/server/src/ccsserver.cpp	Fri Apr 16 14:56:15 2010 +0300
@@ -0,0 +1,270 @@
+/*
+ * Copyright (c) 2007 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:  CS Server main class. Co-ordinates server startup,
+ *                shutdown and receives client requests.
+ *
+ */
+
+// INCLUDE FILES
+#include <e32base.h>
+#include <ccsdefs.h>
+#include <ccsconversationentry.h>
+
+// USER INCLUDES
+#include "ccsdebug.h"
+#include "ccsserver.h"
+#include "ccssession.h"
+#include "ccsplugininterface.h"
+#include "ccsconversationevent.h"
+#include "ccsconversationcache.h"
+#include "ccscontactsmanager.h"
+
+//Costant Declaration
+
+// ============================== MEMBER FUNCTIONS ============================
+
+// ----------------------------------------------------------------------------
+// CCsServer::NewL
+// Two Phase Construction
+// ----------------------------------------------------------------------------
+CCsServer* CCsServer::NewL()
+{
+    //TODO check the print macro for warning
+    //TODO handle all error conditions
+
+    PRINT ( _L("Enter CCsServer::NewL") );
+
+    CCsServer* self = new (ELeave) CCsServer;
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    self->StartL(KCsServerName);
+    CleanupStack::Pop(self);
+
+    PRINT ( _L("End CCsServer::NewL") );
+
+    return self;
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::CCsServer
+// Constructor
+// ----------------------------------------------------------------------------
+CCsServer::CCsServer() :
+    CServer2(EPriorityLow)
+{
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::ConstructL
+// Second phase constructor
+// ----------------------------------------------------------------------------
+void CCsServer::ConstructL()
+{
+    PRINT ( _L("Enter CCsServer::ConstructL") );
+
+    // Create contacts manager and resgiter for events
+    iContactsManager = new CCsContactsManager();
+    
+    iConversationPlugin = CCsPluginInterface::NewL();
+
+    // Create the plugin for the required entries
+    iConversationPlugin->InstantiatePluginL(this);
+    
+    //fetch all initial set of messages
+    iConversationPlugin->GetConversationsL();
+    
+    // create cache
+    iConversationCache = CCsConversationCache::NewL(iContactsManager, this);
+
+    iCsCachingStatus = KCachingStatusUnknown;
+
+    PRINT ( _L("End CCsServer::ConstructL") );
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::~CCsServer
+// Destructor
+// ----------------------------------------------------------------------------
+CCsServer::~CCsServer()
+{
+    PRINT ( _L("Enter CCsServer::~CCsServer") );
+
+    // delete cache
+    if (iConversationCache)
+    {
+        delete iConversationCache;
+        iConversationCache = NULL;
+    }
+
+    // delete the plugin interface object
+    if (iConversationPlugin)
+    {
+        delete iConversationPlugin;
+        iConversationPlugin = NULL;
+    }
+
+    // Delete the contact manager
+    if (iContactsManager)
+    {
+        delete iContactsManager;
+        iContactsManager = NULL;
+    }
+
+    REComSession::FinalClose();
+
+    PRINT ( _L("End CCsServer::~CCsServer") );
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::NewSessionL
+// Constructor
+// ----------------------------------------------------------------------------
+CSession2* CCsServer::NewSessionL(const TVersion& aVersion, const RMessage2& /*aMessage*/) const
+{
+    TVersion serverVersion(1, 0, 0);
+    if (!User::QueryVersionSupported(serverVersion, aVersion))
+        User::Leave(KErrNotSupported);
+
+    CCsSession* session = CCsSession::NewL(const_cast<CCsServer*> (this));
+
+    PRINT ( _L("CCsServer::NewSessionL - New Session Created") );
+
+    return session;
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::ConversationCacheInterface
+// Get the cache interface
+// ----------------------------------------------------------------------------
+CCsConversationCache* CCsServer::ConversationCacheInterface()
+{
+    return iConversationCache;
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::AddConversations
+// This is to handle the new conversation event callback from plugin dll
+// The idea is to add entries to the cache and at the same time
+// update the client UI
+// ----------------------------------------------------------------------------
+void CCsServer::AddConversations(
+                                 const RPointerArray<CCsConversationEntry>& aConversationEntryLists)
+{
+    PRINT ( _L("Enter CCsServer::AddConversations") );
+
+    iConversationCache->HandleConversations(aConversationEntryLists,
+                                            KConversationEventNew);
+
+    PRINT ( _L("End CCsServer::AddConversations") );
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::ModifyConversations
+// This is to handle the modify conversation event callback from plugin dll
+// The idea is to update entries to the cache and at the same time update
+// the client UI
+// ----------------------------------------------------------------------------
+void CCsServer::ModifyConversations(
+                                    const RPointerArray<CCsConversationEntry>& aConversationEntryLists)
+{
+    PRINT ( _L("Enter CCsServer::ModifyConversations") );
+
+    iConversationCache->HandleConversations(aConversationEntryLists,
+                                            KConversationEventUpdate);
+
+    PRINT ( _L("End CCsServer::ModifyConversations") );
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::DeleteConversations
+// This is to handle the delete event callback from plugin dll
+// The idea is to delete entries to the cache and at the same time update the client UI
+// ----------------------------------------------------------------------------
+void CCsServer::DeleteConversations(
+                                    const RPointerArray<CCsConversationEntry>& aConversationEntryLists)
+{
+    PRINT ( _L("Enter CCsServer::DeleteConversations") );
+
+    iConversationCache->HandleConversations(aConversationEntryLists,
+                                            KConversationEventDelete);
+
+    PRINT ( _L("End CCsServer::DeleteConversations") );
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::NotifySessions
+// Callback for on-the-fly data changes
+// ----------------------------------------------------------------------------
+void CCsServer::NotifySessions(CCsClientConversation* aConversation,
+                               TUint32 aEvent)
+{
+    iSessionIter.SetToFirst();
+    CCsSession* session;
+    while ( (session = (CCsSession*) iSessionIter++) != NULL)
+    {
+        TRAPD(error, session->HandleChangeEventL( aConversation, aEvent ));
+        if (error != KErrNone)
+        {
+            PRINT1 ( _L("CCsServer::NotifySessions - Error:%d"), error );
+        }
+    }
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::CachingCompleted
+// This is to get caching complete event from plugins
+// ----------------------------------------------------------------------------
+void CCsServer::CachingCompleted()
+{
+    // NOTE:- NO CHECK DONE NOW ON NUMBER OF PLUGINS TO KEEP IT SIMPLE.
+    // NOT EXPECTED TO BE MORE THAN 1 PLUGIN FOR TB 9.2.
+    iCsCachingStatus = KCachingStatusCompleted;
+}
+
+// ----------------------------------------------------------------------------
+// CCsServer::RefreshConversations
+// Refresh conversations.
+// ----------------------------------------------------------------------------
+void CCsServer::RefreshConversations()
+{
+    // NOTE:- NO CHECK DONE NOW ON NUMBER OF PLUGINS TO KEEP IT SIMPLE.
+    // NOT EXPECTED TO BE MORE THAN 1 PLUGIN FOR TB 9.2.
+
+    // Delete and recreate cache.
+    if (iConversationCache)
+    {
+        delete iConversationCache;
+        iConversationCache = NULL;
+
+        iCsCachingStatus = KCachingStatusUnknown;
+        TRAPD(error, iConversationCache = CCsConversationCache::
+                NewL(iContactsManager, this));
+        if (error != KErrNone)
+        {
+            PRINT1 ( _L("CCsServer::RefreshConversations - Error:%d"), error );
+        }
+    }
+
+    // Notify client to refresh
+    NotifySessions(NULL, KConversationEventRefresh);
+    NotifySessions(NULL, KConversationEventListRefresh);
+    // Read again.
+    TRAPD(error, iConversationPlugin->GetConversationsL());
+    if (error != KErrNone)
+    {
+        PRINT1 ( _L("CCsServer::RefreshConversations - Error:%d"), error );
+    }
+}
+
+// end of file