// 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/cmtptypeobjectinfo.h>

#include "rmtpframework.h"
#include "cmtpdataprovidercontroller.h"
#include "cmtpparserrouter.h"
#include "cmtpdataprovider.h"
#include "cmtpsendobjectinfo.h"
#include "mtpproxydppanic.h"
#include "cmtpproxydpconfigmgr.h"
#include "cmtpstoragemgr.h"

__FLOG_STMT( _LIT8( KComponent,"PrxySendObjectInfo" ); )

/**
Verification data for the SendObjectInfo request
*/
const TMTPRequestElementInfo KMTPSendObjectInfoPolicy[] =
    {
        {TMTPTypeRequest::ERequestParameter1, EMTPElementTypeStorageId, EMTPElementAttrWrite, 1, 0, 0},
        {TMTPTypeRequest::ERequestParameter2, EMTPElementTypeObjectHandle, EMTPElementAttrDir | EMTPElementAttrWrite, 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* CMTPSendObjectInfo::NewL(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection)
    {
    CMTPSendObjectInfo* self = new (ELeave) CMTPSendObjectInfo(aFramework, aConnection);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

/**
Destructor
*/
CMTPSendObjectInfo::~CMTPSendObjectInfo()
    {
    __FLOG(_L8("~CMTPSendObjectInfo - Entry"));
    
    delete iObjectInfo;
    iSingletons.Close();
    iProxyDpSingletons.Close();
    
    __FLOG(_L8("~CMTPSendObjectInfo - Exit"));
    __FLOG_CLOSE;
    }

/**
Standard c++ constructor
*/
CMTPSendObjectInfo::CMTPSendObjectInfo(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection) :
    CMTPRequestProcessor(aFramework, aConnection, sizeof(KMTPSendObjectInfoPolicy)/sizeof(TMTPRequestElementInfo), KMTPSendObjectInfoPolicy)
    {

    }

/**
Second phase constructor.
*/
void CMTPSendObjectInfo::ConstructL()
    {
    __FLOG_OPEN(KMTPSubsystem, KComponent);
    __FLOG(_L8("ConstructL - Entry"));
    
    iSingletons.OpenL();
    
    __FLOG(_L8("ConstructL - Exit"));
    }

/**
SendObjectInfo/SendObject request handler
NOTE: SendObjectInfo has to be comes before SendObject requests.  To maintain the state information
between the two requests, the two requests are combined together in one signal processor.
*/
void CMTPSendObjectInfo::ServiceL()
    {
    delete iObjectInfo;
    iObjectInfo = NULL;
    iObjectInfo = CMTPTypeObjectInfo::NewL();
    ReceiveDataL(*iObjectInfo);
    }

/**
Override to handle the response phase of SendObjectInfo requests
@return EFalse
*/
TBool CMTPSendObjectInfo::DoHandleResponsePhaseL()
    {
    DoHandleSendObjectInfoCompleteL();
    return EFalse;
    }

TBool CMTPSendObjectInfo::HasDataphase() const
    {
    return ETrue;
    }

/**
Handling the completing phase of SendObjectInfo request
@return ETrue if the specified object can be saved on the specified location, otherwise, EFalse
*/
void CMTPSendObjectInfo::DoHandleSendObjectInfoCompleteL()
    {
    __FLOG(_L8("DoHandleSendObjectInfoCompleteL - Entry"));
    
    CMTPParserRouter::TRoutingParameters params(*iRequest, iConnection);
    iSingletons.Router().ParseOperationRequestL(params);
    TBool fileFlag=EFalse;
    RArray<TUint> targets;
    CleanupClosePushL(targets);
    params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatCode, iObjectInfo->Uint16L(CMTPTypeObjectInfo::EObjectFormat));
    
    iProxyDpSingletons.OpenL(iFramework);
    TInt index(KErrNotFound);
	const TUint16 formatCode=iObjectInfo->Uint16L(CMTPTypeObjectInfo::EObjectFormat);
	__FLOG_1( _L8("formatCode = %d"), formatCode );
	switch(formatCode)
		{
	case EMTPFormatCodeAssociation:
        params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatSubCode, iObjectInfo->Uint16L(CMTPTypeObjectInfo::EAssociationType));
        break;

    case EMTPFormatCodeScript:
    	{
    	__FLOG_1( _L8("formatCode = %d"), EMTPFormatCodeScript );
    	const TDesC& filename = iObjectInfo->StringCharsL(CMTPTypeObjectInfo::EFilename);
    	HBufC* lowFileName = HBufC::NewLC(filename.Length());
    	TPtr16 prt(lowFileName->Des());
    	prt.Append(filename);
    	prt.LowerCase();   	
    	__FLOG_1( _L8("lowFileName = %s"), &prt );
    	if (iProxyDpSingletons.FrameworkConfig().GetFileName(prt,index) )
    		{
    		fileFlag=ETrue;
    		}
    	CleanupStack::PopAndDestroy(lowFileName);
    	
    	params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatSubCode, EMTPAssociationTypeUndefined);	
        break;
    	}
    default:
    	params.SetParam(CMTPParserRouter::TRoutingParameters::EParamFormatSubCode, EMTPAssociationTypeUndefined);
        break;
		}
	
    __FLOG_1( _L8("fileFlag = %d"), fileFlag );
    if(fileFlag)
    	{
    	TInt  syncdpid =  iSingletons.DpController().DpId(iProxyDpSingletons.FrameworkConfig().GetDPId(index));
       	iSingletons.DpController().DataProviderL(syncdpid).ExecuteProxyRequestL(Request(), Connection(), *this);
    	}
    else
    	{
    	iSingletons.Router().RouteOperationRequestL(params, targets);
        CMTPStorageMgr& storages(iSingletons.StorageMgr());
    	const TUint KStorageId = Request().Uint32(TMTPTypeResponse::EResponseParameter1);
        __FLOG_1( _L8("KStorageId = %d"), KStorageId );
        __FLOG_1( _L8("targets.Count() = %d"), targets.Count() );
        if( KMTPNotSpecified32 == KStorageId)
            {
            iSingletons.DpController().DataProviderL(targets[0]).ExecuteProxyRequestL(Request(), Connection(), *this);
            }
        else if( storages.ValidStorageId(KStorageId) )
            {
        	if(targets.Count() == 1)
        		{
        		__FLOG_1( _L8("targets[0] = %d"), targets[0] );
        		iSingletons.DpController().DataProviderL(targets[0]).ExecuteProxyRequestL(Request(), Connection(), *this);
        		}
        	else
        		{
	            TInt dpID(KErrNotFound);
	            if (storages.LogicalStorageId(KStorageId))
	                {
	                dpID = storages.LogicalStorageOwner(KStorageId);
	                }
	            else
	                {
	                dpID = storages.PhysicalStorageOwner(KStorageId);
	                }
	            __FLOG_1( _L8("dpID = %d"), dpID );
	            if( targets.Find( dpID ) == KErrNotFound )
	                {
	                __FLOG(_L8("No target dp is found, so send one GeneralError response."));
	                SendResponseL( EMTPRespCodeGeneralError );
	                }
	            else
	                {
	                iSingletons.DpController().DataProviderL(dpID).ExecuteProxyRequestL(Request(), Connection(), *this);
	                }
        		}
            }
        else
            {
            __FLOG(_L8("StorageID is invalid."));
            SendResponseL( EMTPRespCodeInvalidStorageID );
            }
    	}	
    CleanupStack::PopAndDestroy(&targets);
    
    __FLOG(_L8("DoHandleSendObjectInfoCompleteL - Exit"));
    }

#ifdef _DEBUG
void CMTPSendObjectInfo::ProxyReceiveDataL(MMTPType& aData, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
#else
void CMTPSendObjectInfo::ProxyReceiveDataL(MMTPType& aData, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
#endif
    {
    __ASSERT_DEBUG(iRequest == &aRequest && &iConnection == &aConnection, Panic(EMTPNotSameRequestProxy));
    MMTPType::CopyL(*iObjectInfo, aData);
    TRequestStatus* status = &aStatus;
    User::RequestComplete(status, KErrNone);
    }

void CMTPSendObjectInfo::ProxySendDataL(const MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/)
    {
    Panic(EMTPWrongRequestPhase);
    }

#ifdef _DEBUG
void CMTPSendObjectInfo::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
#else
void CMTPSendObjectInfo::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 CMTPSendObjectInfo::ProxyTransactionCompleteL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
    {
    __ASSERT_DEBUG(iRequest == &aRequest && &iConnection == &aConnection, Panic(EMTPNotSameRequestProxy));
    iFramework.SendResponseL(iResponse, aRequest, aConnection);
    }