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