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

//

/** 	@file

	@internalTechnology */

#include <e32base.h>

#include "InputStream.h"

#include "MngChunks.h"

#include "MngPanic.h"

#include "PngLayer.h"

#include "MngPlayer.h"

#include "logger.h"

#include "PngProcessor.h"

/*static*/

CPngProcessor* CPngProcessor::NewL(CMngPlayer& aPlayer)

	{

	CPngProcessor* self=new (ELeave) CPngProcessor(aPlayer);

	return self;

	}

inline

CPngProcessor::CPngProcessor(CMngPlayer& aPlayer):

								CChunkProcessor(aPlayer)

	{

	}

CPngProcessor::~CPngProcessor()

	{

	delete iCurrentLayer;

	Stop();

	}

void CPngProcessor::DoRunL()

	{

	switch (iState)

		{

		case ECreateLayer:

			if (NULL != iCurrentLayer)

				{

				MngPanic(EPanicAlreadyCreated);

				}

			iCurrentLayer = CPngLayer::NewL();

			iState=TState(iState+1);

			// and go further

		case EReadHeader:

			if (iInputStream->DataAvailable() < TMNGChunkHeader::RequiredData() )

				{

				iInputStream->WaitForData(TMNGChunkHeader::RequiredData(), iStatus);

				SetActive();

				break;

				}

			else 

				{

				iCurrentChunkHeader.ReadL(*iInputStream);

				LOG3("Chunk %4s, len=%d", iCurrentChunkHeader.iChunkId.iChunkIdChr, iCurrentChunkHeader.iLength);

				// PNG decoder needs chunk headers, so we go back to the chunk header

				iInputStream->SeekL( iInputStream->Tell() - TMNGChunkHeader::RequiredData() );

				iState=TState(iState+1);

				}

			// go further for reading the chunk body

		case EReadChunk:

			{

			const TInt overallChunkSize=TMNGChunkHeader::RequiredData()+iCurrentChunkHeader.iLength + sizeof(TChunkCrc);

			if (iInputStream->DataAvailable() < overallChunkSize )

				{

				iInputStream->WaitForData(overallChunkSize, iStatus);

				SetActive();

				break;

				}

			else

				{

				switch (iCurrentChunkHeader.iChunkId.iChunkIdInt)

				{

				case KIhdrChunkId:

				case KIendChunkId:

				case KIdatChunkId:

				case KPlteChunkId:

				case KTrnsChunkId:

				case KBkgdChunkId:

				case KPhysChunkId:

					iCurrentLayer->AppendChunkL(iCurrentChunkHeader, *iInputStream);

					break;

				default:

					iInputStream->SeekL( iInputStream->Tell() + overallChunkSize );

				}

				if (iCurrentChunkHeader.iChunkId != KIendChunkId)

					{

					iState = EReadHeader;

					RunAgain();

					}

				else

					{

					iState = ECreateLayer;

					iMngPlayer.AppendObjectL(reinterpret_cast<CMngObject*&>(iCurrentLayer));

					NotifyCaller(KErrNone);

					}

				}

			}

			break;

		default:

			ASSERT(EFalse);

		}

	}

void CPngProcessor::Start(MInputStream& aInputStream, TRequestStatus& aRequest)

	{

	if (NULL != iCallerRequest)

		{

		MngPanic(EPanicAlreadyStarted);

		}

	iCallerRequest	= &aRequest;

	*iCallerRequest	= KRequestPending;

	iInputStream	= &aInputStream;

	iInputStream->AddRef();

	iState = ECreateLayer;

	RunAgain();

	}

TInt CPngProcessor::AddSubProcessor(MChunkProcessor& /*aSubProcessor*/)

	{

	ASSERT(EFalse);

	return KErrNotSupported;

	}

TBool CPngProcessor::OfferChunkType(const TChunkId& aChunkId)

	{

	return (aChunkId == KIhdrChunkId);

	}