/** @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 uploads

*

*/

// System include files

#include <es_sock.h>

// User include files

#include "httpuploader.h"

#include "httpuploadworker.h"

#include "httptransferbase.h"

#include "httptransferobserver.h"

// Constants

const TUint KMaxParallelTransfers = 5;

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

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

// CHttpUploader::CHttpDownloader()

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

//

CHttpUploader::CHttpUploader( 

                       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;

        }

    }

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

// CHttpUploader::ConstructL()

// (See comments in header file)

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

//

void CHttpUploader::ConstructL()

    {

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

        {

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

                                                      iIAPId,

                                                      iBufferSize,

                                                      *this ) );

        }

    }

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

// CHttpUploader::NewL()

// (See comments in header file)

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

//

EXPORT_C CHttpUploader* CHttpUploader::NewL( 

                                          MHttpTransferObserver& aObserver,

                                          TUint aIAPId,

                                          TUint aBufferSize,

                                          TUint aParallelTransfers )

    {

    CHttpUploader* self = CHttpUploader::NewLC( aObserver, 

                                                aIAPId, 

                                                aBufferSize,

                                                aParallelTransfers );

    CleanupStack::Pop( self );

    return self;

    }

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

// CHttpDownloader::NewLC()

// (See comments in header file)

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

//

EXPORT_C CHttpUploader* CHttpUploader::NewLC( 

                                          MHttpTransferObserver& aObserver,

                                          TUint aIAPId,

                                          TUint aBufferSize,

                                          TUint aParallelTransfers )

    {

    CHttpUploader* self = new( ELeave ) CHttpUploader( aObserver, 

                                                       aIAPId,

                                                       aBufferSize,

                                                       aParallelTransfers );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

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

// CHttpUploader::~CHttpUploader()

// (See comments in header file)

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

//

CHttpUploader::~CHttpUploader()

    {

    }

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

// CHttpUploader::UploadFileL

// (See comments in header file)

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

//

EXPORT_C void CHttpUploader::UploadFileL( 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();

    }

// end of file