/*

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

// UID used for Publish and Subscribe mechanism

// This should be same as the one defined in CPcsAlgorithm.cpp

// Server UID3 has to be used for this framework

const TUid KCStatus = {0x2000B5B6};

// ========================= 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(KCStatus, 0 );

    User::LeaveIfError(err);   

    // Attach the cache error property

    err = iCacheErrorProperty.Attach(KCStatus, 1);

    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();

}

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

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

	{

		for(TInt i = 0; i < iRequestHandler->iObservers.Count(); i++)

			iRequestHandler->iObservers[i]->CachingStatus(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