/*

* Copyright (c) 2002 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 class communicates with the log db. This also handles all the

*     filtering options and registers Mce to LogEng to get notidied about

*     changes in log DB.

*

*/

// INCLUDE FILES

#include <e32base.h>

#ifndef SYMBIAN_ENABLE_SPLIT_HEADERS

#include "logeng.h"         // for Event Type enumerations

#else

#include "logeng.h"         // for event type enumerations

#include "logsmspdudata.h"         // for event type enumerations

#endif

#include "MceLogEngine.h"

#include "MceLogEngineReader.h"

#include "MceLogPbkMatcher.h"

#include "MMceLogEngObserver.h"

// LOCAL CONSTANTS AND MACROS

_LIT( KPrivateNumber, "Private");

//  LOCAL FUNCTIONS

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

CMceLogEngine::CMceLogEngine() :

    iForeground( ETrue ), // at foreground

    iDbDirty( EFalse )    // db is "clean"

    {

    }

EXPORT_C CMceLogEngine* CMceLogEngine::NewL()

    {

    CMceLogEngine* self = new(ELeave) CMceLogEngine();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

CMceLogEngine::~CMceLogEngine()

    {

    if (iEventArray)

        {

        iEventArray->ResetAndDestroy();

        delete iEventArray;

        }

    delete iEngineReader;

    delete iLogClient;

    delete iPbkMatcher;

    iFsSession.Close();

    }

void CMceLogEngine::ConstructL()

    {

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

    iEventArray = new (ELeave) CArrayPtrFlat<CLogEvent>(1);

    iLogClient = CLogClient::NewL(iFsSession);

    }

EXPORT_C const CLogEvent* CMceLogEngine::Event( TInt aIndex )

    {

    return iEventArray->At(aIndex);

    }

EXPORT_C TInt CMceLogEngine::Count() const

    {

    return iEventArray->Count();

    }

void CMceLogEngine::ReadEventsCompletedL( TBool aStatus )

    {

    if ( ! aStatus )

       {

       ResetArray();

       }

    if( iContainerObserver )

        {

        iContainerObserver->MceLogEngineListBoxStateHasChangedL();

        }

    }

void CMceLogEngine::ResetArray()

    {

    if( iEventArray )

        {

        iEventArray->ResetAndDestroy();

        }

    }

void CMceLogEngine::UpdateEventsL()

    {

    if (iEngineReader)

        {

        iEngineReader->Cancel();

        }

    else

        {

        iEngineReader = CMceLogEngineReader::NewL(this);

        }

    iEngineReader->StartReadingL();

    }

void CMceLogEngine::AddEventToListL( CLogEvent* aEvent )

    {

    iEventArray->AppendL( aEvent );

    }

EXPORT_C void CMceLogEngine::SetContainerObserver( MMceLogEngObserver* aContainerObserver )

    {

    iContainerObserver = aContainerObserver;

    }

EXPORT_C void CMceLogEngine::RemoveContainerObserver()

    {

    iContainerObserver = NULL;

    }

EXPORT_C TInt CMceLogEngine::PurgeData( const CLogEvent* aEvent, CArrayFixFlat<TInt>* aData )

    {

    TPckgBuf<TLogSmsPduData> packedData;

    TInt sMsTotal( 0 );

    TInt sMsPending( 0 );

    if( aEvent->EventType() == ( KLogsEngMmsEventTypeUid ))

        {

        return sMsTotal;

        }

    packedData.Copy( aEvent->Data().Ptr(), sizeof( TLogSmsPduData ) );

    if( aEvent->Data().Length() > 0 )

        {

        sMsTotal = packedData().iTotal;

        sMsPending = sMsTotal

                      - packedData().iDelivered

                      - packedData().iFailed;

        aData->At( 0 ) = sMsPending;

        aData->At( 1 ) = sMsTotal;

        }

    return sMsTotal;

    }

EXPORT_C void CMceLogEngine::GetStandardStrings( TDes& aFailed, TDes& aPending )

    {

    iLogClient->GetString( aPending, R_LOG_DEL_PENDING );

    iLogClient->GetString( aFailed, R_LOG_DEL_FAILED );

    }

EXPORT_C TBool CMceLogEngine::IsNumberAvailable( TInt aIndex )

    {

    if( Count() == 0 )

        {

        return EFalse;

        }

    if( Event( aIndex )->Number().Size() == 0 )

        {

        return EFalse;

        }

    if( Event( aIndex )->RemoteParty() == KPrivateNumber )

        {

        return EFalse;

        }

    return ETrue;

    }

EXPORT_C void CMceLogEngine::ForegroundGainedL()

    {

    UpdateEventsL();

    if( !iPbkMatcher )

        {

        iPbkMatcher = CMceLogPbkMatcher::NewL( iFsSession, this );

        }

    iPbkMatcher->StartL();

    }

EXPORT_C void CMceLogEngine::ForegroundLost()

    {

    }

void CMceLogEngine::PbkMatchingDoneL()

    {

    }

EXPORT_C void CMceLogEngine::ClearDrListL()

    {

    ResetArray();

    if( !iEngineReader )

        {

        iEngineReader = CMceLogEngineReader::NewL(this);

        }

    iEngineReader->ClearDrListL();

    if( iContainerObserver )

        {

        iContainerObserver->MceLogEngineListBoxStateHasChangedL();

        }

    }

// End of file