/*

* Copyright (c) 2007 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:  PCS Session class

*

*/

// INCLUDE FILES

#include <e32cmn.h>

#include <s32mem.h>

#include <e32debug.h>

#include <utf.h>

#include "CPcsDefs.h"

#include "CPcsServer.h"

#include "CPcsSession.h"

#include "CPsClientData.h"

#include "CPsQuery.h"

#include "CPcsPluginInterface.h"

#include "CPcsDebug.h"

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

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

// CPcsSession::NewL

// Two Phase Construction

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

CPcsSession* CPcsSession::NewL(CPcsServer* aServer)

{

    PRINT ( _L("Enter CPcsSession::NewL") );

    CPcsSession* self= new (ELeave) CPcsSession(aServer);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(); // self

    PRINT ( _L("End CPcsSession::NewL") );

    return self;

}

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

// CPcsSession::CPcsSession

// Construtor

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

CPcsSession::CPcsSession( CPcsServer* aServer ) :iServer(aServer)

{

	PRINT ( _L("Enter CPcsSession::CPcsSession") );

	PRINT ( _L("End CPcsSession::CPcsSession") );

}

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

// CPcsSession::ConstructL

// Second phase constructor

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

void CPcsSession::ConstructL()

{

	PRINT ( _L("Enter CPcsSession::ConstructL") );

	iBufferOverFlow = EFalse;

	iSettings = CPsSettings::NewL();

	PRINT ( _L("End CPcsSession::ConstructL") );

}

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

// CPcsSession::CPcsSession

// Destructor

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

CPcsSession::~CPcsSession()

{

	PRINT ( _L("Enter CPcsSession::~CPcsSession") );

	delete iSettings;

	delete iDes;

	PRINT ( _L("End CPcsSession::~CPcsSession") );

}

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

// CPcsSession::ServiceL

//

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

void CPcsSession::ServiceL(const RMessage2& aMessage)

{

	PRINT ( _L("Enter CPcsSession::ServiceL") );

	TInt errStatus = KErrNone;

	// Do the service

	TRAP ( errStatus, DoServiceL(aMessage) );

    // Check the error status returned

    if ( errStatus != KErrNone )

    {

    	aMessage.Complete(errStatus);

    }

    PRINT ( _L("End CPcsSession::ServiceL") );

}

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

// CPcsSession::DoServiceL

//

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

void CPcsSession::DoServiceL(const RMessage2& aMessage)

{

	PRINT ( _L("Enter CPcsSession::DoServiceL") );

    switch ( aMessage.Function() )

    {

    	case ESearchSettings:

    	    PRINT ( _L("Received function ESearchSettings") );

    	    SetSearchSettingsL(aMessage);

    	    break;

    	case ESearch:

    	    PRINT ( _L("Received function ESearch") );

     	    GetAsyncPcsResultsL(aMessage);

    	    break;

    	case ECancelSearch:

    	    PRINT ( _L("Received function ECancelSearch") );

    	    iBufferOverFlow = EFalse;

            delete iDes;

            iDes = NULL;

    	    aMessage.Complete(ECancelComplete);

    	    break;

    	case ESearchInput:

	    	PRINT ( _L("Received function ESearchInput") );

     	    SearchInputL(aMessage);

    	    break;

        case ESearchMatchString:

            PRINT ( _L("Received function ESearchMatchString") );

            SearchMatchStringL(aMessage);

            break;

    	case ELangSupport:

			PRINT ( _L("Received function ELangSupport") );

			IsLanguageSupportedL(aMessage);

			break;

    	case EGetDataOrder:

			PRINT ( _L("Received function EGetDataOrder") );

			GetDataOrderL(aMessage);

			break;

    	case EGetSortOrder:

			PRINT ( _L("Received function EGetSortOrder") );

			GetSortOrderL(aMessage);

			break;

        case ESetSortOrder:

			PRINT ( _L("Received function ESetSortOrder") );

			ChangeSortOrderL(aMessage);

			break;

        case EGetAdaptiveGrid:

            PRINT ( _L("Received function EGetAdaptiveGrid") );

			GetAdaptiveGridL(aMessage);

			break;

	    case EShutdown:

		    PRINT ( _L("Received function EShutdown") );

			ShutdownServerL(aMessage);

			break;

    }

	PRINT ( _L("End CPcsSession::DoServiceL") );

	return;

}

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

// CPcsSession::ServiceError

//

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

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

{

	PRINT ( _L("Enter CPcsSession::ServiceError") );

	aMessage.Complete(aError);

	PRINT ( _L("End CPcsSession::ServiceError") );

}

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

// CPcsSession::SetSearchSettings

//

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

void CPcsSession::SetSearchSettingsL(const RMessage2& aMessage)

{

	PRINT ( _L("Enter CPcsSession::SetSearchSettingsL") );

	// Read search settings from the message

	HBufC8* searchSettings = HBufC8::NewLC(KBufferMaxLen);

	TPtr8 searchSettingsPtr(searchSettings->Des());

	aMessage.ReadL(0, searchSettingsPtr);

	// Stream over the buffer

	RDesReadStream searchSettingsStream(searchSettingsPtr);

	searchSettingsStream.PushL();

    if ( iSettings )

    {

    	delete iSettings;

    	iSettings = NULL;

    }

    iSettings = CPsSettings::NewL();

	iSettings->InternalizeL(searchSettingsStream);

	// searchSettingsStream, searchSettings

	CleanupStack::PopAndDestroy(2, searchSettings);

	aMessage.Complete(KErrNone);

	PRINT ( _L("End CPcsSession::SetSearchSettingsL") );

}

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

// CPcsSession::GetAsyncPcsResultsL

//

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

void CPcsSession::GetAsyncPcsResultsL(const RMessage2& aMessage)

{

    __LATENCY_MARK ( _L("CPcsSession::GetAsyncPcsResultsL") );

    PRINT ( _L("Enter CPcsSession::GetAsyncPcsResultsL") );

    if ( iBufferOverFlow == EFalse )

    {

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

	    // Read search query from the message

	    CPsQuery* psQuery = ReadQueryLC( 0, aMessage );

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

        RPointerArray<CPsClientData> searchResults;

        RPointerArray<CPsPattern> searchSeqs;

        CleanupStack::PopAndDestroy( psQuery );

		// Dynamic data buffer

	    CBufFlat* buf = CBufFlat::NewL(KBufferMaxLen);

	    CleanupStack::PushL(buf);

	    // Stream over the buffer

	    RBufWriteStream stream(*buf);

	    stream.PushL();

        // Write the number of contacts

	    stream.WriteInt32L(searchResults.Count());

	    // Write the contacts

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

	    {

	        searchResults[i]->ExternalizeL(stream);

	    }

	    // Write the number of char seqs

	    stream.WriteInt32L(searchSeqs.Count());

	    // Write the seqs

	    for ( TInt j = 0; j < searchSeqs.Count(); j++ )

	    {

	        searchSeqs[j]->ExternalizeL(stream);

	    }

	    // Cleanup

	    searchResults.ResetAndDestroy();

	    searchSeqs.ResetAndDestroy();

        // Results are already packed in the stream

        stream.CommitL();

        // Create a heap descriptor from the buffer

        delete iDes;

        iDes = NULL;

	    iDes = buf->Ptr(0).AllocL();

	    CleanupStack::PopAndDestroy(2, buf); // buf, stream

    }

    TInt rcevdBufferSize = aMessage.GetDesMaxLength(1);

    User::LeaveIfNull( iDes );

    TInt reqdBufferSize  = iDes->Size();

    PRINT1 ( _L("Received buffer size = %d"), rcevdBufferSize );

    PRINT1 ( _L("Required buffer size = %d"), reqdBufferSize );

    // If the received buffer size from Client API is less than

    // the required buffer size write the required buffer size

    // and return.

    if ( rcevdBufferSize < reqdBufferSize )

    {

        PRINT ( _L("In-adequate buffer received") );

        PRINT ( _L("Packing the required buffer size in response") );

    	TPckgC<TInt> bufferSizePackage(reqdBufferSize);

    	aMessage.WriteL(1, bufferSizePackage);

    	aMessage.Complete(KErrOverflow);

    	iBufferOverFlow = ETrue;

    }

    else

    {

        PRINT ( _L("Adequate buffer received") );

        PRINT ( _L("Packing the results in response") );

		aMessage.Write(1, *iDes);

		aMessage.Complete(ESearchComplete);

		iBufferOverFlow = EFalse;

    	delete iDes;

        iDes = NULL;

    }

    PRINT ( _L("End CPcsSession::GetAsyncPcsResultsL") );

    __LATENCY_MARKEND ( _L("CPcsSession::GetAsyncPcsResultsL") );

}

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

// CPcsSession::SearchInputL

//

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

void CPcsSession::SearchInputL(const RMessage2& aMessage)

{

    PRINT ( _L("Enter CPcsSession::SearchInputL") );

    __LATENCY_MARK ( _L("CPcsSession::SearchInputL") );

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

    // Read search query from the message

    CPsQuery* psQuery = ReadQueryLC( 0, aMessage );

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

    // Read search data from the message

    HBufC8* searchData = HBufC8::NewLC(KBufferMaxLen);

    TPtr8 searchDataPtr(searchData->Des());

    aMessage.ReadL(1, searchDataPtr);

    // Stream over the buffer

    RDesReadStream searchDataStream(searchDataPtr);

    searchDataStream.PushL();

    // Data to be searched

    // Read data size

	TUint16 szData = searchDataStream.ReadUint16L();

    HBufC* data =  HBufC::NewL(searchDataStream, szData);

    // searchQueryStream, searchQuery

    CleanupStack::PopAndDestroy(2, searchData);

    CleanupStack::PushL( data );

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

    // To hold the matches

    RPointerArray<TDesC> searchSeqs;

    // To hold matched location

    RArray<TPsMatchLocation> sequenceLoc;

    // Delete the search query and search data

	CleanupStack::PopAndDestroy( data );

    CleanupStack::PopAndDestroy( psQuery );

    // --------- create write stream ---------------------------

    // Dynamic data buffer

    CBufFlat* buf = CBufFlat::NewL(KBufferMaxLen);

    CleanupStack::PushL(buf);

    // Stream over the buffer

    RBufWriteStream stream(*buf);

    stream.PushL();

    // --------- write match sequence ---------------------------

    // Write the number of match seqs

    stream.WriteUint16L(searchSeqs.Count());

    // Write the matches

    for ( TInt j = 0; j < searchSeqs.Count(); j++ )

    {

        TInt length = searchSeqs[j]->Length();

        // Write the char sequence length

        stream.WriteUint16L(length);

        // Write the char sequence

    	stream << *searchSeqs[j];

    }

    // --------- write match sequence location ------------------

    // write number of sequnece

    stream.WriteUint16L(sequenceLoc.Count());

    // write each structure element

    for(TInt k = 0; k < sequenceLoc.Count(); k++)

    {

    	TPsMatchLocation temp = sequenceLoc[k];

    	// write the starting index

    	stream.WriteUint16L(temp.index);

    	// write the length of match

    	stream.WriteUint16L(temp.length);

    	//write directionality of string

    	stream.WriteUint16L(temp.direction);

    }

    // Reset search seqs

    searchSeqs.ResetAndDestroy();

    sequenceLoc.Reset();

    sequenceLoc.Close();

    stream.CommitL();

	aMessage.Write(2, buf->Ptr(0));

	aMessage.Complete(KErrNone);

	CleanupStack::PopAndDestroy(2, buf); // buf, stream

    PRINT ( _L("End CPcsSession::SearchInputL") );

    __LATENCY_MARKEND ( _L("CPcsSession::SearchInputL") );

}

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

// CPcsSession::SearchMatchStringL

//

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

void CPcsSession::SearchMatchStringL(const RMessage2& aMessage)

{

    PRINT ( _L("Enter CPcsSession::SearchMatchStringL") );

    __LATENCY_MARK ( _L("CPcsSession::SearchMatchStringL") );

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

    // Create result buffer

    HBufC* des = HBufC::NewLC(KBufferMaxLen);

    TPtr ptr(des->Des());

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

    // Read search query from the message

    CPsQuery* psQuery = ReadQueryLC( 0, aMessage );

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

    // Read search data from the message

    HBufC8* searchData = HBufC8::NewLC(KBufferMaxLen);

    TPtr8 searchDataPtr(searchData->Des());

    aMessage.ReadL(1, searchDataPtr);

    // Stream over the buffer

    RDesReadStream searchDataStream(searchDataPtr);

    searchDataStream.PushL();

    // Data to be searched

    // Read data size

    TUint16 szData = searchDataStream.ReadUint16L();

    HBufC* data = HBufC::NewL(searchDataStream, szData);

    // searchQueryStream, searchQuery

    CleanupStack::PopAndDestroy(2, searchData);

    CleanupStack::PushL( data );

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

    iServer->PluginInterface()->SearchMatchStringL( *psQuery, *data, ptr );

    // Delete the search query and search data

    CleanupStack::PopAndDestroy( data );