// 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:
//

/**
 @file
 @internalTechnology
*/

#include "ss_commsdataobject.h"

#include <comms-infras/ss_log.h>

#include <comms-infras/api_ext_list.h>
#include <es_sock.h>
#include <comms-infras/es_parameterbundle.h>
#include <comms-infras/es_commsdataobject.h>

using namespace ESock;
using namespace Messages;

TBool TGetOrSetParameters::CanProcess(MeshMachine::TNodeContextBase& aContext)
	{
	TUint interfaceId = (*iDataObject)->RequiredItfExtId();
	return HasInterface(aContext, (TSupportedCommsApiExt)interfaceId);
	}

void TGetOrSetParameters::ForwardL(MeshMachine::TNodeContextBase& aContext)
	{
	TUint interfaceId = (*iDataObject)->RequiredItfExtId();
	RLegacyResponseMsg responseMsg(aContext, iMessage, iMessage.Int0());
	TRAPD(err, ForwardRequestL(aContext));
	if(err == KErrNotReady)
		{
		// We've reached the bottom of the stack, so complete the message
		if ((*iDataObject)->IsProgressive())
			{
			// If the data object was progressive (meaning it traverses the entire
			// stack progressively building up information using all nodes that
			// support its required interface) then we complete with KErrNone at
			// the bottom...
			__CFLOG_VAR((KESockComponentTag, KESockMessage,
					_L8("TGetOrSetParameters::ForwardL() Node %08x implementing interface id 0x%08x completing message (%08X) with %d"),
					&aContext.Node(), interfaceId, iMessage.Handle(), err));
			responseMsg.Complete(KErrNone);
			}
		else
			{
			// ...if on the other hand the data object was not progressive
			// hitting the bottom of the stack means it didn't find any
			// nodes that supporting its required interface. In thay case
			// we complete with KErrNotFound
			User::Leave(KErrNotFound);
			}
		return;
		}
	User::LeaveIfError(err);
	}

void TGetOrSetParameters::ProcessL(MeshMachine::TNodeContextBase& aContext)
	{
	TAny* interface = NULL;
	TUint interfaceId = (*iDataObject)->RequiredItfExtId();
	TRAPD(err, interface = FetchInterfaceL(aContext.Node(), (TSupportedCommsApiExt)interfaceId));
	ASSERT(interface);
	
	RLegacyResponseMsg responseMsg(aContext, iMessage, iMessage.Int0());
	User::LeaveIfError(err);

    if (interface)
    	{
    	XCommsDataObject::TProgressAction action(XCommsDataObject::EComplete);
    	TRAP(err, action = (*iDataObject)->DispatchL(interface, this));
		if (err != KErrNone)
			{
            NM_LOG_START_BLOCK(KESockMessage, _L8("TGetOrSetParameters::ProcessL()"));
            NM_LOG((KESockMessage, _L8("Node implementing interface id 0x%08x failed with %d"), interfaceId, err));
            NM_LOG_NODE(KESockMessage, aContext.Node().Id().Node());
            NM_LOG_END_BLOCK(KESockMessage, _L8("TGetOrSetParameters::ProcessL()"));
                
			Complete(aContext, err);
			return;
			}

		if ((action == XCommsDataObject::EComplete)
			|| !(*iDataObject)->IsProgressive())
			{
			Complete(aContext, KErrNone);
			return;
			}

	    // On successful handling of a progressive data object
	    // forward the data object down to the next node
	    TRAP(err, ForwardRequestL(aContext));

		if(err == KErrNotReady)
			{
			// We've reached the bottom of the stack, so complete the message
			Complete(aContext, KErrNone);
			return;
			}
		User::LeaveIfError(err);
    	}
	}

TInt TGetOrSetParameters::CheckError(MeshMachine::TNodeContextBase& /*aContext*/, TInt aError)
	{
	// The query set container is owned by the CConnection that originated
    // this message - if an error occurs we need to delete it and NULL the
    // pointer
	if (aError != KErrNone)
		{
		delete (*iDataObject);
		*iDataObject = NULL;
		}

	return aError;
	}

void TGetOrSetParameters::Complete(MeshMachine::TNodeContextBase& aContext, TInt aError)
	{
	RLegacyResponseMsg responseMsg(aContext, iMessage, iMessage.Int0());
	
	__CFLOG_VAR((KESockComponentTag, KESockMessage,
		_L8("TGetOrSetParameters::Complete() completing message (%08X) with %d"),
		iMessage.Handle(), aError));

	if ((*iDataObject)->OperationMode() == XCommsDataObject::EOperationSet)
		{
		// Done with the object
		delete (*iDataObject);
		*iDataObject = NULL;
		}

	responseMsg.Complete(aError);
	}