// Copyright (c) 2007-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 <msventry.h>

#include <miut_err.h>

#include <imapcmds.h>

#include "cimapprotocolcontroller.h"

#include "cimapupsresponsewaiter.h"

#include "cimapsettings.h"

/**

Construction method

@return a new instance of CImapUpsResponseWaiter

*/

CImapUpsResponseWaiter* CImapUpsResponseWaiter::NewL(CMsvServerEntry& aServerEntry, CImapProtocolController& aImapProtocolController)

	{

	return new(ELeave)CImapUpsResponseWaiter(aServerEntry, aImapProtocolController);

	}

/**

Default constructor.

*/

CImapUpsResponseWaiter::CImapUpsResponseWaiter(CMsvServerEntry& aServerEntry, CImapProtocolController& aImapProtocolController)

	:CMsgActive(EPriorityStandard), iServerEntry(aServerEntry), iImapProtocolController(aImapProtocolController)

	{

	CActiveScheduler::Add(this);

	}

/**

Destructor.

*/	

CImapUpsResponseWaiter::~CImapUpsResponseWaiter()

	{

	Cancel();

	iUpsSubsession.Close();

	iUpsSession.Close(); 

	}

/**

Connect to UPS server and check if the client thread has the capability to check to the 

imap server.

@param aEntrySelection 	The CMsvEntrySelection containg the imap serviceID.

@param aCommand 		The Imap command(KIMAP4MTMConnect OR KIMAP4MTMConnectAndSynchronise).

@param aClientThread	The Rthread of the client application.

@param aHasCapability	TBool indicating if the client has passes the server's check on capability.

@param aStatus			TRequestStatus of the Active Object.

@return void.

*/

void CImapUpsResponseWaiter::AuthoriseAndConnectL(CMsvEntrySelection& aEntrySelection, TInt aCommand, TThreadId aClientThreadId, TBool aHasCapability, TRequestStatus& aStatus)

	{

	__ASSERT_DEBUG(iState==EIMAP4MTMDisConnected, User::Invariant());

	if(aCommand == KIMAP4MTMConnect)

		{

		iState = EIMAP4MTMConnect;

		}

	else if(aCommand == KIMAP4MTMConnectAndSynchronise)	

		{

		iState = EIMAP4MTMConnectAndSynchronise;

		}

	iEntrySelection = &aEntrySelection;

	iDecision = EUpsDecNo;

	CImapSettings* imapSettings = CImapSettings::NewL(iServerEntry);

	CleanupStack::PushL(imapSettings);

	imapSettings->LoadSettingsL(iServerEntry.Entry().Id());

	// Connect to UPS service.....

	User::LeaveIfError(iUpsSession.Connect());

	RThread clientThread;

 	User::LeaveIfError(clientThread.Open(aClientThreadId));

	CleanupClosePushL(clientThread);

 	User::LeaveIfError(iUpsSubsession.Initialise(iUpsSession, clientThread));

	CleanupStack::PopAndDestroy(&clientThread);

	iStatus=KRequestPending;

	iUpsSubsession.Authorise(aHasCapability, KUidIMAPService, imapSettings->ServerAddress(), iDecision, iStatus);

	Queue(aStatus);

	SetActive();

	CleanupStack::PopAndDestroy();// imapSettings

	}

void CImapUpsResponseWaiter::DoRunL()

	{

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

	if(iDecision != EUpsDecYes && iDecision != EUpsDecSessionYes)

		{

		Complete(KErrPermissionDenied);

		return;

		}

	switch (iState)

		{

		case EIMAP4MTMConnect:

			{

			iState = EIMAP4MTMConnected;

			iImapProtocolController.ConnectL(iStatus, *iEntrySelection);

			SetActive();

			}break;

		case EIMAP4MTMConnectAndSynchronise:

			{

			iState = EIMAP4MTMConnected;

			iImapProtocolController.ConnectAndSynchroniseL(iStatus, *iEntrySelection);

			SetActive();	

			}break;

		case EIMAP4MTMConnected:

			{

			Complete(iStatus.Int());

			iState=EIMAP4MTMDisConnected;

			}break;

		default:

			{

			__ASSERT_DEBUG(iState==EIMAP4MTMDisConnected, User::Invariant());

			break;

			}	

		}

	}

void CImapUpsResponseWaiter::DoCancel()

	{

	iUpsSubsession.CancelPrompt();

	iImapProtocolController.CancelAndCleanup();

	}