/*
* 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 <S32MEM.h>

#include "CLogPlayerRecorder.h"

TBool CLogPlayerRecorder::iLogOpen = EFalse;
RFs CLogPlayerRecorder::iRfs;
RFile CLogPlayerRecorder::iFile;
RArray<TUint> CLogPlayerRecorder::iHandleArray;
TInt64 CLogPlayerRecorder::iStartTimeStamp = KErrNotFound;

const TUint digitsIn64BitNumber = 20;

//_LIT(KCPixLogPlayerLogFolder, "CPix\\LogPlayer");
//_LIT(KCPixLogPlayerLogFile, "LogPlayer.txt");
_LIT8(KFlush, "FLUSH");
_LIT8(KSpace, " ");
_LIT8(KNewLine, "\n");
_LIT8( KDefineVolume, "DEFINEVOLUME" );
_LIT8( KHouseKeep, "HOUSEKEEP" );
_LIT8( KOpenDb, "OPENDB" );
_LIT8( KAdd, "ADD" );
_LIT8( KUpdate, "UPDATE" );
_LIT8( KDelete, "DELETE" );
_LIT8( KSearch, "SEARCH" );
_LIT8( KGetDocument, "GET" );
_LIT8( KReset, "RESET" );
_LIT8( KCancel, "CANCEL" );
_LIT8( KDefineVolumeSeparator, "/" );

void CLogPlayerRecorder::LogHouseKeepL()
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KHouseKeep );
    AppendToMsgBuffer( buffer, KSpace ); // TODO: Fix. Ugly hack to make log execution work.
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy( &buffer );
    }

void CLogPlayerRecorder::LogDefineVolumeL(const TDesC& aQualifiedBaseAppClass, 
        const TDesC& aIndexDbPath)
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KDefineVolume );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, aQualifiedBaseAppClass );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, KDefineVolumeSeparator );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, aIndexDbPath );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy( &buffer );
    }

void CLogPlayerRecorder::LogFlushL(TUint aId)
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KFlush );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::LogDatabaseOpenL(TUint aId, TBool aSearcher, const TDesC& aBaseAppClass)
    {
    OpenL();
 
    TPtrC typePtr = KNullDesC();
    if ( aSearcher )
        {
        typePtr.Set( _L( "SEARCHER" ) );
        }
    else
        {
        typePtr.Set( _L( "INDEXER" ) );
        }
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KOpenDb );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, typePtr );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, aBaseAppClass );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy( &buffer );
    }

void CLogPlayerRecorder::LogAddL( TUint aId, const CSearchDocument& aSearchDocument )
    {
    OpenL();
    
    HBufC8* data = SerializeDocumentL( aSearchDocument );
    CleanupStack::PushL( data );
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KAdd );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, data->Length() );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, *data );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    CleanupStack::PopAndDestroy(data);
    }

void CLogPlayerRecorder::LogUpdateL( TUint aId, const CSearchDocument& aSearchDocument )
    {
    OpenL();
    
    HBufC8* data = SerializeDocumentL( aSearchDocument );
    CleanupStack::PushL( data );
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KUpdate );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, data->Length() );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, *data );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    CleanupStack::PopAndDestroy(data);
    }

void CLogPlayerRecorder::LogDeleteL( TUint aId, const TDesC& aDocUid )
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KDelete );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, aDocUid );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::LogSearchL( TUint aId, const TDesC& searchTerms )
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KSearch );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, searchTerms );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::LogGetDocumentL( TUint aId, TUint aIndex )
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KGetDocument );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, aIndex );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::LogResetL( TUint aId )
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KReset );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::LogCancelL( TUint aId )
    {
    OpenL();
    
    RBuf8 buffer;
    buffer.CleanupClosePushL();
    AppendTimeStampToMsgBuffer( buffer );
    AppendToMsgBuffer( buffer, KCancel );
    AppendToMsgBuffer( buffer, KSpace );
    AppendToMsgBuffer( buffer, GetHandleId(aId) );
    AppendToMsgBuffer( buffer, KNewLine );
    iFile.Write( buffer );
    iFile.Flush();
    
    CleanupStack::PopAndDestroy(&buffer);
    }

void CLogPlayerRecorder::OpenL()
    {
    _LIT( KLogName, "C:\\logs\\CPix\\LogPlayer\\LogPlayer.txt");
    
    if ( !iLogOpen )
        {
        User::LeaveIfError( iRfs.Connect() );
        TInt err = iFile.Open( iRfs, KLogName(), EFileWrite | EFileStream );
        if ( err != KErrNone )
            {
            err = iFile.Create( iRfs, KLogName(), EFileWrite );
            User::LeaveIfError(err);
            }
        
        iLogOpen = ETrue;
        }
    }

HBufC8* CLogPlayerRecorder::SerializeDocumentL( const CSearchDocument& aSearchDocument )
    {
    HBufC8* serializedDocument = HBufC8::NewLC( aSearchDocument.Size() );
    TPtr8 serializedDocumentPtr = serializedDocument->Des();
    
    // Initialize a new stream
    RDesWriteStream stream;
    stream.Open(serializedDocumentPtr);
    stream.PushL();

    // Externalize hits to the stream
    aSearchDocument.ExternalizeL(stream);

    // Commit and destroy the stream
    stream.CommitL();
    CleanupStack::PopAndDestroy(&stream);   

    CleanupStack::Pop(serializedDocument);
    return serializedDocument;
    }


TUint CLogPlayerRecorder::GetHandleId( TUint aId )
    {
    TInt index = iHandleArray.Find( aId );
    if ( index == KErrNotFound )
        {
        iHandleArray.Append(aId);
        index = iHandleArray.Count() - 1;
        }
    
    return index;
    }

void CLogPlayerRecorder::AppendTimeStampToMsgBuffer( RBuf8& aBuffer )
    {
    TTime time;
    time.HomeTime();
    
    TInt64 timeDiff = 0;
    
    if  ( iStartTimeStamp == KErrNotFound )
        {
        iStartTimeStamp = time.Int64();
        }
    else
        {
        timeDiff = time.Int64() - iStartTimeStamp;
        }
    
    TBuf8<digitsIn64BitNumber> timeBuffer;
    timeBuffer.AppendNum( timeDiff );
    AppendToMsgBuffer( aBuffer, timeBuffer );
    AppendToMsgBuffer( aBuffer, KSpace );
    }

void CLogPlayerRecorder::AppendToMsgBuffer( RBuf8& aBuffer, const TDesC8& aData )
    {
    TUint requiredLength = aBuffer.Length() + aData.Length();
    if ( aBuffer.MaxLength() < requiredLength )
        {
        aBuffer.ReAlloc(requiredLength);
        }
    
    aBuffer.Append( aData );
    }

void CLogPlayerRecorder::AppendToMsgBuffer( RBuf8& aBuffer, const TDesC16& aData )
    {
    HBufC8* data = HBufC8::New( aData.Length() );
    if ( !data )
        {
        return;
        }
    
    data->Des().Copy( aData );
    
    AppendToMsgBuffer(aBuffer, *data);
    
    delete data;
    }

void CLogPlayerRecorder::AppendToMsgBuffer( RBuf8& aBuffer, TInt64 aData )
    {
    TUint requiredLength = aBuffer.Length() + digitsIn64BitNumber;
    if ( aBuffer.MaxLength() < requiredLength )
        {
        aBuffer.ReAlloc(requiredLength);
        }
    
    aBuffer.AppendNum( aData );
    }