/*

* Copyright (c) 2002-2006 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:  

*     State machine for handling MMS log entries

*     (sent messages and delivery reports)

*

*/

// INCLUDE FILES

#include    <badesca.h>

#include    <msvids.h>

#include    <logcli.h>

#include    <logview.h>

// common component

#include    <sysutil.h>

#include    "LogsApiConsts.h"

// MMS specific

#include    "mmsconst.h"

#include    "mmslog.h"

#include    "mmsgenutils.h"

#include    "mmsservercommon.h" // needed for logging

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

extern void gPanic(TMmsPanic aPanic);

// CONSTANTS

_LIT(KMmsLogEventTypeName, "MMS");

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// ==================== LOCAL FUNCTIONS ====================

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

// C++ default constructor can NOT contain any code, that

// might leave.

//

CMmsLog::CMmsLog( CLogClient& aLogClient, CLogViewEvent& aLogViewEvent )

    :CMsgActive( EPriorityStandard ),

    iState( EMmsLogIdle ),

    iError( KErrNone ),

    iLogClient( aLogClient ),

    iLogViewEvent( aLogViewEvent ),

    iLastMatchedLink( KLogNullLink )

    {

    }

// Symbian OS default constructor can leave.

void CMmsLog::ConstructL( RFs& aFs )

    {

    iFs = aFs;

    iEntryId = KMsvNullIndexEntryId;

    iLogUpdatedEvent = CLogEvent::NewL();

    iFilterList = new ( ELeave ) CLogFilterList;

    CActiveScheduler::Add(this);

    }

// Two-phased constructor.

CMmsLog* CMmsLog::NewL( CLogClient& aLogClient, CLogViewEvent& aLogViewEvent, RFs& aFs )

    {

    CMmsLog* self = new (ELeave) CMmsLog( aLogClient, aLogViewEvent );

    CleanupStack::PushL( self );

    self->ConstructL( aFs );

    CleanupStack::Pop( self );

    return self;

    }

// Destructor

CMmsLog::~CMmsLog()

    {

    Cancel();

    // we don't delete those pointers that the caller owns.

    if( iFilterList )

        {

        iFilterList->ResetAndDestroy();

        delete iFilterList;

        }

    delete iLogUpdatedEvent;

    delete iLogEventType;

    }

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

// CMmsLog::StartL

//

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

//

void CMmsLog::StartL(

    CLogEvent& aLogEvent,

    CDesCArray& aRemoteParties,

    TRequestStatus& aStatus)

    {

    __ASSERT_DEBUG(iState==EMmsLogIdle,gPanic(EMmsAlreadyBusy));

    // We must save this because we are a state machine,

    // and we keep running around in circles ...

    iLastMatchedLink = KLogNullLink; 

    iLogEvent = &aLogEvent;

    iRemoteParties = &aRemoteParties;

    iCurrentRemoteParty = iRemoteParties->MdcaCount() - 1;

    if ( iCurrentRemoteParty < 0 )

        {

        // if no entries nothing to do

        TRequestStatus* status = &aStatus;

        aStatus = KRequestPending;

        User::RequestComplete( status, KErrNone );

        return;

        }

    TTime now;

    // the dates in log must be in universal time, not local time

    now.UniversalTime();

    if ( iLogEvent->Time().Int64() == 0 )

        {

        iLogEvent->SetTime( now );

        }

    iFilterList->ResetAndDestroy(); // Clear old filters - just in case

    // try adding event type only once

    iEventTypeAdded = EFalse;

    // Unfortunately neither Link nor Data (message id) can be used

    // in the filter.

    // We must filter for each remote party and match the id's separately

    Queue( aStatus );

    iStatus=KRequestPending;

    SetActive();

    // Pretend that we called an asynchronous service

    // in order to get into the state machine loop

    TRequestStatus* status = &iStatus;

    User::RequestComplete( status, KErrNone );

    }

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

// CMmsLog::GetLink()

// Returns the link id which is the same as TMsvId of the 

// related message

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

//

TLogLink CMmsLog::GetLink()

{

    return iLastMatchedLink;	

}

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

// CMmsLog::RunL()

//

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

//

void CMmsLog::RunL()

//

// When the AO is state driven, this form of Run() is very effective

// DoRunL() takes the AO through the states, queuing another asynch step as required

// if DoRunL() detects the end of the cycle it returns without queuing another cycle.

//

// If Run() would exit without queuing another cycle it reports completion to the client.

// This is true if the asynch step or DoRunL() fails, or the state cycle is complete

//

    {

    iError = iStatus.Int();

#ifndef _NO_MMSS_LOGGING_

    if ( iError != KErrNone )

        {

        TMmsLogger::Log( _L("CMmsLog RunL iError = %d"), iError);

        }

#endif

    if ( iError >= KErrNone ||

        ( iError == KErrNotFound && iState == EMmsLogCreatingEntry ) )

        {

        TRAPD( error,DoRunL() );      // continue operations, may re-queue

        __ASSERT_DEBUG( error==KErrNone || !IsActive(),User::Invariant() );   // must not requeue in error situations

        if ( IsActive() )             // requeued

            return;

        iError = error;

        }

    Complete( iError );

    }

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

// CMmsLog::DoRunL()

//

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

//

void CMmsLog::DoRunL()

    {

    // This routine takes the state machine through the states

    // until an error is encountered or the cycle completes.

    if ( iError != KErrNone &&

        !( iState == EMmsLogCreatingEntry && iError == KErrNotFound 

           && iEventTypeAdded == EFalse ) )

        {

        // We encountered an error, and cannot continue

        iStatus = iError;

        iState = EMmsLogIdle;

        // If we return from DoRunL without becoming active again,

        // RunL completes.

        return;

        }

    if ( iError == KErrNotFound && iState == EMmsLogCreatingEntry )

        {

        iState = EMmsLogAddingEventType;

        iError = KErrNone;

        iEventTypeAdded = ETrue;

        // CreateEntryL decrements remote party

        // We get here only if we have tried creating entry and failed

        // after we have tried adding the event type, we retry

        // creating log entry

        iCurrentRemoteParty++;

        }

    else

        {

        SelectNextState();

        }

    if ( iState != EMmsLogFinal )

        {

        // If appropriate, ChangeState makes us active again

        ChangeStateL();

        // If we return from DoRunL without becoming active again,

        // RunL completes.

        }

    else

        {

        iState = EMmsLogIdle;

        // If we return from DoRunL without becoming active again,

        // RunL completes.

        }

    }

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

// CMmsLog::DoComplete

//

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

//

void CMmsLog::DoComplete( TInt& /* aStatus */ )

    {

    // We are exiting the loop - we say we are idle now

    // This is needed when the mms event type does not exist

    // in the log database.

    // In that case the entries cannot be logged, and the

    // state machine exits before reaching the final state.

    iState = EMmsLogIdle;

    }

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

// CMmsLog::SelectNextState

//

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

//

void CMmsLog::SelectNextState()

   {

    // If appropriate, the functions called within the switch statement

    // will make us active again. If all is done, the asynchronous request

    // will complete

    switch ( iState )

        {

        case EMmsLogIdle:

            iState = EMmsLogFiltering;

            break;

        case EMmsLogFiltering:

            if ( iEvents )

                {

                // Check if any of found entries matches our criteria

                iState = EMmsLogMatchingEntry;

#ifndef _NO_MMSS_LOGGING_

                TMmsLogger::Log( _L("CMmsLog matching log entry"));

#endif

                }

            else

                {

                iState = EMmsLogCreatingEntry;

                }

            break;

        case EMmsLogMatchingEntry:

            if ( iEventMatched )

                {

                iState = EMmsLogUpdatingEntry;

                }

            else if ( iEvents )

                {

                // Something found from the database

                // Check if any of found entries matches our criteria

                iState = EMmsLogMatchingEntry;

                }

            else

                {

                // no match, create new entry

                iState = EMmsLogCreatingEntry;

                }

            break;

        case EMmsLogUpdatingEntry:

            if ( iCurrentRemoteParty >= 0 )

                {

                iState = EMmsLogFiltering;

                }

            else

                {

                // done

                iState = EMmsLogFinal;

                }

            break;

        case EMmsLogCreatingEntry:

            if ( iCurrentRemoteParty >= 0 )

                {

                iState = EMmsLogFiltering;

                }

            else

                {

                // done

                iState = EMmsLogFinal;

                }

            break;

        case EMmsLogAddingEventType:

            iState = EMmsLogCreatingEntry;

            break;

        case EMmsLogFinal:

            break;

        default:

            break;

        }

   }

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

// CMmsLog::ChangeState

//

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

//

void CMmsLog::ChangeStateL()

    {

    switch ( iState )

        {

        case EMmsLogIdle:

            break;

        case EMmsLogFiltering:

            FilterL();

            break;

        case EMmsLogMatchingEntry:

            MatchEntryL();

            break;

        case EMmsLogUpdatingEntry:

            UpdateEntryL();

            break;

        case EMmsLogCreatingEntry:

            CreateEntryL();

            break;

        case EMmsLogAddingEventType:

            AddEventTypeL();

            break;

        case EMmsLogFinal:

            break;

        default:

            break;

        }

    }

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

// CMmsLog::Filter

//

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

//

void CMmsLog::FilterL()

    {

    iEvents = EFalse;

    iEventMatched = EFalse;

    // Try filtering by status

    // We cannot filter by remote party as it may be either a phone number

    // or an email address.

    // The best filter would be message id but it is stored in data field

    // and events cannot be filtered by data field.

    // We need to use several statuses depending on what we are doing

    // - If we are adding an entry in pending state, we only search pending entries

    // - If we are handling a delivery or read report, we must use all states

    TLogString logString;

    iLogClient.GetString( logString, R_LOG_DEL_PENDING );

    iFilterList->ResetAndDestroy(); // Clear old filters - just in case

    CLogFilter* filter = CLogFilter::NewL();

    CleanupStack::PushL( filter );

    filter->SetEventType( iLogEvent->EventType() );

    // We always filter with pending entries

    iLogClient.GetString( logString, R_LOG_DEL_PENDING );

    filter->SetStatus( logString );

    iFilterList->AppendL(filter);

    // Filter is now in the list - popped from cleanup stack		

    CleanupStack::Pop( filter );

#ifndef _NO_MMSS_LOGGING_

    TMmsLogger::Log( _L("CMmsLog Filtering with status %S"), &filter->Status() );

#endif

    filter = NULL; // this is out of our hands now

    // If we are handling reports, we must filter other statuses, too

    // logstring was set to pending, and that is the state when

    // creating new entries after sending.

    // If we are handling a delivery report or a read report, the status is

    // R_LOG_DEL_DONE, R_LOG_DEL_FAILED, or KLogsMsgReadText

    // We don't care about the failed ones.

    // If the entry has gone into failed state, we create a new one.

    // That should never happen - no new reports should arrive once something has

    // been put into failed state.

    if ( iLogEvent->Status().CompareF( logString ) != 0 )

        {

        // Filter entries that are already in delivered state

        filter = CLogFilter::NewL();

        CleanupStack::PushL( filter );

        filter->SetEventType( iLogEvent->EventType() );

        iLogClient.GetString( logString, R_LOG_DEL_DONE );

        filter->SetStatus( logString );

        iFilterList->AppendL(filter);

        // Filter is now in the list - popped from cleanup stack		

        CleanupStack::Pop( filter );

#ifndef _NO_MMSS_LOGGING_

        TMmsLogger::Log( _L("CMmsLog Filtering with status %S"), &filter->Status() );

#endif

        filter = NULL; // this is out of our hands now

        // Filter entries in "read" state just to prevent creation of a new one

        filter = CLogFilter::NewL();

        CleanupStack::PushL( filter );

        filter->SetEventType( iLogEvent->EventType() );

        logString.Copy( KLogsMsgReadText );

        filter->SetStatus( logString );

        iFilterList->AppendL(filter);

        // Filter is now in the list - popped from cleanup stack		

        CleanupStack::Pop( filter );

#ifndef _NO_MMSS_LOGGING_

        TMmsLogger::Log( _L("CMmsLog Filtering with status %S"), &filter->Status() );

#endif

        filter = NULL; // this is out of our hands now

        }

#ifndef _NO_MMSS_LOGGING_

    if ( iLogEvent->EventType() == KLogMmsEventTypeUid )

        {

        TMmsLogger::Log( _L(" - and event type MMS") );

        }

    else

        {

        TMmsLogger::Log( _L("wrong event type %d"), iLogEvent->EventType() );

        }

#endif

    iEvents = iLogViewEvent.SetFilterL( *iFilterList, iStatus );

    if ( iEvents )

        {

        SetActive();

        }

    else

        {

        // If there are no events, CLogViewEvent will not issue an asynchronous request

        // In that case we must complete ourselves

#ifndef _NO_MMSS_LOGGING_

        TMmsLogger::Log( _L("CMmsLog found no MMS events in any state searched") );

#endif

        iStatus = KRequestPending;

        SetActive();

        TRequestStatus* status = &iStatus;

        User::RequestComplete( status, KErrNone );

        }

    }

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

// CMmsLog::MatchEntryL

//

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

//

void CMmsLog::MatchEntryL()

    {

    iEventMatched = EFalse;

    // When a view is created, it is positioned on the first event

    // If we know our message entry id, we try to match it

    if ( iLogEvent->Link() != KLogNullLink )

        {

        if ( iLogEvent->Link() == iLogViewEvent.Event().Link() )

            {

            iEventMatched = ETrue;

            }