/*

* Copyright (c) 2010 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 FILES

#include <pathinfo.h>

#include "cfilemonitor.h"

#include "cfolderrenamedharvester.h"

#include "harvesterserverlogger.h"

// -----------------------------------------------------------------------------

// CFileMonitor::NewL

// -----------------------------------------------------------------------------

//

CFileMonitor* CFileMonitor::NewL(  CFilePlugin& aFilePlugin, RFs* aFsSession )

	{

	CFileMonitor* self = new ( ELeave ) CFileMonitor( aFilePlugin, aFsSession );

	CleanupStack::PushL(self);

	self->ConstructL(aFilePlugin, aFsSession);

	CleanupStack::Pop(self);

	return self;

	}

// -----------------------------------------------------------------------------

// CFileMonitor::CFileMonitor

// -----------------------------------------------------------------------------

//

CFileMonitor::CFileMonitor( CFilePlugin& aFilePlugin, RFs* aFsSession ) :

                            CActive(CActive::EPriorityStandard),

                            iFilePlugin( aFilePlugin )

    {

    CPIXLOGSTRING("ENTER CFileMonitor::CFileMonitor");

    CActiveScheduler::Add(this);

    iFsSession = aFsSession;

    CPIXLOGSTRING("END CFileMonitor::CFileMonitor");

    }

// -----------------------------------------------------------------------------

// CFileMonitor::~CFileMonitor

// -----------------------------------------------------------------------------

//

CFileMonitor::~CFileMonitor() 

	{

	CPIXLOGSTRING("ENTER ~CFileMonitor");

	Cancel();

	iEngine.Disable();

	iEngine.Close();

	delete iFolderRenamedHarvester;

	CPIXLOGSTRING("END ~CFileMonitor");	

	}

// -----------------------------------------------------------------------------

// CFileMonitor::ConstructL

// -----------------------------------------------------------------------------

//

void CFileMonitor::ConstructL( CFilePlugin& aFilePlugin, RFs* aFsSession )

    {

    iFolderRenamedHarvester = CFolderRenamedHarvester::NewL(aFilePlugin, *aFsSession);

    }

// -----------------------------------------------------------------------------

// CFileMonitor::RunError

// -----------------------------------------------------------------------------

//

TInt CFileMonitor::RunError( TInt aError )

	{

	CPIXLOGSTRING2( "CFileMonitor::RunError %d", aError );

	return KErrNone;

	}

// -----------------------------------------------------------------------------

// CFileMonitor::DoCancel

// -----------------------------------------------------------------------------

//

void CFileMonitor::DoCancel()

	{

	iEngine.NotificationCancel();

	}

// -----------------------------------------------------------------------------

// CFileMonitor::RunL

// -----------------------------------------------------------------------------

//	

void CFileMonitor::RunL()

    {

    CPIXLOGSTRING("ENTER CFileMonitor::RunL");

    Deque();

    CActiveScheduler::Add( this );

    /*

    Handle pkg here

    It has event type and other stuff

    Execute event and pass params to FilePlugin

    */

    // TODO TFileName on stack twice - consider allocating on heap!

    TFastFindFSPStatus& status = iPckg();

    const TDesC& fileNameOld = status.iFileName;

    const TDesC& fileNameNew = status.iNewFileName;

    /*

    * IMPORTANT:

    * Rename of whole directory happens as change to every file in dir.

    * We get an event of every file in dir.

    */

    CPIXLOGSTRING2("CFileMonitor::RunL, status.iFileEventType: %i", status.iFileEventType );    

    switch(status.iFileEventType)

		{

		case EFastFindFileCreated:

			{

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileCreated old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileCreated new = %S", &fileNameNew);

            // File creation (for example over PC suite) gives fileNameOld as the created files, fileNameOld is empty.

            iFilePlugin.CreateFileIndexItemL(fileNameOld, ECPixAddAction);

			}

		break;

		case EFastFindFileModified:

			{

			// This event can be generated by some file manager applications 

			// when copying a file to a new destination.

			// Introduce a small delay, so that file copying can complete before

			// cpix opens the file for indexing. Without the delay, sometimes file 

			// indexing fails as CLucene cannot open the file for indexing.

			// Decided to block the CPiXHarvesterServer thread rather than introduce 

			// new active object state into the CFileMonitor.

			User::After(50000); // 0.05 seconds

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileModified old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileModified new = %S", &fileNameNew);

			// File copy, fileNameOld contains the file name, fileNameNew is empty

			iFilePlugin.CreateFileIndexItemL(fileNameOld, ECPixUpdateAction);

			}

		break;

		case EFastFindFileRenamed:

			{

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileRenamed old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileRenamed new = %S", &fileNameNew);

			TEntry entry; 

			if ( iFsSession->Entry( fileNameNew, entry ) == KErrNone ) 

				{

				if ( !entry.IsDir() )

					{

					if (fileNameOld.Length()>0 && fileNameOld.Compare(fileNameNew)!=0)

						{

						iFilePlugin.CreateFileIndexItemL(fileNameOld, ECPixRemoveAction);

						}

					iFilePlugin.CreateFileIndexItemL(fileNameNew, ECPixUpdateAction);

					}

				else

					{

					iFolderRenamedHarvester->StartL(fileNameOld, fileNameNew);

					}

				}

			}

		break;

		case EFastFindFileReplaced:

			{

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileReplaced old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileReplaced new = %S", &fileNameNew);

			// File rename (funnily), fileNameOld contains the old file name, fileNameNew the new name

			if (fileNameOld.Length()>0 && fileNameOld.Compare(fileNameNew)!=0)

				iFilePlugin.CreateFileIndexItemL(fileNameOld, ECPixRemoveAction);

			iFilePlugin.CreateFileIndexItemL(fileNameNew, ECPixUpdateAction);

			}

		break;

		case EFastFindFileDeleted:

			{

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileDeleted old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, EFastFindFileDeleted new = %S", &fileNameNew);

			// File delete, fileNameOld contains the name of the deleted file

			iFilePlugin.CreateFileIndexItemL(fileNameOld, ECPixRemoveAction);

			}

		break;

		default:

			{

			CPIXLOGSTRING2("CFileMonitor::RunL, unknown event old = %S", &fileNameOld);

			CPIXLOGSTRING2("CFileMonitor::RunL, unknown event new = %S", &fileNameNew);

			}

		break;

		}

    ResetStatus();

    iEngine.RegisterNotification(iPckg, iStatus);

    CPIXLOGSTRING("END CFileMonitor::RunL");

    SetActive();

    }

// -----------------------------------------------------------------------------

// CFileMonitor::StartMonitoring

// -----------------------------------------------------------------------------

//

TBool CFileMonitor::StartMonitoring()

	{

	CPIXLOGSTRING("ENTER CFileMonitor::StartMonitoring")

    if ( !IsActive() )

		{

		CPIXLOGSTRING("CFileMonitor::StartMonitoring - IF ")

		iEngine.Enable();

		ResetStatus();

	    iEngine.RegisterNotification( iPckg, iStatus );

	    SetActive();

		}

	CPIXLOGSTRING("END CFileMonitor::StartMonitoring");	

	return ETrue;

	}

// ---------------------------------------------------------------------------

// CFileMonitor::ResetStatus

// ---------------------------------------------------------------------------

//

void CFileMonitor::ResetStatus()

    {

    CPIXLOGSTRING( "CFileMonitor::ResetStatus" );

    TFastFindFSPStatus& status = iPckg();

    status.iDriveNumber = 0;

    status.iFileEventType = EFastFindFileUnknown;

    status.iFileName.Zero();

    status.iNewFileName.Zero();

    status.iProcessId = TUid::Null();

    }

// -----------------------------------------------------------------------------

// CFileMonitor::Initialize

// -----------------------------------------------------------------------------

//	

TInt CFileMonitor::Initialize()

    {

    CPIXLOGSTRING("ENTER CFileMonitor::Initialize");

    TInt err = OpenEngine();

    CPIXLOGSTRING2("CFileMonitor::Initialize - OpenEngine: %i", err );

	if ( err != KErrNone )

		{

		CPIXLOGSTRING("CFileMonitor::Initialize if( err != KErrNone ) ");

		return err;

		}

	CPIXLOGSTRING("END CFileMonitor::Initialize");

	return err;

    }

// -----------------------------------------------------------------------------

// CFileMonitor::Release

// -----------------------------------------------------------------------------

//

TInt CFileMonitor::Release()

    {

    iEngine.Disable();

	iEngine.Close();

	return KErrNone;

    }

// -----------------------------------------------------------------------------

// CFileMonitor::OpenEngine

// -----------------------------------------------------------------------------

//

TInt CFileMonitor::OpenEngine()

    {

    TInt err = iEngine.Open( *iFsSession, KFastFindFSPluginPosition );

	return err;

    }

// -----------------------------------------------------------------------------

// CFileMonitor::AddNotificationPathsL

// -----------------------------------------------------------------------------

//

void CFileMonitor::AddNotificationPathsL( const TDriveNumber aDriveNumber )

    {

    TFileName notificationPath;

    TChar chr;

    User::LeaveIfError( RFs::DriveToChar( aDriveNumber, chr ) );

    notificationPath.Append( chr );

    notificationPath.Append( KExcludePathSystem );

    iEngine.AddIgnorePath( notificationPath );

	CPIXLOGSTRING2("CFileMonitor::AddNotificationPathsL - AddIgnorePath: %S", &notificationPath );

    notificationPath.Zero();

    // As index databases are located under \\Private\\ path,

    // this ignore path will mean index databases are also ignored.

    notificationPath.Append( chr );

    notificationPath.Append( KExcludePathPrivate );

    iEngine.AddIgnorePath( notificationPath );

    CPIXLOGSTRING2("CFileMonitor::AddNotificationPathsL - AddIgnorePath: %S", &notificationPath );

    notificationPath.Zero();

    // Maps data must not be indexed

    notificationPath.Append( chr );

    notificationPath.Append( KExcludePathMapsCities );

    iEngine.AddIgnorePath( notificationPath );

    CPIXLOGSTRING2("CFileMonitor::AddNotificationPathsL - AddIgnorePath: %S", &notificationPath );

    notificationPath.Zero();

    User::LeaveIfError( PathInfo::GetRootPath( notificationPath, aDriveNumber ) );

    iEngine.AddNotificationPath( notificationPath );

    CPIXLOGSTRING2("CFileMonitor::AddNotificationPathsL - AddNotificationPath: %S", &notificationPath );

    }

// -----------------------------------------------------------------------------

// CFileMonitor::RemoveNotificationPaths

// -----------------------------------------------------------------------------

//

void CFileMonitor::RemoveNotificationPaths( const TDriveNumber aDriveNumber )

    {

    TFileName ignorePath;

    TChar chr;

    RFs::DriveToChar( aDriveNumber, chr );

    ignorePath.Append( chr );

    ignorePath.Append( KExcludePathSystem );

    iEngine.RemoveIgnorePath( ignorePath );

    CPIXLOGSTRING2("CFileMonitor::RemoveNotificationPaths - RemoveIgnorePath: %S", &ignorePath );

    ignorePath.Zero();

    // As index databases are located under \\Private\\ path,

    // this ignore path will mean index databases are also ignored.

    ignorePath.Append( chr );

    ignorePath.Append( KExcludePathPrivate );

    iEngine.RemoveIgnorePath( ignorePath );

    CPIXLOGSTRING2("CFileMonitor::RemoveNotificationPaths - RemoveIgnorePath: %S", &ignorePath );

    ignorePath.Zero();

    // Maps

    ignorePath.Append( chr );

    ignorePath.Append( KExcludePathMapsCities );

    iEngine.RemoveIgnorePath( ignorePath );

    CPIXLOGSTRING2("CFileMonitor::RemoveNotificationPaths - RemoveIgnorePath: %S", &ignorePath );

    ignorePath.Zero();

    PathInfo::GetRootPath( ignorePath, aDriveNumber );

    iEngine.RemoveNotificationPath( ignorePath );

    CPIXLOGSTRING2("CFileMonitor::RemoveNotificationPaths - RemoveNotificationPath: %S", &ignorePath );

    }

// -----------------------------------------------------------------------------

// CFileMonitor::Enable

// -----------------------------------------------------------------------------

//

TInt CFileMonitor::Enable()

    {

    return iEngine.Enable();

    }

// -----------------------------------------------------------------------------

// CFileMonitor::Disable

// -----------------------------------------------------------------------------

//

TInt CFileMonitor::Disable()

    {

    return iEngine.Disable();

    }

// End Of File