/*
* Copyright (c) 2002-2006 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:  Service implementation class
*
*/



// INCLUDE FILES
#include    "RNewFileServiceClient.h"
#include    "NewFileServiceDefs.h"
#include    "cnewfileserviceserverobserver.h"
#include <NewFileServiceClient.h>

#include <s32mem.h>


// ============================ MEMBER FUNCTIONS =============================

// ---------------------------------------------------------------------------
// RNewFileServiceClient::RNewFileServiceClient
// C++ default constructor can NOT contain any code, that
// might leave.
// ---------------------------------------------------------------------------
//
RNewFileServiceClient::RNewFileServiceClient()
    {
    }


// ---------------------------------------------------------------------------
// RNewFileServiceClient::~RNewFileServiceClient
// Destructor
// ---------------------------------------------------------------------------
//
RNewFileServiceClient::~RNewFileServiceClient()
    {
    delete iObserver;
    
    if ( iWait.IsStarted() )
        {
        iWait.AsyncStop();
        }

    }


// ---------------------------------------------------------------------------
// RNewFileServiceClient::ServiceUid
// 
// ---------------------------------------------------------------------------
//
TUid RNewFileServiceClient::ServiceUid() const
	{
	return TUid::Uid( NEWSERVICEUID );

	}


// ---------------------------------------------------------------------------
// RNewFileServiceClient::NewFileL
// 
// ---------------------------------------------------------------------------
//
TBool RNewFileServiceClient::NewFileL( RFile& aFile, TDesC8* aGenericParams,
													TNewServiceFileType aType )
	{
	TIpcArgs args;

	TNewServiceParamPack pack;
	pack.iType = aType;
	pack.iMultipleFiles = EFalse;

	TPckgBuf< TNewServiceParamPack > paramPack;
	paramPack = pack;
	args.Set( 0, &paramPack );


	if ( aGenericParams )
	{
		args.Set( ENewServiceIndexFileName, aGenericParams );
	}

	TInt err = aFile.TransferToServer( args, ENewServiceIndexFsHandle,
	                                   ENewServiceIndexFileHandle );
#ifdef _DEBUG	
	RDebug::Print( _L("transfer to server error: %d"), err );
#endif	

    iObserver = CNewFileServiceServerObserver::NewL();

  	// Send through IPC, pass iObservers TRequestStatus to server
	SendReceive( ENewFileToHandle, args, iObserver->IssueWait( this ) );

    // Wait until server notifies iObserver
    if ( !iWait.IsStarted() )
        {
        iWait.Start(); // CSI: 10 #
        }

	return paramPack().iReturnValue;
	}


// ---------------------------------------------------------------------------
// RNewFileServiceClient::NewFileL
// 
// ---------------------------------------------------------------------------
//
TBool RNewFileServiceClient::NewFileL( CDesCArray& aFilenames, 
									   TDesC8* aGenericParams,
									   TNewServiceFileType aType, 
									   TBool aMultipleFiles )
	{
#ifdef _DEBUG	
	RDebug::Print( _L("RNewFileServiceClient::NewFileL") );
#endif

	TIpcArgs args;

	TNewServiceParamPack pack;
	pack.iType = aType;
	pack.iMultipleFiles = aMultipleFiles;

	TPckgBuf< TNewServiceParamPack > paramPack = pack;
	args.Set( ENewServiceIndexParams, &paramPack );

	if ( aGenericParams )
	{
		args.Set( ENewServiceIndexFileName, aGenericParams );
	}
	else
	{
		args.Set( ENewServiceIndexFileName, &KNullDesC() );
	}

    iObserver = CNewFileServiceServerObserver::NewL();

	// Send through IPC, pass iObservers TRequestStatus to server
	SendReceive( ECreateNewFile, args, iObserver->IssueWait( this )  );

    // Wait until server notifies iObserver
    if ( !iWait.IsStarted() )
        {
        iWait.Start(); // CSI: 10 #
        }

	pack = paramPack();

	if ( !pack.iReturnValue )
		{
#ifdef _DEBUG
		RDebug::Print( _L("RNewFileServiceClient::NewFileL - return value received: False") );
#endif	
		// don't bother with filename array if the user canceled	
		return EFalse;		
		}

#ifdef _DEBUG
	RDebug::Print( _L("RNewFileServiceClient::NewFileL - return value received: True") );
#endif	

	TPckgBuf< TInt > lengthBuf;
	args.Set( ENewServiceIndexParams, &lengthBuf );
	User::LeaveIfError( SendReceive( EGetFilenameArrayLength, args ) );

	TInt length( lengthBuf() );

	HBufC8* buffer = HBufC8::NewLC( length );
	TPtr8 ptr = buffer->Des();
	args.Set( ENewServiceIndexParams, &ptr );
	User::LeaveIfError( SendReceive( EGetFilenameArray, args ) );

	// Unpack filename array
	RDesReadStream stream;
	stream.Open( ptr );

	TInt count( stream.ReadInt32L() );

	for ( TInt i( 0 ); i < count; i++ )
		{
		TInt length( stream.ReadInt16L() );
		TFileName filename;
		stream.ReadL( filename, length );
#ifdef _DEBUG
		RDebug::Print( filename );
#endif		
		aFilenames.AppendL( filename );
		}

	CleanupStack::PopAndDestroy(); // buffer


	return ETrue;
	}


// ----------------------------------------------------------------------------
// RNewFileServiceClient::ServerRequestReady
// 
// ----------------------------------------------------------------------------
//
void RNewFileServiceClient::ServerRequestReady( TInt aError )
    {

    if (aError == KErrAbort)
    	{
    		iError = KErrAbort;
    	}
    // Server processed command and active object was notified and
    // client can continue now
    if ( iWait.IsStarted() )
        {
        iWait.AsyncStop();
        }
    }


void RNewFileServiceClient::SetFileServiceClient(CNewFileServiceClient* aClient)
	{
	iNewFileServiceClient = aClient;	
	}


//  End of File