/*
* Copyright (c) 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:  WMDRM Fileserver Client implementation
*
*/


#include "wmdrmfileserverclient.h"
#include "wmdrmfsclientserver.h"

//#define _LOGGING_FILE L"wmdrmfileserver.txt"

//#include "logfn.h"

// Message slots a client can have open: taken from the global slot pool
const TInt KServerDefaultMessageSlots = -1;

// Number of times the server is attempted to start if it is not running
const TInt KServerRetryCount = 3;

// ======== LOCAL FUNCTIONS ========

// ---------------------------------------------------------------------------
// Try to start the server if it is not running
// ---------------------------------------------------------------------------
//
static TInt StartServer()
	{
	RProcess server;
	TInt r = server.Create( KWmDrmFileServerImg, KNullDesC );
	if ( r != KErrNone )
		return r;
	TRequestStatus stat;
	server.Rendezvous( stat );
	if ( stat != KRequestPending )
	    {
		server.Kill( 0 );
		}
	else
	    {
		server.Resume();
		}
	User::WaitForRequest( stat );
	r = ( server.ExitType() == EExitPanic ) ? KErrGeneral : stat.Int();
	server.Close();
	return r;
	}

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

EXPORT_C TInt RWmDrmFileServerClient::Open( const TDesC& aFilename )
    {
    TInt r = KErrNone;

    //LOGFNR( "RWmDrmFileServerClient::Open", r );
    r = SendReceive( EFsOpen, TIpcArgs( &aFilename ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Create( const TDesC& aFilename )
    {
    TInt r = KErrNone;

    //LOGFNR( "RWmDrmFileServerClient::Create", r );
    r = SendReceive( EFsCreate, TIpcArgs( &aFilename ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Read( TDes8& aBuffer )
    {
    TInt r = KErrNone;
    TInt amountRead;
    TPckg<TInt> amountPckg( amountRead );

    //LOGFNR( "RWmDrmFileServerClient::Read", r );
    r = SendReceive( EFsRead, TIpcArgs( &aBuffer, &amountPckg ) );
    if ( r == KErrNone )
        {
        aBuffer.SetLength( amountRead );
        }
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Write( const TDesC8& aBuffer )
    {
    TInt r = KErrNone;

    //LOGFNR( "RWmDrmFileServerClient::Write", r );
    r = SendReceive( EFsWrite, TIpcArgs( &aBuffer ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Size( TInt& aSize )
    {
    TInt r = KErrNone;
    TPckg<TInt> sizePckg( aSize );

    //LOGFNR( "RWmDrmFileServerClient::Size", r );
    r = SendReceive( EFsSize, TIpcArgs( &sizePckg ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Delete( const TDesC& aFilename )
    {
    TInt r = KErrNone;

    //LOGFNR( "RWmDrmFileServerClient::Delete", r );
    r = SendReceive( EFsDelete, TIpcArgs( &aFilename ) );
    return r;
    }

EXPORT_C TBool RWmDrmFileServerClient::IsOpen()
    {
    TInt r = KErrNone;

    //LOGFNR( "RWmDrmFileServerClient::IsOpen", r );
    r = SendReceive( EFsIsOpen );
    return (r == KErrNone ? ETrue : EFalse);
    }

EXPORT_C void RWmDrmFileServerClient::CloseFile()
    {
    //LOGFN( "RWmDrmFileServerClient::CloseFile" );
    SendReceive( EFsCloseFile );
    }

EXPORT_C TInt RWmDrmFileServerClient::MkDirAll( const TDesC& aPath, TBool aCreateIfMissing )
    {
    TInt r = KErrNone;
    
    //LOGFNR( "RWmDrmFileServerClient::MkDirAll", r );
    r = SendReceive( EFsMkDirAll, TIpcArgs( &aPath, aCreateIfMissing ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::RmDirAll( const TDesC& aPath )
    {
    TInt r = KErrNone;
    
    //LOGFNR( "RWmDrmFileServerClient::RmDirAll", r );
    r = SendReceive( EFsRmDirAll, TIpcArgs( &aPath ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::RmDir( const TDesC& aPath )
    {
    TInt r = KErrNone;
    
    //LOGFNR( "RWmDrmFileServerClient::RmDir", r );
    r = SendReceive( EFsRmDir, TIpcArgs( &aPath ) );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::DeleteRights()
    {
    TInt r = KErrNone;
    
    //LOGFNR( "RWmDrmFileServerClient::DeleteRights", r );
    r = SendReceive( EFsDeleteRights );
    return r;
    }

EXPORT_C TInt RWmDrmFileServerClient::Connect()
	{
	TInt r = KErrNone;
	
	//LOGFNR( "RWmDrmFileServerClient::Connect", r );
	TInt retry = KServerRetryCount;
	for ( ;; )
		{
		r = CreateSession( KWmDrmFileServerName, TVersion( 0, 0, 0 ), KServerDefaultMessageSlots );
		if ( r != KErrNotFound && r != KErrServerTerminated )
		    {
			return r;
			}
		if ( --retry == 0 )
		    {
			return r;
			}
		r = StartServer();
		if ( r != KErrNone && r != KErrAlreadyExists )
		    {
			return r;
			}
		}
	}


EXPORT_C TInt RWmDrmFileServerClient::UpdateSecureTime( TTime& aHomeTime, TTime& aUTCTime )
    {
    TInt r = KErrNone;
    TPckg<TTime> homeTime( aHomeTime );
    TPckg<TTime> utcTime( aUTCTime );
    
    //LOGFNR( "RWmDrmFileServerClient::UpdateSecureTime", r );
    r = SendReceive( EFsUpdateSecureTime, TIpcArgs( &homeTime, &utcTime ) );
    return r;    
    }