// Copyright (c) 2006-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:
//

#include <mtp/tmtptyperequest.h>
#include <mtp/mmtpdataproviderframework.h>
#include <mtp/mtpprotocolconstants.h>
#include <mtp/cmtptypeobjectproplist.h>

#include "cmtpdataprovider.h"
#include "cmtpdataprovidercontroller.h"
#include "cmtpparserrouter.h"
#include "cmtpsendobjectproplist.h"
#include "mtpproxydppanic.h"
#include "rmtpframework.h"
#include "cmtpstoragemgr.h"

/**
Verification data for the SendObjectPropList request
*/
const TMTPRequestElementInfo KMTPSendObjectPropListPolicy[] = 
    {
        {TMTPTypeRequest::ERequestParameter1, EMTPElementTypeStorageId, EMTPElementAttrWrite, 1, 0, 0}, 
        {TMTPTypeRequest::ERequestParameter2, EMTPElementTypeObjectHandle, EMTPElementAttrDir, 2, KMTPHandleAll, KMTPHandleNone}
    };

/**
Two-phase construction method
@param aFramework    The data provider framework
@param aConnection    The connection from which the request comes
@return a pointer to the created request processor object
*/ 
MMTPRequestProcessor* CMTPSendObjectPropList::NewL(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection)
    {
    CMTPSendObjectPropList* self = new (ELeave) CMTPSendObjectPropList(aFramework, aConnection);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

/**
Destructor
*/    
CMTPSendObjectPropList::~CMTPSendObjectPropList()
    {
    delete iObjectPropList;
    iSingletons.Close();
    }

/**
Standard c++ constructor
*/    
CMTPSendObjectPropList::CMTPSendObjectPropList(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection) :
    CMTPRequestProcessor(aFramework, aConnection, (sizeof(KMTPSendObjectPropListPolicy) / sizeof(TMTPRequestElementInfo)), KMTPSendObjectPropListPolicy)
    {
    
    }
    
/**
Second phase constructor.
*/
void CMTPSendObjectPropList::ConstructL()
    {
    iSingletons.OpenL();
    }
    
void CMTPSendObjectPropList::ServiceL()
    {
    delete iObjectPropList;
    iObjectPropList = NULL;
    iObjectPropList = CMTPTypeObjectPropList::NewL();
    ReceiveDataL(*iObjectPropList);
    }

TBool CMTPSendObjectPropList::HasDataphase() const
    {
    return ETrue;
    }
    
TBool CMTPSendObjectPropList::DoHandleResponsePhaseL()
    {
    TMTPResponseCode rsp(EMTPRespCodeOK);
    
    TUint formatcode = Request().Uint32(TMTPTypeResponse::EResponseParameter3);
    
    if( EMTPFormatCodeAssociation != formatcode )
        {
        //Here, it must be that FormatCode is supported by multi DPs and the first Parameter (StorageID) should be used.
        //Because if only one target DP, Parser&Router will directly dispatch the request to it
        //if no target DP, the request will be dispatch to Device DP.
        
        RArray<TUint> targets;
        CleanupClosePushL(targets);
        CMTPParserRouter::TRoutingParameters params(*iRequest, iConnection);
        iSingletons.Router().ParseOperationRequestL(params);
        iSingletons.Router().RouteOperationRequestL(params, targets);
        CMTPStorageMgr& storages(iSingletons.StorageMgr());
        const TUint KStorageId = Request().Uint32(TMTPTypeResponse::EResponseParameter1);
        if( KMTPNotSpecified32 == KStorageId)
            {
            rsp = EMTPRespCodeGeneralError;
            }
        else if( storages.ValidStorageId(KStorageId) )
            {
            TInt dpID(KErrNotFound);
            if (storages.LogicalStorageId(KStorageId))
                {
                dpID = storages.LogicalStorageOwner(KStorageId);
                }
            else
                {
                dpID = storages.PhysicalStorageOwner(KStorageId);
                }
            
            if( targets.Find( dpID ) == KErrNotFound )
                {
                rsp = EMTPRespCodeGeneralError;
                }
            else
                {
                iSingletons.DpController().DataProviderL(dpID).ExecuteProxyRequestL(Request(), Connection(), *this);
                }
            }
        else
            {
            rsp = EMTPRespCodeInvalidStorageID;
            }
        
        CleanupStack::PopAndDestroy(&targets);
        
        }
    else
        {
        /* 
        Only requests with an ObjectFormatCode of EMTPFormatCodeAssociation 
        are routed to the proxy DP. Locate and extract the association type from 
        the received ObjectPropList dataset.
        */
        TUint32 count(iObjectPropList->NumberOfElements());
		iObjectPropList->ResetCursor();		
        TInt    type(KErrNotFound);
        TUint16 tmpAssocValue(EMTPAssociationTypeGenericFolder);
        for (TUint i(0); ((rsp == EMTPRespCodeOK) && (type == KErrNotFound) && (i < count)); i++)
            {
			CMTPTypeObjectPropListElement& prop=iObjectPropList->GetNextElementL();			
            if (prop.Uint16L(CMTPTypeObjectPropListElement::EPropertyCode) == EMTPObjectPropCodeAssociationType)
                {
                if (prop.Uint16L(CMTPTypeObjectPropListElement::EDatatype) != EMTPTypeUINT16)
                    {
                    rsp = EMTPRespCodeInvalidObjectPropFormat;
                    }
                else
                    {
                    type = i;
					tmpAssocValue = prop.Uint16L(CMTPTypeObjectPropListElement::EValue);
                    }
                }
            }	        
        TUint16 assocValue;
        if ((type == KErrNotFound) &&
            (rsp == EMTPRespCodeOK))
            {
            // If no property type is specified, create a generic folder
            assocValue = EMTPAssociationTypeGenericFolder;
            }
        else
            {
            assocValue = tmpAssocValue;
            }
        
        if (rsp == EMTPRespCodeOK)
            {
            CMTPParserRouter::TRoutingParameters params(*iRequest, iConnection);
            iSingletons.Router().ParseOperationRequestL(params);
            params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatCode, EMTPFormatCodeAssociation);
            params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatSubCode, assocValue);
            RArray<TUint> targets;
            CleanupClosePushL(targets);
            iSingletons.Router().RouteOperationRequestL(params, targets);
            __ASSERT_DEBUG((targets.Count() == 1), User::Invariant());
            iSingletons.DpController().DataProviderL(targets[0]).ExecuteProxyRequestL(Request(), Connection(), *this);
            CleanupStack::PopAndDestroy(&targets);
            }
        }
    if (rsp != EMTPRespCodeOK)
        {
        SendResponseL(rsp);
        }
    return EFalse;
    }

#ifdef _DEBUG
void CMTPSendObjectPropList::ProxyReceiveDataL(MMTPType& aData, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
#else
void CMTPSendObjectPropList::ProxyReceiveDataL(MMTPType& aData, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
#endif
    {
    __ASSERT_DEBUG(iRequest == &aRequest && &iConnection == &aConnection, Panic(EMTPNotSameRequestProxy));

	CMTPTypeObjectPropList* targetObjectPropList = static_cast<CMTPTypeObjectPropList*>(&aData); 
	
	targetObjectPropList->AppendObjectPropListL(*iObjectPropList);

    TRequestStatus* status = &aStatus;
    User::RequestComplete(status, KErrNone);
    }
    
void CMTPSendObjectPropList::ProxySendDataL(const MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/)
    {
    Panic(EMTPWrongRequestPhase);
    }
    
#ifdef _DEBUG    
void CMTPSendObjectPropList::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
#else
void CMTPSendObjectPropList::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
#endif
    {
    __ASSERT_DEBUG(iRequest == &aRequest && &iConnection == &aConnection, Panic(EMTPNotSameRequestProxy));
    MMTPType::CopyL(aResponse, iResponse);
    TRequestStatus* status = &aStatus;
    User::RequestComplete(status, KErrNone);    
    }

void CMTPSendObjectPropList::ProxyTransactionCompleteL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
    {
    __ASSERT_DEBUG(((iRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
    iFramework.SendResponseL(iResponse, aRequest, aConnection);
    }
    
void CMTPSendObjectPropList::SendResponseL(TUint16 aCode)
    {
    const TMTPTypeRequest& req(Request());
    iResponse.SetUint16(TMTPTypeResponse::EResponseCode, aCode);
    iResponse.SetUint32(TMTPTypeResponse::EResponseSessionID, req.Uint32(TMTPTypeRequest::ERequestSessionID));
    iResponse.SetUint32(TMTPTypeResponse::EResponseTransactionID, req.Uint32(TMTPTypeRequest::ERequestTransactionID));
    iFramework.SendResponseL(iResponse, req, Connection());
    }