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

 Implements a Session of a Symbian OS server for the RUsbMassStorage API

 */

#include <e32property.h>

#include <coreapplicationuisdomainpskeys.h>

#include "mscfilesession.h"

#include "mscfilecontroller.h"

#include "mscfileserver.h"

#include "usbmscfileshared.h"

#include "debug.h"

/**

 Construct a Symbian OS session object.

 @param	aServer		Service the session will be a member of

 @param	aMessage	The message from the client.

 @return	A new CMscFileSession object

 */

CMscFileSession* CMscFileSession::NewL(CMscFileServer& aServer)

	{

	CMscFileSession* r = new (ELeave) CMscFileSession(aServer);

	CleanupStack::PushL(r);

	r->ConstructL();

	CleanupStack::Pop();

	return r;

	}

/**

 Constructor.

 @param	aServer	Service the session will be a member of

 */

CMscFileSession::CMscFileSession(CMscFileServer& aServer)

	: iMscFileServer( aServer )

	{

    TRACE_FUNC

	}

/**

 2nd Phase Construction.

 */

void CMscFileSession::ConstructL()

	{

	TRACE_FUNC

	iMscFileServer.IncrementSessionCount();

    if ( iMscFileServer.SessionCount() > 1 )

        {

        TRACE_ERROR(( _L( "SessionCount: %d" ), iMscFileServer.SessionCount() ))

        // Only one session is allowed

        User::Leave( KErrInUse );

        }        

 	}

/**

 Destructor.

 */

CMscFileSession::~CMscFileSession()

	{

	iMscFileServer.DecrementSessionCount();

	}

/**

 Called when a message is received from the client.

 @param	aMessage	Message received from the client

 */

void CMscFileSession::ServiceL( const RMessage2& aMessage )

	{

	TRAPD( err, DispatchMessageL( aMessage ) );

    aMessage.Complete( err );

	}

void CMscFileSession::DispatchMessageL( const RMessage2& aMessage )

    {

    switch (aMessage.Function())

        {

        case EMscFileSetupLu:

            SetupLogicalUnitL( aMessage );

            break;

        case EMscFileStart:

            StartL( aMessage );

            break;

        case EMscFileStop:

            LEAVE_IF_ERROR( Stop() );

            break;

        case EMscFileShutdown:

            LEAVE_IF_ERROR( Shutdown() );

            break;

        default:

            aMessage.Panic( KUsbMsCliPncCat, EUsbMsPanicIllegalIPC );

            break;

        }

    }

void CMscFileSession::SetupLogicalUnitL( const RMessage2& aMessage )

    {

    TRACE_FUNC_ENTRY

    TInt protocol;

    TInt lun;

    RBuf buf;

    TInt len = aMessage.GetDesLength( 0 );

    buf.CreateL( len );

    buf.CleanupClosePushL();

    aMessage.ReadL( 0, buf );

    protocol = aMessage.Int1();

    lun = aMessage.Int2();

    //get the directory and name of image file

    RFs fs;

    LEAVE_IF_ERROR(fs.Connect());

    CleanupClosePushL(fs);

    TFileName fileName;

    const TDriveNumber KResourceDrive = EDriveZ;

    TDriveUnit driveUnit( KResourceDrive );

    TDriveName drive = driveUnit.Name();

    fileName.Insert( 0, drive );

    // append private path

    TPath privatePath;

    fs.PrivatePath(privatePath);

    fileName.Append(privatePath);      

    CleanupStack::PopAndDestroy(&fs);   

    fileName.Append(buf);

    iMscFileServer.Controller().SetupLogicalUnitL( fileName, protocol, lun );

    CleanupStack::PopAndDestroy( &buf );

    TRACE_FUNC_EXIT

    }

/**

 Client request to start the device.

 @return	Any error that occurred or KErrNone

 */

void CMscFileSession::StartL( const RMessage2& aMessage )

	{

	TRACE_FUNC

    User::LeaveIfError(RProperty::Set(KPSUidCoreApplicationUIs, 

        KCoreAppUIsUSBFileTransfer, 

        ECoreAppUIsUSBFileTransferActive));

	TMassStorageConfig msConfig;

	GetMsConfigL( aMessage, msConfig );

	LEAVE_IF_ERROR( iMscFileServer.Controller().Start( msConfig ) );

	}

/**

 Client request to stop the device.

 @return	Any error that occurred or KErrNone

 */

TInt CMscFileSession::Stop()

    {

    TRACE_FUNC

    RProperty::Set(KPSUidCoreApplicationUIs, 

        KCoreAppUIsUSBFileTransfer, 

        ECoreAppUIsUSBFileTransferNotActive);

	return iMscFileServer.Controller().Stop();

	}

/**

 Client request to shut down the server

 @return KErrNone

 */

TInt CMscFileSession::Shutdown()

    {

    TRACE_FUNC

    CActiveScheduler::Stop();

	return KErrNone;

	}

 /**

  Get mass storage configuration data from the received message

  */

 void CMscFileSession::GetMsConfigL( const RMessage2& aMessage, 

                                     TMassStorageConfig& aMsStorage )

 	{

 	aMessage.ReadL( 0, aMsStorage.iVendorId );

 	aMessage.ReadL( 1, aMsStorage.iProductId );

 	aMessage.ReadL( 2, aMsStorage.iProductRev );

 	}