/*
* Copyright (c) 2006-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:  ?Description
*
*/


// INCLUDE FILES
#include <e32std.h>
#include <s32mem.h>
#include <f32file.h>
#include <caf/caf.h>
#include <caf/caferr.h>
#include <caf/SupplierOutputFile.h>
#include <WmdrmAgent.h>
#include "WmDrmAgentImportfile.h"
#include "logfn.h"

using namespace ContentAccess;

// LOCAL FUNCTION PROTOTYPES
template<class S>
LOCAL_C void PointerArrayResetDestroyAndClose(TAny* aPtr);

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

// -----------------------------------------------------------------------------
// ?function_name ?description.
// ?description
// Returns: ?value_1: ?description
//          ?value_n: ?description_line1
//                    ?description_line2
// -----------------------------------------------------------------------------
//
template<class S>
void PointerArrayResetDestroyAndClose(TAny* aPtr)
    {
    (reinterpret_cast<RPointerArray<S>*>(aPtr))->ResetAndDestroy();
    (reinterpret_cast<RPointerArray<S>*>(aPtr))->Close();
    }

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

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
CWmDrmAgentImportFile* CWmDrmAgentImportFile::NewL(
    const TDesC8& aMimeType,
    const CMetaDataArray& aMetaDataArray,
    const TDesC& aOutputDirectory,
    const TDesC& aSuggestedFileName)
	{
	LOGFN( "CWmDrmAgentImportFile::NewL" );
	CWmDrmAgentImportFile* self=new(ELeave) CWmDrmAgentImportFile(EFalse);
	CleanupStack::PushL(self);
	self->ConstructL(aMimeType, aMetaDataArray, aOutputDirectory,
	    aSuggestedFileName);
	CleanupStack::Pop(self);
	return self;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
CWmDrmAgentImportFile* CWmDrmAgentImportFile::NewL(
    const TDesC8& aMimeType,
    const CMetaDataArray& aMetaDataArray)
	{
	LOGFN( "CWmDrmAgentImportFile::NewL (2)" );
	CWmDrmAgentImportFile* self=new(ELeave) CWmDrmAgentImportFile(EFalse);
	CleanupStack::PushL(self);
	self->ConstructL(aMimeType, aMetaDataArray, KNullDesC(), KNullDesC());
	CleanupStack::Pop(self);
	return self;
	}
	
// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
CWmDrmAgentImportFile::CWmDrmAgentImportFile(
    TBool aAgentCreatesOutputFiles):
    iOutputDirectory(NULL),
    iSuggestedFileName(NULL),
    iOutputFileName(NULL),
    iLastWriteData(NULL),
    iAgentCreatesOutputFiles(aAgentCreatesOutputFiles)
	{
	LOGFN( "CWmDrmAgentImportFile::CWmDrmAgentImportFile" );
	iImportStatus = EInProgress;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
CWmDrmAgentImportFile::~CWmDrmAgentImportFile()
	{
	LOGFN( "CWmDrmAgentImportFile::~CWmDrmAgentImportFile" );
	if (iFileOpen)
		{
		iFile.Close();
		iFileOpen = EFalse;
		}
	iFs.Close();
	delete iOutputDirectory;
	delete iSuggestedFileName;
    delete iOutputFileName;
	delete iLastWriteData;
	iOutputFiles.ResetAndDestroy();
	iOutputFiles.Close();
	}
  
// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::ConstructL(
    const TDesC8& aMimeType,
    const CMetaDataArray& /*aMetaDataArray*/,
    const TDesC& aOutputDirectory,
    const TDesC& aSuggestedFileName)
	{
	LOGFN( "CWmDrmAgentImportFile::ConstructL" );

    iMimeType = aMimeType.AllocL();
	iOutputDirectory = aOutputDirectory.AllocL();
	iSuggestedFileName = aSuggestedFileName.AllocL();
    iOutputFileName = HBufC::NewL(iOutputDirectory->Des().Length() +
                                  iSuggestedFileName->Des().Length());
	iAgentCreatesOutputFiles = ETrue;

	User::LeaveIfError(iFs.Connect());
    User::LeaveIfError(iFs.ShareAuto());
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::OpenOutputFile()
	{
	TInt r = KErrNone;
	TPtr fileNamePtr = iOutputFileName->Des();
	
	fileNamePtr.Copy(*iOutputDirectory);
	fileNamePtr.Append(*iSuggestedFileName);

	r = iFile.Create(iFs, fileNamePtr, EFileShareReadersOrWriters  | EFileStream |
	    EFileWrite);
	if (r == KErrNone)
		{
		iFileOpen = ETrue;
		}
    else
        {
        r = KErrCANewFileHandleRequired;
        }
    return r;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::WriteDataL( const TDesC8& aData )
    {
    LOGFN( "CWmDrmAgentImportFile::WriteDataL" );
    TInt err = KErrNone;
    
    if( !iFileOpen ) 
        {
        err = OpenOutputFile();
        if( err )
            {
            User::Leave(KErrCANewFileHandleRequired);
            }
        }
    User::LeaveIfError( iFile.Write( aData ) );        
    }
    
// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::WriteData(const TDesC8& aData)
	{
	LOGFN( "CWmDrmAgentImportFile::WriteData" );
	TInt r = KErrNone;
	TRAP(r, WriteDataL(aData));
	return r;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::WriteDataComplete()
	{
	LOGFN( "CWmDrmAgentImportFile::WriteDataComplete" );
    TInt r = KErrNone;
    CSupplierOutputFile *temp = NULL;
    
    if( iFileOpen )
        {
        iFile.Close();
        iFileOpen = EFalse;
        }

    if( iOutputFileName )
        {
        TRAP(r, temp = CSupplierOutputFile::NewL( iOutputFileName->Des(), EContent, iMimeType->Des()));
        if( r == KErrNone )
            {
            r = iOutputFiles.Append(temp);
            if( r != KErrNone )
                {
                delete temp;
                }
            }
        }
	return r;
	}
		
// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::WriteData(
    const TDesC8& aData,
    TRequestStatus &aStatus)
	{
	LOGFN( "CWmDrmAgentImportFile::WriteData" );
	TRequestStatus *ptr = &aStatus;
	TInt r = WriteData(aData);
	User::RequestComplete(ptr,r);
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::WriteDataComplete(
    TRequestStatus &aStatus)
	{
	LOGFN( "CWmDrmAgentImportFile::WriteDataComplete" );
	TRequestStatus *ptr = &aStatus;
	TInt r = WriteDataComplete();
	User::RequestComplete(ptr,r);
	}
	
// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::OutputFileCountL() const
	{
	LOGFN( "CWmDrmAgentImportFile::OutputFileCountL" );
	return iOutputFiles.Count();
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
CSupplierOutputFile& CWmDrmAgentImportFile::OutputFileL(
    TInt aIndex)
	{
	LOGFN( "CWmDrmAgentImportFile::OutputFileL" );
	return *iOutputFiles[aIndex];
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TImportStatus CWmDrmAgentImportFile::GetImportStatus() const
	{
	LOGFN( "CWmDrmAgentImportFile::GetImportStatus" );
	return iImportStatus;
	}	

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::GetSuggestedOutputFileExtension(
    TDes& /*aFileExtension*/)
	{
	LOGFN( "CWmDrmAgentImportFile::GetSuggestedOutputFileExtension" );
    return KErrNotSupported;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::GetSuggestedOutputFileName(
    TDes& /*aFileName*/)
	{
	LOGFN( "CWmDrmAgentImportFile::GetSuggestedOutputFileName" );
	return KErrNotSupported;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
TInt CWmDrmAgentImportFile::ContinueWithNewOutputFile(
    RFile& aFile,
    const TDesC& aFileName)
	{
	RFile file;
	TInt r = KErrNone;
	LOGFN( "CWmDrmAgentImportFile::ContinueWithNewOutputFile" );

	if (iOutputFileName != NULL)
	    {
	    delete iOutputFileName;
	    iOutputFileName = NULL;
	    }
	    
	TRAP(r, iOutputFileName = aFileName.AllocL());
	
	if (r == KErrNone)
	    {
	    iFile.Close();
	    iFile.Duplicate(aFile);
        iFileOpen = ETrue;
	    }
	return r;
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::ContinueWithNewOutputFile(
    RFile& aFile,
    const TDesC& aFileName,
    TRequestStatus& aStatus)
	{
	LOGFN( "CWmDrmAgentImportFile::ContinueWithNewOutputFile (2)" );
	TRequestStatus *ptr = &aStatus;
	TInt r = ContinueWithNewOutputFile(aFile, aFileName);
	User::RequestComplete(ptr,r);
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::NewMimePartL(
    const TDesC8& /*aMimeType*/,
    const CMetaDataArray& /*aImportMetaData*/)
	{
	LOGFN( "CWmDrmAgentImportFile::NewMimePartL" );
	User::Leave(KErrCANotSupported);
	}

// -----------------------------------------------------------------------------
// CWmDrmAgentImportFile::
// 
// -----------------------------------------------------------------------------
//
void CWmDrmAgentImportFile::EndMimePartL()
	{
	LOGFN( "CWmDrmAgentImportFile::EndMimePartL" );
	User::Leave(KErrCANotSupported);
	}

// End of file