/*

* Copyright (c) 2005-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:  Metadata server logger class*

*/

#include "mdslogger.h"

#include "mdsclausebuffer.h"

#include "mdssqliteconnection.h"

#ifdef LOG_MASTER_FLAG

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

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

// NewInstanceL

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

//

CMdSLogger* CMdSLogger::NewInstanceL()

    {

    static CMdSLogger* singleton;

    if ( singleton == NULL )

        {

        singleton = new (ELeave) CMdSLogger();      

        CleanupStack::PushL(singleton);

        singleton->ConstructL();

        CleanupStack::Pop(singleton);

        }

    return singleton;

    }

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

// Default constructor

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

//

CMdSLogger::CMdSLogger()

	: iAltFileFlag(EFalse), iValid(EFalse)

    {

    }

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

// Destructor

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

//

CMdSLogger::~CMdSLogger()

    {

    iLog.CloseLog(); 

    iLog.Close();

    }

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

// ConstructL

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

//

void CMdSLogger::ConstructL()

    {

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

    iLog.CreateLog(KDirectory, KFilename, EFileLoggingModeOverwrite);

    iLog.SetDateAndTime(EFalse, ETrue);

    iValid = iLog.LogValid();

    // set up logging categories

    Activate( ELogAlways );

#ifdef LOG_QUERY

    Activate( ELogQuery );

#endif

#ifdef LOG_DB

    Activate( ELogDb );

#endif

#ifdef LOG_MUTEX

    Activate( ELogMutex );

#endif

#ifdef LOG_SERVER

    Activate( ELogServer );

#endif

    }

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

// LogLit

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

//

void CMdSLogger::LogLit( const TDesC8& aText )

    {

    if (!iValid)

    	{

    	return;

    	}

    TInt offset = 0;

    TInt linecount = 0;

    TInt length = aText.Length();

    while( offset < length )

        {

        TInt partLength = Min( length-offset, KLineLength );

#ifdef MDE_FILE_LOGGING

        iLog.Write( aText.Mid( offset, partLength ) );

#else

        TBuf<KLineLength> buffer;

        buffer.Copy( aText.Mid( offset, partLength ) );

        RDebug::Print( buffer );

#endif

        ++linecount;

        offset += partLength;

        }

    CheckSize( linecount );

    }

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

// LogLit

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

//

void CMdSLogger::LogLit( const TDesC16& aText )

    {

    if (!iValid)

    	{

    	return;

    	}

    TInt offset = 0;

    TInt linecount = 0;

    TInt length = aText.Length();

    while( offset < length )

        {

        TInt partLength = Min( length-offset, KLineLength );

#ifdef MDE_FILE_LOGGING

        iLog.Write( aText.Mid( offset, partLength ) );

#else

        RDebug::Print( aText.Mid( offset, partLength ) );

#endif

        ++linecount;

        offset += partLength;

        }

    CheckSize( linecount );

    }

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

// CheckSize

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

//

void CMdSLogger::CheckSize( TInt aLines )

    {

#ifdef MDE_FILE_LOGGING

    iLineCounter += aLines;

    if ( iLineCounter < KLogfileMaxLength ) return; // no worries

    iLineCounter = 0;

    iLog.CloseLog();

    if ( !iAltFileFlag )

        {

        iLog.CreateLog(KDirectory, KAltFilename, EFileLoggingModeOverwrite);

        iAltFileFlag = ETrue;       

        }

    else

        {

        iLog.CreateLog(KDirectory, KFilename, EFileLoggingModeOverwrite);

        iAltFileFlag = EFalse;        

        }    

    iLog.SetDateAndTime(EFalse, ETrue);

#else

    aLines = 0;

#endif

    }

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

// DescribeL                Returns sql clause with variables

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

//

CMdsClauseBuffer* CMdSLogger::DescribeL( const CMdsClauseBuffer& aBuffer, const RRowData& aRowData )

    {

    if (!iValid)

    	{

    	return NULL;

    	}

    CMdsClauseBuffer* buf = CMdsClauseBuffer::NewLC( aBuffer.ConstBufferL().Length() + 1024 );

    buf->BufferL().Copy( aBuffer.ConstBufferL() );

    buf->AppendL( _L(" variables=") );

    for( TInt i=0; i<aRowData.Size(); ++i )

        {

        if ( i>0 ) buf->AppendL( _L(", ") );

        LogVariableL( *buf, aRowData.Column(i) );

        }

    CleanupStack::Pop( buf );

    return buf;

    }

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

// DescribeL                Returns sql clause with variables

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

//

CMdsClauseBuffer* CMdSLogger::DescribeFullL( const TDesC& aBuffer, const RRowData& aRowData )

    {

    if (!iValid)

    	{

    	return NULL;

    	}

    const TChar KQuestionMark = '?';

    TPtrC buffer( aBuffer );

    const TInt aBufferLength = aBuffer.Length();

    CMdsClauseBuffer* buf = CMdsClauseBuffer::NewLC( aBufferLength *2 );

    TInt columnNumber = 0;

    TInt qpos = buffer.Locate( KQuestionMark );

    while( qpos >= 0 )

    	{

		buf->ReserveSpaceL( buf->ConstBufferL().Length() + qpos );

		buf->BufferL().Append( buffer.Left( qpos ) );

		LogVariableL( *buf, aRowData.Column(columnNumber++) );

    	buffer.Set( buffer.Mid( qpos + 1 ) );

    	qpos = buffer.Locate( KQuestionMark );

    	}

	buf->ReserveSpaceL( buf->ConstBufferL().Length() + buffer.Length() );

	buf->BufferL().Append( buffer );

	CleanupStack::Pop( buf );

    return buf;

    }

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

// LogVariableL         Logging method for query variables

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

//

void CMdSLogger::LogVariableL( CMdsClauseBuffer& aBuf, const TColumn& aColumn )

    {

    _LIT( KApostrophe, "\'" );

    switch( aColumn.Type() )

        {

        case EColumnNotUsed:

            {

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 8 );

            _LIT( KMessageUnused, "<unused>" );

            aBuf.BufferL().Append( KMessageUnused );

            break;

            }

        case EColumnBool:

            {

            TBool val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 4 );

            aBuf.BufferL().AppendNum( val );

            }

            break;

        case EColumnInt32:

            {

            TInt32 val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 16 );

            aBuf.BufferL().AppendNum( static_cast<TInt>(val) );

            }

            break;

        case EColumnUint32:

            {

            TUint32 val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 16 );

            aBuf.BufferL().AppendNum( val, EDecimal );

            }

            break;

        case EColumnTime:

            {

            TTime val(0);

            TBuf<128> tmp;

            aColumn.Get( val );

            _LIT(KTimeFormat, "%D%1.%M%2.%Y%3 %H:%T:%S");

            val.FormatL(tmp, KTimeFormat);

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 20 );

            aBuf.BufferL().Append( tmp );

            }

            break;

        case EColumnInt64:

            {

            TInt64 val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 32 );

            aBuf.BufferL().AppendNum( val );

            }

            break;

        case EColumnReal32:

            {

            TReal32 val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 32 );

            aBuf.BufferL().AppendNum( val, TRealFormat() );

            }

            break;

        case EColumnReal64:

            {

            TReal64 val=0;

            aColumn.Get( val );

            aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 32 );

            aBuf.BufferL().AppendNum( val, TRealFormat() );

            }

            break;

        case EColumnDes16:

            {

            TPtrC16 val= TPtr16((TUint16*)0, 0); //KNullPtr16;

            aColumn.Get( val );

            if( val.Ptr() )

            	{

            	aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 

            			val.Length() + 2 * KApostrophe().Length() ); // for ''

            	aBuf.BufferL().Append( KApostrophe );

            	aBuf.BufferL().Append( val );

            	aBuf.BufferL().Append( KApostrophe );

            	}

            else

            	{

            	_LIT( KNull, "NULL" );

            	aBuf.ReserveSpaceL( aBuf.ConstBufferL().Length() + 

            			KNull().Length() );

            	aBuf.BufferL().Append( KNull );

            	}

            }

            break;

        default:

            User::Leave( KErrCorrupt );

        }

    }

#endif // LOG_MASTER_FLAG