--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/networkprotocolmodules/suplprotocolmodule/SuplPushAPI/src/lbssuplpushreceiverchannel.cpp	Fri Jun 04 10:34:15 2010 +0100
@@ -0,0 +1,250 @@
+// 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");
+	}
+