/*
* Copyright (c) 2004 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 "mceinsessionobserver.h"
#include "mcemanager.h"
#include "mceinsession.h"
#include "mcetransactiondatacontainer.h"
#include "mcemanagerreceiver.h"
#include "mce.h"
#include "mcecomsession.h"
#include "mceserial.h"
#include "mceclilogs.h"
#include "mcesecureinsession.h"

// -----------------------------------------------------------------------------
// CMceManagerReceiver::CMceManagerReceiver
// -----------------------------------------------------------------------------
//
CMceManagerReceiver::CMceManagerReceiver( RMce& aMce,
                                          CMceManager& aManager )
 : CMceItcReceiverBase ( aMce ),
   iManager( aManager )
	{
	iIdsPckg().iAppUID = aManager.AppUid().iUid;
	iIdsPckg().iManagerType = KMceCSSIPSession;
	
    Init();
	
	}

// -----------------------------------------------------------------------------
// CMceManagerReceiver::~CMceManagerReceiver
// -----------------------------------------------------------------------------
//
CMceManagerReceiver::~CMceManagerReceiver () 
	{
	}

// -----------------------------------------------------------------------------
// CMceManagerReceiver::IncomingEventL
// -----------------------------------------------------------------------------
//
void CMceManagerReceiver::IncomingEventL( TMceItcCallBack aEvent, 
                                          TMceIds& aIds, 
                                          const TDesC8& aContext )
	{

    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Entry");
    MCECLI_DEBUG_DVALUE("context size", aContext.Length() );
	
	__ASSERT_ALWAYS( aEvent == EMceItcObjectAdded , 
	    User::Leave( KErrNotSupported ) );
	__ASSERT_ALWAYS( aIds.iMsgType == EMceItcMsgTypeSession , 
	    User::Leave( KErrNotSupported ) );
    
    HandleIncomingSessionL( aContext, NULL, aIds );
    
    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Exit");
    
	}

	
// -----------------------------------------------------------------------------
// CMceManagerReceiver::IncomingEventL
// -----------------------------------------------------------------------------
//
void CMceManagerReceiver::IncomingEventL( TMceItcCallBack aEvent, 
                                          TMceIds& aIds, 
                                          const TDesC8& aContext, 
                                          HBufC8* aContent )
	{
    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Entry");
    MCECLI_DEBUG_DVALUE("context size", aContext.Length() );
    MCECLI_DEBUG_DVALUE("content size", aContent ? aContent->Length() : 0 );

	__ASSERT_ALWAYS( aEvent == EMceItcObjectAdded , 
	    User::Leave( KErrNotSupported ) );
	__ASSERT_ALWAYS( aIds.iMsgType == EMceItcMsgTypeSession , 
	    User::Leave( KErrNotSupported ) );
    
    HandleIncomingSessionL( aContext, aContent, aIds );

    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Exit");
    
	}
	
// -----------------------------------------------------------------------------
// CMceManagerReceiver::IncomingEventL
// -----------------------------------------------------------------------------
//
void CMceManagerReceiver::IncomingEventL( TMceItcCallBack /*aEvent*/, 
                                          TMceIds& aIds )
	{
    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Entry");
	iManager.HandleIncomingEventL( aIds );
    MCECLI_DEBUG("CMceManagerReceiver::IncomingEventL, Exit");
	}


// -----------------------------------------------------------------------------
// CMceManagerReceiver::ErrorOccuredL
// -----------------------------------------------------------------------------
//
void CMceManagerReceiver::ErrorOccuredL (TMceIds& /*aIds*/, TInt aError )
	{
    MCECLI_DEBUG_DVALUE("CMceManagerReceiver::ErrorOccuredL, error", aError );
	User::Leave( aError );
	}


// -----------------------------------------------------------------------------
// CMceManagerReceiver::HandleIncomingSessionL
// -----------------------------------------------------------------------------
//
void CMceManagerReceiver::HandleIncomingSessionL ( const TDesC8& aContext, 
                                                   HBufC8* aContent,
                                                   TMceIds& aIds )
	{
    MCECLI_DEBUG("CMceManagerReceiver::HandleIncomingSessionL, Entry");
	
	if ( iManager.InSessionObserver() )
		{	
	    CMceInSession* session = NULL;
	    
		RDesReadStream readStream( aContext );
	    CleanupClosePushL( readStream );

        MCECLI_DEBUG("CMceManagerReceiver::HandleIncomingSessionL, creating new session");
		
		if (aIds.iSecureFlag)
			{
			session = CMceSecureInSession::NewL( readStream, iManager, aIds.iProfileID );
			}
		else
			{
			session = CMceInSession::NewL( readStream, iManager, aIds.iProfileID );
			}
		

		CleanupStack::PopAndDestroy();//readStream
		CleanupStack::PushL( session );
		CDesC8Array* headers = NULL;
	    HBufC8* contentType = NULL;
	    CDesC8Array* contentHeaders = NULL;
	    session->GetSIPParams( headers, contentType, contentHeaders );
	    
		TInt pushs = 0;
		
		if ( headers )
			{
			CleanupStack::PushL( headers );++pushs;
			}
		if ( contentType )
			{
			CleanupStack::PushL( contentType );++pushs;
			}
        if ( contentHeaders )
			{
			CleanupStack::PushL( contentHeaders );++pushs;
			}
		
		
	    TMceTransactionDataContainer* container = 
	        iManager.TransactionContainer();
	    
		if ( container )
			{
            container->SetHeaders( headers );
            container->SetContentType( contentType );
            container->SetContent( aContent );
            container->SetContentHeaders( contentHeaders );
			iManager.InSessionObserver()->IncomingSession( session, 
			                                               container );
			CleanupStack::Pop( pushs );
			}
	    else
	        {
			CleanupStack::PopAndDestroy( pushs );
			iManager.InSessionObserver()->IncomingSession( session, 
			                                               container );
	        }
	        
		CleanupStack::Pop( session );
		
	    if (container)
	    	{
	    	container->Clear();
	    	}						
		}
	else
		{
		delete aContent;	
		}

    MCECLI_DEBUG("CMceManagerReceiver::HandleIncomingSessionL, Exit");

	}