/*

* 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: 

*

*/

 /*************************************************************************

 *

 * System Includes

 *

 *************************************************************************/

#include <e32std.h>

#include <e32base.h>

#include <f32file.h>

/*************************************************************************

 *

 * Local Includes

 *

 *************************************************************************/

#include "dataconsumer_file.h"

#include "stat.h"

/*************************************************************************

 *

 * Definitions

 *

 *************************************************************************/

_LIT( KTxtDiskError, "DiskError" );

/*************************************************************************

 *

 * CDataConsumerFile - Construction

 *

 *************************************************************************/

CDataConsumerFile *CDataConsumerFile::NewL()

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CDataConsumerFile::CDataConsumerFile()

	{

	;

	}

void CDataConsumerFile::ConstructL( void ) 

	{

	_LIT(KFileSrvDll, "efsrv.dll");

	_LIT(KFileSeparator, "\\");

	TBuf<8> systemDrive;

	iLock.CreateLocal( EOwnerProcess );

	User::LeaveIfError( iFsSession.Connect( ) );

	TDriveNumber defaultSysDrive(EDriveC);

	RLibrary pluginLibrary;

	TInt pluginErr = pluginLibrary.Load(KFileSrvDll);

	if (pluginErr == KErrNone)

		{

		typedef TDriveNumber(*fun1)();

		fun1 sysdrive;

	#ifdef __EABI__

		sysdrive = (fun1)pluginLibrary.Lookup(336);

	#else

		sysdrive = (fun1)pluginLibrary.Lookup(304);

	#endif

		if(sysdrive!=NULL)

			{

			defaultSysDrive = sysdrive();

			}

		}

	pluginLibrary.Close();

	systemDrive.Append(TDriveUnit(defaultSysDrive).Name());

	systemDrive.Append(KFileSeparator);

	RFile	file;

	TInt err = file.Temp( iFsSession, systemDrive,iFilePath, EFileShareExclusive );

	file.Close( );

	User::LeaveIfError( err );

	}

CDataConsumerFile::~CDataConsumerFile( )

	{

	iLock.Wait( );

		{

		iFsSession.Close();

		iLock.Close( );

		}

	}

/*************************************************************************

 *

 * CDataConsumerFile - Public interface

 *

 *************************************************************************/

/*************************************************************************

 *

 * Delete

 *

 *************************************************************************/

void CDataConsumerFile::Delete( void ) 

	{

	delete this;

	}

/*************************************************************************

 *

 * GetTotalSize

 *

 *************************************************************************/

TInt CDataConsumerFile::GetTotalSize( TInt &aTotalSize )

	{

	TInt	err = KErrNone;

	TInt	size = 0;

	iLock.Wait( );

		{

		RFile	file;

		err = file.Open( iFsSession, iFilePath, EFileRead | EFileStream | EFileShareReadersOnly );

		if( err == KErrNone )

			{

			err = file.Size( size );

			if( err == KErrNone )

				{

				aTotalSize = size;

				}

			file.Close( );

			}

        iLock.Signal( );

		}

	return ( err );

	}

/*************************************************************************

 *

 * AddData

 *

 *************************************************************************/

TInt CDataConsumerFile::AddData( const TDesC8 &aSource )

	{

	TInt	err = KErrNone;

	if( err == KErrNone )

		{

		iLock.Wait( );

			{

			RFile	file;

			TInt	shareMode = EFileWrite | EFileStream | EFileShareExclusive;

			err = file.Open( iFsSession, iFilePath, shareMode );

			if( err == KErrNotFound )

    			{

    			err = file.Create( iFsSession, iFilePath, shareMode );

    			}

			if( err == KErrNone )

				{

				TInt pos = 0;

				err = file.Seek( ESeekEnd, pos );

				if( err == KErrNone )

					{

					err = file.Write( aSource );

					}

				file.Flush( );

				file.Close( );

				}

            if( err != KErrNone )

                {

                err = iFsSession.Delete(iFilePath);

                User::Panic(KTxtDiskError, err);

                }

			iLock.Signal( );

			}

		}

	return ( err );

	}

/*************************************************************************

 *

 * GetData

 *

 *************************************************************************/

TInt CDataConsumerFile::GetData( HBufC8 & )

	{

	return ( KErrNotSupported );

	}

/*************************************************************************

 *

 * SaveData

 *

 *************************************************************************/

TInt CDataConsumerFile::SaveData( const TDesC &filePath )

	{

	TInt	err = KErrNone;

	if( err == KErrNone )

		{

		iLock.Wait( );

			{

				CFileMan *theFile = CFileMan::NewL(iFsSession);

				CleanupStack::PushL(theFile);

				err = theFile->Copy( iFilePath, filePath );

				if( err == KErrNone )

					{

					err = theFile->Delete(iFilePath);	

					}

				CleanupStack::PopAndDestroy();

			iLock.Signal( );

			}

		}

	return ( err );

	}

/*************************************************************************

 *

 * operator const TDesC8&

 *

 *************************************************************************/

CDataConsumerFile::operator const TDesC8&( void ) const

	{

	_LIT8( empty, "" );

	return ( empty );

	}