--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnpavcontrolpoint/avcpengine/src/upnpdownloadcommand.cpp	Thu Dec 17 08:52:00 2009 +0200
@@ -0,0 +1,257 @@
+/** @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