// Copyright (c) 2003-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 <e32cons.h>

#include <es_sock.h>

#include "agentnotifierdefs.h"

#include "agentshellnotifier.h"

EXPORT_C CArrayPtr<MNotifierBase2>* NotifierArray()

//

// Lib main entry point

//

	{

	CArrayPtrFlat<MNotifierBase2>* subjects=new (ELeave)CArrayPtrFlat<MNotifierBase2>(1);

	CleanupStack::PushL(subjects);

	subjects->AppendL(CAgentShellNotifier::NewL());

	CleanupStack::Pop();//subjects

	return(subjects);

	}

const TInt KAgentDialogWidth=38;

const TInt KAgentDialogHeight=4;

__FLOG_STMT(_LIT8(KDlgLogSubsys, "agentdialog");)

__FLOG_STMT(_LIT8(KDlgLogComponent, "notifier");)

CAgentDialogUpdate* CAgentDialogUpdate::NewL(const RMessagePtr2& aMessage)

	{

	CAgentDialogUpdate* self=new (ELeave) CAgentDialogUpdate(aMessage);

	CleanupStack::PushL(self);

	self->ConstructL(aMessage);

	CleanupStack::Pop();

	return self;

	}

void CAgentDialogUpdate::Update(const RMessagePtr2& aMessage)

	{

	__FLOG(_L("CAgentDialogUpdate::Update Starting Agent Shell Dialog"));

	iMessagePtr = aMessage;

	TAgentDialogInputBuf agentDialogInputBuf;

	aMessage.ReadL(1, agentDialogInputBuf);

	TAgentDialogInput& agentdialogInput = agentDialogInputBuf();

	iConsole->ClearScreen();

	iConsole->SetTitle(agentdialogInput.iTitle);

	TBuf<KAgentDialogWidth> buf1;

	TBuf<KAgentDialogWidth> buf2;

	buf1.Append(agentdialogInput.iLabel);

	if(buf1.Length() >= 44 )

	{

		buf1.SetLength(40);

		buf1.AppendFill('*',3);

	}

	buf1.Append(' ');

	_LIT(KYesNoChoice, "Yes [y] No [n] Cancel[c]");

	_LIT(KContinuePrompt, "Continue Yes [y]");

	TInt operation = agentdialogInput.getDialogOperation();    

	switch ( operation )

		{

		case ENoYesDialog:

			buf2.Append(KYesNoChoice);

			break;

		case EContinueDialog:

			buf2.Append(KContinuePrompt);

			break;

		default:

		__ASSERT_DEBUG(EFalse, _L("Illegal Agent UI operation type"));

		}

	TPoint point;

	TInt x = (iConsole->ScreenSize().iWidth - buf1.Length()) / 2; // put the string in the middle

	point.SetXY(x, 0);

	iConsole->SetCursorPosAbs(point);

	iConsole->Printf(buf1);

	x = (iConsole->ScreenSize().iWidth - buf2.Length()) / 2; // put the string in the middle

	point.SetXY(x, 1);

	iConsole->SetCursorPosAbs(point);

	iConsole->Printf(buf2);

	}

void CAgentDialogUpdate::DoCancel()

	{

	if (IsActive())

		{

		if (!iMessagePtr.IsNull())

			{

			iMessagePtr.Complete(KErrCancel);

			}

		iConsole->ReadCancel();

		iConsole->Printf(_L("\ndialog cancelled.\nPress any key to continue...\n"));

		}

	}

void CAgentDialogUpdate::RunL()

	{

	TInt key = iConsole->KeyCode();

	__FLOG_1(_L("KeyPressed : %c"),key);

	switch (key)

		{

		case 'y':

		case 'Y':

			iMessagePtr.Complete(EAgentYesPressed);

			break;

		case 'n':

		case 'N':

			iMessagePtr.Complete(EAgentNoPressed);

			break;

		case 'c':

		case 'C':

			iMessagePtr.Complete(KErrCancel);

			break;

		default:

			iConsole->Printf(_L("\n Press 'y' 'n' or 'c'\n"));

			iConsole->Read(iStatus);

			SetActive();

		}

	}

CAgentDialogUpdate::CAgentDialogUpdate(const RMessagePtr2& aMessage)

:	CActive(EPriorityStandard),

	iMessagePtr(aMessage)

	{

	__FLOG_OPEN(KDlgLogSubsys, KDlgLogComponent);

	}

void CAgentDialogUpdate::ConstructL(const RMessagePtr2& /*aMessage*/)

	{

	TRAPD(r,iConsole = Console::NewL(_L("AgentDialog"), TSize(KAgentDialogWidth,KAgentDialogHeight)));

	__FLOG_1(_L("CAgentDialogUpdate::ConstructL - Console::NewL returned %d"),r);

	if (r < KErrNone) //So why not User::LeaveIfError - well Console::NewL is know to return 2

		{

		User::Leave(r);

		}

		if (iConsole == NULL)

		{

		User::Leave(KErrGeneral);

		}

	CActiveScheduler::Add(this);

	// Read back the response

	iConsole->Read(iStatus);

	SetActive();

	__FLOG_1(_L("Performed read for response should still be KRequestPending - %x"),iStatus.Int());

	}

CAgentDialogUpdate::~CAgentDialogUpdate()

	{

	Cancel();

	delete iConsole;

	__FLOG_CLOSE;

	}

CAgentShellNotifier* CAgentShellNotifier::NewL()

	{

	CAgentShellNotifier* self=new (ELeave) CAgentShellNotifier();

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

void CAgentShellNotifier::ConstructL()

	{

	}

CAgentShellNotifier::~CAgentShellNotifier()

	{

	delete iAgentShellDialog;

	}

	//	From MNotifierBase

void CAgentShellNotifier::Release()

	{

	delete this;

	}

CAgentShellNotifier::TNotifierInfo CAgentShellNotifier::RegisterL()

	/**

	 * Called when a notifier is first loaded to allow any initial construction that is required.

	 */

	{

	iInfo.iUid=KUidAgentDialogNotifier;

	iInfo.iChannel=KUidAgentDialogNotifier;

	iInfo.iPriority=ENotifierPriorityLow;

	return iInfo;

	}

CAgentShellNotifier::TNotifierInfo CAgentShellNotifier::Info() const

	/**

	 * Start the notifier with data aBuffer and return an initial response.

	 */

	{

	return iInfo;

	}

TPtrC8 CAgentShellNotifier::StartL(const TDesC8& /*aBuffer*/)

	/**

	 * Start the notifier with data aBuffer.  aMessage should be completed when the notifier is deactivated.

	 * May be called multiple times if more than one client starts the notifier.  The notifier is immediately

	 * responsible for completing aMessage.

	 */

	{

	TPtrC8 ret(KNullDesC8);

	return (ret);

	}

void CAgentShellNotifier::StartL(const TDesC8& /*aBuffer*/, TInt /*aReplySlot*/, const RMessagePtr2& aMessage)

	/**

	 * Start the notifier with data aBuffer.  aMessage should be completed when the notifier is deactivated.

	 * May be called multiple times if more than one client starts the notifier.  The notifier is immediately

	 * responsible for completing aMessage.

	 */

	{

	//	Keep this short! Must schedule an update and return immediately

	if (!aMessage.IsNull())

		{

		if (iAgentShellDialog)

			{

			delete iAgentShellDialog;

			iAgentShellDialog = NULL;

			}

		iAgentShellDialog = CAgentDialogUpdate::NewL(aMessage);

		iAgentShellDialog->Update(aMessage);

		}

	}

void CAgentShellNotifier::Cancel()

	/**

	 * The notifier has been deactivated so resources can be freed and outstanding messages completed.

	 */

	{

	if (iAgentShellDialog)

		{

		iAgentShellDialog->Cancel();

		delete iAgentShellDialog;

		iAgentShellDialog=NULL;

		}

	}

TPtrC8 CAgentShellNotifier::UpdateL(const TDesC8& /*aBuffer*/)

	/**

	 * Update a currently active notifier with data aBuffer.

	 */

	{

	//	Keep this short! Must schedule an update and return immediately

	TPtrC8 ret(KNullDesC8);

	return (ret);

	}