/*

* Copyright (c) 2004-2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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 <e32std.h>

#include <sysutil.h>

#include "IptvDebug.h"

#include <bautils.h>

#include "CIptvTimer.h"

#include "CIptvRssDownload.h"

#include "CIptvRssPlugin.h"

#include "CIptvEpgService.h"

#include "CIptv3XmlContentHandler.h"

#include "ciptvxmldatetime.h"

// 0x10281F1E is the uid of the IptvUtil dll. This is taken

// into use by reason following:

// There can be two simultaneous RSS downloads ongoing at the

// same time; one for search and one for vod. Download manager

// prevents simultaneous downloads if uid given during Connect

// is already active. That's why we take another uid into use

// to allow search operations to run simultaneously with the

// normal vod update.

const TUid KIptvSearchUid = { 0x10281F1E };

const TInt KIptvMaxTimeoutInSeconds( 60 );

const TInt KIptvMaxPauseInSeconds( 10 );

const TInt KIptvTime_1_second( 1000000 );

const TInt KIptvTime_200_microsecond( 200 );

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

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

// Symbian 2nd phase constructor can leave.

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

//

void CIptvRssDownload::ConstructL()

    {

    iTimer = CIptvTimer::NewL( CActive::EPriorityUserInput, *this );

    }

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

// Two-phased constructor.

// Create instance of concrete interface implementation

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

//

CIptvRssDownload* CIptvRssDownload::NewL(

    CIptvRssPlugin& aPlugin,

    RFs& aFs,

    CIptvXmlContentHandler& aXmlContentHandler )

    {

    CIptvRssDownload* self = new( ELeave ) CIptvRssDownload(

        aPlugin,

        aFs,

        aXmlContentHandler );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// Destructor

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

//

CIptvRssDownload::~CIptvRssDownload()

    {

    IPTVLOGSTRING_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::~CIptvRssDownload" );

    if ( iTimer )

        {

        if ( iTimer->IsActive() )

            {

            iTimer->Cancel();

            }

        delete iTimer;

        iTimer = NULL;

        }

    Disconnect();

    iService = NULL;

    delete iDlDeleteTimer;

    delete iFileName;

    delete iUri;

    delete iETag;

    IPTVLOGSTRING_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::~CIptvRssDownload exit" );

    }

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

// C++ default constructor

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

//

CIptvRssDownload::CIptvRssDownload(

    CIptvRssPlugin& aPlugin,

    RFs& aFs,

    CIptvXmlContentHandler& aXmlContentHandler ) :

    iService( NULL ),

    iPlugin( aPlugin ),

    iThumbnail( EFalse ),

    iDownloadId( 0 ),

    iTimer( NULL ),

    iConnected( EFalse ),

    iState( ENormal ),

    iPauseCounter( 0 ),

    iFs( aFs ),

    iXmlContentHandler( aXmlContentHandler )

    {

    }

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

// Start download.

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

//

void CIptvRssDownload::DownloadL(

    const TDesC8& aUri,

    const TDesC& aFileName,

    TBool aThumbnail,

    const TDesC& aETag,

    const TTime& aLastUpdated )

    {

    if ( iState != ENormal && iState != EFinished )

        {

        IPTVLOGSTRING_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::DownloadL Busy Leave" );

        User::Leave( KErrAlreadyExists );

        }

    if ( ( 0 == aFileName.Length() ) || ( 0 == aUri.Length() ) )

        {

        IPTVLOGSTRING_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::DownloadL Argument Leave" );

        User::Leave( KErrArgument );

        }

    ChangeState( ENormal );

#ifdef _DEBUG

    // Debug print filename.

    TBuf<KIptvMaxPath> debugFileName;

    debugFileName.Copy( aFileName );

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL aFileName :         %S",

        &debugFileName );

    // Debug print Uri.

    TBuf<KIptvUrlMaxLength> debugUri;

    debugUri.Copy( aUri );

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL aUri :              %S",

        &debugUri );

#endif

    // When header information is given, fist dowload will fetch these values

    // for check. Thumbnail file must also exist to enable check.

    iWaitingContentTypeCheck =

        ( ( 0 != aETag.CompareC( KIptvEmptyDes ) ) ||

          ( TTime( 0LL ) != aLastUpdated ) )  &&

        !iDisableLastModifiedCheck &&

        ( !aThumbnail || BaflUtils::FileExists( iFs, aFileName ) );

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL Content type check: %d",

        iWaitingContentTypeCheck );

    // Store argument data for further use.

    if ( iUri )

        {

        delete iUri;

        iUri = NULL;

        }

    iUri = HBufC8::NewL( aUri.Length() );

    iUri->Des().Copy( aUri );

    if ( iFileName )

        {

        delete iFileName;

        iFileName = NULL;

        }

    iFileName = HBufC::NewL( aFileName.Length() );

    iFileName->Des().Copy( aFileName );

    if ( iETag )

        {

        delete iETag;

        iETag = NULL;

        }

    if ( 0 < aETag.Length() )

        {

        iETag = HBufC::NewL( aETag.Length() );

        iETag->Des().Copy( aETag );

        }

    iLastUpdated = aLastUpdated;

    iThumbnail = aThumbnail;

    // When no check, old thumbnail can be removed at once.

    if ( iThumbnail && iFileName && !iWaitingContentTypeCheck )

        {

        iPlugin.RemoveIconFromList( iFileName, ETrue );

        }

    // Create new download.

    RHttpDownload& download =

        iDownloadManager.CreateDownloadL( aUri );

    // Set download attributes.

    download.SetBoolAttribute( EDlAttrNoContentTypeCheck, !iWaitingContentTypeCheck );

    SetAuthenticationInformationL( download );

    if ( !iWaitingContentTypeCheck )

        {

        // Content check will not require filename and DownloadManager would anyway

        // delete it.

        download.SetStringAttribute( EDlAttrDestFilename, aFileName );

        }

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL Using IAP: %d",

        iService->iIap );

    User::LeaveIfError(

        iDownloadManager.SetIntAttribute( EDlMgrIap, iService->iIap ) );

    // Start download.

    User::LeaveIfError( download.Start() );

    download.GetIntAttribute( EDlAttrId, iDownloadId );

    iDownloadIdValid = ETrue;

    }

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

// Restart download.

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

//

void CIptvRssDownload::DownloadL()

    {

    if ( iState != ENormal && iState != EFinished )

        {

        IPTVLOGSTRING_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::DownloadL Busy Leave" );

        User::Leave( KErrAlreadyExists );

        }

    if ( !iFileName || !iUri )

        {

        IPTVLOGSTRING_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::DownloadL Argument Leave" );

        User::Leave( KErrArgument );

        }

    ChangeState( ENormal );

#ifdef _DEBUG

    // Debug print filename.

    TBuf<KIptvMaxPath> debugFileName;

    debugFileName.Copy( iFileName->Des() );

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL aFileName :         %S",

        &debugFileName );

#endif

    iWaitingContentTypeCheck = EFalse;

    // Create new download.

    RHttpDownload& download =

        iDownloadManager.CreateDownloadL( iUri->Des() );

    // Set download attributes.

    download.SetBoolAttribute( EDlAttrNoContentTypeCheck, ETrue );

    SetAuthenticationInformationL( download );

    download.SetStringAttribute( EDlAttrDestFilename, iFileName->Des() );

    IPTVLOGSTRING2_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::DownloadL Using IAP: %d",

        iService->iIap );

    User::LeaveIfError(

        iDownloadManager.SetIntAttribute( EDlMgrIap, iService->iIap ) );

    // Start download.

    User::LeaveIfError( download.Start() );

    download.GetIntAttribute( EDlAttrId, iDownloadId );

    iDownloadIdValid = ETrue;

    }

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

// From MHttpDownloadMgrObserver.

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

//

void CIptvRssDownload::HandleDMgrEventL(

    RHttpDownload& aDownload,

    THttpDownloadEvent aEvent )

    {

    IPTVLOGSTRING_LOW_LEVEL(

        "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL" );

    // In EThumbnail and ENoDiskSpace states we do not need to do anything

    // for new events. We are just waiting for our timer to step in.

    // When iTimer is NULL, we are shutting down.

    if ( ( iState == EThumbnail ) || ( iState == ENoDiskSpace ) || !iTimer || iDlDeleteTimer )

        {

        return;

        }

    //lint -e{961} Else block not needed, default is no operation.

    if ( iState == EPause )

        {

        iTimer->Cancel();

        ChangeState( ENormal );

        IPTVLOGSTRING2_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL PAUSED %d SECONDS, NOW CONTINUING!",

            iPauseCounter );

        iPauseCounter = 0;

        }

    else if ( iState == EWaiting )

        {

        iTimer->Cancel();

        ChangeState( ENormal );

        IPTVLOGSTRING2_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL WAITED EVENTS FROM DL-MANAGER %d SECONDS",

            iPauseCounter );

        iPauseCounter = 0;

        }

    else if ( iState == ETimeout )

        {

        if ( aEvent.iDownloadState == EHttpDlCreated )

            {

            IPTVLOGSTRING_LOW_LEVEL(

                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL download state was EHttpDlCreated." );

            ChangeState( ENormal );

            iPauseCounter = 0;

            }

        else

            {

            IPTVLOGSTRING_LOW_LEVEL(

                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL iState == ETimeout -> return" );

            return;

            }

        }

    TInt32 fileSizeReported = 0;

    aDownload.GetIntAttribute( EDlAttrUserData, fileSizeReported );

    // We keep checking file size until it is available in EDlAttrLength.

    if ( fileSizeReported == 0 )

        {

        TInt32 fullSize = 0;

        aDownload.GetIntAttribute( EDlAttrLength, fullSize );

        IPTVLOGSTRING2_LOW_LEVEL(

            "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL  Full size: %d", fullSize );

        if ( fullSize > 0 )

            {

            aDownload.SetIntAttribute( EDlAttrUserData, ETrue );

            // For thumbnails, we check if size of file exceeds the maximum

            // allowed. If it does, the file is not downloaded at all.

            if ( iThumbnail && fullSize > KIptvRssMaxThumbnailSize )

                {

                IPTVLOGSTRING3_LOW_LEVEL(

                    "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL Thumbnail too big %d, max size %d, download cancelled!!!",

                    fullSize,

                    KIptvRssMaxThumbnailSize );

#ifdef _DEBUG

                    switch ( iState )

                        {

                        case ENormal:

                            IPTVLOGSTRING_LOW_LEVEL(

                                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL iState changed from ENormal -> EThumbnail" );

                            break;

                        case EThumbnail:

                            IPTVLOGSTRING_LOW_LEVEL(

                                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL iState changed from EThumbnail -> EThumbnail" );

                            break;

                        case EFinished:

                            IPTVLOGSTRING_LOW_LEVEL(

                                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL iState changed from EFinished -> EThumbnail" );

                            break;

                        default:

                            IPTVLOGSTRING_LOW_LEVEL(

                                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL iState changed from ? -> EThumbnail" );

                            break;

                        }

#endif // _DEBUG

                iState = EThumbnail;

                if ( iTimer )

                    {

                    iTimer->Cancel();

                    iTimer->After( KIptvTime_200_microsecond );

                    return;

                    }

                }

            // For all other files, those that will be actually downloaded,

            // we check that we don't exceed critical disk space levels.

            else

                {

                TBool checkResult = EFalse;

                TRAPD( checkError, checkResult =

                    SysUtil::DiskSpaceBelowCriticalLevelL(

                        &iFs, static_cast<TInt64>(fullSize), EDriveC ) );

                if ( checkError != KErrNone || checkResult )

                    {

                    IPTVLOGSTRING_LOW_LEVEL(

                        "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL Disk space under critical level!!!" );

                    ChangeState( ENoDiskSpace );

                    if ( iTimer )

                        {

                        iTimer->Cancel();

                        iTimer->After( KIptvTime_200_microsecond );

                        return;

                        }

                    }

#ifdef _DEBUG

                else

                    {

                    IPTVLOGSTRING_LOW_LEVEL(

                        "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL Disk space ok." );

                    }

#endif // _DEBUG

                }

            }

        }

    switch ( aEvent.iProgressState )

        {

        case EHttpContentTypeReceived:

            {

            IPTVLOGSTRING_LOW_LEVEL(

                "RSS Plugin --- CIptvRssDownload::HandleDMgrEventL EHttpContentTypeReceived" );

            // Fetch header info to find out whether item has bee updated.

            TBuf<KMaxGeneralHeaderFieldLength> responseETag;

            TBuf<KMaxGeneralHeaderFieldLength> responseModifiedSince;

            aDownload.GetStringAttribute( EDlAttrResponseETag, responseETag );

            aDownload.GetStringAttribute( EDlAttrEntityLastModified, responseModifiedSince );

            iWaitingContentTypeCheck = EFalse;

            // Compare header info.

            TBool eTagMatch( EFalse );

            if ( iETag )

                {

                if ( responseETag.Length() > 0 )

                    {

                    eTagMatch = ( responseETag.Compare( iETag->Des() ) == 0 );

                    IPTVLOGSTRING2_LOW_LEVEL( "EDlAttrResponseETag :            %S",

                        &responseETag );

                    IPTVLOGSTRING2_LOW_LEVEL( "Local eTag valid :               %d",

                        eTagMatch );

                    }

                delete iETag;

                iETag = NULL;

                iETag = HBufC::NewL( responseETag.Length() );

                iETag->Des().Copy( responseETag );

                }

            TBool modifiedSinceMatch( EFalse );

            if ( responseModifiedSince.Length() > 0 )

                {

                TTime lastUpdated( static_cast<TUint64>( 0 ) );

                // Parse time string to TTime

                HBufC* lastUpdatedStr = HBufC::NewLC( responseModifiedSince.Length() );

                lastUpdatedStr->Des().Copy( responseModifiedSince );

                CIptvXmlDateTime::ParseGmtL( lastUpdatedStr, lastUpdated );

                CleanupStack::PopAndDestroy( lastUpdatedStr );

                modifiedSinceMatch = lastUpdated <= iLastUpdated;

#ifdef _DEBUG

                // Debug print last updated info.

                TBuf<KIptvEpgDbLastModifiedMaxLength> ecgDatePrint;

                TBuf<KIptvEpgDbLastModifiedMaxLength> itemDatePrint;

                _LIT( KIptvDatePrint, "%D%M%Y%/0%1%/1%2%/2%3%/3" );

                iLastUpdated.FormatL( ecgDatePrint, KIptvDatePrint );

                lastUpdated.FormatL( itemDatePrint, KIptvDatePrint );

                TBuf<KIptvEpgDbLastModifiedMaxLength> ecgTimePrint;

                TBuf<KIptvEpgDbLastModifiedMaxLength> itemTimePrint;

                _LIT( KIptvTimePrint, "%-B%:0%J%:1%T%:2%S%.%*C4%:3%+B" );

                iLastUpdated.FormatL( ecgTimePrint, KIptvTimePrint );

                lastUpdated.FormatL( itemTimePrint, KIptvTimePrint );

                IPTVLOGSTRING2_LOW_LEVEL( "EDlAttrEntityLastModified :      %S",

                    &responseModifiedSince );

                IPTVLOGSTRING3_LOW_LEVEL( "Local entity was last updated :  %S %S",

                    &ecgDatePrint,

                    &ecgTimePrint );

                IPTVLOGSTRING3_LOW_LEVEL( "Server entity was last updated : %S %S",

                    &itemDatePrint,

                    &itemTimePrint );

                IPTVLOGSTRING2_LOW_LEVEL( "Local entity valid :             %d",

                    modifiedSinceMatch );