// Copyright (c) 2007-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:
// The class provides an implementation of the SUPL Push API SMS or WAP Push channel for 
// the receiver's part of the interface.
// 
//

/**
 @file
 @internalComponent
 @deprecated
*/

#include <e32base.h>
#include <e32property.h>

#include <lbs/lbssuplpushreceiver.h>
#include "lbsdevloggermacros.h"

#include "lbssuplpushprops.h"
#include "lbssuplpushreceiverchannel.h"


/**
Creates the channel and starts listening for incoming SUPL INIT messages.

@param aChannel [In] The id of the channel to listen messages on. 
@param aObserver [In] A reference to an observer waiting for SUPL INIT messages.
@param aPropOwnerSecureId [In] The secure id of the process that owns the P&S propertirs used.

@return an instance of the channel. The calling class becomes the
owner of the returned instance and is responsible its disposal.

@leave If a error happens, it leaves with the correspondent error code.

@see CLbsSuplPushRecImpl::NewL
*/
CLbsSuplPushRecChannel* CLbsSuplPushRecChannel::NewL(TLbsSuplPushChannel aChannel, 
		MLbsSuplPushRecObserver& aObserver, TUid aPropOwnerSecureId)
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::NewL() Begin\n");
	CLbsSuplPushRecChannel* self = new (ELeave) CLbsSuplPushRecChannel(aChannel, aObserver, aPropOwnerSecureId);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::NewL() End\n");
	return self;
	}
	
/**
Cancels the subscription for new messages and close the property used.
  
@see CLbsSuplPushRecImpl::~CLbsSuplPushRecImpl
*/
CLbsSuplPushRecChannel::~CLbsSuplPushRecChannel()
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::~CLbsSuplPushRecChannel() Begin\n");
	Cancel();
	iInitProperty.Close();
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::~CLbsSuplPushRecChannel() End\n");
	}
	
/**
Constructor.

@param aChannel [In] The id of the channel to listen messages on. 
@param aObserver [In] A reference to an observer waiting for SUPL INIT messages.
@param aPropOwnerSecureId [In] The secure id of the process that owns the P&S propertirs used.

@see CLbsSuplPushRecChannel::NewL
*/
CLbsSuplPushRecChannel::CLbsSuplPushRecChannel(TLbsSuplPushChannel aChannel, MLbsSuplPushRecObserver& aObserver, 
		TUid aPropOwnerSecureId) : CActive(EPriorityStandard), 
		iObserver(aObserver), iChannel(aChannel), iPropOwnerSecureId(aPropOwnerSecureId)
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::CLbsSuplPushRecChannel() Begin\n");
	if(aChannel==ELbsSuplPushChannelSMS)
		{
		iInitPropKey=KLbsSuplPushSmsInitKey;
		iAckPropKey=KLbsSuplPushSmsAckKey;
		}
	else
		{	
		iInitPropKey=KLbsSuplPushWapInitKey;
		iAckPropKey=KLbsSuplPushWapAckKey;
		}	
	CActiveScheduler::Add(this);
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::CLbsSuplPushRecChannel() End\n");
	}

/**
The 2nd phase constructor. Attaches to the property, completes the async request to cause the RunL 
method to be called for the first time and check if already there is a message set to the INIT property.

@leave If a error happens, it leaves with one of the system error codes.

@see CLbsSuplPushRecChannel::NewL
*/
void CLbsSuplPushRecChannel::ConstructL()
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::ConstructL() Begin\n");
	User::LeaveIfError(iInitProperty.Attach(iPropOwnerSecureId, iInitPropKey, EOwnerThread));
	
	TRequestStatus* status = &iStatus;
	User::RequestComplete(status, KErrNone);
	SetActive();
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::ConstructL() End\n");
	}


/**
Called when the INIT property is changed and once on the construction of the object. Extracts 
the message from the INIT property, notifies both the observer by calling the 
MLbsSuplPushRecObserver::OnSuplInit function and the sender by setting the ACK property.
Then it resubscribes for the INIT property to listen for next messages.

@see CSuplPushImpl
@see MLbsSuplPushRecObserver::OnSuplInit
@see CActive::RunL
*/
void CLbsSuplPushRecChannel::RunL()
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() Begin\n");
	if(iStatus==KErrNone)
		{
		iInitProperty.Subscribe(iStatus);
		SetActive();
		
		TPckgBuf<TInt> length;
		TInt err = RProperty::Get(iPropOwnerSecureId, iInitPropKey, length);
		
		//The INIT propery has been defined but not set yet.
		if(err==KErrNone && length.Length()==0)
			{
			LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() - err==KErrNone && length.Length()==0 End\n");
			return;
			}
		
		//Can't do anything here, just resubscribe
		if(err!=KErrOverflow || length()<=0)
			{
			//The property must be set in the correct value.
			__ASSERT_DEBUG(0, User::Invariant());
			LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() - err!=KErrOverflow || length()<=0 End\n");
			return;
			}

		TInt len = length() + 2*sizeof(TInt);
		
		HBufC8* msg = HBufC8::New(len);
		
		//Not enough memory to handle the message, just resubscribe 
		if(msg==0)
			{
			LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() - msg==0 End\n");
			return;
			}
		
		TPtr8 ptr = msg->Des();
		err = RProperty::Get(iPropOwnerSecureId, iInitPropKey, ptr);
		if(err!=KErrNone || ptr.Length()!=len)
			{
			delete msg;
			//Unexpected environment error or the length of the message is not equal the length declared in
			//the header.
			__ASSERT_DEBUG(0, User::Invariant());
			LBSLOG(ELogP1, 
				"CLbsSuplPushRecChannel::RunL() RProperty::Get(iPropOwnerSecureId, iInitPropKey, ptr)|| ptr.Length()!=len End\n");
			return;
			}
		
		TPckgBuf<TInt> reqId;
		reqId.Copy(msg->Mid(sizeof(TInt), sizeof(TInt))); 
		
		if(reqId()<=0)
			{
			delete msg;
			//Message is corrupted, the reqId must be > 0. 
			__ASSERT_DEBUG(0, User::Invariant());
			LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() - reqId()<=0 End\n");
			return;
			}

			
		TInt ackId = 0;
		err = RProperty::Get(iPropOwnerSecureId, iAckPropKey, ackId);

		if(err!=KErrNone || ackId<0)
			{
			delete msg;
			if(ackId<0)
				{
				RProperty::Set(iPropOwnerSecureId, iAckPropKey, 0);
				}
			//Unexpected environment error or wrong ackId, it must be > 0.
			__ASSERT_DEBUG(0, User::Invariant());
			LBSLOG(ELogP1, 
					"CLbsSuplPushRecChannel::RunL() - RProperty::Get(iPropOwnerSecureId, iAckPropKey, ackId)!=KErrNone || ackId<0 End\n");
			return;
			}
		

		//We notify the observer only if message was not delivered before
		if(ackId!=reqId())
			{
			TLbsSuplPushRequestId reqIdUnsgn = reqId(); 
			TPtrC8 msgPtr = msg->Right(length());
			err = RProperty::Set(iPropOwnerSecureId, iAckPropKey, reqId());
			//Unexpected environment error.
			__ASSERT_DEBUG(err==KErrNone, User::Invariant());
			iObserver.OnSuplInit(iChannel, reqIdUnsgn , msgPtr);
			LBSLOG(ELogP9, "<-S MLbsSuplPushRecObserver::OnSuplInit() SuplPush\n");
			LBSLOG2(ELogP9, "  > TLbsSuplPushChannel aChannel = %d\n", iChannel);
			LBSLOG2(ELogP9, "  > TLbsSuplPushRequestId aReqId = %d\n", reqIdUnsgn);
			
			}
						
		delete msg;
		}
	else
		{
		iInitProperty.Subscribe(iStatus);
		SetActive();
		}
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::RunL() End\n");
	}
/**
Cancels the subscription for the INIT property.

@see CActive::Cancel
@see CLbsSuplPushRecChannel::~CLbsSuplPushRecChannel
*/
void CLbsSuplPushRecChannel::DoCancel()
	{
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::DoCancel() Begin\n");
	iInitProperty.Cancel();
	LBSLOG(ELogP1, "CLbsSuplPushRecChannel::DoCancel() End\n");
	}