/** @file

* 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:  Handles downloads

*

*/

// System include files

#include <es_sock.h>

// User include files

#include "httpdownloader.h"

#include "httpdownloadworker.h"

#include "httptransferbase.h"

#include "httptransferobserver.h"

#include "httpworkerobserver.h"

// Constants

const TUint KMaxParallelTransfers = 5;

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

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

// CHttpDownloader::CHttpDownloader()

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

//

CHttpDownloader::CHttpDownloader( 

                       MHttpTransferObserver& aObserver,

                       TUint aIAPId,

                       TUint aBufferSize,

                       TUint aParallelTransfers = KDefaultParallelTransfers )

    {

    iObserver = &aObserver;

    iIAPId = aIAPId;

    iBufferSize = aBufferSize;

    if ( aParallelTransfers <= 0 )

        {

        iParallelTransfers = KDefaultParallelTransfers;

        }

    else if ( aParallelTransfers > KMaxParallelTransfers )

        {

        iParallelTransfers = KMaxParallelTransfers;

        }

    else

        {

        iParallelTransfers = aParallelTransfers;

        }

    }

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

// CHttpDownloader::ConstructL()

// (See comments in header file)

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

//

void CHttpDownloader::ConstructL()

    {

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

        {

        iWorkerArray.Append( CHttpDownloadWorker::NewL( *iObserver,

                                                        iIAPId,

                                                        iBufferSize,

                                                        *this ) );

        }

    }

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

// CHttpDownloader::NewL()

// (See comments in header file)

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

//

EXPORT_C CHttpDownloader* CHttpDownloader::NewL( 

                                        MHttpTransferObserver& aObserver,

                                        TUint aIAPId,

                                        TUint aBufferSize,

                                        TUint aParallelTransfers )

    {

    CHttpDownloader* self = CHttpDownloader::NewLC( aObserver, 

                                                    aIAPId, 

                                                    aBufferSize,

                                                    aParallelTransfers );

    CleanupStack::Pop( self );

    return self;

    }

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

// CHttpDownloader::NewLC()

// (See comments in header file)

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

//

EXPORT_C CHttpDownloader* CHttpDownloader::NewLC( 

                                         MHttpTransferObserver& aObserver,

                                         TUint aIAPId,

                                         TUint aBufferSize,

                                         TUint aParallelTransfers )

    {

    CHttpDownloader* self = 

                new( ELeave ) CHttpDownloader( aObserver, 

                                               aIAPId,

                                               aBufferSize,

                                               aParallelTransfers );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

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

// CHttpDownloader::~CHttpDownloader()

// (See comments in header file)

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

//

CHttpDownloader::~CHttpDownloader()

    {

    }

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

// CHttpDownloader::DownloadFileL

// (See comments in header file)

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

//

EXPORT_C void CHttpDownloader::DownloadFileL( const TDesC8& aUri, 

                                              const TDesC& aTargetPath, 

                                              TAny* aKey )

    {

    // if aKey already exists -> leave

    for ( TInt i=0; i < iFileQueue.Count(); i++ )

        {

        if ( iFileQueue[i]->Key() == aKey )

            {

            User::Leave( KErrAlreadyExists );

            }

        }

    // Add new CHttpFile into the iFileQueue

    CreateAndQueueHttpFileL( aUri, aTargetPath, aKey );

    // Activate new request

    ActivateNewTransferRequest();

    }

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

// CHttpDownloader::DownloadFileL

// (See comments in header file)

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

//

EXPORT_C void CHttpDownloader::DownloadFileL( const TDesC8& aUri, 

                                              const RFile& aFileHandle, 

                                              TAny* aKey )

    {

    // if aKey already exists -> leave

    for ( TInt i=0; i < iFileQueue.Count(); i++ )

        {

        if ( iFileQueue[i]->Key() == aKey )

            {

            User::Leave( KErrAlreadyExists );

            }

        }

    // Add new CHttpFile into the iFileQueue

    CreateAndQueueHttpFileL( aUri, aFileHandle, aKey );

    // Activate new request

    ActivateNewTransferRequest();

    }

// end of file