--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentpublishingsrv/contentpublishingserver/cpserver/inc/cpserversession.h	Thu Dec 17 08:54:17 2009 +0200
@@ -0,0 +1,249 @@
+/*
+* 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:  Server Session
+ *
+*/
+
+
+#ifndef C_CCPSERVERSESSION_H
+#define C_CCPSERVERSESSION_H
+
+// INCLUDES
+#include <e32base.h>
+
+// FORWARD DECLARATIONS
+#ifdef CONTENT_PUBLISHER_DEBUG
+class CCPDebug;
+#endif
+class CLiwGenericParamList;
+class CLiwDefaultMap;
+class CLiwDefaultList;
+class CCPServer;
+class CCPDataManager;
+class CCPLiwMap;
+class CCPActionHandlerThread;
+class CCPNotificationHandler;
+struct TPointersForSession;
+
+// CLASS DECLARATION
+/** 
+ *  Server side session representation
+ *
+ *  @since Series 60 5.0
+ */
+class CCPServerSession : public CSession2
+    {
+
+public:
+    // New methods
+
+    /**
+     * Two-phased constructor.
+     */
+    static CCPServerSession* NewL( TPointersForSession& aPasser );
+
+    /**
+     * Two-phased constructor.
+     */
+    static CCPServerSession* NewLC( TPointersForSession& aPasser );
+
+    /**
+     * Destroy the object and release all memory objects
+     */
+    virtual ~CCPServerSession();
+
+public:
+    // From CSession
+
+    /**
+     * Called after a service request from client
+     * @param aMessage message from client (containing requested operation 
+     * and any data)
+     */
+    void ServiceL( const RMessage2& aMessage );
+
+    /**
+     * Selects correct function from message
+     * @param aMessage message from client (containing requested operation 
+     * and any data)
+     */
+    void DispatchMessageL( const RMessage2& aMessage, TBool& aPanicedClient );
+
+private:
+    // New methods
+
+    /**
+     * Standard C++ constructor.
+     */
+    CCPServerSession();
+
+    /**
+     * Perform the second phase construction of a CCPServerSession object
+     */
+    void ConstructL( TPointersForSession& aPasser );
+
+    /**
+     * Add Data request
+     * @param Message from client
+     */
+    void AddDataL( const RMessage2& aMessage );
+
+    /**
+     * Specific add data request - data is not actually added to database
+     * but notification is send.
+     * @param Message from client
+     */
+    void AddDataNonPersistentL( const RMessage2& aMessage );
+
+    /**
+     * Get data request - first phase
+     * @param Message from client
+     */
+    void GetListSizeL( const RMessage2& aMessage );
+
+    /**
+     * Get data request - second phase
+     * @param Message from client
+     */
+    void GetListDataL( const RMessage2& aMessage );
+
+    /**
+     * Remove data request
+     * @param Message from client
+     */
+    void RemoveDataL( const RMessage2& aMessage );
+
+    /**
+     * Executes action request
+     * @param Message from client
+     */
+    void ExecuteActionL( const RMessage2& aMessage );
+
+    /**
+     * Executes action request
+     * @param aActionParams list with actions
+     */
+    void ExecuteL( const CLiwGenericParamList& aActionParams );
+
+    /**
+     * Register for notification request
+     * @param Message from client
+     */
+    void RegisterObserverL( const RMessage2& aMessage );
+
+    /**
+     * Adds new observer
+     * @param Message from client
+     */
+    void AddObserverL( const RMessage2& aMessage );
+
+    /**
+     * Removes observer
+     * @param Message from client
+     */
+    void RemoveObserverL( const RMessage2& aMessage );    
+    
+    /**
+     * Unregister from notification request
+     * @param Message from client
+     */
+    void UnregisterObserverL();
+
+    /**
+     * Send information about change in database to client
+     * @param Message from client
+     */
+    void GetChangeInfoDataL( const RMessage2& aMessage );
+
+    /**
+     * Converts CLiwGenericParamList to descriptor and
+     * sends to client
+     * @param Message to complete 
+     * @param Parameters for message
+     */
+    void ExternalizeAndWriteToClientL( const RMessage2& aMessage,
+        const CLiwGenericParamList* outParamList );
+    
+     /**
+      * Unpacks message from client to map
+      * @param Message to complete 
+      * @return CCPLiwMap with data from client
+      */
+    CCPLiwMap* UnpackFromClientLC( const RMessage2& aMessage );
+
+     /**
+      * Send notification
+      * @param aNotificationList
+      */
+    void SendNotificationL( CCPLiwMap* aMap,
+    		CLiwDefaultList* aNotificationList ); 
+
+    /**
+     * Get and Execute Activate or Deactivate action from the DB 
+     * @param Map containing ids of item
+     */
+    void GetAndExecuteActionL( CCPLiwMap* aMap, CLiwDefaultList* aNotificationList,
+    		TBool aInsertTrigger = EFalse );
+    
+    /**
+     * Get Server Lock
+     * @return ETrue if aMessege cannot be processed
+     * because Backup or Restore is running 
+     **/
+    TBool GetServerLock( const RMessage2& aMessage );
+       
+private:
+
+    /*
+     * Own.
+     * Handler for asynchronous request for notifications
+     */
+    CCPNotificationHandler* iNotificationHandler;
+
+    /*
+     * Not own.
+     * True if message is register
+     */
+    TBool isRegister;
+
+    /*
+     * Not own.
+     * Pointer to Content Publisher Server
+     */
+    CCPServer* iServer;
+
+    /*
+     * Not own.
+     * Manager to send and receive data beetween server and storage 
+     */
+    CCPDataManager* iDataManager;
+
+    /*
+     * Own.
+     * List write to message with getList function
+     */
+    CLiwGenericParamList* iParamList;
+
+    /*
+     * Not Own.
+     * Manager to prepare and execute action
+     */
+    CCPActionHandlerThread* iActionHandlerThread;
+
+#ifdef CONTENT_PUBLISHER_DEBUG
+    CCPDebug* iDebug;
+#endif
+    };
+
+#endif // C_CCPSERVERSESSION_H