--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/mmcecli/src/mcesessionreceiver.cpp	Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,288 @@
+/*
+* 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;    
+    }