/** @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:  CUpnpUploadCommand

*

*/

#include "upnpuploadcommand.h"

#include "upnppathresolver.h"

#include "upnppathelement.h"

#include "upnpavcpmanager.h"

#include "upnpavcontrolpoint.h"

#include "upnphttpmessagefactory.h"

#include "upnpavcpenginehelper.h"

using namespace UpnpAVCPEngine;

_LIT8(KBrowseFilter, "res,res@protocolInfo,res@importUri");

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

// CUpnpUploadCommand::NewL

// Two-phased constructor.

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

//

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

	{

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

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;   

	}	

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

// CUpnpUploadCommand::ConstructL

// Symbian 2nd phase constructor can leave.

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

//    

void CUpnpUploadCommand::ConstructL() 

	{

	CUpnpCommand::BaseConstructL();

	} 

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

// CUpnpUploadCommand::CUpnpUploadCommand

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

// might leave.

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

//     

CUpnpUploadCommand::CUpnpUploadCommand(CUpnpAVCPManager& aAVCPManager, 

                   CUpnpAVCPEngineSession& aSession, 

                   const RMessage2& aMessage):

                   CUpnpCommand( aAVCPManager,

                   		     aSession, 

                   		     aMessage)

	{

	}

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

// CUpnpUploadCommand::~CUpnpUploadCommand

// desctructor

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

// 

CUpnpUploadCommand::~CUpnpUploadCommand()

	{

    delete iObjectId;

    delete iImportURI;   

    delete iSrcPath;

	}

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

// CUpnpUploadCommand::SessionId

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

// 

TInt CUpnpUploadCommand::SessionId() 

	{

    return CUpnpCommand::SessionId();   

	}

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

// CUpnpUploadCommand::RunError

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

// 

void CUpnpUploadCommand::RunError(TInt aErrorCode) 

	{

    return CUpnpCommand::RunError(aErrorCode);   

	}

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

// CUpnpUploadCommand::ExecuteL

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

// 

void CUpnpUploadCommand::ExecuteL()

	{

	//ASSERT(iType == EPutFile);

    HBufC8* uuid = NULL;

    HBufC8* dstPath = NULL;

    HBufC* srcPath = NULL;

   	DEBUGSTRING(("Execute Upload command"));

    uuid = ReadDes8FromMessageLC(0); 

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

	srcPath = ReadDes16FromMessageLC(1);                     	

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

	dstPath = ReadDes8FromMessageLC(2); 

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

    // convert to 8-bit representation 

    iSrcPath = HBufC8::NewL(srcPath->Length()); 

    iSrcPath->Des().Copy(*srcPath);

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

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

    CleanupStack::PopAndDestroy(dstPath);          

    CleanupStack::PopAndDestroy(srcPath);          

	CleanupStack::PopAndDestroy(uuid);          

	}

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

// CCUploadCommand::SetResultL

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

// 

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

	{

	}

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

// CUpnpUploadCommand::Interpret

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

// 

void CUpnpUploadCommand::InterpretL(TInt aErrorCode, CUpnpAction* /*aAction*/) 

	{

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

    if (aErrorCode == EHttp200Ok)

    	{    	

    	if( iImportURI) 

    		{    	    	        

        	CUpnpHttpMessage* msg = RUpnpHttpMessageFactory::HttpPostL( *iImportURI );       

	    	CleanupStack::PushL( msg );

			msg->SetOutFilenameL( *iSrcPath );		    	    			

        	iAVCPManager.SendL(msg);  

        	iSessionId = msg->SessionId();

        	iAVCPManager.RegisterForHttp(*this);         

        	CleanupStack::PopAndDestroy( msg );              

    		}

    	else

    		{

    		iMessage.Complete(KErrPathNotFound); 

        	delete this;	

    		}

    	}

    else 

    	{

        iMessage.Complete(KErrAbort); 

        delete this;

    	}   

	}

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

// CUpnpUploadCommand::Interpret

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

// 

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

	{

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

    if (aErrorCode == KHttpPostStarted) 

    	{

      	// transfer pending   

      	return;

    	}

    iAVCPManager.UnregisterForHttp(*this); 

    if (aErrorCode == EHttp200Ok) 

    	{

    	iMessage.Complete(KErrNone);

    	delete this; 

    	}

    else  

    	{

       	iMessage.Complete(KErrNotFound);         

       	delete this;

    	}    

	}

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

// CUpnpUploadCommand::ResolvedId

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

// 

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

	{

    if (aErrCode == KErrNone)  

    	{

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

        iImportURI = (aIdElement->ImportURI()!= KNullDesC8()) ? aIdElement->ImportURI().AllocL(): NULL;

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

        iAVCPManager.RegisterForAction(*this);        

    	}

    else 

    	{

        iMessage.Complete(KErrNotFound);

        delete this;

    	}

	}