/*

* Copyright (c) 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:  Imports a m3u playlist file

*

*/

// INCLUDE FILES

#include <bautils.h>

#include <utf.h>

#include <charconv.h>

#include <mpxlog.h>

#include <mpxmediaarray.h>

#include <mpxattribute.h>

#include <mpxmediageneraldefs.h>

#include <mpxmediacontainerdefs.h>

#include "mpxm3uplaylistdefs.h"

#include "mpxm3uplaylistimporter.h"

// ============================ CONSTANTS ==============================

const TUint KUnicodeBOM = 0xFEFF;

const TInt KMinimumConfidenceRequired = 60;

const TInt KPathStartingChars = 3;

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

// ----------------------------------------------------------------------------

// ----------------------------------------------------------------------------

EXPORT_C CMPXM3uPlaylistImporter::CMPXM3uPlaylistImporter(

            RFs* aFs,

            MMPXPlaylistPluginObserver* aObserver,

            const CArrayFix<CCnvCharacterSetConverter::SCharacterSet>& aTopCharacterSet,

            const CArrayFix<CCnvCharacterSetConverter::SCharacterSet>& aAvailableCharacterSet,

            TRequestStatus& aStatus ) :

    CActive( EPriorityStandard ),

    iFs( aFs ),

    iObserver( aObserver ),

    iCallerStatus( &aStatus ),

    iEndLineNumber( KMPXM3UNumOfLinesToProcess ),

    iCurrentLineNumber( 0 ),

    iMoreToDo( ETrue ),

    iEndOfFile( EFalse ),

    iAutoEncodingInvalidItems( 0 ),

    iState( EMPXM3UReadBufferWithAutoDetectEncoding ),

    iTopCharacterSet( aTopCharacterSet ),

    iAvailableCharacterSet( aAvailableCharacterSet )

    {

    CActiveScheduler::Add( this );

    }

// ----------------------------------------------------------------------------

// 2nd phase constructor

// ----------------------------------------------------------------------------

EXPORT_C void CMPXM3uPlaylistImporter::ConstructL( const TDesC& aPlaylistUri )

    {

    MPX_DEBUG2("CMPXM3uPlaylistImporter::ConstructL(%S) entering", &aPlaylistUri);

    __ASSERT_DEBUG(aPlaylistUri.Length() != 0, User::Leave(KErrArgument));

    iPlaylistFilePath.Set(aPlaylistUri);

    iAutoEncodingPlaylistArray = CMPXMediaArray::NewL();

    *iCallerStatus = KRequestPending;

    TRequestStatus* status = &iStatus;

    *status = KRequestPending;

    SetActive();

    MPX_DEBUG1("CMPXM3uPlaylistImporter::ConstructL() exiting");

    }

// ----------------------------------------------------------------------------

// ----------------------------------------------------------------------------

EXPORT_C CMPXM3uPlaylistImporter* CMPXM3uPlaylistImporter::NewL(

            RFs* aFs,

            MMPXPlaylistPluginObserver* aObserver,

            const TDesC& aPlaylistUri,

            const CArrayFix<CCnvCharacterSetConverter::SCharacterSet>& aTopCharacterSet,

            const CArrayFix<CCnvCharacterSetConverter::SCharacterSet>& aAvailableCharacterSet,

    {

    CMPXM3uPlaylistImporter* self =

        new(ELeave)CMPXM3uPlaylistImporter(

            aFs, aObserver, aTopCharacterSet, aAvailableCharacterSet, aStatus );

    CleanupStack::PushL( self );

    self->ConstructL( aPlaylistUri );

    CleanupStack::Pop( self );

    return self;

    }

// ----------------------------------------------------------------------------

// ----------------------------------------------------------------------------

//

EXPORT_C CMPXM3uPlaylistImporter::~CMPXM3uPlaylistImporter()

    {

    Cancel();

    Cleanup();

    }

// ----------------------------------------------------------------------------

// Handles request completion event

// ----------------------------------------------------------------------------

//

EXPORT_C void CMPXM3uPlaylistImporter::RunL()

    {

    MPX_DEBUG1("CMPXM3uPlaylistImporter::RunL");

    if ( iMoreToDo && iStatus.Int() == KErrNone )

        {

        DoTaskStep();

        SetActive();

        }

    else

        {

        }

    }

// ----------------------------------------------------------------------------

// Implements cancellation of an outstanding request.

// ----------------------------------------------------------------------------

//

EXPORT_C void CMPXM3uPlaylistImporter::DoCancel()

    {

    MPX_DEBUG1("CMPXM3uPlaylistImporter::DoCancel");

    TInt error( KErrCancel );

    // notify client that the request has been cancelled

    NotifyClient(error);

    Cleanup();

    if ( iCallerStatus )

        {

        User::RequestComplete( iCallerStatus, error );

        }

    }

// ----------------------------------------------------------------------------

// Performs one step of the task

// ----------------------------------------------------------------------------

//

EXPORT_C void CMPXM3uPlaylistImporter::DoTaskStep()

    {

    MPX_DEBUG1("CMPXM3uPlaylistImporter::DoTaskStep()");

    TRequestStatus* status = &iStatus;

    *status = KRequestPending;

    TInt error( KErrNone );

    MPX_TRAP( error, DoTaskStepL() );

    User::RequestComplete( status, error );

    }

// ----------------------------------------------------------------------------

// Performs one step of the task. Leaves when an error is encountered

// ----------------------------------------------------------------------------

//

EXPORT_C void CMPXM3uPlaylistImporter::DoTaskStepL()

    {

    MPX_DEBUG1("CMPXM3uPlaylistImporter::DoTaskStepL()");

    switch( iState )

        case EMPXM3UReadBufferWithAutoDetectEncoding:

            {

            ReadPlaylistFileToBufferL();

            iState = EMPXM3UParseWithAutoDetectEncoding;

            }

            break;

        case EMPXM3UParseWithAutoDetectEncoding:

            {

            ParsePlaylistBufferL(

                *iAutoEncodingPlaylistArray, iAutoEncodingInvalidItems );

            // If at the moment, we know that there is at least one error parsing

            // with auto detect encoding, we don't need to proceed until end of

            // file anymore, this playlist file is concluded to be corrupted

            if ( iAutoEncodingInvalidItems > 0 )

                {

                delete iAutoEncodingPlaylistArray;

                iAutoEncodingPlaylistArray = NULL;

                User::Leave(KErrCorrupt);

                }

            // we've finished parsing with auto detect encoding we will return

            // the playlist parsed with auto encoding

            else if ( iEndOfFile )

                iState = EMPXM3UComposePlaylistMedia;

                }

            break;

        case EMPXM3UComposePlaylistMedia:

            {

            ComposePlaylistL();

            iMoreToDo = EFalse;

            }

            break;

        default:

            {

            User::Leave(KErrAbort);

            }

            break;

        }

    }

// -----------------------------------------------------------------------------

// CMPXM3uPlaylistImporter::ReadPlaylistFileToBufferL

// -----------------------------------------------------------------------------

//

void CMPXM3uPlaylistImporter::ReadPlaylistFileToBufferL()

    {

    delete iBuffer;

    iBuffer = NULL;

    //

    // leave with KErrNotFound if the playlist file does not exist

    if (!BaflUtils::FileExists(*iFs, iPlaylistFilePath))

        {

        User::Leave(KErrNotFound);

        }

    TEntry entry;

    User::LeaveIfError(iFs->Entry(iPlaylistFilePath, entry));

    HBufC* buffer = HBufC::NewLC(entry.iSize);

    TPtr ptr = buffer->Des();

    HBufC8* buf8 = HBufC8::NewLC(entry.iSize);

    TPtr8 ptr8 = buf8->Des();

    // Read the first KPlaylistSampleLength bytes of the file

    TInt sampleLength(KPlaylistSampleLength);

    if (sampleLength > entry.iSize)

        {

        sampleLength = entry.iSize;

        }

    User::LeaveIfError(iFs->ReadFileSection(

                            iPlaylistFilePath, 0, ptr8, sampleLength));

    // auto detect character encoding

    TUint charSetId(0);

    TInt error = DetectCharacterSetL(*buf8, iTopCharacterSet, charSetId);

    MPX_DEBUG3("encoding detected using top character set is 0x%x, error %d", charSetId, error);

    // when we fail to detect the encoding, use all available character set in the

    // system to try again. If that also fails, abandon the operation.

    if (error)

        {

        User::LeaveIfError(DetectCharacterSetL(*buf8, iAvailableCharacterSet, charSetId));

        }

    // read the whole file if the sample taken isn't the whole file

    if (sampleLength != entry.iSize)

        {

        User::LeaveIfError(iFs->ReadFileSection(

                                iPlaylistFilePath, 0, ptr8, entry.iSize));

        }

    // perform character conversion using the selected encoding

    TInt state(CCnvCharacterSetConverter::KStateDefault);

    TInt numOfUnconvertibleChars(0);

    CCnvCharacterSetConverter* charSetConv = CCnvCharacterSetConverter::NewLC();

    charSetConv->PrepareToConvertToOrFromL(charSetId, iAvailableCharacterSet, *iFs);

    TInt retVal = charSetConv->ConvertToUnicode(ptr, *buf8, state, numOfUnconvertibleChars);

    User::LeaveIfError(retVal);

    // try again if the character set wasn't detected using the whole file

    if ((retVal > 0 || numOfUnconvertibleChars > 0) && (sampleLength != entry.iSize))

        {

        MPX_DEBUG4("retVal = %d, numOfUnconvertibleChars = %d, entry.iSize = %d",

                    retVal, numOfUnconvertibleChars, entry.iSize);

        numOfUnconvertibleChars = 0;

        retVal = 0;

        User::LeaveIfError(DetectCharacterSetL(*buf8, iAvailableCharacterSet, charSetId));

        charSetConv->PrepareToConvertToOrFromL(charSetId, iAvailableCharacterSet, *iFs);

        retVal = charSetConv->ConvertToUnicode(ptr, *buf8, state, numOfUnconvertibleChars);

        }

    if (retVal > 0 || numOfUnconvertibleChars > 0)

        {

        MPX_DEBUG3("Unable to find character encoding for the playlist file. retVal = %d, numOfUnconvertibleChars = %d",

        User::Leave(KErrNotSupported);

        }

    // remove the byte order mark (BOM) character prepended at the beginning

    // of the stream if encoded with unicode as per Unicode section 2.4

    if ((charSetId == KCharacterSetIdentifierUnicodeLittle ||

         charSetId == KCharacterSetIdentifierUnicodeBig) &&

        ptr.Length() > 0 &&

        ptr[0] == KUnicodeBOM)

        {

        ptr.Delete(0,1);

        }

    iBuffer = buffer;

    iBufferPtr.Set(*iBuffer);

    CleanupStack::Pop(buffer);

    // brand new buffer which hasn't been read, reset iCurrentLineNumber and

    // iEndLineNumber, and iEndOfFile

    iCurrentLineNumber = 0;

    iEndLineNumber = KMPXM3UNumOfLinesToProcess;

    iEndOfFile = EFalse;

    }

// -----------------------------------------------------------------------------

// CMPXM3uPlaylistImporter::DetectCharacterSetL

// copied and revised based on CMetaDataParserID3v1::DetectCharacterSetL version 4

// -----------------------------------------------------------------------------

//

TInt CMPXM3uPlaylistImporter::DetectCharacterSetL(

            const TDesC8& aSample,

            const CArrayFix<CCnvCharacterSetConverter::SCharacterSet>& aCharacterSet,

            TUint& aCharSetId)

	{

	// CCnvCharacterSetConverter::ConvertibleToCharSetL hangs if sample is too big

	if (aSample.Size() > KPlaylistMaxSampleLength)

	    {

	    User::Leave(KErrNotSupported);

	    }

	TInt confidence(0);

	TInt highestConfidence(0);

	TUint charSetId(0);

	TUint highestConfidencecharSetId(0);

	CCnvCharacterSetConverter* charSetConv = CCnvCharacterSetConverter::NewLC();

	TInt count = aCharacterSet.Count();

	for ( TInt i=0; i < count; i++)

		{

		charSetId = aCharacterSet.At(i).Identifier();

		charSetConv->ConvertibleToCharSetL(confidence, charSetId, aCharacterSet, aSample);

		if ( confidence > highestConfidence )

			{

			highestConfidence = confidence;

			highestConfidencecharSetId = charSetId;

			}

		}

	CleanupStack::PopAndDestroy(charSetConv);

	MPX_DEBUG3("CMPXM3uPlaylistImporter::DetectCharacterSetL :-> Confidence[%d] CharSetId[0x%x]",

   		confidence, aCharSetId);

	if ( highestConfidence == 0 || highestConfidence < KMinimumConfidenceRequired )

		{

		return KErrNotFound;

		}

	else

		{

		aCharSetId = highestConfidencecharSetId;

		return KErrNone;

		}

	}

// -----------------------------------------------------------------------------

// CMPXM3uPlaylistPlugin::ParsePlaylistBufferL

// -----------------------------------------------------------------------------

//

void CMPXM3uPlaylistImporter::ParsePlaylistBufferL(

            CMPXMediaArray& aPlaylist,

            TInt& aInvalidItemCount)

    {

    // Read and process all the lines in the file

    //

    // the order of the following conditions is important. ReadNextLineL

    // should be called last to avoid skipping one line

    while (iCurrentLineNumber < iEndLineNumber &&

           aPlaylist.Count() < KMPXM3UPlaylistMaxItemCount &&

           ReadNextLineL())

        {

        }

    if ( aPlaylist.Count() == KMPXM3UPlaylistMaxItemCount )

        {

        User::Leave(KErrOverflow);

        }

    //

    // haven't finished processing all lines in the file, but have processed

    // KMPXM3UNumOfLinesToProcess number of lines. Set up iEndLineNumber for

    // the next iteration

    if ( !iEndOfFile && iCurrentLineNumber == iEndLineNumber )

        {

        iEndLineNumber += KMPXM3UNumOfLinesToProcess;

        }

    }

// -----------------------------------------------------------------------------

// CMPXM3uPlaylistPlugin::ReadNextLineL

// -----------------------------------------------------------------------------

//

TBool CMPXM3uPlaylistImporter::ReadNextLineL()

    {

    // iBuffer should exist when this function is called

    __ASSERT_DEBUG(iBuffer, User::Leave(KErrBadDescriptor));

    if (!iBufferPtr.Length())

        {

        // File end reached.

        iEndOfFile = ETrue;

        return EFalse;

        }

    delete iLine;

    iLine = NULL;

    // Try to find line change

    TInt offset = iBufferPtr.FindF(KMPXM3ULineChange);

    if (offset == KErrNotFound)

        {

        // No line change was found --> last line had no line change

        iLine = iBufferPtr.AllocL();

        // Set iBufferPtr to the end of buffer

        iBufferPtr.Set(iBufferPtr.Right(0)); //magic

        }

    else

        {

        // Found line change

        TInt length(offset);

            (iBufferPtr[length - 1] == KMPXM3UCarriageReturn)) // magic

            {

            --length;

            }

        iLine = iBufferPtr.Left(length).AllocL();

        // Move past the line feed

        iBufferPtr.Set(iBufferPtr.Mid(++offset));

        }

    // Remove leading and trailing space characters from iLine's data.

    TPtr ptr = iLine->Des();

    ptr.Trim();

    iCurrentLineNumber++;

    return ETrue;

    }

// -----------------------------------------------------------------------------

// CMPXM3uPlaylistImporter::ProcessLineL()

// -----------------------------------------------------------------------------

//

void CMPXM3uPlaylistImporter::ProcessLineL(

            CMPXMediaArray& aPlaylist,

            TInt& aInvalidItemCount)

    {

    if ( iCurrentLineNumber == 1 ) // first line

        {

        // Check whether the file is in the extented format

        TInt offset = iLine->Find(KMPXM3UTagExtm3u);

        if (offset == KErrNotFound || offset != KMPXM3UNoOffset ||

            iLine->Length() != KMPXM3UTagExtm3u().Length())

            {

            // The file is not in the extented format

            iExtendedFormat = EFalse;

            }

        else

            {

            // The file is in the extented format

            iExtendedFormat = ETrue;

            return;

        }

    if (!iItem)

        {

        iItem = CMPXMedia::NewL();

        iItem->SetTObjectValueL(KMPXMediaGeneralType, EMPXItem);

        iItem->SetTObjectValueL(KMPXMediaGeneralCategory, EMPXSong);

        }

    // Parse line and then decide what to do with it

    switch (ParseLineL(iItem, aInvalidItemCount))

        {

        case EMPXM3UPlaylistLineTypeExtinf:

            // Continue to next round

            break;

        case EMPXM3UPlaylistLineTypePath:

            {