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

// $Header$

// This source file implements the basic event management control (active

// objects) for our domain command supprt.

// based loosely on the WSP version...

// Note: you must regenerate from this for the domain you require, providing the

// appropriate callbacks - this way reuse and oo is maintained.

// 

//

#include "CEventDispatcher.h"

#include "CTimeoutTimer.h"

#include "MHTTPEventCallback.h"

//-----------------------------------------------------------------------------

const TInt KSecondsToMicroSecondsFactor	= 1000000;

//-----------------------------------------------------------------------------

CEventDispatcher *CEventDispatcher::NewL(MHTTPEventCallback& aCallback)

{

CEventDispatcher *self = new (ELeave) CEventDispatcher(aCallback);

CleanupStack::PushL(self);

self->ConstructL();

CleanupStack::Pop(self);

return self;

}

//-----------------------------------------------------------------------------

CEventDispatcher::~CEventDispatcher()

{

Cancel();

delete iTimer;

}

//-----------------------------------------------------------------------------

CEventDispatcher::CEventDispatcher(MHTTPEventCallback &aCallback)

	: 

	CActive(EPriorityStandard), 

	iCallback(aCallback),

	iSession(NULL),

	iTransaction(NULL)

{

CActiveScheduler::Add(this);

}

//-----------------------------------------------------------------------------

void CEventDispatcher::ConstructL()

{

iTimer = CTimeoutTimer::NewL(*this);

}

//-----------------------------------------------------------------------------

void CEventDispatcher::WaitForHTTPEvent(RHTTPSession *aSess, TInt aTimeoutValueSeconds)

{

iSession = aSess;

// Request the get event from the co session

//iTrans = NULL;

//iConn->GetEvent(iEvent, iTrans, iStatus);

// Set ourselves active

SetActive();

// Start the timeout timer

iTimer->After(aTimeoutValueSeconds * KSecondsToMicroSecondsFactor);

}

//-----------------------------------------------------------------------------

void CEventDispatcher::CancelWait()

{

Cancel();

}

//-----------------------------------------------------------------------------

//	Methods from CActive

void CEventDispatcher::RunL()

{

// Check to see if this event is for a transaction in the aborting state

if (iTransaction != NULL)

	{

	/*

	// Check the state

	TWspMethodState state;

	iTrans->GetState(state);

	if (state == EAborting && iEvent != EMethodAbortInd)

		{

		// Transaction is in Aborting state and this not the S-MethodAbort.ind

		// event - need to ignore this event. Ask the session for next event.

		iTrans = NULL;

		iConn->GetEvent(iEvent, iTrans, iStatus);

		// Set ourselves active

		SetActive();

		// NOTE - don't cancel timeout timer, nor start it again.

		return;

		}

	*/

	}

//	Record the iStatus

TRequestStatus status = iStatus;

//	Cancel the timer

iTimer->Cancel();

//	We are waiting for HTTP event	

iCallback.HandleHTTPEvent(iEvent, iSession, status);

}

//-----------------------------------------------------------------------------

void CEventDispatcher::DoCancel()

{

if (iTransaction)

	iTransaction->Cancel();

iTimer->Cancel();

}

//-----------------------------------------------------------------------------

//	Methods from MTimeoutCallback

void CEventDispatcher::Timeout()

{

// Cancel the get event request

Cancel();

// Inform the call back

iCallback.HandleHTTPEvent(iEvent, iSession, KRequestPending);

}

//-----------------------------------------------------------------------------