// Copyright (c) 2006-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:
//

/**
 @file
 @internalTechnology
*/

#include "cmtpconnectionmgr.h"
#include "cmtpserversession.h"
#include "rmtpframework.h"
#include "cmtpframeworkconfig.h"
#include "cmtpdataprovidercontroller.h"
#include "cmtpparserrouter.h"
#include "e32def.h"
__FLOG_STMT(_LIT8(KComponent,"ServerSession");)


/**
Constructor.
*/
CMTPServerSession::CMTPServerSession()
    {
    __FLOG_OPEN(KMTPSubsystem, KComponent);
    __FLOG(_L8("CMTPServerSession - Entry"));
    __FLOG(_L8("CMTPServerSession - Exit"));
    }
    
/**
Destructor.
*/
CMTPServerSession::~CMTPServerSession()
    {
    __FLOG(_L8("~CMTPServerSession - Entry"));
    static_cast<CMTPServer*>(const_cast<CServer2*>(CSession2::Server()))->DropSession();
    iSingletons.Close();
    __FLOG(_L8("~CMTPServerSession - Exit"));
    __FLOG_CLOSE;
    }
    
void CMTPServerSession::CreateL()
    {
    __FLOG(_L8("CreateL - Entry"));
    iSingletons.OpenL();
    static_cast<CMTPServer*>(const_cast<CServer2*>(CSession2::Server()))->AddSession();
    __FLOG(_L8("CreateL - Exit"));
    }

void CMTPServerSession::ServiceL(const RMessage2& aMessage)
    {
    __FLOG(_L8("ServiceL - Entry"));
    switch (aMessage.Function())
        {
    case EMTPClientStartTransport:
        __FLOG(_L8("StartTransport message received"));        
        DoStartTransportL(aMessage);
        break;
    case EMTPClientStopTransport:
        __FLOG(_L8("StopTransport message received"));
        DoStopTransport(aMessage);
        break;
     case EMTPClientIsAvailable :
        __FLOG(_L8("IsAvailable message received"));
        DoIsAvailableL(aMessage);
     
        break;
    default:
        __FLOG(_L8("Unrecognised message received"));
        break;        
        }
    __FLOG(_L8("ServiceL - Exit"));
    }
TBool CMTPServerSession::CheckIsAvailableL(TUid aNewUID,TUid aCurUID)
{

	    TInt SwitchEnabled;
	    iSingletons.FrameworkConfig().GetValueL(CMTPFrameworkConfig::ETransportSwitchEnabled, SwitchEnabled);	    
	    if(!SwitchEnabled )
		    {		    
		    return EFalse;
		    }
       TBuf<30> value;
       iSingletons.FrameworkConfig().GetValueL(CMTPFrameworkConfig::ETransportHighPriorityUID,value);	    	    
	   TUint HighUID;	    
	   TLex lex(value);	    
	   TInt conErr = lex.Val(HighUID,EHex);
	   if(aCurUID.iUid == HighUID)
		    {
		    return EFalse;	

		    }
	   else if(aNewUID.iUid ==HighUID)
		    {
	    	return ETrue;
		    }
	   return EFalse;	
}
/**
Starts up the specified MTP transport protocol.
@param aTransport The implementation UID of the transport protocol implemetation.
@leave One of the system wide error codes, if a processing error occurs.
*/
void CMTPServerSession::DoStartTransportL(const RMessage2& aMessage)
    {
    __FLOG(_L8("DoStartTransportL - Entry"));
    TUid newUID = TUid::Uid(aMessage.Int0()); 
    TUid curUID = iSingletons.ConnectionMgr().TransportUid();
    if(curUID !=(KNullUid))  // Another Transport is already running
		{
    	if(!CheckIsAvailableL(newUID,curUID))
    		{
    		aMessage.Complete(KErrServerBusy);
    		iSingletons.ConnectionMgr().QueueTransportL( newUID, NULL );
    		return;
    		}
	    iSingletons.ConnectionMgr().StopTransport(curUID);
    	}
    
    TUid secureid=aMessage.SecureId();    
    iSingletons.ConnectionMgr().SetClientSId(secureid);
    
    TInt length = aMessage.GetDesLength( 1 );
    
    if((!CheckIsBlueToothTransport(newUID) || (length!=0)) && (iSingletons.DpController().Count()==0))
    	{
    	iSingletons.DpController().LoadDataProvidersL();
    	iSingletons.Router().ConfigureL();
    	}
   
    if (length > 0)
    	{
    	HBufC8* paramHbuf = HBufC8::NewLC(length);
    	TPtr8 bufptr = paramHbuf->Des();
    	aMessage.ReadL( 1, bufptr, 0);
    	TRAPD(err, iSingletons.ConnectionMgr().StartTransportL( newUID, static_cast<TAny*>(paramHbuf) ));
    	if ( KErrArgument == err )
    		{
    		PanicClient( aMessage, EPanicErrArgument );
    		}
    	else if ( KErrNone == err )
    		{
    		aMessage.Complete(KErrNone);
    		}
    	else 
    		{
    		User::LeaveIfError( err );
    		}
    	CleanupStack::PopAndDestroy(paramHbuf);
    	}
    else
    	{
    	iSingletons.ConnectionMgr().StartTransportL(newUID, NULL);
    	aMessage.Complete(KErrNone);
    	}
    
    
    __FLOG(_L8("DoStartTransportL - Exit"));
    }  


/**
Shuts down the specified MTP transport protocol.
@param aTransport The implementation UID of the transport protocol implemetation.
*/  
void CMTPServerSession::DoStopTransport(const RMessage2& aMessage)
    {
    __FLOG(_L8("DoStopTransport - Entry"));
   iSingletons.ConnectionMgr().StopTransport( TUid::Uid( aMessage.Int0() ), ETrue );
    aMessage.Complete(KErrNone);
    __FLOG(_L8("DoStopTransport - Exit"));
    }

/**
Checks whether MTP Framework shall allow the StartTransport Command for given transport.
@param aTransport The implementation UID of the transport protocol implementation.
@leave One of the system wide error codes, if a processing error occurs.
*/  
void CMTPServerSession::DoIsAvailableL(const RMessage2& aMessage)
    {
    __FLOG(_L8("DoStopTransport - Entry"));
   
   TUid newUID = TUid::Uid(aMessage.Int0()); 
   TUid curUID = iSingletons.ConnectionMgr().TransportUid();
   
   if(curUID !=(KNullUid))  // Another Transport is already running
		{
		if(curUID== newUID)
			{
    		aMessage.Complete(KErrAlreadyExists); 	
    		return;				
			}
    	else if(!CheckIsAvailableL(newUID,curUID))
    		{
    		aMessage.Complete(KErrServerBusy); 	
    		return;
    		}	    
    	}

    aMessage.Complete(KErrNone);
    __FLOG(_L8("DoStopTransport - Exit"));
    }

TBool CMTPServerSession::CheckIsBlueToothTransport(TUid aNewUid)
	{
	TInt32 bluetoothUid = 0x10286FCB;
	return aNewUid.iUid == bluetoothUid;
	}