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

//
// CWapPortWatcher
//

//
// Global Defines
//
const TInt KSmsWRetryTimer = 1000000 * 15; // 15 Secs

//
// Construction
//	private
//
CWapPortWatcher::CWapPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, TUint16 aWapPort)
:	CBaseSmsActiveSocketWatcher(aWatcherLog, aPriority, aBioID, aFs), iWapPort(aWapPort)
	{
	}

CWapPortWatcher* CWapPortWatcher::NewL(TMsvId aBioServiceId, 
									   TMsvId aSmsServiceId, 
									   CBIODatabase& aBioDb, 
									   CWatcherLog& aWatcherLog, 
									   TInt aPriority, 
									   TUid aBioID, 
									   RFs& aFs, 
									   const TBioMsgId& aBioMsg)
	{
	CWapPortWatcher* self = NULL;

	//Create either a WDP or WSP watcher, depending on the BioMsgId type
	switch (aBioMsg.iType)
		{
		case EBioMsgIdNbs:
		case EBioMsgIdWap:
		case EBioMsgIdWapSecure:
			{
			self = new (ELeave) CWdpPortWatcher(aWatcherLog, aPriority, aBioID, aFs, STATIC_CAST(Wap::TPort,aBioMsg.iPort));
			break;
			}
		case EBioMsgIdWsp:
		case EBioMsgIdWspSecure:
			{
			self = new (ELeave) CWspPortWatcher(aWatcherLog, aPriority, aBioID, aFs, STATIC_CAST(Wap::TPort,aBioMsg.iPort));
			break;
			}
		default:
			User::Leave(KErrNotSupported);
		}

	CleanupStack::PushL(self);
	self->ConstructL(aBioDb, aBioServiceId, aSmsServiceId);
	CleanupStack::Pop(self);
	return self;
	}

CWapPortWatcher::~CWapPortWatcher()
	{
	delete iRecvBuf;
	iRecvBuf = NULL;
	}

void CWapPortWatcher::DoComplete(TInt& rStatus)
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWap: DoComplete: %S, port %d, status %d"), &iBioMsgText, iWapPort, rStatus));

	CloseConn();
	}

void CWapPortWatcher::DoReceiveL(const TDesC8& aRecvFrom)
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L("BioWap: DoReceiveL: %S, port %d"),&iBioMsgText, iWapPort));
	
	// Code for collecting message goes here...
	BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioWap: Recv datagram length: %d on socket OK"), iRecvBuf->Length()));
	
	// Create a CSmsMessage from the recieved buffer
	CSmsBuffer* buffer=CSmsBuffer::NewL();
	
	
	CSmsMessage* smsmessage = CSmsMessage::NewL(iFs, CSmsPDU::ESmsDeliver, buffer);
	CleanupStack::PushL(smsmessage);

	smsmessage->SmsPDU().SetAlphabet(TSmsDataCodingScheme::ESmsAlphabet8Bit);

	if (aRecvFrom.Length())
		{
		//Convert aRecvFrom to 16-bit
		HBufC* tempRemoteAddr = HBufC::NewLC(aRecvFrom.Length());
		tempRemoteAddr->Des().Copy(aRecvFrom);

		//Set the from address in the CSmsMessage
		smsmessage->SmsPDU().SetToFromAddressL(*tempRemoteAddr);
		CleanupStack::PopAndDestroy(tempRemoteAddr);
		}
	
	//Convert iRecvTotalMessage to 16-bit
	HBufC* tempRecvBuf = HBufC::NewLC(iRecvBuf->Length());
	tempRecvBuf->Des().Copy(*iRecvBuf);
	buffer->InsertL(0, *tempRecvBuf);
	CleanupStack::PopAndDestroy(tempRecvBuf);

	//Pop buffer and smsmessage off the cleanup stack,
	//because StoreMsgL() will destroy the CSmsMessage (which contains the buffer).
	CleanupStack::Pop();// smsmessag

	StoreMsgL(smsmessage);
	
	// Not Async so signal here...
	TRequestStatus* pS=&iStatus;
	User::RequestComplete(pS, KErrNone);
	}

void CWapPortWatcher::AppendToHBufC8L(HBufC8*& aBuf, const TDesC8& aAppend)
	{
	//Appends aAppend to aBuf. If aBuf is NULL, then copies aAppend into aBuf.

	if (!aBuf || aBuf->Length() == 0)
		{
		delete aBuf;
		aBuf = NULL;
		aBuf = aAppend.AllocL();
		}
	else
		{
		//Append the new message in iWspRecvBuf to the iTempRecvBuf
		aBuf = aBuf->ReAllocL(aBuf->Length() + aAppend.Length());
		aBuf->Des().Append(aAppend);
		}
	}

void CWapPortWatcher::CloseConn()
	{
	delete iRecvBuf;
	iRecvBuf = NULL;
	}

void CWapPortWatcher::DoRunL()
	{
	switch(iState)
		{
		case ESmsWWaitForMsg:
			iState = ESmsWReadMsg;
			WaitForMessageL();
			break;
		
		case ESmsWReadMsg:
			iState = ESmsWWaitForMsg;
			ReceiveL();
			break;

		case ESmsWRetryError:
			if (!iTimer.Handle())
				{
				User::LeaveIfError(iTimer.CreateLocal());
				}
			iState=ESmsWWaitForMsg;
			iTimer.After(iStatus, KSmsWRetryTimer);
			break;
		
		case ESmsIsClass0Msg:
			iState = ESmsWWaitForMsg;
			CompleteSelf();
			break;
		}

	SetActive();

	}

// WAP messages that use Class 0 SMS messages should be treated as non Class 0 messages,
// so need to go back to ESmsWWaitForMsg state.
void CWapPortWatcher::CompleteSelf()
	{
	// Complete self.
	TRequestStatus* status = &iStatus;
	iStatus = KRequestPending;
	User::RequestComplete(status, KErrNone);
	}