/*
* Copyright (c) 2004-2007 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 "cfilemanager.h"
#include "rsutils.h"
#include "clog.h"

//  CONSTANTS
namespace
	{
	const TInt KBufferSize = 1000;
	}
	
#define USE_CFILEMAN_FIRST	

CFileManager* CFileManager::NewL( RFs& aFs )
    {	
	CFileManager* self = new ( ELeave ) CFileManager( aFs );
    CleanupStack::PushL( self );
    self->ConstructL();
	CleanupStack::Pop();    // self
    return self;
    }

CFileManager::CFileManager( RFs& aFs ) : CActive( CActive::EPriorityHigh ),
										iFs( aFs ),
										iBuffer( NULL )
										
    {
    CActiveScheduler::Add( this );
    }

CFileManager::~CFileManager()
    {
    Cancel(); 
    CloseCopy();
    if(iBuffer)
    {
    	delete iBuffer;
    	iBuffer = NULL;    	
    }
    delete iFileMan; 
    }

void CFileManager::ConstructL()
    {
    iFileMan = CFileMan::NewL( iFs );
    }
	
	
TInt CFileManager::Copy( const TDesC& aFile, const TDesC& aDir, TRequestStatus& aStatus )
	{	
	LOG( "CFileManager::Copy begin" );
	Cancel();
	CloseCopy();
	iCallerStatus = &aStatus;
	TInt err( KErrNone );
#ifdef USE_CFILEMAN_FIRST
	// check if file is used by another application
	err = iSource.Open( iFs, aFile, EFileRead | EFileShareReadersOnly );
	LOG1("CFileManager::Copy check err: %d", err);
	iSource.Close();
	if( !err )
		{
		err = iFileMan->Copy( aFile, aDir, CFileMan::EOverWrite, iStatus );
		LOG1("CFileManager::Copy iFileMan->Copy err: %d", err);
		if( !err )
			{
			iOperation = EFileManCopy;
			SetActive();				
			}					
		}
	else
#endif	
		{
		iOperation = EBufferCopy;
		TRAP( err, InitCopyL( aFile, aDir ) );
		LOG1( "CFileManager::Copy InitCopyL err: %d", err );
		if( err )
			{
			CloseCopy();
			}
		else
			{
			TPtr8 ptr = iBuffer->Des();
			LOG1( "CFileManager::Copy iBytesNum: %d", iBytesNum );
			iSource.Read( ptr, iBytesNum, iStatus );
			LOG( "CFileManager::Copy call to SetActive()" );
			SetActive();	
			}	
		}	
	LOG1( "CFileManager::Copy end with: %d", err );
	return err;
	}

	
void CFileManager::DoCancel()
	{
	LOG( "CFileManager::DoCancel begin" );
	CloseCopy();
	LOG( "CFileManager::DoCancel end" );	
	}

void CFileManager::RunL()
	{
	LOG1( "CFileManager::RunL iStatus: %d", iStatus.Int() );
	LOG1( "CFileManager::RunL iOperation: %d", iOperation );
	
	if( iStatus == KErrNone )	
		{
		switch( iOperation )
			{
			case ERemoveDir:
				{
				LOG( "CFileManager::RunL directory removed" );
				User::RequestComplete( iCallerStatus, iStatus.Int() );
				}
				break;				
			case EFileManCopy:
				{
				LOG( "CFileManager::RunL file copied" );
				User::RequestComplete( iCallerStatus, iStatus.Int() );
				}
				break;				
			case EBufferCopy:
				{
				TPtr8 ptr = iBuffer->Des();
				LOG( "CFileManager::RunL call to RFile::Write()" );
				User::LeaveIfError( iDest.Write( ptr, iBytesNum ) );
				iBytesLeft -= iBytesNum;
				if( iBytesLeft )
					{
					iBytesNum = ( KBufferSize < iBytesLeft ) ? KBufferSize : iBytesLeft;
					LOG1( "CFileManager::RunL iBytesLeft: %d", iBytesLeft );
					iSource.Read( ptr, iBytesNum, iStatus );
					SetActive();	
					}
				else
					{
					User::LeaveIfError( iDest.Flush() );
					CloseCopy();
					LOG( "CFileManager::RunL file copied" );
					User::RequestComplete( iCallerStatus, iStatus.Int() );	
					}	
				}
				break;				
			default:
				break;
			}						
		}
	else
		{
		CloseCopy();
		User::RequestComplete( iCallerStatus, iStatus.Int() );	
		}
	}
	
TInt CFileManager::RunError( TInt aError )
	{
	LOG1( "CFileManager::RunError aError: %d", aError );
	return KErrNone;	
	}
	
void CFileManager::CloseCopy()
	{
	LOG( "CFileManager::CloseCopy begin" );
	iSource.Close();
	iDest.Close();
	delete iBuffer;
	iBuffer = NULL;	
	iBytesLeft = 0;
	iBytesNum = 0;
	LOG( "CFileManager::CloseCopy end" );	
	}
	
void CFileManager::InitCopyL( const TDesC& aFile, const TDesC& aDir )		
	{
	LOG( "CFileManager::InitCopyL begin" );		
	TInt err = iSource.Open( iFs, aFile, EFileRead | EFileShareReadersOnly );
	LOG1("CFileManager::InitCopyL file.Open (shareread mode): %d", err);
	if ( err != KErrNone )
		{
		err = iSource.Open( iFs, aFile, EFileRead | EFileShareAny );
		LOG1("CFileManager::InitCopyL file.Open (shareany mode): %d", err);
		}
	User::LeaveIfError( err );
	
	TParsePtrC parse( aFile );
	TFileName writeFileName( aDir );
	writeFileName.Append( parse.NameAndExt() );	
	User::LeaveIfError( iDest.Replace( iFs, writeFileName, EFileWrite ) );
	iBuffer = HBufC8::NewL( KBufferSize );
	User::LeaveIfError( iSource.Size( iBytesLeft ) );
	LOG1( "CFileManager::InitCopyL file size: %d", iBytesLeft );
	iBytesNum = ( KBufferSize < iBytesLeft ) ? KBufferSize : iBytesLeft;
	LOG( "CFileManager::InitCopyL end" );	
	}

void CFileManager::CancelCopy()
	{
	LOG("CFileManager::CancelCopy begin");
	if( IsActive() )
		{
		Cancel();
		User::RequestComplete( iCallerStatus, KErrCancel );
		}
	LOG("CFileManager::CancelCopy end");
	}
	
void CFileManager::CancelRmDir()
	{
	LOG("CFileManager::CancelRmDir begin");
	if( IsActive() )
		{
		Cancel();
		User::RequestComplete( iCallerStatus, KErrCancel );
		}
	LOG("CFileManager::CancelRmDir end");
	}
								
TInt CFileManager::RmDir( const TDesC& aDir, TRequestStatus& aStatus )
	{
	LOG1("CFileManager::RmDir aDir: %S", &aDir);
	TInt err( KErrNone );
	Cancel();
	iCallerStatus = &aStatus;
	if( RsUtils::PathExists( aDir, iFs ) )
		{
		err = iFileMan->RmDir( aDir, iStatus );
		iOperation = ERemoveDir;				
		if( !err ) SetActive();
		}
	else
		{
		User::RequestComplete( iCallerStatus, KErrNone );
		}			
	LOG1("CFileManager::RmDir return: %d", err);
	return err;
	}

//  End of File