// Copyright (c) 2000-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:
//


#include "WapSocketWatcher.h"
#include <watcher.h>

#include <wapmessage.h>
#include <wapmsgerr.h>

//
//CWspPortWatcher
//

CWspPortWatcher::CWspPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, Wap::TPort aWapPort)
	: CWapPortWatcher(aWatcherLog, aPriority, aBioID, aFs, aWapPort),iPushPckgId(0)
	{
	}

CWspPortWatcher::~CWspPortWatcher()
	{
	Cancel();
	CloseConn();
	delete iWspConn;
	delete iRecvHeader;
	}

void CWspPortWatcher::CloseConn()
	{
	//Close the WSP connection
	delete iWspConn;
	iWspConn=NULL;

	delete iRecvHeader;
	iRecvHeader = NULL;

	CWapPortWatcher::CloseConn(); //deletes iRecvBuf
	}

void CWspPortWatcher::DoCancel()
	{
	if (iWspConn!=NULL)
		iWspConn->CancelAwaitPush();
	}

void CWspPortWatcher::DoSetupL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWsp: DoSetupL: %S, port %d"), &iBioMsgText, iWapPort));

	//Open Connectionless WSP connection on port iWapPort
	if(iWspConn==NULL)
		iWspConn=CWapBoundCLPushService::NewL();
	User::LeaveIfError(iWspConn->Connect(Wap::ESMS,iWapPort,EFalse));
	}

void CWspPortWatcher::WaitForMessageL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWsp: WaitForMessageL: %S, port %d"), &iBioMsgText, iWapPort));

	User::LeaveIfError(iStatus.Int());

	//Wait for WSP push message on port iWapPort	
	iTempRecvBuf.Zero();
	iTempRecvHeader.Zero();
	User::LeaveIfError(iWspConn->AwaitPush(iTempRecvHeader,iTempRecvBuf,iPushPckgId,iStatus));

	//SetActive() is called by CBaseSmsActiveSocketWatcher::DoRunL()
	}

void CWspPortWatcher::ReceiveL()
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWsp: ReceiveL: %S, port %d"), &iBioMsgText, iWapPort));

	//Receive the WAP Message.

	switch (iStatus.Int())
		{
		case Wap::EMoreData:
			{
			//if iStatus == EMoreData, then must wait for the rest of the message
			AppendToHBufC8L(iRecvHeader, iTempRecvHeader);
			AppendToHBufC8L(iRecvBuf, iTempRecvBuf);

			TRequestStatus* pS=&iStatus;
			User::RequestComplete(pS, KErrNone);
			break;
			}
		case KErrNone:
			{
			AppendToHBufC8L(iRecvHeader, iTempRecvHeader);
			AppendToHBufC8L(iRecvBuf, iTempRecvBuf);
			
			// DEF053845 Provide a NULL pointer for GetServerAddress().
			// GetServerAddress() Allocs and sets up the pointer.
			HBufC8* serverAddress = NULL;
			// Pick up and interrogate the return rather than User::LeaveIfError.
			// Leaving here could result in us receiving the message again
			// and again.
			TInt err = iWspConn->GetServerAddress(serverAddress);
			if(err == KErrNone && serverAddress->Length())
				{
				CleanupStack::PushL(serverAddress);
				DoReceiveL(*serverAddress);
				CleanupStack::PopAndDestroy(serverAddress);
				}
			else
				{
				delete serverAddress; // Could have been alloc'd but it won't hurt to delete if NULL
				DoReceiveL(KNullDesC8);
				}							
			delete iRecvBuf;
			iRecvBuf = NULL;
			delete iRecvHeader;
			iRecvHeader = NULL;
			}
			break;
		default:
			User::Leave(iStatus.Int());
			break;
		}
	}