// Copyright (c) 2004-2009 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:
// Implements the CSimPubSub class
// 
//

#include "CSimPubSub.h"
#include "Simlog.h"


/**
Standard two phase construction.

@param aPSSimObserver pointer to event observer
@param aUid uids of Publish&Subscribe uids to subscribe to.
*/
CSimPubSub* CSimPubSub::NewL(MPSSimObserver* aPSSimObserver, const CSimPubSub::TPubSubProperty aProperty)
	{
	LOGSCOMMON1(">>CSimPubSub::NewL");
	CSimPubSub* pubsub=new(ELeave) CSimPubSub(aPSSimObserver,aProperty);
	CleanupStack::PushL(pubsub);
	pubsub->ConstructL();
	CleanupStack::Pop();
	LOGSCOMMON1("<<CSimPubSub::NewL");
	return pubsub;
	}

/**
Private constructor used in the first phase of construction.
 
@param aPSSimObserver pointer to event observer
@param aUid uids of Publish&Subscribe uids to subscribe to.
*/
CSimPubSub::CSimPubSub(MPSSimObserver* aPSSimObserver, const CSimPubSub::TPubSubProperty aProperty)
	: CActive(EPriorityStandard),
	iProperty(aProperty),
	iPSSimCallBack(aPSSimObserver)
	{
	}

/**
2nd phase of construction - subscribe to event.
*/
void CSimPubSub::ConstructL()
	{
	User::LeaveIfError(iSubscribe.Attach(iProperty.iCategory,iProperty.iKey));
	CActiveScheduler::Add(this);
	}

/**
Destructor.  Cancels any outstanding request on P&S.
*/
CSimPubSub::~CSimPubSub()
	{
	Cancel();
	iSubscribe.Close();
	}
	
/**
Start the subscription
*/
void CSimPubSub::Start()
	{
	iSubscribe.Subscribe(iStatus);
	SetActive();
	}

/**
Handles completion of our P&S request.
Notifies the event observer.
*/
void CSimPubSub::RunL()
	{
	TInt status = iStatus.Int();
	// As described in documentation resubscribe before processing new value to prevent missing updates.
	if(status != KErrNone)
		User::After(1000000L);	//pause before attempting re-subscribe to avoid a tight-loop.
	Start();
	//pass new state to observer
	if (status==KErrNone)
		{
		TInt state;
		if(iSubscribe.Get(state) == KErrNone)
			{
			iPSSimCallBack->SimPSEvent(iProperty,state);	
			}
		}
	}

/**
Handles a request to cancel the state machine.
Cancels any P&S subscriptions.
*/
void CSimPubSub::DoCancel()
	{
	iSubscribe.Cancel();
	}

/**
Empty constructor
*/
CSimPubSub::TPubSubProperty::TPubSubProperty()
{
}


/**
Overloaded constructor
*/
CSimPubSub::TPubSubProperty::TPubSubProperty(TUid aCategory, TInt aKey,	TInt aType)
: iCategory(aCategory), iKey(aKey), iType(aType)
{
}


/**
Compare for equality.
*/
TBool CSimPubSub::TPubSubProperty::operator==(const CSimPubSub::TPubSubProperty& aProperty) const
	{
	return (iCategory == aProperty.iCategory && iKey == aProperty.iKey	&& iType == aProperty.iType);
	}