/*

* Copyright (c) 2006 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:  See class definition below.

*

*/

#include "CTcSIPHttpDigestContainer.h"

#include "CTcSIPContext.h"

#include "CTcSIPConnectionContainer.h"

#include "SipConstants.h"

#include "ErrorHandling.h"

#include "SIPRefresh.h"

const TInt KReceivedChallengesQueueGranularity = 4;

CTcSIPHttpDigestContainer* CTcSIPHttpDigestContainer::NewL( 

    CTcSIPContext& aContext,

    CSIP& aSip )

    {

    CTcSIPHttpDigestContainer* self = 

        new ( ELeave ) CTcSIPHttpDigestContainer( aContext );

    CleanupStack::PushL( self );

    self->ConstructL( aSip );

    CleanupStack::Pop( self );

    return self;

    }

CTcSIPHttpDigestContainer::~CTcSIPHttpDigestContainer()

    {

    delete iSipHttpDigest;

    delete iTimer;

    iReceivedChallengesQueue.ResetAndDestroy();

    }

CTcSIPHttpDigestContainer::CTcSIPHttpDigestContainer( CTcSIPContext& aContext )

    : iContext( aContext ),

      iReceivedChallengesQueue( KReceivedChallengesQueueGranularity )

    {

    }

void CTcSIPHttpDigestContainer::ConstructL( CSIP& aSip )

    {

   	iTimer = CDeltaTimer::NewL( CActive::EPriorityStandard );

	TCallBack cb( ReceiveTimeout, this );

	iReceiveTimeout.Set( cb );

    iSipHttpDigest = CSIPHttpDigest::NewL( 

        aSip, static_cast< MSIPHttpDigestChallengeObserver& >( *this ) );

    }

void CTcSIPHttpDigestContainer::ChallengeReceived( const TDesC8& aRealm )

    {

    TRAPD( err, QueueReceivedChallengeL( aRealm ) );

    __ASSERT_ALWAYS( !err, Panic( KSIPErrOOMInNotifier ) );

    }

void CTcSIPHttpDigestContainer::ChallengeReceived( 

    const CSIPClientTransaction& aTransaction )

    {

    iContext.Connection().IncomingResponse( 

        const_cast< CSIPClientTransaction& >( aTransaction ) );

    }

void CTcSIPHttpDigestContainer::ChallengeReceived( 

    const CSIPRefresh& aRefresh )

    {

	TRAPD( err, {

		iContext.Registry().AddObjectL( aRefresh );

		TTcSIPReceived received;

		received.Set( &aRefresh );

		received.SetEvent( TTcSIPReceived::EIncomingResponse );

		iContext.Connection().QueueReceivedL( received );

		} )

	__ASSERT_ALWAYS( !err, Panic( KSIPErrOOMInNotifier ) );

    }

HBufC8* CTcSIPHttpDigestContainer::ReceivedChallengeL( TInt aTimeout )

    {

    if( iReceivedChallengesQueue.Count() == 0 )

		{

		// wait for items to arrive

		iTimer->Queue( aTimeout * KSecondAsMicros, iReceiveTimeout );

		iActiveWait.Start();

		}

	// Is the queue still empty ? (i.e. timeout occurred)

	if( iReceivedChallengesQueue.Count() == 0 )

		{

		User::Leave( KErrTimedOut );

		}

    HBufC8* challenge = iReceivedChallengesQueue[ 0 ];

    iReceivedChallengesQueue.Remove( 0 );

    iReceivedChallengesQueue.Compress();

    return challenge;

    }

void CTcSIPHttpDigestContainer::QueueReceivedChallengeL( const TDesC8& aRealm )

    {

    HBufC8* realm = aRealm.AllocLC();

    User::LeaveIfError( iReceivedChallengesQueue.Append( realm ) );

    CleanupStack::Pop(); //realm

    if( iActiveWait.IsStarted() )

		{

		iTimer->Remove( iReceiveTimeout );

		iActiveWait.AsyncStop();

		}

    }

TInt CTcSIPHttpDigestContainer::ReceiveTimeout( TAny* aSelf )

	{

	CTcSIPHttpDigestContainer& self =

				*reinterpret_cast< CTcSIPHttpDigestContainer* >( aSelf );

	if( self.iActiveWait.IsStarted() )

		{

		self.iActiveWait.AsyncStop();

		}

	return KErrNone;

	}