/*

* 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: This file contains testclass implementation.

*

*/

// change the level of RVCT compiler warning 'non-POD class passed thru ellipses' to a remark.

#ifdef __MARM__

#pragma diag_remark 1446

#endif

// [INCLUDE FILES] - do not remove

#include "harvesterplugintester.h"

#include <e32svr.h>

#include <f32file.h> 

#include <stifparser.h>

#include <stiftestinterface.h>

#include <favouritesdb.h>

#include <msvapi.h>

#include <bautils.h>

#include "harvesterobserver.h"

#include "cmessageplugin.h"

#include "cmessagesessionobserver.h" //For CMsvSession

#include "ccpixsearcher.h"

#include "bookmarksplugin.h"

#include "applicationsplugin.h"

#include "ccontactsplugin.h"

#include "ccalendarplugin.h"

#include "ccalendarobserver.h"

#include "mediaplugin.h"

#include <harvesterclient.h>

#include "mdsitementity.h"

#include "cpixmdedbmanager.h"

//#include "CBlacklistMgr.h"

#include "videoplugin.h"

#include "imageplugin.h"

_LIT(KAppBasePath,"@c:root file");

const TInt KMsgPluginBaseAppClassMaxLen = 64;

// For Notes --Start

#include <d32dbms.h>

#include <utf.h>

#include "notesplugin.h"

//Test Uid for testing Blacklist manager

//const TUid KTestUid = { 0x101D6348 };

#define MEDIA_QBASEAPPCLASS   "@c:root media audio"

#define LMEDIA_QBASEAPPCLASS  L"@c:root media audio"

#define VIDEO_QBASEAPPCLASS   "@c:root media video"

#define LVIDEO_QBASEAPPCLASS  L"@c:root media video"

#define IMAGE_QBASEAPPCLASS   "@c:root media image"

#define LIMAGE_QBASEAPPCLASS  L"@c:root media image"

// For Notes --End

// ============================ MEMBER FUNCTIONS ===============================

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

// Delete here all resources allocated and opened from test methods. 

// Called from destructor. 

void CHarvesterPluginTester::Delete() 

    {

    }

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

// Run specified method. Contains also table of test mothods and their names.

TInt CHarvesterPluginTester::RunMethodL( 

    CStifItemParser& aItem ) 

    {

    static TStifFunctionInfo const KFunctions[] =

        {  

        // Copy this line for every implemented function.

        // First string is the function name used in TestScripter script file.

        // Second is the actual implementation member function. 

        ENTRY( "TestStartHarvester", CHarvesterPluginTester::TestStartHarvesterL ),

        ENTRY( "TestFolderRename", CHarvesterPluginTester::TestFolderRenamingL ),

        ENTRY( "TestFormBaseAppClass", CHarvesterPluginTester::TestFormBaseAppClass ),

        ENTRY( "TestDatabasePath", CHarvesterPluginTester::TestDatabasePathL ),

        ENTRY( "TestCreateIndexItemL_Add", CHarvesterPluginTester::TestCreateIndexItemL ),

        ENTRY( "TestCreateIndexItemL_Update", CHarvesterPluginTester::TestCreateIndexItemL ),

        ENTRY( "TestCreateIndexItemL_Delete", CHarvesterPluginTester::TestCreateIndexItemL ),

        ENTRY( "TestMessaging", CHarvesterPluginTester::TestMessageHarvesterL ),

        ENTRY( "TestMessageHarvesting", CHarvesterPluginTester::TestMessageHarvesterWithMessageL ),

        ENTRY( "TestMessageDriveChange", CHarvesterPluginTester::TestMessageHarvesterChangeDriveL ),

        ENTRY( "TestStartBookmarksHarvesterL", CHarvesterPluginTester::TestStartBookmarksHarvesterL ),

        ENTRY( "TestAddBookmarkL", CHarvesterPluginTester::TestAddBookmarkL ),

        ENTRY( "TestAddGetDomainL", CHarvesterPluginTester::TestAddGetDomainL ),

        ENTRY( "TestStartApplicationsHarvesterL", CHarvesterPluginTester::TestStartApplicationsHarvesterL ),        

        ENTRY( "TestCreateApplicationsIndexItemL", CHarvesterPluginTester::TestCreateApplicationsIndexItemL ),

		ENTRY( "TestStartNotesHarvesterL", CHarvesterPluginTester::TestStartNotesHarvesterL ),

        ENTRY( "TestAddNoteL", CHarvesterPluginTester::TestAddNoteL ),

        ENTRY( "TestAddLongNoteL", CHarvesterPluginTester::TestAddLongNoteL ),

        ENTRY( "TestAddAlphaNumericNoteL", CHarvesterPluginTester::TestAddAlphaNumericNoteL ),

        ENTRY( "TestDeleteNoteL", CHarvesterPluginTester::TestDeleteNoteL ),

        ENTRY( "TestUpdateNoteL", CHarvesterPluginTester::TestUpdateNoteL ),                

        ENTRY( "TestContactsHarvesting", CHarvesterPluginTester::TestStartContactsHarvesterL ),

        ENTRY( "TestCreateContactIndexItemL_Add", CHarvesterPluginTester::TestCreateContactIndexItemL ),

        ENTRY( "TestCreateContactIndexItemL_Edit", CHarvesterPluginTester::TestCreateContactIndexItemL ),

        ENTRY( "TestCreateContactIndexItemL_Delete", CHarvesterPluginTester::TestCreateContactIndexItemL ),

        ENTRY( "TestCreateContactGroup", CHarvesterPluginTester::TestCreateContactGroupL ),

        ENTRY( "TestCalenderHarvesting", CHarvesterPluginTester::TestStartCalenderHarvesterL ),

        ENTRY( "TestCalenderEntry",CHarvesterPluginTester::TestCalenderEntryL ),

        ENTRY( "TestCreateMMS",CHarvesterPluginTester::TestCreateMmsL ),

        ENTRY( "TestCreateEmail",CHarvesterPluginTester::TestCreateEmailL ),

		ENTRY( "TestAudioHarvesting",CHarvesterPluginTester::TestAudioHarvestingL ),

		ENTRY( "TestMdsSyncController",CHarvesterPluginTester::TestMdsSyncControllerL ),

		//ENTRY( "TestBlacklistPlugin",CHarvesterPluginTester::TestBlacklistPluginL ),

		//ENTRY( "TestBlacklistPluginVersion",CHarvesterPluginTester::TestBlacklistPluginVersionL ),

		ENTRY( "TestVideoHarvestingIndex",CHarvesterPluginTester::TestVideoHarvestingIndexL ),		

		ENTRY( "TestVideoHarvestingUpdateIndex",CHarvesterPluginTester::TestVideoHarvestingUpdateIndexL ),

		ENTRY( "TestVideoHarvestingDeleteIndex",CHarvesterPluginTester::TestVideoHarvestingDeleteIndexL ),

		ENTRY( "TestImageHarvestingAddIndex",CHarvesterPluginTester::TestImageHarvestingAddIndexL ),

		ENTRY( "TestImageHarvestingUpdateIndex",CHarvesterPluginTester::TestImageHarvestingUpdateIndexL ),

		ENTRY( "TestImageHarvestingDeleteIndex",CHarvesterPluginTester::TestImageHarvestingDeleteIndexL ),

		ENTRY( "TestAudioMMCEventL",CHarvesterPluginTester::TestAudioMMCEventL ),

		ENTRY( "TestVideoMMCEventL",CHarvesterPluginTester::TestVideoMMCEventL ),

		ENTRY( "TestImageMMCEventL",CHarvesterPluginTester::TestImageMMCEventL ),

        //ADD NEW ENTRY HERE

        // [test cases entries] - Do not remove

        };

    const TInt count = sizeof( KFunctions ) / 

                        sizeof( TStifFunctionInfo );

    return RunInternalL( KFunctions, count, aItem );

    }

_LIT( KNoErrorString, "No Error" );

//_LIT( KErrorString, " *** Error ***" );

void doLog( CStifLogger* logger, TInt error, const TDesC& errorString )

    {

    if( KErrNone == error ) logger->Log( KNoErrorString );

    else logger->Log( errorString );

    }

// Example test method function.

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

TInt CHarvesterPluginTester::TestStartHarvesterL( CStifItemParser& /*aItem*/ )

    {

    // Print to UI

    _LIT( KHarvesterPluginTester, "HarvesterPluginTester: %S" );

    _LIT( KExample, "In TestStartHarvesterL" );

    TestModuleIf().Printf( 0, KHarvesterPluginTester, KExample );

    // Print to log file

    iLog->Log( KExample );

    CFilePlugin* filePlugin = CFilePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( filePlugin );

    filePlugin->StartPluginL(); //Calls Add

    filePlugin->StartHarvestingL( KAppBasePath );

    iPluginTester->iWaitForHarvester->Start();//Wait here till Harvesting is complete.

    delete filePlugin;

    delete iPluginTester;

    doLog( iLog, KErrNone, KNoErrorString );

    return KErrNone;

    }

//Same as before, except we rename a directory before calling wait->Start()

TInt CHarvesterPluginTester::TestFolderRenamingL( CStifItemParser& /*aItem*/ )

    {

    CFilePlugin* filePlugin = CFilePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( filePlugin );

    filePlugin->StartPluginL(); //Calls Add

    filePlugin->StartHarvestingL( KAppBasePath );

    _LIT( KDirectoryToRenameFrom, "C:\\data\\FileToTestRename" );

    _LIT( KDirectoryToRenameTo, "C:\\data\\FileToTestRenamed" );

    RFs fs;

    fs.Connect();

    TInt error = fs.Rename( KDirectoryToRenameFrom, KDirectoryToRenameTo );

    iPluginTester->iWaitForHarvester->Start();//Wait here till Harvesting is complete.

    //rename it back to what it was.

    error = fs.Rename( KDirectoryToRenameTo, KDirectoryToRenameFrom );

    delete filePlugin;

    delete iPluginTester;

    doLog( iLog, error, _L("Error: TestFolderRename.") );

    return error;

    }

TInt CHarvesterPluginTester::TestFormBaseAppClass( CStifItemParser& aItem )

    {

    // Print to UI

    _LIT( KFilePluginBaseAppClass, "FormBaseAppClass" );

    _LIT( KExample, "In TestFormBaseAppClass" );

    TestModuleIf().Printf( 0, KFilePluginBaseAppClass, KExample );

    TInt driveNumber;

    TBuf<100> formedBaseAppClass;

    TBuf<100> expectedBaseAppClass;

    TChar driveChar;

    CFilePlugin* filePlugin = CFilePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( filePlugin );

    filePlugin->StartPluginL();

    TInt error = KErrNone;

    TInt errorNumber = 0;

    _LIT( KBaseAppClassFormatString, "@%c:root file");

    _LIT( KTestFormBaseAppClassNoError, "TestFormBaseAppClass: No Error" );

    if( aItem.GetNextInt ( driveNumber ) == KErrNone  && error == KErrNone )

        {

        filePlugin->FormBaseAppClass(  static_cast<TDriveNumber>( driveNumber ), formedBaseAppClass  );

        if( aItem.GetNextChar ( driveChar ) == KErrNone )

            {

            expectedBaseAppClass.Format( KBaseAppClassFormatString, driveChar );

            error = expectedBaseAppClass.Compare( formedBaseAppClass );

            if( aItem.GetNextInt ( errorNumber ) == KErrNone )

                error = ( KErrNone == error || -1 == errorNumber ) ? KErrNone : KErrGeneral ;

            }

        }

    delete filePlugin;

    delete iPluginTester;

    doLog( iLog, error, KTestFormBaseAppClassNoError );

    return error;

    }

TInt CHarvesterPluginTester::TestDatabasePathL( CStifItemParser& aItem )

    {

    TInt driveNumber;

    CFilePlugin* filePlugin = CFilePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( filePlugin );

    filePlugin->StartPluginL();

    HBufC* buffer;

    TBuf<KMaxFileName> returnedDbPath;

    TBuf<KMaxFileName> expectedDbPath;

    TInt error = KErrNone;

    TInt errorNumber;

    TChar driveChar;

    _LIT( KTestDatabasePathNoError, "TestDatabasePathL: No Error" );

    _LIT( KDbFormatString, "%c:\\Private\\2001f6f7\\indexing\\indexdb\\root\\file" );

    if( aItem.GetNextInt ( driveNumber ) == KErrNone  && error == KErrNone )

        {

        buffer = filePlugin->DatabasePathLC( static_cast<TDriveNumber>( driveNumber ) );

        returnedDbPath.Copy( *buffer );

        if( aItem.GetNextChar ( driveChar ) == KErrNone )

            {

            expectedDbPath.Format( KDbFormatString, driveChar );

            error = expectedDbPath.Compare( returnedDbPath );

            if( aItem.GetNextInt ( errorNumber ) == KErrNone )

                error = ( KErrNone == error || -1 == errorNumber ) ? KErrNone : KErrGeneral ;

            }

        }

    CleanupStack::PopAndDestroy( buffer );

    delete filePlugin;

    delete iPluginTester;

    doLog( iLog, error, KTestDatabasePathNoError );

    return error;

    }

//Helper functions

enum TSearchType

    {

    ESearchTypeResultsExpected=0,

    ESearchTypeNoResultsExpected

    };

TInt doSearch( const TDesC& aSearchString, const TDesC& aBaseAppClass, TSearchType aSearchType )

    {

    RSearchServerSession session;

    User::LeaveIfError( session.Connect() );

    CCPixSearcher* searcher = CCPixSearcher::NewLC( session );

    searcher->OpenDatabaseL( aBaseAppClass );

    TInt docCount = searcher->SearchL( aSearchString, KNullDesC);

    CleanupStack::PopAndDestroy( searcher );

    session.Close();

    if( aSearchType == ESearchTypeResultsExpected )

        {

        return docCount > 0 ? KErrNone : KErrNotFound;

        }

    else

        {

        return 0 == docCount ? KErrNone : KErrNotFound;

        }

    }

TInt CHarvesterPluginTester::TestCreateIndexItemL( CStifItemParser& aItem )

    {

    TInt error = KErrNone;

    TPtrC fileName;

    TPtrC createIndexAction;

    CFilePlugin* filePlugin = CFilePlugin::NewL();

    CHarvesterObserver* observer = CHarvesterObserver::NewL( filePlugin );

    filePlugin->StartPluginL();

    _LIT( KFileNameFormat, "C:\\TestFramework\\" );

    _LIT( KActionAdd, "add" );

    _LIT( KActionDelete, "delete" );

    _LIT( KActionUpdate, "update" );

    _LIT( KCreateIndexItemNoError, "CreateIndexItemL: Error" );

    TBuf<KMaxFileName> filePathName( KFileNameFormat );

    if( aItem.GetNextString ( createIndexAction ) == KErrNone )

        {

        if( createIndexAction.Compare( KActionAdd ) == 0 )

            {

            if( aItem.GetNextString ( fileName ) == KErrNone  && error == KErrNone )

                {

                filePathName.Append( fileName );

                filePlugin->CreateFileIndexItemL( filePathName, ECPixAddAction );

                TPtrC searchString;

                while( aItem.GetNextString ( searchString ) == KErrNone  && error == KErrNone )

                    {

                    error = doSearch( searchString, _L(FILE_QBASEAPPCLASS), ESearchTypeResultsExpected );

                    }

                filePlugin->CreateFileIndexItemL( filePathName, ECPixRemoveAction );

                }

            }

        if( createIndexAction.Compare( KActionDelete ) == 0 )

            {

            if( aItem.GetNextString ( fileName ) == KErrNone  && error == KErrNone )

                {

                filePathName.Append( fileName );

                filePlugin->CreateFileIndexItemL( filePathName, ECPixRemoveAction );

                TPtrC searchString;

                while( aItem.GetNextString ( searchString ) == KErrNone  && error == KErrNone )

                    {

                    error = doSearch( searchString, _L(FILE_QBASEAPPCLASS), ESearchTypeNoResultsExpected );

                    }

                }

            }

        if( createIndexAction.Compare( KActionUpdate ) == 0 )

            {

            if( aItem.GetNextString ( fileName ) == KErrNone  && error == KErrNone )

                {

                filePathName.Append( fileName );

                filePlugin->CreateFileIndexItemL( filePathName, ECPixUpdateAction );

                TPtrC searchString;

                while( aItem.GetNextString ( searchString ) == KErrNone  && error == KErrNone )

                    {

                    error = doSearch( searchString, _L(FILE_QBASEAPPCLASS), ESearchTypeResultsExpected );

                    }

                }

            }

        }

    delete filePlugin;

    delete observer;

    doLog( iLog, error, KCreateIndexItemNoError );

    return error;

    }

/**

* Message harvester test method.

* @since ?Series60_version

* @param aItem Script line containing parameters.

* @return Symbian OS error code.

*/

TInt CHarvesterPluginTester::TestMessageHarvesterL( CStifItemParser& /*aItem*/ )

    {

    // Print to UI

    _LIT( KHarvesterPluginTester, "HarvesterPluginTester" );

    _LIT( KExample, "In TestMessageHarvesterL" );

    TestModuleIf().Printf( 0, KHarvesterPluginTester, KExample );

    // Print to log file

    iLog->Log( KExample );

    CMessagePlugin* plugin = CMessagePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( plugin );

    plugin->StartPluginL();

    CMessageSessionObserver* sessionobserver = CMessageSessionObserver::NewL();

    CMsvSession* msgSession = CMsvSession::OpenSyncL(*sessionobserver);

    // Form the baseappclass for this media

    TBuf<KMsgPluginBaseAppClassMaxLen> baseAppClass;

    TInt drive = msgSession->CurrentDriveL();

    CMessagePlugin::FormBaseAppClass(TDriveNumber(drive),baseAppClass);

    //Get current base app class for drive

    //CMessagePlugin::FormBaseAppClass

    plugin->StartHarvestingL( baseAppClass );

    iPluginTester->iWaitForHarvester->Start();

    delete plugin; 

    delete iPluginTester;

    delete sessionobserver;

    delete msgSession;

    doLog(iLog,KErrNone,KNoErrorString);

    return KErrNone;

    }

TInt CHarvesterPluginTester::TestMessageHarvesterWithMessageL( CStifItemParser& /*aItem*/ )

    {

    _LIT( KHarvesterPluginTester, "HarvesterPluginTester" );

    _LIT( KExample, "In TestMessageHarvesterWithMessageL" );

    TInt error(KErrNone);

    TestModuleIf().Printf( 0, KHarvesterPluginTester, KExample );

    // Print to log file

    iLog->Log( KExample );

    CMessagePlugin* plugin = CMessagePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( plugin );

    plugin->StartPluginL();

    CMessageSessionObserver* sessionobserver = CMessageSessionObserver::NewL();

    CMsvSession* msgSession = CMsvSession::OpenSyncL(*sessionobserver);

    // Form the baseappclass for this media

    TBuf<KMsgPluginBaseAppClassMaxLen> baseAppClass;

    TInt drive = msgSession->CurrentDriveL();

    //Get current base app class for drive

    CMessagePlugin::FormBaseAppClass(TDriveNumber(drive),baseAppClass);

    plugin->StartHarvestingL( baseAppClass );

    //Create a new SMS message

    TMsvId msgid = MessagingUtils::CreateMessageL(msgSession,

                                                 _L("+3584400220055"),

                                                 _L("+919845062437"),

                                                 _L("This is test from bhuvnesh"));

    iPluginTester->iWaitForHarvester->Start();

    TInt count = SearchForTextL(_L("+919845062437"),baseAppClass,KNullDesC);

    MessagingUtils::RemoveEntryL(msgSession,msgid);

    if(count <= 0)

        {

        error = KErrNotFound;

        }

    delete plugin; 

    delete iPluginTester;

    delete sessionobserver;

    delete msgSession;

    doLog(iLog,error,_L("Error in TestMessageHarvesterWithMessageL"));

    return error;

    }

TInt CHarvesterPluginTester::TestMessageHarvesterChangeDriveL( CStifItemParser& /*aItem*/ )

    {

    _LIT( KHarvesterPluginTester, "HarvesterPluginTester" );

    _LIT( KExample, "In TestMessageHarvesterChangeDriveL" );

    TInt error(KErrNone);

    TestModuleIf().Printf( 0, KHarvesterPluginTester, KExample );

    // Print to log file

    iLog->Log( KExample );

    CMessagePlugin* plugin = CMessagePlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( plugin );

    plugin->StartPluginL();

    CMessageSessionObserver* sessionobserver = CMessageSessionObserver::NewL();

    CMsvSession* msgSession = CMsvSession::OpenSyncL(*sessionobserver);

    // Form the baseappclass for this media

    TBuf<KMsgPluginBaseAppClassMaxLen> baseAppClass;

    TInt drive = msgSession->CurrentDriveL();

    //Get current base app class for drive

    CMessagePlugin::FormBaseAppClass(TDriveNumber(drive),baseAppClass);

    plugin->StartHarvestingL( baseAppClass );

    iPluginTester->iWaitForHarvester->Start();

    //Harvesting completed change the drive and make sure new message harvested

    drive == EDriveC ? drive = EDriveE : drive = EDriveC;

    TRequestStatus status = KRequestPending;

    msgSession->ChangeDriveL(drive,status);

    User::WaitForAnyRequest();

    //User::WaitForRequest(status);//Wait to complete this request

    plugin->StartHarvestingL( baseAppClass );

    TMsvId msgid = MessagingUtils::CreateMessageL(msgSession,

                                                 _L("+3584400220055"),

                                                 _L("+919845062437"),

                                                 _L("This is test from bhuvnesh"));

    iPluginTester->iWaitForHarvester->Start();//Start again

    drive = msgSession->CurrentDriveL();

    CMessagePlugin::FormBaseAppClass(TDriveNumber(drive),baseAppClass);

    TInt count = SearchForTextL(_L("+919845062437"),baseAppClass,KNullDesC);

    if(count <= 0)

        {

        error = KErrNotFound;

        }

    MessagingUtils::RemoveEntryL(msgSession,msgid);

    delete plugin;

    delete iPluginTester;

    delete sessionobserver;

    delete msgSession;

    doLog(iLog,error,_L("Error in TestMessageHarvesterChangeDriveL"));

    return error;

    }

TInt CHarvesterPluginTester::SearchForTextL(const TDesC& aQueryString, const TDesC& aBaseAppclass,const TDesC& aDefaultField)

    {

    TInt DocumentCount(KErrNotFound);

    RSearchServerSession session;

    User::LeaveIfError(session.Connect());

    CCPixSearcher* searcher = CCPixSearcher::NewL(session);

    searcher->OpenDatabaseL(aBaseAppclass);

    // Send for indexing

    if ( searcher )

        {

        DocumentCount = searcher->SearchL(aQueryString, aDefaultField);

        }

    return DocumentCount;

    }

TInt CHarvesterPluginTester::TestStartBookmarksHarvesterL( CStifItemParser& /*aItem */)

    {

    CBookmarksPlugin* plugin = CBookmarksPlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( plugin );

    plugin->StartPluginL();

    plugin->StartHarvestingL( _L(BOOKMARK_QBASEAPPCLASS) );

    iPluginTester->iWaitForHarvester->Start();//Wait here till Harvesting is complete.

    delete plugin;

    delete iPluginTester;

    doLog( iLog, KErrNone, KNoErrorString );

    return KErrNone;

    }

TInt CHarvesterPluginTester::TestAddBookmarkL( CStifItemParser& aItem )

    {

    TInt error = KErrNone;

    CBookmarksPlugin* plugin = CBookmarksPlugin::NewL();

    CHarvesterObserver* iPluginTester = CHarvesterObserver::NewL( plugin );

    plugin->StartPluginL(); //starts the bookmarks db monitor.