/** @file

* Copyright (c) 2005-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:  CUpnpDownloadCommand

*

*/

#include "upnpdownloadcommand.h"

#include "upnppathresolver.h"

#include "upnppathelement.h"

#include "upnpavcpmanager.h"

#include "upnpavcontrolpoint.h"

#include "upnphttpmessagefactory.h"

#include "upnpstring.h"

#include "upnpavcpenginehelper.h"

using namespace UpnpAVCPEngine;

_LIT8(KFilterFlag, "res,res@protocolInfo");

// Operation option flags

const TUint KRemoteAccessOptionGetToStartOfFile = 0x01;

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

// CUpnpDownloadCommand::NewL

// Two-phased constructor.

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

//

CUpnpDownloadCommand* CUpnpDownloadCommand::NewL(CUpnpAVCPManager& aAVCPManager, CUpnpAVCPEngineSession& aSession, const RMessage2& aMessage)

	{

    CUpnpDownloadCommand* self = new( ELeave ) CUpnpDownloadCommand(aAVCPManager, aSession, aMessage);

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;   

	}	

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

// CUpnpDownloadCommand::ConstructL

// Symbian 2nd phase constructor can leave.

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

//   

void CUpnpDownloadCommand::ConstructL() 

	{

	CUpnpCommand::BaseConstructL();

	} 

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

// CUpnpDownloadCommand::CUpnpDownloadCommand

// C++ default constructor can NOT contain any code, that

// might leave.

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

//     

CUpnpDownloadCommand::CUpnpDownloadCommand(CUpnpAVCPManager& aAVCPManager, 

                   CUpnpAVCPEngineSession& aSession, 

                   const RMessage2& aMessage):

                   CUpnpCommand( aAVCPManager,

                   		     aSession, 

                   		     aMessage)

	{

	}

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

// CUpnpDownloadCommand::~CUpnpDownloadCommand

// desctructor

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

// 

CUpnpDownloadCommand::~CUpnpDownloadCommand()

	{

    delete iObjectId;   

    delete iDestPath;

	}

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

// CUpnpDownloadCommand::SessionId

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

// 

TInt CUpnpDownloadCommand::SessionId() 

	{

    return CUpnpCommand::SessionId();   

	}

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

// CUpnpDownloadCommand::RunError

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

// 

void CUpnpDownloadCommand::RunError(TInt aErrorCode) 

	{

    return CUpnpCommand::RunError(aErrorCode);   

	}

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

// CUpnpDownloadCommand::ExecuteL

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

// 

void CUpnpDownloadCommand::ExecuteL()

	{

	//ASSERT(iType == EGetFile);

    HBufC8* uuid = NULL;

    HBufC8* srcPath = NULL;

    HBufC* destPath = NULL;    

    DEBUGSTRING(("Execute Download command "));

    uuid = ReadDes8FromMessageLC(0); 

    DEBUGSTRING8(("  uuid: %S",uuid));    

	srcPath = ReadDes8FromMessageLC(1);     

	DEBUGSTRING8(("  srcPath: %S",srcPath));                    	

	destPath = ReadDes16FromMessageLC(2); 		

	DEBUGSTRING16(("  destPath: %S",destPath));    

    TPckg<TFilePosition> posPkg(iPosition);

	iMessage.ReadL( 3,posPkg );    

    // convert to 8-bit representation 

    iDestPath = HBufC8::NewL(destPath->Length()); 

    iDestPath->Des().Copy(*destPath);

    iPathResolver = &(iAVCPManager.PathResolverL(*uuid, &iSession));

    iPathResolver->ResolveIdL(*srcPath, *this);

    CleanupStack::PopAndDestroy(destPath);          

    CleanupStack::PopAndDestroy(srcPath);          

	CleanupStack::PopAndDestroy(uuid);          

	}

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

// CUpnpDownloadCommand::SetResultL

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

// 

void CUpnpDownloadCommand::SetResultL(const RMessage2& /*aMessage*/) 

	{

	}

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

// CUpnpDownloadCommand::Interpret

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

// 

void CUpnpDownloadCommand::InterpretL(TInt aErrorCode, CUpnpAction* aAction) 

	{

	DEBUGSTRING(("Interpret action response %d", aErrorCode));	

    HBufC8* resURI = NULL;

    if (aErrorCode == EHttp200Ok && 

        iPathResolver->GetResUriL( aAction->ArgumentValue( KResult ), *iObjectId, resURI)) 

    	{    	    	    	    	

    	DEBUGSTRING8(("Send HTTP GET request for %S", resURI));

    	// encode URI

    	CleanupStack::PushL(resURI);

    	HBufC8* resURIencoded = UpnpString::StringReplaceL(*resURI, _L8(" "), _L8("%20"));    	

    	CleanupStack::PopAndDestroy(resURI);

        CleanupStack::PushL(resURIencoded);

        CUpnpHttpMessage* msg = RUpnpHttpMessageFactory::HttpGetL( *resURIencoded );

        CleanupStack::PopAndDestroy(resURIencoded);

	    CleanupStack::PushL( msg );

		msg->SetInFilenameL( *iDestPath, ETrue );		

    	msg->SetHttpPriority( EPriorityLess );

    	if (iPosition.iStart != 0 || iPosition.iLength != 0 ) 

    		{

    		DEBUGSTRING8(("  Use ramge header. From %d to %d (flag:%d) ", 

    			iPosition.iStart, iPosition.iLength, iPosition.iFlags));

    		iUseRange = ETrue;

    		if (iPosition.iFlags == KRemoteAccessOptionGetToStartOfFile)

    			msg->SetRangeL(iPosition.iStart, iPosition.iLength, ETrue);

    		else 

    			msg->SetRangeL(iPosition.iStart, iPosition.iLength, EFalse);    	    

    		}	

        iAVCPManager.SendL(msg);  

        iSessionId = msg->SessionId();

        iAVCPManager.RegisterForHttp(*this);         

        CleanupStack::PopAndDestroy( msg );              

    	}

    else 

    	{

    	DEBUGSTRING8(("   No resouse URI found"));

        iMessage.Complete(KErrAbort); 

        delete this;

    	}   

	}

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

// CUpnpDownloadCommand::Interpret

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

// 

void CUpnpDownloadCommand::InterpretL(TInt aErrorCode, CUpnpHttpMessage* /*aMessage*/) 

	{

	DEBUGSTRING(("HTTP Interpret %d", aErrorCode));	

    if (aErrorCode == KHttpGetStarted) 

    	{

      	// transfer pending   

      	return;

    	}

    iAVCPManager.UnregisterForHttp(*this); 

    if (aErrorCode == EHttp200Ok || aErrorCode == EHttpPartialContent) 

    	{

    	if (iUseRange && aErrorCode == EHttp200Ok) 

    		{

    		iPosition.iLength = 0;

    	    TPckg<TFilePosition> posPkg(iPosition);

			iMessage.WriteL( 3,posPkg );

    		}

       	iMessage.Complete(KErrNone); 

       	delete this;

    	}

    else  

    	{

       	iMessage.Complete(KErrAbort);         

       	delete this;

    	}    

	}	

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

// CUpnpDownloadCommand::ResolvedId

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

// 

void CUpnpDownloadCommand::ResolvedIdL(TInt aErrCode, CUpnpPathElement* aIdElement)

	{

    DEBUGSTRING(("ResolvedId %d", aErrCode));    

    if (aErrCode == KErrNone)  

    	{

        iObjectId = aIdElement->Id().AllocL();

        iSessionId = iAVCPManager.CdsBrowseActionL(iPathResolver->UUID(), *iObjectId, KBrowseMetadata,KFilterFlag , 0, 0, KNullDesC8);    

        iAVCPManager.RegisterForAction(*this);        

    	}

    else 

    	{

        iMessage.Complete(KErrNotFound);

        delete this;

    	}

};

//End of File