/*
* 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 file creations, modifications and deletions.*
*/


#include <mdeobject.h>

#include "harvestercommon.h"
#include "filemonitorao.h"
#include "harvesterlog.h"
#include "fsutil.h"
#include "mdeharvestersession.h"
#include "processoriginmapper.h"
#include "fileeventhandlerao.h"
#include "harvesterpluginfactory.h"

using namespace MdeConstants;

_LIT( KMdsFSPluginFile, "mdsfileserverplugin" );
_LIT( KMdsFSPluginName, "MdsFileServerPlugin" );

// ---------------------------------------------------------------------------
// CFileMonitorAO::NewL()
// ---------------------------------------------------------------------------
//
CFileMonitorAO* CFileMonitorAO::NewL()
    {
    WRITELOG( "CFileMonitorAO::NewL" );

    CFileMonitorAO* self = new (ELeave) CFileMonitorAO;
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::ConstructL()
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::ConstructL()
    {
    WRITELOG( "CFileMonitorAO::ConstructL" );
    
    CActiveScheduler::Add( this );
    iFsConnectOk = EFalse;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::~CFileMonitorAO()
// ---------------------------------------------------------------------------
//
CFileMonitorAO::~CFileMonitorAO()
    {
    WRITELOG( "CFileMonitorAO::~CFileMonitorAO" );
    
    Cancel();
    
    StopMonitoring();

    delete iMdeSession;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::StartMonitoring()
// ---------------------------------------------------------------------------
//
TBool CFileMonitorAO::StartMonitoring( MMonitorPluginObserver& aObserver,
	CMdESession* aMdeSession, const TDesC& aPath, CHarvesterPluginFactory* aHarvesterPluginFactory )
    {
    WRITELOG( "CFileMonitorAO::StartMonitoring" );
    
    iObserver = &aObserver;
    iHarvesterPluginFactory = aHarvesterPluginFactory;
    TRAPD( err, iMdeSession = CMdEHarvesterSession::NewL( *aMdeSession ) );
    if ( err != KErrNone )
    	{
    	return EFalse;
    	}
    
    TRAP( err, iFileEventHandler = CFileEventHandlerAO::NewL( aObserver, iMdeSession, aHarvesterPluginFactory ));
    if ( err != KErrNone )
    	{
    	return EFalse;
    	}
    
    TInt error = iFs.Connect();
    if ( error != KErrNone )
    	{
    	iFs.Close();
    	return EFalse;
    	}
	iFsConnectOk = ETrue;

    // add mds fileserver plugin
    error = iFs.AddPlugin( KMdsFSPluginFile );
    if ( error != KErrAlreadyExists )
        {
        error = iFs.MountPlugin( KMdsFSPluginName );
        if ( error != KErrNone )
            {
            return EFalse;
            }
        }
    
    error = iEngine.Open( iFs, KMdsFSPluginPosition );
    if ( error != KErrNone )
        {
        return EFalse;
        }

    iEngine.Enable();
    iEngine.AddNotificationPath( aPath );
    
    StartNotify();
    return ETrue;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::StartNotify()
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::StartNotify()
    {
    WRITELOG( "CFileMonitorAO::StartNotify" );
    
    ResetMdsFSPStatus();
        
    iEngine.RegisterNotification( iStatusPckg, iStatus );
    
    SetActive();
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::StopMonitoring()
// ---------------------------------------------------------------------------
//
TBool CFileMonitorAO::StopMonitoring()
    {
    WRITELOG( "CFileMonitorAO::StopMonitoring" );

    if ( iFsConnectOk == EFalse )
    	{
    	return ETrue;
    	}
    
    Cancel();
    
    // remove mds fileserver plugin
    iEngine.Disable();
    iEngine.Close();
    
	iFs.DismountPlugin( KMdsFSPluginName );
	iFs.RemovePlugin( KMdsFSPluginName );
    
    iFs.Close();
    iFsConnectOk = EFalse;
    
    return ETrue;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::RunL()
// From CActive
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::RunL()
    {
    WRITELOG( "CFileMonitorAO::RunL" );
    
    User::LeaveIfError( iStatus.Int() );
    TMdsFSPStatus& status = iStatusPckg();

    iFileEventHandler->AddToQueueL(status);

    StartNotify();
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::ResetMdsFSPStatus()
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::ResetMdsFSPStatus()
    {
    WRITELOG( "CFileMonitorAO::ResetMdsFSPStatus" );
    
    TMdsFSPStatus& status = iStatusPckg();
    
    status.iDriveNumber = 0;
    status.iFileEventType = EMdsFileUnknown;
    status.iFileName.Zero();
    status.iNewFileName.Zero();
    status.iProcessId = TUid::Null();
    }
    
// ---------------------------------------------------------------------------
// CFileMonitorAO::RunError()
// From CActive
// ---------------------------------------------------------------------------
//
TInt CFileMonitorAO::RunError( TInt aError )
    {
    WRITELOG1( "CFileMonitorAO::RunError %d", aError );

    if ( aError == KErrInUse )
        {
        iEngine.NotificationCancel();
        }
    else
        {
        StartNotify();
        }

    return KErrNone;
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::DoCancel()
// From CActive
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::DoCancel()
    {
    WRITELOG( "CFileMonitorAO::DoCancel" );
    iEngine.Disable();
    iEngine.NotificationCancel();
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::CFileMonitorAO()
// Constructor
// ---------------------------------------------------------------------------
//
CFileMonitorAO::CFileMonitorAO() : CActive( KHarvesterPriorityMonitorPlugin )
    {
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::Mapper()
// Returns a handle to CProcessOriginMapper.
// ---------------------------------------------------------------------------
//
CProcessOriginMapper& CFileMonitorAO::Mapper()
    {
    return iFileEventHandler->Mapper();
    }

// ---------------------------------------------------------------------------
// CFileMonitorAO::Mapper()
// Set event caching status
// ---------------------------------------------------------------------------
//
void CFileMonitorAO::SetCachingStatus( TBool aCachingStatus )
	{
	iFileEventHandler->SetCachingStatus( aCachingStatus );
	}