/** @file

 * Copyright (c) 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:  CUpnpFileSender implementation

 *

 */

#include "upnpfilesender.h"

#include "httpuploader.h"

#include "upnphttpmessage.h"

#include "upnpstring.h"

#include "upnpcons.h"

#include "upnphttpmessagefactory.h"

#include "upnpcontrolpoint.h"

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

// CUpnpFileSender::CUpnpFileSender

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

//

CUpnpFileSender::CUpnpFileSender( CUpnpControlPoint& aCPToNotifyOfSendingResult )

    : iControlPoint( aCPToNotifyOfSendingResult )

    {

    // No implementation required

    }

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

// CUpnpFileSender::~CUpnpFileSender

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

//

CUpnpFileSender::~CUpnpFileSender()

    {

    delete iUploader;

    }

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

// CUpnpFileSender::NewLC

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

//

CUpnpFileSender* CUpnpFileSender::NewLC( CUpnpControlPoint& aCPToNotifyOfSendingResult )

    {

    CUpnpFileSender* self = new (ELeave) CUpnpFileSender( aCPToNotifyOfSendingResult );

    CleanupStack::PushL( self );

    return self;

    }

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

// CUpnpFileSender::NewL

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

//

CUpnpFileSender* CUpnpFileSender::NewL( CUpnpControlPoint& aCPToNotifyOfSendingResult )

    {

    CUpnpFileSender* self = CUpnpFileSender::NewLC( aCPToNotifyOfSendingResult );

    CleanupStack::Pop(self);

    return self;

    }

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

// DestinationUriL

// Allocate destination uri from message

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

//

static HBufC8* DestinationUriL( CUpnpHttpMessage& aMessage )

    {

    TInetAddr add( aMessage.Receiver() );

    HBufC8* address = UpnpString::InetToStringL( add );

    CleanupStack::PushL( address );

    TPtrC8 path( aMessage.SenderPathFromHeader() ) ;

    HBufC8* uriBuf = HBufC8::NewL(

        UpnpHTTP::KHTTPUrl().Length() + address->Length() + path.Length() );

    TPtr8 uri( uriBuf->Des() );

    uri.Append( UpnpHTTP::KHTTPUrl );

    uri.Append( *address );

    uri.Append( path );

    CleanupStack::PopAndDestroy( address );

    return uriBuf;

    }

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

// CUpnpFileSender::SendL

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

//

void CUpnpFileSender::SendL( CUpnpHttpMessage& aMessageToSend )

    {

    ASSERT( aMessageToSend.Method() == KHttpPost && aMessageToSend.OutFilename().Length() > 0 );

    if ( !iUploader )   //late initialisation

        {

        const TInt KUnused(0);

        const TUint KBufferSize( 10 * 1024 );

        const TUint KParallelTransfersNumber( 1 );

        iUploader = CHttpUploader::NewL(*this,KUnused,KBufferSize,KParallelTransfersNumber);

        }

    RBuf fileName;

    User::LeaveIfError( fileName.Create( aMessageToSend.OutFilename().Length() ) );

    CleanupClosePushL( fileName );

    fileName.Copy( aMessageToSend.OutFilename() );

    HBufC8* destUri = DestinationUriL( aMessageToSend );

    CleanupStack::PushL( destUri );

    iUploader->UploadFileL( *destUri, fileName, (TAny*)aMessageToSend.SessionId() );

    CleanupStack::PopAndDestroy( destUri );

    CleanupStack::PopAndDestroy( &fileName );

    }

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

// CUpnpFileSender::TransferProgress

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

//

void CUpnpFileSender::TransferProgress( TAny* /*aKey*/,

                               TInt /*aBytes*/,

                               TInt /*aTotalBytes*/ )

     {

     // no implementation needed

     }

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

// CUpnpFileSender::ReadyForTransferL

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

//

void CUpnpFileSender::ReadyForTransferL( TAny* aKey )

    {

    _LIT8( KTextHtmlMimeType, "text/html" );

    iUploader->SetHeaderL( aKey, UpnpHTTP::KHdrContentType, KTextHtmlMimeType );

    iUploader->SetHeaderL( aKey, UpnpHTTP::KConnection, UpnpHTTP::KClose );

    iUploader->StartTransferL( aKey );

    }

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

// CUpnpFileSender::TransferCompleted

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

//

void CUpnpFileSender::TransferCompleted( TAny* /*aKey*/, TInt aStatus )

    {

    CUpnpHttpMessage* rsp = NULL;

    TRAP_IGNORE(

        rsp = RUpnpHttpMessageFactory::HttpResponseErrorL( TInetAddr(), aStatus ) );

    iControlPoint.HttpResponseReceived( rsp );

    delete rsp;

    }