/*

* Copyright (c) 2010 Kanrikogaku Kenkyusho, Ltd.

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:

* Kanrikogaku Kenkyusho, Ltd. - Initial contribution

*

* Contributors:

*

* Description:  

*

*/

#include "directprintserverjobguard.h"

#include "directprintbody.h"

#include "clog.h"

#include "directprintmessage.h"

CDirectPrintServerJobGuard* CDirectPrintServerJobGuard::NewL( CDirectPrintBody& aEngine )

	{

	CDirectPrintServerJobGuard* self = new ( ELeave ) CDirectPrintServerJobGuard( aEngine );

	CleanupStack::PushL( self );

	self->ConstructL();

	CleanupStack::Pop();    // self

	return self;

	}

CDirectPrintServerJobGuard::CDirectPrintServerJobGuard( CDirectPrintBody& aEngine )

	: iEngine( aEngine )

	, iRequestActive( EFalse )

	{

	}

CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard()

	{

	LOG("CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard begin");

	iImages.ResetAndDestroy();

	iImages.Close();

	iBuffer.Close();

	LOG("CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard end");

	}

void CDirectPrintServerJobGuard::ConstructL()

	{

	}

void CDirectPrintServerJobGuard::PrepareL( TDpMessage& aMessage )

	{

	LOG("CDirectPrintServerJobGuard::PrepareL begin");

	TInt len = aMessage.GetDesLength( 0 );

	HBufC* buf = HBufC::NewLC( len );

	TPtr ptr( buf->Des() );

	aMessage.ReadL( 0, ptr );

	iImages.AppendL( buf );

	CleanupStack::Pop(); // buf

	LOG("CDirectPrintServerJobGuard::PrepareL end");

	}

void CDirectPrintServerJobGuard::Stop()	

	{

	LOG("CDirectPrintServerJobGuard::Stop begin");

	iImages.ResetAndDestroy();

	if( iRequestActive )

		{

		LOG("CDirectPrintServerJobGuard::Stop cancelling...");

		iMessage->Complete( KErrCancel );

		iRequestActive = EFalse;

		}

	LOG("CDirectPrintServerJobGuard::Stop end");

	}

TInt CDirectPrintServerJobGuard::CreateL( TDpMessage& aMessage )

	{

	LOG("CDirectPrintServerJobGuard::CreateL begin");

	iRequestActive = EFalse;

	iBuffer.Reset();

	TInt printer = aMessage.Int0();

	TInt err = iEngine.CreatePrintJobL( printer, iImages, *this );

	LOG1("CDirectPrintServerJobGuard::CreateL err: %d", err);

	if( err )

		{

		iImages.ResetAndDestroy();

		}

	LOG1("CDirectPrintServerJobGuard::CreateL return: %d", err);

	return err;

	}

void CDirectPrintServerJobGuard::ContinueCreateL( TDpMessage& aMessage )

	{

	LOG("CDirectPrintServerJobGuard::ContinueCreateL begin");

	if( iMessage ) iMessage->SetDisposable( ETrue );

	iMessage = &aMessage;

	iRequestActive = ETrue;

	if( iBuffer.Count() )

		{

		LOG("CDirectPrintServerJobGuard::ContinueCreateL before ProcessL");

		Process();

		LOG("CDirectPrintServerJobGuard::ContinueCreateL after ProcessL");

		}

	LOG("CDirectPrintServerJobGuard::ContinueCreateL end");

	}

void CDirectPrintServerJobGuard::PrintJobProgressEvent(TInt aStatus, TInt aPercentCompletion, TInt aJobStateCode)

	{

	LOG("CDirectPrintServerJobGuard::PrintJobProgressEvent begin");

	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aStatus: %d", aStatus);

	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aPercentCompletion: %d", aPercentCompletion);

	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aJobStateCode: %d", aJobStateCode);

	TDirectPrintJobGuardData data;

	data.iCb = TDirectPrintJobGuardData::EProgressEventCb;

	data.iStatus = aStatus;

	data.iPercentCompletion = aPercentCompletion;

	data.iJobStateCode = aJobStateCode;

	TRAPD( err, DoPreProcessL( data ) );

	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent DoPreProcessL's TRAP err: %d", err);

	Process( err );

	LOG("CDirectPrintServerJobGuard::PrintJobProgressEvent end");

	}

void CDirectPrintServerJobGuard::PrintJobErrorEvent(TInt aError, TInt aErrorStringCode)

	{

	LOG("CDirectPrintServerJobGuard::PrintJobErrorEvent begin");

	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent aError: %d", aError);

	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent aErrorStringCode: %d", aErrorStringCode);

	TDirectPrintJobGuardData data;

	data.iCb = TDirectPrintJobGuardData::EErrorEventCb;

	data.iError = aError;

	data.iErrorStringCode = aErrorStringCode;

	TRAPD( err, DoPreProcessL( data ) );

	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent DoPreProcessL's TRAP err: %d", err);

	Process( err );

	LOG("CDirectPrintServerJobGuard::PrintJobErrorEvent end");

	}

void CDirectPrintServerJobGuard::PrinterStatusEvent(TInt aError, TInt aErrorStringCode)

	{

	LOG("CDirectPrintServerJobGuard::PrinterStatusEvent begin");

	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent aError: %d", aError);

	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent aErrorStringCode: %d", aErrorStringCode);

	TDirectPrintJobGuardData data;

	data.iCb = TDirectPrintJobGuardData::EStatusEventCb;

	data.iError = aError;

	data.iErrorStringCode = aErrorStringCode;

	TRAPD( err, DoPreProcessL( data ) );

	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent DoPreProcessL's TRAP err: %d", err);

	Process( err );

	LOG("CDirectPrintServerJobGuard::PrinterStatusEvent end");

	}

void CDirectPrintServerJobGuard::PreviewImageEvent(TInt aFsBitmapHandle)

	{

	LOG("CDirectPrintServerJobGuard::PreviewImageEvent begin");

	LOG1("CDirectPrintServerJobGuard::PreviewImageEvent aFsBitmapHandle: %d", aFsBitmapHandle);

	TDirectPrintJobGuardData data;

	data.iCb = TDirectPrintJobGuardData::EImageEventCb;

	data.iFsBitmapHandle = aFsBitmapHandle;

	TRAPD( err, DoPreProcessL( data ) );

	LOG1("CDirectPrintServerJobGuard::PreviewImageEvent DoPreProcessL's TRAP err: %d", err);

	Process( err );

	LOG("CDirectPrintServerJobGuard::PreviewImageEvent end");

	}

void CDirectPrintServerJobGuard::DoPreProcessL( const TDirectPrintJobGuardData& aData )

	{

	LOG("CDirectPrintServerJobGuard::DoPreProcessL begin");

	User::LeaveIfError( iBuffer.Append( aData ) );

	LOG("CDirectPrintServerJobGuard::DoPreProcessL end");

	}

void CDirectPrintServerJobGuard::DoProcessL()

	{

	LOG("CDirectPrintServerJobGuard::ProcessL begin");

	if( iBuffer.Count() && iRequestActive )

		{

		LOG("CDirectPrintServerJobGuard::DoProcessL step 1");

		TPtr8 ptr(reinterpret_cast<TUint8*>(&(iBuffer[0])), sizeof(iBuffer[0]), sizeof(iBuffer[0]));

		LOG("CDirectPrintServerJobGuard::DoProcessL step 2");

		iMessage->WriteL( 0, ptr );

		LOG("CDirectPrintServerJobGuard::DoProcessL step 3");

		iMessage->Complete( KErrNone );

		LOG("CDirectPrintServerJobGuard::DoProcessL step 4");

		iRequestActive = EFalse;

		LOG("CDirectPrintServerJobGuard::DoProcessL step 5");

		iBuffer.Remove( 0 );

		LOG("CDirectPrintServerJobGuard::DoProcessL step 6");

		}	

	LOG("CDirectPrintServerJobGuard::ProcessL end");

	}

void CDirectPrintServerJobGuard::Process( TInt aErr )

	{

	LOG("CDirectPrintServerJobGuard::Process begin");

	if( aErr )

		{

		LOG1("CDirectPrintServerJobGuard::Process aErr: %d", aErr);

		iMessage->Complete( aErr );

		iRequestActive = EFalse;

		}

	else

		{

		LOG("CDirectPrintServerJobGuard::Process calling DoProcessL");

		TRAPD( err, DoProcessL() );

		LOG1("CDirectPrintServerJobGuard::Process DoProcessL's TRAP err: %d", err);

		if( err )

			{

			iMessage->Complete( err );

			iRequestActive = EFalse;

			}

		}

	LOG("CDirectPrintServerJobGuard::Process end");	

	}

// DEPRECATED

void CDirectPrintServerJobGuard::ShowMessageL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )

	{

	}

TBool CDirectPrintServerJobGuard::AskYesNoQuestionL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )

	{

	return EFalse;

	}

const TDesC& CDirectPrintServerJobGuard::AskForInputL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )

	{

	return KNullDesC;

	}

//  End of File