/*
* Copyright (c) 2005-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 "T_GraphicsUtil.h"
#include "T_DataDsaSession.h"

_LIT(KDataClassname,	"RDirectScreenAccess");
//command
_LIT( KCmdnewL, "new" );
_LIT( KCmdConstruct, "Construct" );
_LIT( KCmdClose, "Close" );
_LIT( KCmdRequest, "Request" );
_LIT( KCmdCompleted, "Completed" );
_LIT( KCmdCancel, "Cancel" );
_LIT( KCmdEatupMemory, "Util_EatupMemory" );
_LIT( KCmdFreeEatenMemory, "Util_FreeEatenMemory" );
// Fields
_LIT( KRWsSessionObj, "ws");
_LIT( KRWindowObj, "win");
_LIT( KFldRegion, "region1");
_LIT( KFldMemLeft, "memleft");

//Error
_LIT( KErrNewL, "Create RDirectScreenAccess() failed.");
_LIT( KErrRequestRegionMatch, "Execute RDirectScreenAccess::Request() failed, Error: region size not match.");
_LIT( KLogMissingParameter, "Missing parameter '%S'");
_LIT( KLogError, "Error=%d");
_LIT( KStraySignal, "Stray signal");

//Info
_LIT( KRdsaNew1, "RDSA::new() has been called");
_LIT( KRdsaNew2, "RDSA::new(session) has been called");
_LIT( KInfoConstruct, "Construct() has been called" );
_LIT( KInfoClose, "Close() has been called" );
_LIT( KInfoRequest, "Request() has been called" );
_LIT( KInfoCompleted, "Completed() has been called" );
_LIT( KInfoCancel, "Cancel() has been called" );
_LIT( KRunRequestReady, "RunRequestReady %d");

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CT_DataDsaSession::CT_DataDsaSession() : 
	iDsaSession(NULL),
	iActiveRequestReady(NULL)
	{
	}

void CT_DataDsaSession::ConstructL()
	{
	iActiveRequestReady = CActiveCallback::NewL(*this);
	}

CT_DataDsaSession::~CT_DataDsaSession()
	{
	this->DestroyData();
	}

CT_DataDsaSession* CT_DataDsaSession::NewL()
	{
	CT_DataDsaSession* self = new (ELeave) CT_DataDsaSession();
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CT_DataDsaSession::SetObjectL(TAny* aAny)
	{
	this->DestroyData();
	iDsaSession = static_cast<RDirectScreenAccess*>(aAny);
	}

void CT_DataDsaSession::DisownObjectL()
	{
	iDsaSession = NULL;
	}

void CT_DataDsaSession::DestroyData()
	{
	delete iDsaSession;
	iDsaSession = NULL;
	delete iActiveRequestReady;
	iActiveRequestReady = NULL;
	}

MWsClientClass* CT_DataDsaSession::GetClientClass() const
	{
	return iDsaSession;
	}

/**
 * Process a command read from the ini file
 *
 * @param aCommand			the command to process
 * @param aSection			the entry in the ini file requiring the command to be processed
 * @param aAsyncErrorIndex	index of command. used for async calls
 *
 * @return ETrue if the command is processed
 */
TBool CT_DataDsaSession::DoCommandL(const TTEFFunction& aCommand, const
			TTEFSectionName& aSection, const TInt aAsyncErrorIndex)
	{
	TBool result( ETrue );
	INFO_PRINTF1(aCommand);
	
	if ( !aCommand.Compare( KCmdnewL ) || !aCommand.Compare( KDataClassname ) )
        {
    	DoCmdnewL(aSection);
        }
	else if ( !aCommand.Compare( KCmdConstruct ) )
        {
        DoCmdConstruct();
        }
	else if ( !aCommand.Compare( KCmdClose ) )
        {
        DoCmdClose();
        }
	else if ( !aCommand.Compare( KCmdRequest) )
        {
        DoCmdRequestL(aSection , aAsyncErrorIndex);
        }
	else if ( !aCommand.Compare( KCmdCompleted ) )
        {
        DoCmdCompleted();
        }
	else if ( !aCommand.Compare( KCmdCancel ) )
        {
        DoCmdCancel();
        }    
    else if ( !aCommand.Compare(KCmdEatupMemory))
    	{
    	DoCmdEatupMemory(aSection);
    	}
    else if (!aCommand.Compare(KCmdFreeEatenMemory))
    	{
    	DoCmdFreeEatenMemory();
    	}
    else
        {
        result = EFalse;
        }
	
    return result;
	}

/**
 * Helper method to get RWsSession
 */
RWsSession* CT_DataDsaSession::GetRWSessionL(const TDesC& aSection)
	{
	RWsSession* iClient = NULL; //Window Session Client
	TPtrC objectName;
	
	if ( GetStringFromConfig(aSection, KRWsSessionObj(), objectName) )
		{
		iClient = static_cast<RWsSession*>(GetDataObjectL(objectName));
		}
	
	return iClient;
	}

/**
 * Test NewL();
 */
void CT_DataDsaSession::DoCmdnewL(const TDesC& aSection)
	{
	RWsSession* session = GetRWSessionL(aSection);
	
	if(!session)
		{
		//no parameter.
		iDsaSession = new (ELeave) RDirectScreenAccess();
		INFO_PRINTF1(KRdsaNew1);
		}
	else
		{
		//with parameter
		iDsaSession = new (ELeave) RDirectScreenAccess(*session);
		INFO_PRINTF1(KRdsaNew2);
		}

	if(!iDsaSession)
		{
		ERR_PRINTF1(KErrNewL);
		SetBlockResult(EFail);
		}
	
	}


/**
 * Test ConstructL();
 */
void CT_DataDsaSession::DoCmdConstruct()
	{
	INFO_PRINTF1(KInfoConstruct);
	TInt result = iDsaSession->Construct();
	
	if(result)
		{
		ERR_PRINTF2(KLogError, result);
		SetBlockResult(EFail);
		}
	
	}


/**
 * Test Close();
 */
void CT_DataDsaSession::DoCmdClose()
	{
	INFO_PRINTF1(KInfoClose);
	iDsaSession->Close();
	}


/**
 * Test RequestL();
 */
void CT_DataDsaSession::DoCmdRequestL(const TDesC& aSection, const TInt aAsyncErrorIndex)
	{
	INFO_PRINTF1(KInfoRequest);
	RWindowBase* iWindow = NULL;
	TPtrC objectName;
	
	if ( GetStringFromConfig(aSection, KRWindowObj(), objectName))
		{
		iWindow = static_cast<RWindowBase*> (GetDataObjectL(objectName));
		}
	
	if(!iWindow)
		{
		ERR_PRINTF2(KLogMissingParameter , &KRWindowObj);
		SetBlockResult(EFail);
		}
	
	RRegion* aRegion = NULL;
	
	TInt result = iDsaSession->Request(aRegion, iActiveRequestReady->iStatus, *iWindow);
	if(result)
		{
 		ERR_PRINTF2(KLogError, result);
		SetError(result);
		}
    else
        {    	
    	TRect temp;
    	if( GetRectFromConfig(aSection ,KFldRegion, temp ) && aRegion->Count())
    		{
    		//compare the region
    		TRect temp2 = (*aRegion)[0];
    		if(temp != temp2)
    			{
    			ERR_PRINTF1(KErrRequestRegionMatch);
    			SetBlockResult(EFail);
    			}
    		
    		}
    	
        iActiveRequestReady->Activate(aAsyncErrorIndex);
        IncOutstanding();		
    	}

	}

/**
 * Test Completed();
 */
void CT_DataDsaSession::DoCmdCompleted()
	{
	INFO_PRINTF1(KInfoCompleted);
	iDsaSession->Completed();
	}

/**
 * Test Cancel();
 */
void CT_DataDsaSession::DoCmdCancel()
	{
	INFO_PRINTF1(KInfoCancel);
	iDsaSession->Cancel();
	}

void CT_DataDsaSession::DoCmdEatupMemory(const TDesC& aSection)
	{
	CT_GraphicsUtil::EatupMemory(*this,aSection,KFldMemLeft);
	}
void CT_DataDsaSession::DoCmdFreeEatenMemory()
	{
	CT_GraphicsUtil::FreeEatenMemory(*this);
	}

void CT_DataDsaSession::RunL(CActive* aActive, TInt aIndex)
	{
	if ( iActiveRequestReady == aActive )
		{
		RunRequestReady(aIndex);
		}
	else
		{
		ERR_PRINTF1(KStraySignal);
		SetBlockResult(EFail);
		}
	
	}

void CT_DataDsaSession::RunRequestReady( const TInt aIndex)
	{
	DecOutstanding();
	TInt err = iActiveRequestReady->iStatus.Int();
	INFO_PRINTF2(KRunRequestReady, err);
	
	if ( KErrNone != err )
		{
		ERR_PRINTF2(KLogError, err);
		SetAsyncError(aIndex, err);
		}
	
	}

void CT_DataDsaSession::DoCancel(CActive* /*aActive*/, TInt /*aIndex*/)
	{
	//nothing.
	}