/*

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

*     Observer of the given folder. If new messages are created to the folder,

*     calls HandleFolderEntryL.

*

*/

#include "AlwaysOnlineEmailPluginLogging.h"

#include "AlwaysOnlineImap4FolderObserver.h"

#include "AlwaysOnlineEmailLoggingTools.h"

const TInt KAlwaysOnlineImap4FolderObserverTimeout = 2000000; // 2 seconds

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

// CAlwaysOnlineImap4FolderObserver()

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

CAlwaysOnlineImap4FolderObserver::CAlwaysOnlineImap4FolderObserver(

    CMsvSession& aMsvSession,

    MAlwaysOnlineImap4FolderObserver& aObserver )

    :

    CActive( EPriorityStandard ),

    iMsvSession( aMsvSession ),

    iObserver( aObserver )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::CAlwaysOnlineImap4FolderObserver" );

    CActiveScheduler::Add( this );

    }

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

// NewL()

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

CAlwaysOnlineImap4FolderObserver* CAlwaysOnlineImap4FolderObserver::NewL(

    CMsvSession& aMsvSession,

    MAlwaysOnlineImap4FolderObserver& aObserver )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::NewL" );

    return CAlwaysOnlineImap4FolderObserver::NewL( aMsvSession, NULL, aObserver );

    }

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

// NewL()

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

CAlwaysOnlineImap4FolderObserver* CAlwaysOnlineImap4FolderObserver::NewL(

    CMsvSession& aMsvSession,

    CMsvEntrySelection* aFoldersToWatch,

    MAlwaysOnlineImap4FolderObserver& aObserver )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::NewL" );

    CAlwaysOnlineImap4FolderObserver* self =

        new (ELeave) CAlwaysOnlineImap4FolderObserver(

        aMsvSession, aObserver );

    CleanupStack::PushL( self );

    self->ConstructL( aFoldersToWatch );

    CleanupStack::Pop( self );

    return self;

    }

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

// ConstructL()

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

void CAlwaysOnlineImap4FolderObserver::ConstructL(

    CMsvEntrySelection* aFoldersToWatch )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::ConstructL" );

    User::LeaveIfError( iTimer.CreateLocal() );

    iRunning = EFalse;

    iSendNotification = EFalse;

    iMsvSession.AddObserverL( *this );

    if ( aFoldersToWatch )

        {

        iFolders = aFoldersToWatch->CopyL();

        }

    else

        {

        iFolders = new (ELeave) CMsvEntrySelection;

        }

    iChangedFolders = new (ELeave) CMsvEntrySelection;

    }

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

// ~CAlwaysOnlineImap4Agent()

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

CAlwaysOnlineImap4FolderObserver::~CAlwaysOnlineImap4FolderObserver()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::~CAlwaysOnlineImap4FolderObserver" );

    iMsvSession.RemoveObserver( *this );

    delete iFolders;

    delete iChangedFolders;

    Cancel();

    iTimer.Close();

    }

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

// Start()

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

void CAlwaysOnlineImap4FolderObserver::Start()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::Start" );

    KAOEMAIL_LOGGER_WRITE("CAlwaysOnlineImap4FolderObserver::Start");

    iRunning = ETrue;

    iSendNotification = EFalse;

    }

void CAlwaysOnlineImap4FolderObserver::Stop()

    {

    KAOEMAIL_LOGGER_WRITE("CAlwaysOnlineImap4FolderObserver::Stop");

    Cancel();

    iRunning = EFalse;

    iSendNotification = EFalse;

    }

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

// DoCancel()

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

void CAlwaysOnlineImap4FolderObserver::DoCancel()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::DoCancel" );

    iTimer.Cancel();

    }

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

// RunL()

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

void CAlwaysOnlineImap4FolderObserver::RunL()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::RunL" );

    KAOEMAIL_LOGGER_FN1("CAlwaysOnlineImap4FolderObserver::RunL");

    iRunning = EFalse;

    if ( iSendNotification )

        {

        iObserver.HandleFolderEntryL( *iChangedFolders );

        iChangedFolders->Reset();

        }

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderObserver::RunL");

    }

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

// HandleSessionEventL()

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

void CAlwaysOnlineImap4FolderObserver::HandleSessionEventL(

    TMsvSessionEvent aEvent, TAny* aArg1, TAny* aArg2, TAny* /*aArg3*/)

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::HandleSessionEventL" );

    KAOEMAIL_LOGGER_WRITE_FORMAT("CAlwaysOnlineImap4FolderObserver::HandleSessionEventL aEvent %d", aEvent);

    if ( !iRunning )

        {

        // just ignore everything, we are not running

        KAOEMAIL_LOGGER_WRITE("CAlwaysOnlineImap4FolderObserver::HandleSessionEventL: ignore everything");

        return;

        }

    const TTimeIntervalMicroSeconds32 timeInterval = KAlwaysOnlineImap4FolderObserverTimeout;

    switch ( aEvent )

        {

        case EMsvEntriesCreated:

        case EMsvEntriesChanged: // Handle this somehow

        case EMsvEntriesDeleted:

            {

            TMsvId parentId = (*(TMsvId*) (aArg2));

            if ( iFolders->Find( parentId ) != KErrNotFound )

                {

                KAOEMAIL_LOGGER_WRITE_FORMAT("parent 0x%x found", parentId);

                iSendNotification = ETrue;

                if ( iChangedFolders->Find( parentId ) == KErrNotFound )

                    {

                    iChangedFolders->AppendL( parentId );

                    }

                KAOEMAIL_LOGGER_WRITE("CAlwaysOnlineImap4FolderObserver::HandleSessionEventL: restart timer case 2");

                Cancel();

                // cancel called right before, no need to check if still active

                iTimer.After( iStatus, timeInterval ); // CSI: 10 # see comment above

                SetActive();

                }

            else

                {

                const CMsvEntrySelection* selection = static_cast<CMsvEntrySelection*>(aArg1);

                if ( iMailboxId > 0 &&

                    selection->Find( iMailboxId ) > KErrNotFound )

                    {

                    iSendNotification = ETrue;

                    iChangedFolders->AppendL( iMailboxId );

                    KAOEMAIL_LOGGER_WRITE("CAlwaysOnlineImap4FolderObserver::HandleSessionEventL: restart timer case 3");

                    Cancel();

                    // cancel called right before, no need to check if still active

                    iTimer.After( iStatus, timeInterval ); // CSI: 10 # see comment above

                    SetActive();

                    }

                }

            }

            break;

        default:

        break;

        }

    }

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

// AppendFolderL()

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

void CAlwaysOnlineImap4FolderObserver::AppendFolderL( TMsvId aFolderId )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::AppendFolderL" );

    if ( iFolders->Find( aFolderId ) == KErrNotFound )

        {

        iFolders->AppendL( aFolderId );

        }

    }

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

// RemoveFolder()

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

void CAlwaysOnlineImap4FolderObserver::RemoveFolder( TMsvId aFolderId )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::RemoveFolder" );

    TInt index = iFolders->Find( aFolderId );

    if ( index != KErrNotFound )

        {

        iFolders->Delete( index );

        }

    }

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

// ResetFoldersL()

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

void CAlwaysOnlineImap4FolderObserver::ResetFoldersL( CMsvEntrySelection* aFoldersToWatch )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::ResetFoldersL" );

    delete iFolders;

    iFolders = NULL;

    iFolders = aFoldersToWatch->CopyL();

    }

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

// SetMailbox()

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

void CAlwaysOnlineImap4FolderObserver::SetMailbox( const TMsvId aMailboxId )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderObserver::SetMailbox" );

    iMailboxId = aMailboxId;

    }

//EOF