// Copyright (c) 1995-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 <s32file.h>
#include <fbs.h>
#include <bitmap.h>
#include <graphics/bitmapuid.h>
#include "fbsbitmapasyncstreamer.h"

CFbsBitmapAsyncStreamer::CFbsBitmapAsyncStreamer(TMode aMode):
	CBase(),
	iFbs(RFbsSession::GetSession()),
	iMode(aMode)
	{}

EXPORT_C CFbsBitmapAsyncStreamer::~CFbsBitmapAsyncStreamer()
	{
	iReadStream.Close();
	iWriteStream.Close();
	delete iStore;
	if(iMode==ELoad) delete iBitmap;
	}

EXPORT_C CFbsBitmapAsyncStreamer* CFbsBitmapAsyncStreamer::NewL(TMode aMode)
	{
	CFbsBitmapAsyncStreamer* thisptr=new(ELeave) CFbsBitmapAsyncStreamer(aMode);
	CleanupStack::PushL(thisptr);
	thisptr->ConstructL();
	CleanupStack::Pop();
	return(thisptr);
	}

void CFbsBitmapAsyncStreamer::ConstructL()
	{
	if(iMode==ELoad) iBitmap=new(ELeave) CFbsBitmap;
	}

EXPORT_C TInt CFbsBitmapAsyncStreamer::Load(const TDesC& aFilename,TInt32 aId,TInt& aScanLines)
	{
	if(iMode!=ELoad) return(KErrGeneral);

	TRAPD(ret,DoLoadL(aFilename,aId));
	if(ret!=KErrNone) return(ret);

	iDispMode = CBitwiseBitmap::DisplayMode(iHeader.iBitsPerPixel,iHeader.iColor);

	ret=iBitmap->Create(iHeader.iSizeInPixels,iDispMode);
	iBitmap->BeginDataAccess();
	iBitmap->Address()->iHeader=iHeader;
	if(ret!=KErrNone) return(ret);

	aScanLines=iHeader.iSizeInPixels.iHeight;
	iScanLineBase=(TUint32*)iBitmap->DataAddress();
	return(KErrNone);
	}

void CFbsBitmapAsyncStreamer::DoLoadL(const TDesC& aFilename,TInt32 aId)
	{
	iStore=CDirectFileStore::OpenL(iFbs->FileServer(),aFilename,EFileShareReadersOnly);
	if (iStore->Type()[1]!=KMultiBitmapFileImageUid)
		User::LeaveIfError(KErrGeneral);
	TStreamId streamid=iStore->Root();
	RStoreReadStream readstream;
	readstream.OpenL(*iStore,streamid);
	TInt numbitmaps=readstream.ReadInt32L();
	if(numbitmaps<aId+1)
		User::Leave(KErrUnknown);
	TStreamId bmpstreamid;
	bmpstreamid.InternalizeL(readstream);
	for(TInt count=0;count<aId;count++)
		bmpstreamid.InternalizeL(readstream);
	readstream.Close();
	iReadStream.OpenL(*iStore,bmpstreamid);
	CBitwiseBitmap::InternalizeHeaderL(iReadStream,iHeader);
	}

EXPORT_C TBool CFbsBitmapAsyncStreamer::LoadScanLinesL(TInt aNumberOfScanLines,CFbsBitmap*& aBitmap)
	{
	if(iMode!=ELoad || iBitmap==NULL) User::Leave(KErrGeneral);
	if(iHeader.iCompression!=ENoBitmapCompression)
		{
		TRAP_IGNORE(iBitmap->Address()->DoInternalizeL(iReadStream,iHeader.iBitmapSize-iHeader.iStructSize,iBitmap->DataAddress()));
		iBitmap->EndDataAccess(EFalse);
		aBitmap=iBitmap;
		iBitmap=NULL;
		return(ETrue);
		}
	aNumberOfScanLines=Abs(aNumberOfScanLines);
	if(aNumberOfScanLines+iCurrentScanLine>iHeader.iSizeInPixels.iHeight)
		aNumberOfScanLines=iHeader.iSizeInPixels.iHeight-iCurrentScanLine;
	TInt slbytes = CBitwiseBitmap::ByteWidth(iHeader.iSizeInPixels.iWidth,iDispMode);
	TUint8* sladd=(TUint8*)iBitmap->Address()->ScanLineAddress(iScanLineBase,iCurrentScanLine);
	iReadStream.ReadL(sladd,aNumberOfScanLines*slbytes);
	iCurrentScanLine+=aNumberOfScanLines;
	if(iCurrentScanLine==iHeader.iSizeInPixels.iHeight)
		{
		iBitmap->EndDataAccess(EFalse);
		aBitmap=iBitmap;
		iBitmap=NULL;
		return(ETrue);
		}
	return(EFalse);
	}

EXPORT_C TInt CFbsBitmapAsyncStreamer::Save(const TDesC& aFilename,CFbsBitmap* aBitmap,TInt32& aId,TInt& aScanLines)
	{
	if(iMode!=ESave || aBitmap==NULL || !aBitmap->iHandle) return(KErrGeneral);
	RFile file;
	TInt ret=file.Replace(iFbs->FileServer(),aFilename,EFileWrite);
	if(ret!=KErrNone) return(ret);
	iHeader=aBitmap->Header();

	iDispMode = CBitwiseBitmap::DisplayMode(iHeader.iBitsPerPixel,iHeader.iColor);

	TRAP(ret,DoSaveL(file));
	if(ret!=KErrNone) return(ret);
	aId=0;
	iBitmap=aBitmap;
	iBitmap->BeginDataAccess();
	aScanLines=iHeader.iSizeInPixels.iHeight;
	iScanLineBase=(TUint32*)aBitmap->DataAddress();
	return(KErrNone);
	}

void CFbsBitmapAsyncStreamer::DoSaveL(RFile& aFile)
	{
	iStore=CDirectFileStore::NewL(aFile);
	TUidType uidtype(KDirectFileStoreLayoutUid,KMultiBitmapFileImageUid);
	iStore->SetTypeL(uidtype);
	iId=iWriteStream.CreateL(*iStore);
	iWriteStream.WriteInt32L(iHeader.iBitmapSize);
	iWriteStream.WriteInt32L(iHeader.iStructSize);
	iWriteStream.WriteInt32L(iHeader.iSizeInPixels.iWidth);
	iWriteStream.WriteInt32L(iHeader.iSizeInPixels.iHeight);
	iWriteStream.WriteInt32L(iHeader.iSizeInTwips.iWidth);
	iWriteStream.WriteInt32L(iHeader.iSizeInTwips.iHeight);
	iWriteStream.WriteInt32L(iHeader.iBitsPerPixel);
	iWriteStream.WriteUint32L(iHeader.iColor);
	iWriteStream.WriteInt32L(0);
	iWriteStream.WriteUint32L(iHeader.iCompression);
	}

EXPORT_C TBool CFbsBitmapAsyncStreamer::SaveScanLinesL(TInt aNumberOfScanLines)
	{
	if(iMode!=ESave || iBitmap==NULL) User::Leave(KErrGeneral);
	aNumberOfScanLines=Abs(aNumberOfScanLines);
	if(aNumberOfScanLines+iCurrentScanLine>iHeader.iSizeInPixels.iHeight)
		aNumberOfScanLines=iHeader.iSizeInPixels.iHeight-iCurrentScanLine;
	TInt slbytes = CBitwiseBitmap::ByteWidth(iHeader.iSizeInPixels.iWidth,iDispMode);
	TUint8* sladd=(TUint8*)iBitmap->Address()->ScanLineAddress(iScanLineBase,iCurrentScanLine);
	iWriteStream.WriteL(sladd,aNumberOfScanLines*slbytes);
	iCurrentScanLine+=aNumberOfScanLines;
	if(iCurrentScanLine==iHeader.iSizeInPixels.iHeight)
		{
		iBitmap->EndDataAccess(ETrue);
		iWriteStream.Close();
		TStreamId headstreamid=iWriteStream.CreateL(*iStore);
		iWriteStream.WriteInt32L(1); // number of bitmaps
		iId.ExternalizeL(iWriteStream); // stream id of bitmap
		iWriteStream.Close();
		iStore->SetRootL(headstreamid);
		delete iStore;
		iStore=NULL;
		return(ETrue);
		}
	return(EFalse);
	}