/*
* Copyright (c) 2007-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:  Monitors Usb insertions and removals.*
*/


#include <usbmsshared.h>

#include "harvesterlog.h"
#include "harvestercommon.h"
#include "mmcusbao.h"
#include "mmcmonitorplugin.h"

CMMCUsbAO* CMMCUsbAO::NewL()
    {
    WRITELOG( "CMMCUsbAO::NewL" );
    
    CMMCUsbAO* self = new (ELeave) CMMCUsbAO();
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

CMMCUsbAO::CMMCUsbAO() : CActive( KHarvesterPriorityMonitorPlugin ), iObserver( NULL )
    {
    iDrive = 0;
    iMassStorageMode = EFalse;
    }

void CMMCUsbAO::ConstructL()
    {
    WRITELOG( "CMMCUsbAO::ConstructL" );
    
    CActiveScheduler::Add( this );
    
    User::LeaveIfError( iFs.Connect() );

    User::LeaveIfError( iDriveState.Attach( 
    		KUsbMsDriveState_Category, EUsbMsDriveState_DriveStatus ) );
    }

CMMCUsbAO::~CMMCUsbAO()
    {
    WRITELOG( "CMMCUsbAO::~CMMCUsbAO" );
    StopMonitoring();
    }

TBool CMMCUsbAO::StartMonitoring( MMMCMonitorObserver& aObserver )
    {
    WRITELOG( "CMMCUsbAO::StartMonitoring" );
    
    iObserver = &aObserver;
    
    return Resume();
    }

void CMMCUsbAO::StartNotify()
    {
    WRITELOG( "CMMCUsbAO::StartNotify" );
    iDriveState.Subscribe( iStatus );
    SetActive();
    }

TBool CMMCUsbAO::StopMonitoring()
    {
    WRITELOG( "CMMCUsbAO::StopNotify" );
    
    return Pause();
    }

TBool CMMCUsbAO::Resume()
    {
    WRITELOG( "CMMCUsbAO::Resume" );
        
    StartNotify();
    
    return ETrue;
    }

TBool CMMCUsbAO::Pause()
    {
    WRITELOG( "CMMCUsbAO::Pause" );
    
    Cancel();
    iDriveState.Close();
    iFs.Close();
    
    return ETrue;
    }

void CMMCUsbAO::RunL()
    {
    WRITELOG1( "CMMCUsbAO::RunL iStatus: %d", iStatus.Int() );
    
    // check if change to pc-suite mode
    if ( iStatus.Int() == KErrNotFound )
        {
        TChar chr;
        RFs::DriveToChar( iDrive, chr );
        iObserver->MountEvent( chr, MediaID(iDrive), EMounted );
        iMassStorageMode = EFalse;
        StartNotify();
        return;
        }
    else
        {
        User::LeaveIfError( iStatus.Int() );
        }
        
    TUsbMsDrivesStatus allDrivesStatus;
    const TInt err = iDriveState.Get( allDrivesStatus );
    
    if ( err == KErrNone )
        {
        WRITELOG1( "CMMCUsbAO::RunL - allDrivesStatus.Length(): %d", allDrivesStatus.Length() );
        const TInt count = allDrivesStatus.Length()/2;
        for ( TInt i = 0; i < count; i++ )
            {
            TInt driveNumber = allDrivesStatus[2*i];
            TInt driveStatus = allDrivesStatus[2*i+1];
            TChar driveChar;
            RFs::DriveToChar( driveNumber, driveChar );
#ifdef _DEBUG
            TFileName* fn = new (ELeave) TFileName( driveChar );
            _LIT( KIndicator, ":" );
            fn->Append( KIndicator );
            WRITELOG1( "CMMCUsbAO::RunL - drive letter: %S", &(*fn) );
            PrintDriveStatus( driveStatus );
            delete fn;
            fn = NULL;
#endif
            switch( driveStatus )
                {
                case EUsbMsDriveState_Connected:
                    {
                    if ( iMassStorageMode )
                        {
                        break;
                        }
                    iObserver->MountEvent( driveChar, MediaID(driveNumber), EDismounted );
                    iMassStorageMode = ETrue;
                    iDrive = driveNumber;
                    }
                break;
                
                case EUsbMsDriveState_Removed:
                    {
                    iObserver->MountEvent( driveChar, MediaID(driveNumber), EMounted );
                    iMassStorageMode = EFalse;
                    }
                break;
                
                default:
                	break;
                }
            }
        }
    else
        {
        WRITELOG1( "CMMCUsbAO::RunL - drive state error %d", err );
        }
    
    StartNotify();
    }

#ifdef _DEBUG
TInt CMMCUsbAO::RunError( TInt aError )
#else
TInt CMMCUsbAO::RunError( TInt )
#endif
    {
    WRITELOG1( "CMMCUsbAO::RunError with error code: %d", aError );
    
    StartNotify();
    return KErrNone;
    }

void CMMCUsbAO::DoCancel()
    {
    WRITELOG( "CMMCUsbAO::DoCancel" );
    
    iDriveState.Cancel();
    }

TUint32 CMMCUsbAO::MediaID( TInt aDrive )
    {
    TUint32 uid = 0;
    TVolumeInfo* vi = NULL;
    vi = new TVolumeInfo;
    if ( !vi )
        {
        return uid;
        }
    
    const TInt err = iFs.Volume( *vi, aDrive );
    if ( err == KErrNone )
        {
        uid = vi->iUniqueID;
        }

    delete vi;
    vi = NULL;
    
    return uid;
    }

#ifdef _DEBUG
void CMMCUsbAO::PrintDriveStatus( TInt aStatus )
    {
    switch( aStatus )
        {
        case EUsbMsDriveState_Disconnected:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Disconnected" );
        break;
        
        case EUsbMsDriveState_Connecting:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Connecting" );
        break;
        
        case EUsbMsDriveState_Connected:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Connected" );
        break;
        
        case EUsbMsDriveState_Disconnecting:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Disconnecting" );
        break;
        
        case EUsbMsDriveState_Active:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Active" );
        break;
        
        case EUsbMsDriveState_Locked:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Locked" );
        break;
        
        case EUsbMsDriveState_MediaNotPresent:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_MediaNotPresent" );
        break;
        
        case EUsbMsDriveState_Removed:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Removed" );
        break;
        
        case EUsbMsDriveState_Error:
        WRITELOG( "CMMCUsbAO::RunL - drive status: EUsbMsDriveState_Error" );
        break;
        
        default:
        WRITELOG( "CMMCUsbAO::RunL - drive status: Unknown" );
        break;
        }
    }

#endif