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

// System includes
#include <wsp/mwspcomethodinvoker.h>
#include <wsp/mwspcomethodcallback.h>
#include <wsp/mwspcosessioncallback.h>
#include <uri8.h>

// Local includes 
#include "cnwssconnectguard.h"

CNwssConnectGuard* CNwssConnectGuard::NewL(MWspCOMethodInvoker& aMethodInvoker, MWspCOSessionCallback& aSessionCallback)
	{
	CNwssConnectGuard* self = new (ELeave) CNwssConnectGuard(aMethodInvoker, aSessionCallback);
	return self;
	}

CNwssConnectGuard::~CNwssConnectGuard()
	{
	ResetMethodInfo();
	}

CNwssConnectGuard::CNwssConnectGuard(MWspCOMethodInvoker& aMethodInvoker, MWspCOSessionCallback& aSessionCallback)
: CActive(CActive::EPriorityStandard), iMethodInvoker(aMethodInvoker), iSessionCallback(aSessionCallback)
	{
	CActiveScheduler::Add(this);
	}

void CNwssConnectGuard::SendMethodInvokeReq()
	{
	// Check to see if object is active - this implies that T-MethodAbort.ind
	// is waiting to sent.
	if( !IsActive() && iMethodCallback )
		{
		// Send the T-MethodInvoke.req primitive.
		iMethodInvoker.MethodInvokeReq(
									  *iMethodCallback,
									  iMethod,
									  iRequestUri->Uri(),
									  *iRequestHeaders,
									  *iRequestBody,
									  EFalse
									  );
		// Release resources - no longer neeeded
		ResetMethodInfo();
		}
	}

void CNwssConnectGuard::SendDisconnectInd(Wap::TWspReason aReason)
	{
	// Specify that need to send S-Disconnect.ind
	iSendDisconnect = ETrue;

	// Store the reason code
	iDisconnectReason = aReason;

	CompleteSelf();
	}

void CNwssConnectGuard::SendMethodAbortInd()
	{
	CompleteSelf();
	}

void CNwssConnectGuard::ReceivedMethodInvokeReqL(
												MWspCOMethodCallback&	aMethodCallback,
												RStringF				aMethod,
												const TUriC8&			aRequestUri,
												const TDesC8&			aRequestHeaders,
												const TDesC8&			aRequestBody
												)
	{
	if( iMethodCallback )
		{
		// Have already got method info - leave as this is not allowed.
		User::Leave(KErrAlreadyExists);
		}
	iMethodCallback	= &aMethodCallback;
	iMethod			= aMethod.Copy();
	iRequestUri		= CUri8::NewL(aRequestUri);
	iRequestHeaders	= aRequestHeaders.AllocL();
	iRequestBody	= aRequestBody.AllocL();
	}

void CNwssConnectGuard::RunL()
	{
	// Check to see if there is any method info.
	if( iMethodCallback )
		{
		Wap::TWspReason reason = Wap::EUserReq;

		if( iSendDisconnect && iDisconnectReason != Wap::EUserReq )
			{
			// The session was disconnected due to a connect failure - could be
			// a WTLS failure, etc.
			reason = Wap::EConnectErr;
			}
		// Yep - send the T-MethodAbort.ind
		iMethodCallback->MethodAbortInd(reason);

		// Release resources - no longer neeeded
		ResetMethodInfo();
		}
	// Send S-Disconnect?
	if( iSendDisconnect )
		{
		TWspRedirectedAddress emptyAddr;
		iSessionCallback.DisconnectInd(iDisconnectReason, EFalse, emptyAddr, KNullDesC8(), KNullDesC8());
		}
	}

void CNwssConnectGuard::DoCancel()
	{
	}

void CNwssConnectGuard::CompleteSelf()
	{
	if (!IsActive())
		{
		TRequestStatus* pStat = &iStatus;
		User::RequestComplete(pStat, KErrNone);
		SetActive();
		}
	}

void CNwssConnectGuard::ResetMethodInfo()
	{
	iMethod.Close();
	iMethod = RStringF();
	delete iRequestUri;
	iRequestUri = NULL;
	delete iRequestHeaders;
	iRequestHeaders = NULL;
	delete iRequestBody;
	iRequestBody = NULL;
	}