/*

* Copyright (c) 2008 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:  Search implementation

*

*/

#include <string.h>

#include <stdlib.h>

#include <ximpprotocolconnectionhost.h>

#include <ximpobjectfactory.h>

#include <searchelement.h>

#include <searchobjectfactory.h>

#include <ximpobjectcollection.h>

#include <searchinfo.h>

#include <searchobjectfactory.h>

#include <protocolsearchdatahost.h>

#include <protocolsearchfeaturedatahost.h>

#include <ximpidentity.h>

#include "stringutils.h"

#include "msg_enums.h"

#include "waittimer.h"

#include "msgliterals.h"

#include "ossprotocoladaptutils.h"

#include "csearchrequest.h"

#include "mossprotocolconnectionmanager.h"

#include "ossprotocolpluginlogger.h"

#include "cossprotocolconnectionmanager.h"

// search  strings  used 

const char* FirstName ="first_name";

const char* LastName ="last_name";

const char* UserId ="user_id";

const char* Jid ="jid";

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

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

// CSearchrequest::CSearchrequest

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

//

CSearchrequest::CSearchrequest(	MOSSProtocolConnectionManager& aConnMan,

									TXIMPRequestId aRequestId ) :

    CActive( EPriorityNormal ),

    iRequestId( aRequestId ),

    iConnMan( aConnMan )

    {

    LOGGER ( TXT("::CSearchrequest Start") );

    CActiveScheduler::Add( this );

    LOGGER ( TXT("::CSearchrequest End") );

    }

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

// CSearchrequest::ConstructL

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

//

void CSearchrequest::ConstructL()

    {

    LOGGER ( TXT("CSearchrequest::ConstructL Start-End") );

	iSearchId=NULL;

    }

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

// CSearchrequest::NewLC

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

//

CSearchrequest* CSearchrequest::NewLC(

    MOSSProtocolConnectionManager& aConnMan,

    TXIMPRequestId aRequestId )

    {

    LOGGER ( TXT("CSearchrequest::NewLC Start") );

     CSearchrequest* self = new( ELeave ) 

    			CSearchrequest( aConnMan, aRequestId );

    CleanupStack::PushL( self );

    self->ConstructL();

    LOGGER ( TXT("CSearchrequest::NewLC End") );

    return self;

    }

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

// CSearchrequest::~CSearchrequest

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

//

CSearchrequest::~CSearchrequest()

    {

    LOGGER ( TXT("::~CSearchrequest Start") );

    delete iSearchId;

    iSearchId=NULL;

	CActive::Cancel();

    LOGGER ( TXT("::~CSearchrequest End") );

    }

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

// CSearchrequest::DoCancel()

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

//

void CSearchrequest::DoCancel()

    {

    LOGGER ( TXT("CSearchrequest::DoCancel Start") );

    LOGGER ( TXT("CSearchrequest::DoCancel End") );

    }

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

// CSearchrequest::RunL()

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

//

void CSearchrequest::RunL()

	{

	LOGGER ( TXT("CSearchrequest::RunL Start") );

	User::LeaveIfError ( iStatus.Int() );

	int len = MAX_SIZE_DATA;

	char* pResponse = NULL, *pOrigResponse = NULL;;

	char* key = NULL; 

	MXIMPObjectFactory& objFact = iConnMan.HandleToHost().ObjectFactory();

	MSearchObjectFactory& searchObjFact = iConnMan.GetSearchHost().SearchObjectFactory();

	MXIMPIdentity* identity = objFact.NewIdentityLC();

	MXIMPObjectCollection* fieldlist = objFact.NewObjectCollectionLC();

  	TInt datacount = iConnMan.DataHandler().SearchDataCount();

 	while( datacount )

		{

		LOGGER ( TXT("CONTACT NO : %d"), datacount );	

		pOrigResponse =pResponse = iConnMan.DataHandler().ResponseL ( 5 );

		CleanupStack::PushL(pOrigResponse) ;

		MSearchInfo* searchInfo = searchObjFact.NewSearchInfoLC();

		pResponse += sizeof ( message_hdr_resp );

		len = strlen(pResponse) + 1;

		while( !( *(pResponse) == '\0' && *(pResponse + 1) == '\0' ))

			{

			len = strlen(pResponse) + 1;

			key = ( char* ) User::AllocLC(len);

			strcpy(key,pResponse);

			pResponse += len;

			len = strlen(pResponse) + 1;

			if( strcmp(key,FirstName) == 0)

				{

				LOGGER ( TXT("FIRSTNAME :") );

			    ParseAndSetL(pResponse,len,*searchInfo, EFirstName);

				}

			else if( strcmp(key,LastName) == 0 )

				{

				LOGGER ( TXT("LASTNAME :"));

				ParseAndSetL(pResponse,len,*searchInfo, ELastName);

				}

			else if( strcmp(key,Jid) == 0 )

				{

				LOGGER ( TXT("JID :") );

				ParseAndSetL(pResponse,len,*searchInfo, EEmailAddress);

				}

			pResponse += len;

			CleanupStack::PopAndDestroy ();// key			

			}

		fieldlist->AddObjectL ( searchInfo );	

		CleanupStack::Pop();//searchInfo

		CleanupStack::PopAndDestroy(pOrigResponse) ;//pOrigResponse	

		datacount = iConnMan.DataHandler().SearchDataCount();

		}

	iConnMan.DataHandler().ResponseL ( 5 ); // this removes the operation from the array

	identity->SetIdentityL(*iSearchId );

	iConnMan.GetSearchHost().SearchFeatureDataAccess().HandleSearchResultsL ( identity,fieldlist );

	iConnMan.HandleToHost().HandleRequestCompleted ( iRequestId, KErrNone );

	CleanupStack::Pop ( 2 );//identity,fieldlist

	delete this;

	LOGGER ( TXT("CSearchrequest::RunL End") );

	}

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

// CSearchrequest::RunError

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

//

TInt CSearchrequest::RunError( TInt  aError )

    {

    LOGGER ( TXT("CSearchrequest::RunError : %d  Start"), aError );

    iConnMan.HandleToHost().HandleRequestCompleted( iRequestId, aError );

    TRAP_IGNORE(iConnMan.DataHandler().ResponseL ( 5 ));	 // this removes the operation from the array

    delete this;

	LOGGER ( TXT("CSearchrequest::RunError End") );

    return KErrNone;

    }

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

// CSearchrequest::SearchL

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

//

void CSearchrequest::SearchL( const MXIMPIdentity& aSearchId,

							  const RPointerArray< MSearchElement >& aObjs,

							  TInt  /*aSearchLimit*/)

	{

    LOGGER ( TXT("CSearchrequest::SearchL Start") );

    char *smsg = NULL;

	char *tmpmsg = NULL;

	message_hdr_req msgHdr = {0,};

	int userLen = 0;

	int totalLen = 0;

	smsg = ( char* ) User::AllocLC(MAX_MSG_SIZE);

	memset ( smsg, '\0', MAX_MSG_SIZE );

	msgHdr.message_type = ESearch;

	memcpy ( smsg, &msgHdr, sizeof ( message_hdr_req ) );

	HBufC* keyStr = NULL;//HBufC::NewL( 1024 );

	CSearchKeyStore& keyStore = iConnMan.GetSearchKeyStore();

	totalLen += sizeof( message_hdr_req );

	TInt elementCount=aObjs.Count();	

	for (TInt i=0; i< elementCount; ++i)

		{

		const MSearchElement* searchElement = aObjs[i];

			switch( searchElement->GetSearchKey() )

			{

			case EUserFirstName:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserFirstName );

				break;	

				}

			case EUser:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUser );

				break;	

				}

			case EUserLastName:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserLastName );

				break;	

				}

			case EUserMiddleName:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserMiddleName );

				break;	

				}

			case EUserFullName:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserFullName );

				break;	

				}

			case EUserCountry:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserCountry );

				break;	

				}

			case EUserCity:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserCity );

				break;	

				}

			case EBirthday:

				{

				keyStr = keyStore.GetLabelFromEnumL( EBirthday );

				break;	

				}

			case EState:

				{

				keyStr = keyStore.GetLabelFromEnumL( EState );

				break;	

				}

			case EUserEmailAddress:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserEmailAddress );

				break;	

				}

			case EUserNickName:

				{

				keyStr = keyStore.GetLabelFromEnumL( EUserNickName );

				break;	

				}

			case EOrganisation:

				{

				keyStr = keyStore.GetLabelFromEnumL( EOrganisation );

				break;	

				}

			case EOrganisationUnit:

				{

				keyStr = keyStore.GetLabelFromEnumL( EOrganisationUnit );

				break;	

				}

			case  EReadLabel: 

				{

				//If key is not supported(case of not localized string)

				keyStr = searchElement->GetSearchLabel().Identity().AllocL();

				break;	

				}

			default:

				{

				//If any other case just continue with next one

				continue;					

				}

			}	

		if ( NULL == keyStr )

			{

			continue;	

			}

		//Add key

		CleanupStack::PushL( keyStr );

		charFormatData tmpmsgData = OssProtocolAdapUtils::ConvertTUint16ToCharLC( *keyStr );

	    tmpmsg = tmpmsgData.data;

	    userLen = tmpmsgData.dataSize;

		 if ( totalLen + userLen > MAX_MSG_SIZE ) 

		    	{

				User::Leave(KErrArgument);		

		    	}

		memcpy ( smsg + totalLen, tmpmsg, userLen );

    	totalLen += userLen;

		//Add value

		charFormatData tmpmsgDataValue = OssProtocolAdapUtils::ConvertTUint16ToCharLC( 

					searchElement->GetSearchId().Identity() );

	    tmpmsg = tmpmsgDataValue.data;

	    userLen = tmpmsgDataValue.dataSize;

		 if ( totalLen + userLen > MAX_MSG_SIZE ) 

		    	{

				User::Leave(KErrArgument);		

		    	}

		memcpy ( smsg + totalLen, tmpmsg, userLen );

    	totalLen += userLen;

    	CleanupStack::PopAndDestroy ( 3 );//For keyStr, tmpmsgData, tmpmsgDataValue

		} // end  : for loop

	iSendId = iConnMan.DataHandler().SendDataL ( iStatus, smsg, totalLen++ );

	delete iSearchId;	

	iSearchId=NULL;

    iSearchId=aSearchId.Identity().AllocL();

	// signal the scheduler

	SetActive();

	CleanupStack::PopAndDestroy ( 1 );//smsg

	LOGGER ( TXT("CSearchrequest::SearchL End") );

	}

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

// CSearchrequest::SearchUtil

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

//

void CSearchrequest::ParseAndSetL(char* aResponse, TInt /*alen*/, MSearchInfo& aSearchInfo, TInfoType aKeytype) 

	{

    char* keyvalue =  aResponse;

	HBufC16* key_value = OssProtocolAdapUtils::ConvertCharToTUint16LC( keyvalue );

	aSearchInfo.SetFieldInfoL(*key_value,aKeytype);

	CleanupStack::PopAndDestroy( key_value );

	}

// End of file