/*

* 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:  This is the client side internal file to handle

*               property used in Publish and Subscribe framework.

*

*/

//SYSTEM INCLUDES

#include <CPsRequestHandler.h>

#include <MPsResultsObserver.h>

// USER INCLUDES

#include "CPsPropertyHandler.h"

#include "CPcsDebug.h"

// ========================= MEMBER FUNCTIONS ==================================

// -----------------------------------------------------------------------------

// CPsPropertyHandler::NewL()

// Two-phased constructor.

// -----------------------------------------------------------------------------

 CPsPropertyHandler* CPsPropertyHandler::NewL( CPSRequestHandler* aRequestHandler )

{

    PRINT ( _L("Enter CPsPropertyHandler::NewL") );

    CPsPropertyHandler* self = new ( ELeave ) CPsPropertyHandler(aRequestHandler);

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    PRINT ( _L("End CPsPropertyHandler::NewL") );

    return( self ) ;

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::ConstructL()

// Symbian 2nd phase constructor can leave.

// -----------------------------------------------------------------------------

void CPsPropertyHandler::ConstructL()

{

    PRINT ( _L("Enter CPsPropertyHandler::ConstructL") );

    TInt err = iCacheStatusProperty.Attach( KPcsInternalUidCacheStatus, EPsKeyCacheStatus );

    User::LeaveIfError(err);

    // Attach the cache error property

    err = iCacheErrorProperty.Attach( KPcsInternalUidCacheStatus, EPsKeyCacheError );

    User::LeaveIfError(err);

    iCacheStatusProperty.Subscribe(iStatus);

    SetActive();

    PRINT ( _L("End CPsPropertyHandler::ConstructL") );

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::CPsPropertyHandler()

// C++ default constructor can NOT contain any code, that might leave.

// -----------------------------------------------------------------------------

CPsPropertyHandler::CPsPropertyHandler( CPSRequestHandler* aRequestHandler )

: CActive( EPriorityStandard ), 

  iRequestHandler(aRequestHandler)

{

    PRINT ( _L("Enter CPsPropertyHandler::CPsPropertyHandler") );

    CActiveScheduler::Add( this );

    PRINT ( _L("End CPsPropertyHandler::CPsPropertyHandler") );

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::~CPsPropertyHandler()

// Destructor.

// -----------------------------------------------------------------------------

CPsPropertyHandler::~CPsPropertyHandler()

{

    PRINT ( _L("Enter CPsPropertyHandler::~CPsPropertyHandler") );

    Cancel(); // Causes call to DoCancel()

    iCacheStatusProperty.Close();

    iCacheErrorProperty.Close();

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::RunL()

// Invoked to handle responses from the server.

// -----------------------------------------------------------------------------

void CPsPropertyHandler::RunL()

{

    iCacheStatusProperty.Subscribe(iStatus);

    SetActive();

    //Get the value

    TCachingStatus status; 

    TInt statusValue;

    iCacheStatusProperty.Get(statusValue);

    status = (TCachingStatus)statusValue;

    TInt cacheError;

    iCacheErrorProperty.Get(cacheError);

    if ( (status == ECachingComplete) || (status == ECachingCompleteWithErrors) )

    {

        iRequestHandler->NotifyCachingStatus( status, cacheError );

    }

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::DoCancel()

// Cancels any outstanding operation.

// -----------------------------------------------------------------------------

void CPsPropertyHandler::DoCancel()

{

	iCacheStatusProperty.Cancel();

}

// -----------------------------------------------------------------------------

// CPsPropertyHandler::GetCachingStatusL()

// Returns the caching status fr synchronous request

// -----------------------------------------------------------------------------

TInt CPsPropertyHandler::GetCachingStatusL(TCachingStatus& aStatus)

{

	TInt status;

	//Get the status from the property

	iCacheStatusProperty.Get(status);

	aStatus = (TCachingStatus)status;

	TInt cacheError;

	iCacheErrorProperty.Get(cacheError);

	return cacheError;

}

//END OF FILE