/*

* 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:  Message store session implementation.

*

*/

// ========

// INCLUDES

// ========

#include "MsgStoreTypes.h"

#include "MsgStorePropertyKeys.h"

#include "MessageStoreSession.h"

#include "MessageStoreServer.h"

#include "ContainerStore.h"

#include "PropertiesSerializer.h"

#include "ContainerStoreMRUAddressTable.h"

#include "bufferedmessagecreator.h"

// =========

// CONSTANTS

// =========

// The maximum number of observer events that will be queued up for a single session.

const TInt KMsgStoreMaximumEventQueueDepth = 100;

const TInt KInitialAddressBufSize          = 256;

const TInt KSortedArrayGranularity         = 100;

const TUint KValThree = 3;

const TUint KGranularity25 = 25;

const TUint KGranularity15 = 15;

// ======================

// CLASS CSearchResult

// ======================

// ==========================================================================

// FUNCTION: NewL

// ==========================================================================

CSearchResult* CSearchResult::NewL( TContainerId aMessageId, TContainerId aFolderId, const TDesC8& aPropertyBuf )

    {

    CSearchResult* self = new(ELeave) CSearchResult( aMessageId, aFolderId );

    CleanupStack::PushL( self );

    self->ConstructL( aPropertyBuf );

    CleanupStack::Pop( self );

    return self;

    }

CSearchResult* CSearchResult::SearchCompleteResultL()

    {

    return NewL( KContainerInvalidId, KContainerInvalidId, KNullDesC8 );

    }

// ==========================================================================

// FUNCTION: Constructor

// ==========================================================================

CSearchResult::CSearchResult( TContainerId aMessageId, TContainerId aFolderId )

    : iMessageId( aMessageId ), iFolderId( aFolderId )

    {

    }

// ==========================================================================

// FUNCTION: ConstructL

// ==========================================================================

void CSearchResult::ConstructL( const TDesC8& aPropertyBuf )

    {

    }

// ==========================================================================

// FUNCTION: Destructor

// ==========================================================================

CSearchResult::~CSearchResult()

    {

    iPropertyBuf.Close();

    }

// ==========================

// CLASS CMessageStoreSession

// ==========================

// ==========================================================================

// FUNCTION: Constructor

// ==========================================================================

CMessageStoreSession::CMessageStoreSession(CMessageStoreServer& aMessageStoreServer) : 

	iServer(aMessageStoreServer),

	iIds( KGranularity25 ),

	iEventQueue( KGranularity15 ),

    iSearchHandler( NULL )

    {

  	__LOG_CONSTRUCT( "msg", "CMessageStoreSession" )

  	}

// ==========================================================================

// FUNCTION: CreateL

// ==========================================================================

void CMessageStoreSession::CreateL()

    {

    __LOG_ENTER( "CreateL" )

    iServer.AddSessionL( this );

    // This could leave if a session is created while the store is unavailable.

    TRAPD( err, iServer.MessageStoreL().ObserveL( this ) );

    // We need to leave the Session active in the case of KErrInUse.  This is

    // because if the observer is dropped during KErrInUse, they cannot

    // re-establish connection, and they will not know when MS in no longer busy.

    // As a result, they will retry for many seconds to connect, then permanently

    // give up.  This is avoided by trapping KErrInUse.

    // Thus, only dropSession and Leave for other errors

    if( err != KErrNone && err != KErrInUse )

    {

        iServer.DropSession( this );

        User::Leave( err );

    }

    __LOG_EXIT

    } // end CreateL

// ==========================================================================

// FUNCTION: Destructor

// ==========================================================================

CMessageStoreSession::~CMessageStoreSession()	

	{

    delete iBufferedMessageCreator;

	iIds.Reset();

    iMruAddressArray.ResetAndDestroy();

	iPropertyNames.ResetAndDestroy();

	iMatchMessages.ResetAndDestroy();

    iSearchStrings.ResetAndDestroy();

	delete iSearchHandler;

	TRAP_IGNORE( iServer.MessageStoreL().StopObserving( this ) );

	//close all the sort iterators when the client exits/crashes

	for ( TInt i = 0 ; i < iSortSessionIds.Count(); i++  )

	    {

	    TRAP_IGNORE( iServer.MessageStoreL().EndSortingL( iSortSessionIds[i] ) );

	    }

	iSortSessionIds.Close();

	iEventQueue.Close();

	if( !iObserverMessage.IsNull() )

		{

		iObserverMessage.Complete( KErrCancel );

		} // end if

	if( !iGetMatchesMessage.IsNull() )

		{

		iGetMatchesMessage.Complete( KErrCancel );

		} // end if

	iServer.DropSession( this );

	__LOG_DESTRUCT

	} // end destructor

// ==========================================================================

// FUNCTION:ServiceL

// ==========================================================================

void CMessageStoreSession::ServiceL(const RMessage2& aMessage)

  {

  __LOG_ENTER_SUPPRESS( "ServiceL" )

  __LOG_WRITE8_FORMAT1_INFO( "%d", aMessage.Function() )

  // Call the appropriate message handler function, based on the message function ID.

  switch( aMessage.Function() )

    {

	case EMsgStoreCmdAuthenticated:

		DoAuthenticatedL( aMessage );

		break;

	case EMsgStoreCmdAuthenticate:

		DoAuthenticateL( aMessage );

		break;

	case EMsgStoreCmdClearAuthentication:

		DoClearAuthenticationL( aMessage );

		break;

	case EMsgStoreCmdHasPassword:

		DoHasPasswordL( aMessage );

		break;

	case EMsgStoreCmdSetPassword:

		DoSetPasswordL( aMessage );

		break;

	case EMsgStoreCmdChangePassword:

		DoChangePasswordL( aMessage );

		break;

    case EMsgStoreCmdEnableEncryption:

        DoEnableEncryptionL( aMessage );

        break;

    case EMsgStoreCmdDisableEncryption:

        DoDisableEncryptionL( aMessage );

        break;

	case EMsgStoreCmdWipeEverything:

		DoWipeEverythingL( aMessage );

		break;

    case EMsgStoreCmdStartObserving:

		DoStartObserving( aMessage );

		break;

    case EMsgStoreCmdGetEvents:

		DoGetEventsL( aMessage );

		break;

    case EMsgStoreCmdStopObserving:	

		DoStopObserving( aMessage );

		break;

    case EMsgStoreCmdCreateAccount:	

    	DoCreateAccountL( aMessage );

    	break;

    case EMsgStoreCmdOpenAccount:	

		DoOpenAccountL( aMessage );

		break;

    case EMsgStoreCmdDeleteAccount:	

		DoDeleteAccountL( aMessage );

		break;

    case EMsgStoreCmdRenameAccount:	

		DoRenameAccountL( aMessage );

		break;

    case EMsgStoreCmdListAccounts:	

		DoListAccountsL( aMessage );

		break;

    case EMsgStoreCmdCreateContainer:

		DoCreateContainerL( aMessage );

		break;

    case EMsgStoreCmdCommitContainer:

		DoCommitContainerL( aMessage );

		break;

    case EMsgStoreCmdAbandonContainer:

		DoAbandonContainerL( aMessage );

		break;

    case EMsgStoreCmdMoveContainer:

		DoMoveContainerL( aMessage );

		break;

    case EMsgStoreCmdCopyContainer:

		DoCopyContainerL( aMessage );

		break;

	case EMsgStoreCmdDeleteContainer:

		DoDeleteContainerL( aMessage );

		break;

	case EMsgStoreCmdChildrenCounts:

		DoChildrenCountsL( aMessage );

		break;

	case EMsgStoreCmdTotalCounts:

		DoTotalCountsL( aMessage );

		break;

    case EMsgStoreCmdChildrenIds:

		DoChildrenIdsL( aMessage );

		break;

    case EMsgStoreCmdPropertiesList:

		DoPropertiesListL( aMessage );

		break;

	case EMsgStoreCmdFetchProperties:

		DoFetchPropertiesL( aMessage );

		break;

	case EMsgStoreCmdUpdateProperties:

		DoUpdatePropertiesL( aMessage );

		break;

	case EMsgStoreCmdUpdateProperty:

		DoUpdatePropertyL( aMessage );

		break;

    case EMsgStoreCmdContentLength:

		DoContentLengthL( aMessage );

		break;

    case EMsgStoreCmdFetchContentToBuffer:

		DoFetchContentToBufferL( aMessage );

		break;

    case EMsgStoreCmdFetchContentToFile:

		DoFetchContentToFileL( aMessage );

		break;

    case EMsgStoreCmdReplaceContentWithBuffer:

		DoReplaceContentWithBufferL( aMessage );

		break;

    case EMsgStoreCmdReplaceContentWithFile:

		DoReplaceContentWithFileL( aMessage );

		break;

    case EMsgStoreCmdAppendToContent:

        DoAppendToContentL( aMessage );

		break;

    case EMsgStoreCmdPrependToContent:

        DoPrependToContentL( aMessage );

        break;

    case EMsgStoreCmdRemoveContent:

		DoRemoveContentL( aMessage );

		break;

    case EMsgStoreCmdOpenContentFile:

        DoOpenContentFileL( aMessage );

        break;

    case EMsgStoreCmdPrepareSearch:

		DoPrepareSearchL( aMessage );

		break;

    case EMsgStoreCmdGetMatches:

		DoGetMatches( aMessage );

		break;

    case EMsgStoreCmdCancelSearch:

		DoCancelSearch( aMessage );

		break;

    case EMsgStoreCmdClearSearchResultCache:

        DoClearSearchResultCache( aMessage );

        break;

    case EMsgStoreCmdStartSorting:

        DoStartSortingL( aMessage );

        break;

    case EMsgStoreCmdEndSorting:

        DoEndSortingL( aMessage );

        break;

    case EMsgStoreCmdGetSortedRows:

        DoGetSortedRowsL( aMessage );

        break;

    case EMsgStoreCmdGetIteratorGroupCount:

        DoGetIteratorGroupCountL( aMessage );

        break;

    case EMsgStoreCmdGetIteratorIdsAndFlags:

        DoGetSortedIdsAndFlagsL( aMessage );

        break;

    case EMsgStoreCmdSortedIndexOf:

        DoGetSortedIndexOfL( aMessage );

        break;

    case EMsgStoreCmdGetIteratorIds:

        DoGetSortedIdsL( aMessage );

        break;

    case EMsgStoreCmdGetIteratorIdsAndGroupCount:

        DoGetSortedIdsAndGroupCountL( aMessage );

        break;

    case EMsgStoreCmdSetMaxMruAddressCount:

        DoSetMaxMruAdressCountL( aMessage );

        break;

    case EMsgStoreCmdSetMruAddressList:

        DoSetMruAddressListL( aMessage );

        break;

    case EMsgStoreCmdGetMruAddressList:

        DoGetMruAddressListL( aMessage );

        break;

    case EMsgStoreCmdBeginBatchInsert:

        DoBeginBatchInsertL( aMessage );

        break;

    case EMsgStoreCmdFinishBatchInsert:

        DoFinishBatchInsertL( aMessage );

        break;

#ifdef _DEBUG

    case EMsgStoreCmdInjectBackupRestoreEvent:

        DoInjectBackupRestoreEventL( aMessage );

        break;

    case EMsgStoreCmdInjectPointSecEvent:

        DoInjectPointSecEvent( aMessage );

        break;

    case EMsgStoreCmdSimulateLowDiskSpace:

        DoSimulateLowDiskSpaceL( aMessage );

        break;

    case EMsgStoreCmdGetEncryptionState:

        DoGetEncryptionStateL( aMessage );

        break;

    case EMsgStoreCmdShutdownServer:

        DoShutdownServer( aMessage );

        break;

#endif  

    default:

      __LOG_WRITE_ERROR( "Illegal function!" )

      PanicClient( aMessage, EPanicIllegalFunction );

      break;

    } // end switch

  __LOG_EXIT    

  } // end ServiceL

// ==========================================================================

// FUNCTION: ServiceError

// ==========================================================================

void CMessageStoreSession::ServiceError(const RMessage2& aMessage, TInt aError)

  {

  __LOG_ENTER_SUPPRESS( "ServiceError" )

  __LOG_WRITE8_FORMAT1_ERROR( "ServiceError %d", aError)

  CSession2::ServiceError( aMessage, aError );

  } // end ServiceError

// ==========================================================================

// FUNCTION: ContainerStoreUnavailable

// ==========================================================================

void CMessageStoreSession::ContainerStoreUnavailable()

	{

    // Cancel any ongoing searches.

    delete iSearchHandler;

    iSearchHandler = NULL;

    iMatchMessages.ResetAndDestroy();    

	TRAP_IGNORE( iServer.MessageStoreL().StopObserving( this ) );

	} // end ContainerStoreUnavailable

// ==========================================================================

// FUNCTION: ContainerStoreAvailable

// ==========================================================================

void CMessageStoreSession::ContainerStoreAvailable()

	{

	TRAP_IGNORE( iServer.MessageStoreL().ObserveL( this ) );

	} // end ContainerStoreAvailable

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

// OBSERVER FUNCTIONALITY

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

// ==========================================================================

// FUNCTION: DoStartObserving

// ==========================================================================

void CMessageStoreSession::DoStartObserving( const RMessage2& aMessage )

	{

	iIsObserving = ETrue;

	aMessage.Complete( KErrNone );

	} // end DoStartObserving

// ==========================================================================

// FUNCTION: DoStopObserving

// ==========================================================================

void CMessageStoreSession::DoStopObserving( const RMessage2& aMessage )

	{

	iIsObserving = EFalse;

	iEventQueue.Reset();

	if( !iObserverMessage.IsNull() )

		{

		iObserverMessage.Complete( KErrCancel );

		} // end if

	aMessage.Complete( KErrNone );

	} // end DoStopObserving

// ==========================================================================

// FUNCTION: DoCreateAccountL

// ==========================================================================

void CMessageStoreSession::DoCreateAccountL( const RMessage2& aMessage )

	{

	TInt32 ownerId = aMessage.Int1();

    RBuf name;    

    CleanupClosePushL( name );

    name.CreateL( aMessage.GetDesLengthL( 2 ) );

	aMessage.ReadL( 2, name );

	RBuf8 propertiesBuf;

	CleanupClosePushL( propertiesBuf );

	propertiesBuf.CreateL( aMessage.GetDesLengthL( KValThree ) );

	aMessage.ReadL( KValThree, propertiesBuf );

	TContainerId mbId = iServer.MessageStoreL().CreateAccountL( ownerId, name, this, propertiesBuf );