// Copyright (c) 2006-2009 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:

//

#include "cimapsearch.h"

#include "moutputstream.h"

#include "cimapsessionconsts.h"

#include "imappaniccodes.h"

// IMAP SEARCH command

_LIT8(KCommandSearch, "%d UID SEARCH %S\r\n");

CImapSearch* CImapSearch::NewL(CImapFolderInfo* aSelectedFolderData, TInt aLogId, const TDesC8& aSearchCriteria, RArray<TUint>& aMatchingMessageIds)

// static method first phase construction

	{

	CImapSearch* self = new (ELeave) CImapSearch(aSelectedFolderData, aLogId, aMatchingMessageIds);

	CleanupStack::PushL(self);

	self->ConstructL(aSearchCriteria);

	CleanupStack::Pop();

	return self;

	}

CImapSearch::CImapSearch(CImapFolderInfo* aSelectedFolderData, TInt aLogId, RArray<TUint>& aMatchingMessageIds)	

	: CImapCommandEx(aSelectedFolderData, aLogId)

	, iMatchingMessageIds(aMatchingMessageIds)

	{

	}

void CImapSearch::ConstructL(const TDesC8& aSearchCriteria)

	{

	iSearchCriteria = aSearchCriteria.AllocL();

	}

CImapSearch::~CImapSearch()

	{

	delete iSearchCriteria;

	}

/**

Formats and sends the IMAP SEARCH command.

@param aTagId Command sequence id which will be send along with the IMAP command.

@param aStream A wrapper for the outbound stream of a connected socket, using which

the command will be send to the server

*/

void CImapSearch::SendMessageL(TInt aTagId, MOutputStream& aStream)

	{

	// From RFC3501

	//	search = "SEARCH" [SP "CHARSET" SP astring] 1*(SP search-key)

	//

	// we have chosen not to send teh optional "CHARSET", which means we

	// don't need to check for a BADCHARSET response text code in the resposne.

	iTagId = aTagId;

	TInt bufLength = KCommandSearch().Length();

	bufLength += TagLength(aTagId);

	bufLength += iSearchCriteria->Length();

	__ASSERT_DEBUG(iOutputBuffer==NULL, TImapServerPanic::ImapPanic(TImapServerPanic::ECommandOutputBufferNotNull));

	iOutputBuffer = HBufC8::NewL(bufLength);

	iOutputBuffer->Des().Format(KCommandSearch, aTagId, iSearchCriteria);

	//send the command to the server

	aStream.SendDataReq(*iOutputBuffer);

	}

/**

Checks if this is a SEARCH response.  If it is, then it is parsed.

@return ECompleteUntagged if the line is an untagged SEARCH response.

		ENotRecognised for any other response (i.e. one that is not known about by this command)

*/

CImapCommand::TParseBlockResult CImapSearch::ParseUntaggedResponseL()

	{	

	TParseBlockResult result = ENotRecognised;

	// Is this a search response?

	TPtrC8 part = GetNextPart(); // returns KNullDesC8 if there is no part available

	if(part.CompareF(KImapTxtSearch) == 0)

		{

		ParseSearchResponseL();

		result = ECompleteUntagged;

		}

	return result;

	}

/**

Parses the message uids from a previously identified untagged search response.

*/

void CImapSearch::ParseSearchResponseL()

	{

	// From RFC3501 section 9 (edited)

	//

	// mailbox-data = "SEARCH" *(SP nz-number)

	//

	// "SEARCH" has already been found, so the remainder of response 

	// should be space-separated numbers representing UIDS of messages.

	RDesParts messageUidList;

	CleanupClosePushL(messageUidList);

	GetDelimitedPartsL(' ', iUnparsedData, messageUidList);

	TUint messageUid = 0;

	TInt countMessageUids = messageUidList.Count(); 	 

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

		{

		TLex8 desToInt(messageUidList[i]);

		TInt err = desToInt.Val(messageUid);

		if (err != KErrNone)

			{

			CorruptDataL();

			}

		iMatchingMessageIds.Append(messageUid);

		}

	CleanupStack::PopAndDestroy(&messageUidList);

	}