/*

* Copyright (c) 2005 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 "mcemanager.h"

#include "mceinsession.h"

#include "mcemediastream.h"

#include "mceaudiocodec.h"

#include "mcesessionreceiver.h"

#include "mcetransactionobserver.h" 

#include "mce.h"

#include "mceserial.h"

#include "mceclilogs.h"

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

// CMceSessionReceiver::CMceSessionReceiver

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

//

CMceSessionReceiver::CMceSessionReceiver( RMce& aMce,

                                          CMceSession& aSession )

 : CMceItcReceiverBase( aMce ),

   iSession( &aSession )

	{

	iIdsPckg().iAppUID = aSession.Manager().AppUid().iUid;

	iIdsPckg().iManagerType = KMceCSSIPSession;

	iIdsPckg().iSessionID = aSession.Id();

    Init();

	}

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

// CMceSessionReceiver::~CMceSessionReceiver

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

//

CMceSessionReceiver::~CMceSessionReceiver () 

	{

	}

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

// CMceSessionReceiver::IncomingEventL

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

//

void CMceSessionReceiver::IncomingEventL( TMceItcCallBack aEvent, TMceIds& aIds, 

                                          const TDesC8& aContext )

	{

    MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, Entry");

    MCECLI_DEBUG_DVALUE("context size", aContext.Length() );

	switch ( aEvent )

	    {

	    case EMceItcIncomingUpdate:

    	    {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming update. \

creating new in-session");

    		RDesReadStream readStream( aContext );

    	    CleanupClosePushL( readStream );

            CMceManager& manager = iSession->Manager();

    		CMceInSession* session = 

    		    CMceInSession::NewL( readStream, manager, aIds.iProfileID, ETrue );

    		CleanupStack::PopAndDestroy();//readStream

    		CleanupStack::PushL( session );

    		iSession->IncomingUpdateL( session, NULL );

    		CleanupStack::Pop( session );

    	    break;   

    	    }

	    case EMceItcStateChanged:

	    case EMceItcUpdateFailed:

	    case EMceItcResponseReceived: 

	    case EMceItcRequestReceived : 

	        {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming event. \

passing to session");

	        CMceMsgBase* message = DecodeMessageLC( aIds, aContext );

	        User::LeaveIfError( message ? KErrNone : KErrGeneral );

            message->PushL();

            iSession->EventReceivedL( aIds, *message );

        	CleanupStack::PopAndDestroy( message );

	        break;

	        }

	    case EMceItcFCMsgReceived:

	        {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming FC event. \

passing to FC session");

			HBufC8* fcMessage = aContext.AllocL();

	        iSession->FCMessageReceived( fcMessage );

	        break;

	        }

	    //no context expected            

        case EMceItcSRReceived:

        case EMceItcRRReceived:

        case EMceItcInactivityTimeout:

        case EMceItcSessionConnectionStateChanged:

        default:

            {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, not supported");

            User::Leave( KErrNotSupported );

            }

	    }

    MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, Exit");

	}

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

// CMceSessionReceiver::IncomingEventL

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

//

void CMceSessionReceiver::IncomingEventL( TMceItcCallBack aEvent, TMceIds& aIds, 

                                          const TDesC8& aContext, 

                                          HBufC8* aContent )

	{

    MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, Entry");

    MCECLI_DEBUG_DVALUE("context size", aContext.Length() );

    MCECLI_DEBUG_DVALUE("content size", aContent ? aContent->Length() : 0 );

	switch ( aEvent )

	    {

	    case EMceItcIncomingUpdate:

    	    {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming update. \

creating new in-session");

    		RDesReadStream readStream( aContext );

    	    CleanupClosePushL( readStream );

            CMceManager& manager = iSession->Manager();

    		CMceInSession* session = 

    		    CMceInSession::NewL( readStream, manager, aIds.iProfileID, ETrue );

    		CleanupStack::PopAndDestroy();//readStream

    		CleanupStack::PushL( session );

    		iSession->IncomingUpdateL( session, aContent );

    		CleanupStack::Pop( session );

    	    break;   

    	    }

	    case EMceItcStateChanged:

	    case EMceItcUpdateFailed:

	    case EMceItcResponseReceived: 

	    case EMceItcRequestReceived:

	        {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming event. \

passing to session");

	        CMceMsgBase* message = DecodeMessageLC( aIds, aContext );

	        User::LeaveIfError( message ? KErrNone : KErrGeneral );

            message->PushL();

            iSession->EventReceivedL( aIds, *message, aContent );

        	CleanupStack::PopAndDestroy( message );

	        break;

	        }

	    //no content expected

        case EMceItcSRReceived:

        case EMceItcRRReceived:

        case EMceItcInactivityTimeout:

        case EMceItcSessionConnectionStateChanged:

        default:

            {

            MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, not supported");

            User::Leave( KErrNotSupported );

            }

	    }

    MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, Exit");

	}

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

// CMceSessionReceiver::IncomingEventL

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

//

void CMceSessionReceiver::IncomingEventL( TMceItcCallBack aEvent, TMceIds& aIds )

	{

    MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, Entry");

	if ( aEvent == EMceItcFCErrorReceived )

	    {

        MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, FC error occured");

	    iSession->FCErrorOccurred( aIds.iStatus );

	    }

	else

	    {

        MCECLI_DEBUG("CMceSessionReceiver::IncomingEventL, incoming event. \

passing to session");

	    iSession->EventReceivedL( aIds );    

	    }

    }

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

// CMceSessionReceiver::ErrorOccuredL

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

//

void CMceSessionReceiver::ErrorOccuredL (TMceIds& aIds, TInt aError )

	{

    MCECLI_DEBUG("CMceSessionReceiver::ErrorOccuredL, Entry");

    MCECLI_DEBUG_DVALUE("error", aError );

    if ( aIds.iTransactionID != KMceNotAssigned )

    	{

    	MCECLI_DEBUG("Handling Extension Requests Error");	

        MMceTransactionObserver* observer = iSession->Manager().TransactionObserver();

        if ( observer )

            {

            observer->TransactionFailed( *iSession, aIds.iTransactionID, aError );

            }

    	}

    else

    	{

    	iSession->ErrorOccuredL( aError );		

    	}

    MCECLI_DEBUG("CMceSessionReceiver::ErrorOccuredL, Exit");

	}

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

// CMceSessionReceiver::DecodeMessageL

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

//

CMceMsgBase* CMceSessionReceiver::DecodeMessageLC( TMceIds& aIds, 

                                                   const TDesC8& aContext )

    {

	RDesReadStream readStream( aContext );

    CleanupClosePushL( readStream );

    CMceMsgBase* message = TMceFactory().CreateL( (TMceItcDataType)aIds.iMsgType, 

                                                  readStream );

	CleanupStack::PopAndDestroy(); // readStream

	CleanupStack::PushL( message );

    return message;

    }

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

// CMceSessionReceiver::ReplaceSession

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

//

void CMceSessionReceiver::ReplaceSession( CMceSession& aNewSession )

    {

    iSession = &aNewSession;    

    }