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

// UPnP-proprietary messages

// 

//

/**

 @file

 @internalTechnology

*/

//System Includes 

#include <ss_glob.h>

#include <comms-infras/metatype.h>

#include <comms-infras/metabuffer.h>

#include <comms-infras/ss_thread.h>

//Local Includes

#include "upnp_cf_msgs.h"

#include "upnpflowbase.h"

#include "httpserverflow.h"

#include "httpclientflow.h"

using namespace Messages;

using namespace Factories;

// UPnP Message _Signatures_ (NOT messages)

enum EMessageTypeId 

	{        

    ESigParamSet			= 1,		

    EUPnPFlow				= 2,

    EClientFlow				= 3,

    EServerFlow				= 4,

    EUdpFlow				= 5,

    ESigNumberVersionMemChunk = 6,

    ESigNumberMemChunk		= 7,

    ESigParamSetFlow 		= 8,

    ESigUPnPRequestInfo		= 9,

    ESigUPnPResponseInfo	= 10,

    ESigUPnPSubscriptionInfo = 11,

    ESigRMemChunkFlow      = 12,

    ESigRMBufInt			= 13,

    ESigSsdpInfo			= 14,

    ESigParamSetAny			= 15,

    ESigTUint8Size       	= 16,

    ESigUPnPClientRequestInfo		= 17,

    ESigUPnPSubscribeReqInfo = 18,

    ESigUPnPEventNotifyReqInfo = 19,

	};

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigParamSet, KUpnpMessagesImplementationUid, ESigParamSet )

	REGISTER_ATTRIBUTE ( TSigParamSet, iParamSet, TMeta<CSubConExtensionParameterSet*> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TUPnPFlowQuery, KUpnpMessagesImplementationUid, EUPnPFlow )

	REGISTER_ATTRIBUTE ( TUPnPFlowQuery, iSCPRId, TMeta<TNodeId> )

	REGISTER_ATTRIBUTE ( TUPnPFlowQuery, iDataClientType, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TUPnPFlowQuery, iChunkManager, TMeta<TAny*> )

END_ATTRIBUTE_TABLE ()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( THttpClientFlowQuery, KUpnpMessagesImplementationUid, EClientFlow )

	REGISTER_ATTRIBUTE ( THttpClientFlowQuery, iSockAddr, TMeta<TAppProtAddr> )

	REGISTER_ATTRIBUTE ( THttpClientFlowQuery, iClientFlags, TMeta<TInt> )

END_ATTRIBUTE_TABLE_BASE ( TUPnPFlowQuery, EUPnPFlow )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN( THttpServerFlowQuery, KUpnpMessagesImplementationUid, EServerFlow )

	REGISTER_ATTRIBUTE ( THttpServerFlowQuery, iUri, TMeta<TUint8*> )

	REGISTER_ATTRIBUTE ( THttpServerFlowQuery, iLength, TMeta<TInt> )

END_ATTRIBUTE_TABLE_BASE(TUPnPFlowQuery, EUPnPFlow)

EXPORT_START_ATTRIBUTE_TABLE_AND_FN( THttpUdpFlowQuery, KUpnpMessagesImplementationUid, EUdpFlow )

END_ATTRIBUTE_TABLE_BASE(TUPnPFlowQuery, EUPnPFlow)

EXPORT_START_ATTRIBUTE_TABLE_AND_FN( TSigNumberVersionMemChunk, KUpnpMessagesImplementationUid, ESigNumberVersionMemChunk )

	REGISTER_ATTRIBUTE ( TSigNumberVersionMemChunk, iStatus, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TSigNumberVersionMemChunk, iVersion, TMeta<TVersion> )

	REGISTER_ATTRIBUTE ( TSigNumberVersionMemChunk, iBodyData, TMeta<RMemChunk> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN( TSigNumberMemChunk, KUpnpMessagesImplementationUid, ESigNumberMemChunk )

	REGISTER_ATTRIBUTE ( TSigNumberMemChunk, iTimeOut, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TSigNumberMemChunk, iURN, TMeta<RMemChunk> )

END_ATTRIBUTE_TABLE_BASE ( TSigNumberVersionMemChunk, ESigNumberVersionMemChunk )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigParamSetFlow, KUpnpMessagesImplementationUid, ESigParamSetFlow )

	REGISTER_ATTRIBUTE ( TSigParamSetFlow, iParamSet, TMeta<CSubConExtensionParameterSet*> )

	REGISTER_ATTRIBUTE ( TSigParamSetFlow, iFlowId, TMeta<TNodeId> )	

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigUPnPResponseInfo, KUpnpMessagesImplementationUid, ESigUPnPResponseInfo )

	REGISTER_ATTRIBUTE ( TSigUPnPResponseInfo, iTrans, TMeta<CTransaction*> )

	REGISTER_ATTRIBUTE ( TSigUPnPResponseInfo, iStatus, TMeta<TInt> )	

	REGISTER_ATTRIBUTE ( TSigUPnPResponseInfo, iInfo, TMetaPtr<SMetaDataNetCtorExt> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigRMemChunkFlow, KUpnpMessagesImplementationUid, ESigRMemChunkFlow )

	REGISTER_ATTRIBUTE ( TSigRMemChunkFlow, iMemChunk, TMeta<RMemChunk> )

	REGISTER_ATTRIBUTE ( TSigRMemChunkFlow, iFlowId, TMeta<TNodeId> )	

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSubsribeResponseInfo, KUpnpMessagesImplementationUid, ESigUPnPSubscriptionInfo )

	REGISTER_ATTRIBUTE ( TSubsribeResponseInfo, iSid, TMeta<RMemChunk> )

	REGISTER_ATTRIBUTE ( TSubsribeResponseInfo, iTimeout, TMeta<TInt> )

END_ATTRIBUTE_TABLE ()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigSsdpInfo, KUpnpMessagesImplementationUid, ESigSsdpInfo )

	REGISTER_ATTRIBUTE ( TSigSsdpInfo, iSsdpInfo, TMeta<TSsdpInfo> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigParamSetAny, KUpnpMessagesImplementationUid, ESigParamSetAny )

	REGISTER_ATTRIBUTE ( TSigParamSetAny, iParamSet, TMeta<CSubConExtensionParameterSet*> )

	REGISTER_ATTRIBUTE ( TSigParamSetAny, iPtr, TMeta<TAny*> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigTUint8Size, KUpnpMessagesImplementationUid, ESigTUint8Size )

	REGISTER_ATTRIBUTE ( TSigTUint8Size, iPtr, TMeta<TUint8*> )

	REGISTER_ATTRIBUTE ( TSigTUint8Size, iSize, TMeta<TInt> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSigUPnPClientRequestInfo, KUpnpMessagesImplementationUid, ESigUPnPClientRequestInfo )

	REGISTER_ATTRIBUTE ( TSigUPnPClientRequestInfo, iRequestMethod, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TSigUPnPClientRequestInfo, iUri, TMeta<RMemChunk> )	

	REGISTER_ATTRIBUTE ( TSigUPnPClientRequestInfo, iBody, TMeta<RMemChunk> )

	REGISTER_ATTRIBUTE ( TSigUPnPClientRequestInfo, iInfo, TMetaPtr<SMetaDataNetCtorExt> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TSubscribeRequestInfo, KUpnpMessagesImplementationUid, ESigUPnPSubscribeReqInfo )

	REGISTER_ATTRIBUTE ( TSubscribeRequestInfo, iTimeOut, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TSubscribeRequestInfo, iCallback, TMeta<RMemChunk> )	

	REGISTER_ATTRIBUTE ( TSubscribeRequestInfo, iSid, TMeta<RMemChunk> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

EXPORT_START_ATTRIBUTE_TABLE_AND_FN ( TEventNotifyRequestInfo, KUpnpMessagesImplementationUid, ESigUPnPEventNotifyReqInfo )

	REGISTER_ATTRIBUTE ( TEventNotifyRequestInfo, iSeqKey, TMeta<TInt> )

	REGISTER_ATTRIBUTE ( TEventNotifyRequestInfo, iSid, TMeta<RMemChunk> )

END_ATTRIBUTE_TABLE_BASE ( TSignatureBase, ESignatureVoid )

DEFINE_MVIP_CTR ( TSigParamSet );

DEFINE_MVIP_CTR ( TUPnPFlowQuery);

DEFINE_MVIP_CTR ( THttpClientFlowQuery );

DEFINE_MVIP_CTR ( THttpServerFlowQuery );

DEFINE_MVIP_CTR ( THttpUdpFlowQuery );

DEFINE_MVIP_CTR ( TSigNumberVersionMemChunk );

DEFINE_MVIP_CTR ( TSigNumberMemChunk );

DEFINE_MVIP_CTR ( TSigParamSetFlow );

DEFINE_MVIP_CTR ( TSigUPnPResponseInfo );

DEFINE_MVIP_CTR ( TSubsribeResponseInfo );

DEFINE_MVIP_CTR ( TSigRMemChunkFlow );

DEFINE_MVIP_CTR ( TSigSsdpInfo );

DEFINE_MVIP_CTR ( TSigParamSetAny );

DEFINE_MVIP_CTR ( TSigTUint8Size );

DEFINE_MVIP_CTR ( TSigUPnPClientRequestInfo );

DEFINE_MVIP_CTR ( TSubscribeRequestInfo );

DEFINE_MVIP_CTR ( TEventNotifyRequestInfo );

const TImplementationProxy SignatureImplementationTable[] = 

	{

	//NOTE: Entries must be sorted for the binary search to work efficiently!

	MVIP_CTR_ENTRY ( ESigParamSet, TSigParamSet ),

	MVIP_CTR_ENTRY ( EUPnPFlow, TUPnPFlowQuery ),

	MVIP_CTR_ENTRY ( EClientFlow, THttpClientFlowQuery ),

	MVIP_CTR_ENTRY ( EServerFlow, THttpServerFlowQuery ),

	MVIP_CTR_ENTRY ( EUdpFlow, THttpUdpFlowQuery ),

	MVIP_CTR_ENTRY ( ESigNumberVersionMemChunk, TSigNumberVersionMemChunk ),

	MVIP_CTR_ENTRY ( ESigNumberMemChunk, TSigNumberMemChunk ),

	MVIP_CTR_ENTRY ( ESigParamSetFlow, TSigParamSetFlow ),

	MVIP_CTR_ENTRY ( ESigUPnPResponseInfo, TSigUPnPResponseInfo ),	

	MVIP_CTR_ENTRY ( ESigUPnPSubscriptionInfo, TSubsribeResponseInfo ),

	MVIP_CTR_ENTRY ( ESigRMemChunkFlow, TSigRMemChunkFlow ),

	MVIP_CTR_ENTRY ( ESigSsdpInfo, TSigSsdpInfo ),

	MVIP_CTR_ENTRY ( ESigParamSetAny, TSigParamSetAny ),

	MVIP_CTR_ENTRY ( ESigTUint8Size, TSigTUint8Size ),

	MVIP_CTR_ENTRY ( ESigUPnPClientRequestInfo, TSigUPnPClientRequestInfo ),

	MVIP_CTR_ENTRY ( ESigUPnPSubscribeReqInfo, TSubscribeRequestInfo ),

	MVIP_CTR_ENTRY ( ESigUPnPEventNotifyReqInfo, TEventNotifyRequestInfo ),

	};

/*

Note we need to register if a message needs to carries completely new set of parameters that is not supported by 

TCFMessage....for this refer TCFUmtsIfMessageSig in IPProtoMessages.h

*/

EXPORT_C void TUpnpMessage::RegisterL ( Den::CCommonWorkerThread *aWorkerThread )

	{

	ASSERT ( aWorkerThread );	

	aWorkerThread->TransportGlobals().RegisterInterfaceL ( TUid::Uid( KUpnpMessagesImplementationUid), sizeof(SignatureImplementationTable) / sizeof(SignatureImplementationTable[0] ), SignatureImplementationTable );	

	}

EXPORT_C void TUpnpMessage::DeRegister ( )

	{

	CWorkerThread* worker = SockManGlobals::Get()->SelfWorker();

	ASSERT ( worker );

	worker->TransportGlobals().DeregisterInterface( TUid::Uid ( KUpnpMessagesImplementationUid ) );

	}

EXPORT_C MFactoryQuery::TMatchResult TUPnPFlowQuery::Match( TFactoryObjectInfo& aObjectInfo )

	{

	CUPnPFlowBase* flow = static_cast<CUPnPFlowBase*>(aObjectInfo.iInfo.iFactoryObject);

	if( ( iDataClientType == EHttpClientFlow ) && ( flow->FlowType() == EHttpClientFlow ) )

		{

		return static_cast<THttpClientFlowQuery&>(*this).Compare(aObjectInfo);

		}

	if( ( iDataClientType == EHttpServerFlow ) && ( flow->FlowType() == EHttpServerFlow ) )

		{

		return static_cast<THttpServerFlowQuery&>(*this).Compare(aObjectInfo);

		}

	if( ( iDataClientType == EHttpUdpFlow ) && ( flow->FlowType() == EHttpUdpFlow ) )

		{

		return static_cast<THttpUdpFlowQuery&>(*this).Compare(aObjectInfo);

		}

	if( ( iDataClientType == EHttpMUdpFlow ) && ( flow->FlowType() == EHttpMUdpFlow ) )

		{

		return static_cast<THttpUdpFlowQuery&>(*this).Compare(aObjectInfo);

		}

	return MFactoryQuery::EContinue;

	}

MFactoryQuery::TMatchResult THttpServerFlowQuery::Compare( TFactoryObjectInfo& aFactoryObjectInfo )

	{

	CHttpServerFlow* flow = static_cast<CHttpServerFlow*>(aFactoryObjectInfo.iInfo.iFactoryObject);

	TPtrC8 uri(iUri);

	if(flow->Uri() == uri)

		{

		return MFactoryQuery::EMatch;

		}

	return MFactoryQuery::EContinue;

	}

MFactoryQuery::TMatchResult THttpUdpFlowQuery::Compare(TFactoryObjectInfo& /*aFactoryObjectInfo*/ )

	{

	return MFactoryQuery::EMatch;

	}

MFactoryQuery::TMatchResult THttpClientFlowQuery::Compare(TFactoryObjectInfo& aFactoryObjectInfo )

	{

	const CHttpClientFlow* flow = static_cast<const CHttpClientFlow*>(aFactoryObjectInfo.iInfo.iFactoryObject);

	// iClientFlags == ECreateNew is handled by factory, other needs to be checked here	

 	TInetAddr remName;

   	flow->RemName( remName );

  	if ( remName.Address ( ) == iSockAddr.iAddr && remName.Port ( ) ==  iSockAddr.iPort && flow->Status( ) == KErrNone )

		{

		return MFactoryQuery::EMatch;

		}

	return MFactoryQuery::EContinue;

	}

EXPORT_C SMetaDataNetCtor* SMetaDataNetCtorExt::LoadL(TPtrC8& aDes)

	{

	TUint8* ptr = const_cast<TUint8*> ( aDes.Ptr() );

	TPtr8 ptr2 ( ptr, aDes.Length() );

	RBuf8 buf;

	buf.CreateL(aDes);

	TPtrC8 ptr3 (buf.Ptr(), buf.Length());

	CMetaDataVirtualCtorInPlace* vctr = SockManGlobals::Get()->SelfWorker()->TransportGlobals().VirtualCtor();

	SMetaDataNetCtor* meta = vctr->New(ptr3, ptr2);

	TInt len = buf.Length() - ptr3.Length();

	aDes.Set(aDes.Ptr() + len, aDes.Length() - len);

	buf.Close();

	return meta;

	}