/*
* 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