/*

* 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:  Content Publisher Server - Main class

*

*/

#ifndef C_CCPSERVER_H

#define C_CCPSERVER_H

// INCLUDES

#include <e32base.h>

#include "cpserverdef.h"

#include "cpserverburlistener.h"

#ifdef CONTENT_PUBLISHER_DEBUG

class CCPDebug;

#endif

class CCPDataManager;

class CCPActionHandlerThread;

class CCPServer;

struct TPointersForSession

    {

    CCPServer* iServer;

    CCPDataManager* iDataManager;

    CCPActionHandlerThread* iActionHandlerThread;

    };

// CLASS DECLARATION

/**

 *  Content Publisher Server implementation

 *

 *  @since Series 60 5.0

 */

class CCPServer : public CPolicyServer, public MBURListenerCallback

    {

public:

    // Constructors and destructor

    /**

     * Two-phased constructor.

     */

    static CCPServer* NewLC();

    /**

     * Destructor.

     */

    virtual ~CCPServer();

public:

    // New functions        

    /**

     * Stops server.

     */

    void Stop();

    /**

     * Panic client. 

     * @param aMessage RMessage2

     * @param aPanic panic code

     */

    static void PanicClient( const RMessage2& aMessage, 

        TCPServerPanic aPanic );

    /**

     * start server

     * @return aErr Error code.

     */

    static TInt ThreadStart();

    /**

     * Decrements session counter

     */

    void RemoveSession();

    /**

     * Increments session counter

     */

    void AddSession();

    /**

     * HandleBUREventL is called when Backup and Restore state has been changed.

     *

     * @since S60 v3.1

     * @param aStatus Current Backup and Restore status.

     */

    void HandleBUREventL( TBURStatus aStatus );

    /**

     * Get Lock

     *

     * @return ETrue if Backup or Restore are running 

     */

    TBool GetLock();

    /**

     * Returns notifications array

     */

    RPointerArray<CLiwDefaultList>& GetNotifications( ); 

    /**

     * Get DataMap Cache

     *

     * @return DataMap cache reference

     */

    TLiwVariant& GetDataMapCache();

private:

    // From CActive

    /**

     * Process any errors.

     * @param aError the leave code reported

     * @return KErrNone if leave is handled

     */

    TInt RunError( TInt aError );

private:

    // New methods

    /**

     * Constructs the server. 

     * @param aPriority CServer2 input parameter

     */

    CCPServer( TInt aPriority );

    /**

     * Perform the second phase construction of a CCPServer object.

     */

    void ConstructL();

    /**

     * Panic the server. 

     * @param param aPanic the panic code

     * @return a updateId of container

     */

    static void PanicServer( TCPServerPanic aPanic );

    /**

     * Send notification

     * @param Map containing ids of item

     */

    void AppendNotificationL( CCPLiwMap* aMap ); 

private:

    // From CServer2

    /**

     * Create a time server session, and return a pointer to the created object.

     * @param aVersion the client version 

     * @param aMessage RMessage2 

     * @return pointer to new session

     */

    CSession2* NewSessionL( const TVersion& /*aVersion*/,

        const RMessage2& /*aMessage*/) const;

    /**

     * create and run server

     */

    static void CreateAndRunServerL();

    /**

     * Publishers deactivation

     */

    void DeactivatePublishersL();

    /**

     * Resets Activate flag and update item in the DB

     */

    void ResetAndUpdateFlagL( CCPLiwMap* aMap );

private:

    //data

    /*

     * Manager to send and receive data beetween server and storage 

     * Own.

     */

    CCPDataManager* iDataManager;

    /*

     * Manager to prepare and execute action

     * Own. 

     */

    CCPActionHandlerThread* iActionHandlerThread;

    /*

     * Count of sessions

     * Own.

     */

    TInt iCountSession;

    /**

     * Notifier for Backup and Restore changes.

     * Own.

     */

    CCPServerBURListener* iBURListener;

#ifdef CONTENT_PUBLISHER_DEBUG

    CCPDebug* iDebug;

#endif

    /*

     * Own.

     * True if database is lock

     */

    TBool iBURLock;

    /*

     * Own.

     * List of waiting notifications about publisher 

     * activation during startup 

     */

    RPointerArray<CLiwDefaultList> iNotifications;

    /*

     * Own.

     */

    TLiwVariant iDataMapCache;

    };

#endif // C_CCPSERVER_H