// 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 connservparams.cpp
*/

#include <e32std.h>
#include <e32test.h>

#include <ecom/ecom.h>
#include <ecom/implementationproxy.h>
#include <comms-infras/metatypearray.h>
#include "cs_connservparams.h"
#include <comms-infras/cs_connservparams_internal.h>

using namespace ConnectionServ;
using namespace Meta;

START_ATTRIBUTE_TABLE( XAccessPointGenericParameterSet, KConnectionServGenericParamImplUid, KAccessPointGenericParameterSetType )
	REGISTER_ATTRIBUTE( XAccessPointGenericParameterSet, iApInfo, TMeta<TAccessPointInfo> )
	REGISTER_ATTRIBUTE( XAccessPointGenericParameterSet, iApStatus, TMeta<TAccessPointStatus> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )

START_ATTRIBUTE_TABLE( XAccessPointGenericQuery, KConnectionServGenericParamImplUid, KAccessPointGenericQueryType )
	REGISTER_ATTRIBUTE( XAccessPointGenericQuery, iApsToMatch, TMetaArray<TAccessPointInfo> )
	REGISTER_ATTRIBUTE( XAccessPointGenericQuery, iApStatusFilter, TMeta<TAccessPointStatusFilter> )
	REGISTER_ATTRIBUTE( XAccessPointGenericQuery, iParameterSetTypesToReturn, TMetaArray<STypeId> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )


// Used internally by the notification mechanism.
//  Contains 2 bit maps. The collector session with index i will mark bit i in each of these,
//   to denote:
//    iRunning  -  whether the collector knows about this access point and must match to allow report of this AP
//    iReceived -  whether the collector has received any data for this access point
//    iInSet    -  that the cache entry matches the collector's interpretation of the query filter
//    iToReport -  that the cache entry needs to be reported to the client
START_ATTRIBUTE_TABLE( XNotificationCacheParameterSet, KConnectionServGenericParamImplUid, KNotificationCacheParameterSetType )
	REGISTER_ATTRIBUTE( XNotificationCacheParameterSet, iRunning, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XNotificationCacheParameterSet, iReceived, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XNotificationCacheParameterSet, iInSet, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XNotificationCacheParameterSet, iToReport, TMeta<TUint32> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )

// Used internally by the notification mechanism between different core data collectors.
//   To allow the separation of the collector of MCPRs and the collector of data from those MCPRs.
//    iMcprCommsId	-  the comms id of the MCPR of this access point.. for passing between collectors
//    iMcprPtr		-  pointer to the same MCPR
START_ATTRIBUTE_TABLE( XCoreCollectorSharedParameterSet, KConnectionServGenericParamImplUid, KCoreCollectorSharedParameterSetType )
	REGISTER_ATTRIBUTE( XCoreCollectorSharedParameterSet, iMcprCommsId, TMeta<Messages::TNodeId> )
	REGISTER_ATTRIBUTE( XCoreCollectorSharedParameterSet, iMcprPtr, TMeta<CBase*> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )

// Used internally to contain information about the IP Proto layer by CConnection legacy calls.
START_ATTRIBUTE_TABLE( XIpProtoAccessPointParameterSet, KConnectionServGenericParamImplUid, KIpProtoAccessPointParameterSetType )
	REGISTER_ATTRIBUTE( XIpProtoAccessPointParameterSet, iIapId, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XIpProtoAccessPointParameterSet, iNetworkId, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XIpProtoAccessPointParameterSet, iConnectionType, TMeta<TUint32> )
	REGISTER_ATTRIBUTE( XIpProtoAccessPointParameterSet, iControlClientId, TMeta<Messages::TNodeId> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )

//  Only used internally at the moment, by EnumerateConnections
START_ATTRIBUTE_TABLE( XAccessPointPlaneStatusParameterSet, KConnectionServGenericParamImplUid, KAccessPointPlaneStatusParameterSetType )
	REGISTER_ATTRIBUTE( XAccessPointPlaneStatusParameterSet, iPlaneStatus, TMeta<TAccessPointPlaneStatus> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )

//  Only used internally at the moment, by EnumerateConnections
START_ATTRIBUTE_TABLE( XAccessPointPlaneStatusQuery, KConnectionServGenericParamImplUid, KAccessPointPlaneStatusQueryType )
	REGISTER_ATTRIBUTE( XAccessPointPlaneStatusQuery, iPlaneStatusFilter, TMeta<TAccessPointPlaneStatusFilter> )
END_ATTRIBUTE_TABLE_BASE( XConnectionServParameterSet, 0 )





// Define the interface UIDs
const TImplementationProxy ImplementationTable[] =
	{
	IMPLEMENTATION_PROXY_ENTRY(KConnectionServGenericParamImplUid, CConnectionServGenericParamsFactory::NewL),
	};

/**
ECOM Implementation Factories
*/

//extern "C" { IMPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount); }

EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
    {
    aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);

    return ImplementationTable;
    }

/**
Plugin Implementation
*/

XConnectionServParameterSet* CConnectionServGenericParamsFactory::NewL(TAny* aConstructionParameters)
	{
	TInt32 type = reinterpret_cast<TInt32>(aConstructionParameters);
	switch (type)
		{
	case (KAccessPointGenericParameterSetType):
		return new (ELeave) XAccessPointGenericParameterSet;
	case (KAccessPointGenericQueryType):
		return new (ELeave) XAccessPointGenericQuery;
	case (KNotificationCacheParameterSetType):
		return new (ELeave) XNotificationCacheParameterSet;
	case (KCoreCollectorSharedParameterSetType):
		return new (ELeave) XCoreCollectorSharedParameterSet;
	case (KIpProtoAccessPointParameterSetType):
		return new (ELeave) XIpProtoAccessPointParameterSet;
	case (KAccessPointPlaneStatusParameterSetType):
		return new (ELeave) XAccessPointPlaneStatusParameterSet;
	case (KAccessPointPlaneStatusQueryType):
		return new (ELeave) XAccessPointPlaneStatusQuery;
	default:
		User::Leave(KErrNotFound);
		}
	return NULL;
	}


/*virtual*/ void XAccessPointGenericParameterSet::UpdateWithL(const XParameterSet& aRhsBase)
	{
	const XAccessPointGenericParameterSet& aRhs = static_cast<const XAccessPointGenericParameterSet&>(aRhsBase);
	if(aRhs.AccessPointInfo().AccessPoint())
		{
		iApInfo = aRhs.iApInfo;
		}
	iApStatus.UpdateWith(aRhs.iApStatus);
	}

/*virtual*/ void XAccessPointGenericParameterSet::CopyFieldsRequiredByQueryFromL(
						const CParameterBundleBase& aQueryBundle,const XConnectionServParameterSet& aSourceBase)
	{
	const XAccessPointGenericParameterSet& aSource = static_cast<const XAccessPointGenericParameterSet&>(aSourceBase);
	const CParameterSetContainer* aQueryCtr = aQueryBundle.GetParamSetContainer(0);
	User::LeaveIfNull((TAny*)aQueryCtr);
	const XAccessPointGenericQuery* aQuerySet = XAccessPointGenericQuery::FindInParamSetContainer(*aQueryCtr);
	User::LeaveIfNull((TAny*)aQuerySet);
	iApInfo = aSource.iApInfo;
	iApStatus.CopyFieldsRequiredByQueryFrom(aQuerySet->AccessPointStatusFilter(),aSource.iApStatus);
	}

/*virtual*/ TInt XAccessPointGenericParameterSet::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	TAccessPointInfo inf = this->AccessPointInfo();
	TAccessPointStatus stat = this->AccessPointStatus();
	aBuf.AppendFormat(_L("GPS: AP:%d C:%c R:%c A:%c S:%c"),&ignoreOverflow,
						inf.AccessPoint(),
						TAccessPointStatus::FlagValueAsChar(stat.Configured()),
						TAccessPointStatus::FlagValueAsChar(stat.Restricted()),
						TAccessPointStatus::FlagValueAsChar(stat.Available()),
						TAccessPointStatus::FlagValueAsChar(stat.Started()) );
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}


/*virtual*/ XAccessPointGenericQuery::~XAccessPointGenericQuery()
	{
	iApsToMatch.Close();
	iParameterSetTypesToReturn.Close();
	}

TBool CompareTypeIds(const STypeId& aFirst, const STypeId& aSecond)
    {
    return( aFirst == aSecond );
    }

/*virtual*/ TBool XAccessPointGenericQuery::ShouldReturnType(const STypeId& aTypeId) const
	{
	return iParameterSetTypesToReturn.Find(aTypeId,TIdentityRelation<STypeId>(CompareTypeIds)) != KErrNotFound ;
	}

/*virtual*/ TInt XAccessPointGenericQuery::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	aBuf.AppendFormat(_L("GQ: APs("),&ignoreOverflow);

	const RArray<TAccessPointInfo>& aps = this->AccessPointsToMatch();
	TAccessPointStatusFilter apsf = this->AccessPointStatusFilter();
	const RArray<STypeId>& types = this->GetParameterSetTypesToReturn();

	TInt i=0;
	for( ; i<aps.Count(); ++i)
		{
		if(i)
			{
			aBuf.AppendFormat(_L(","),&ignoreOverflow);
			}
		aBuf.AppendFormat(_L("%d"),&ignoreOverflow,aps[i].AccessPoint());
		}
	
	aBuf.AppendFormat(_L(") C:%c R:%c A:%c S:%c typ("),&ignoreOverflow,
					TAccessPointStatusFilter::FilterValueAsChar(apsf.Configured()),
					TAccessPointStatusFilter::FilterValueAsChar(apsf.Restricted()),
					TAccessPointStatusFilter::FilterValueAsChar(apsf.Available()),
					TAccessPointStatusFilter::FilterValueAsChar(apsf.Started()) );

	for(i=0 ; i<types.Count(); ++i)
		{
		if(i)
			{
			aBuf.AppendFormat(_L(","),&ignoreOverflow);
			}
		aBuf.AppendFormat(_L("%S-%08x)"),&ignoreOverflow,
				types[i].iUid.iUid,
				types[i].iType );
		}
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}


/*virtual*/ TInt XNotificationCacheParameterSet::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	aBuf.AppendFormat(_L("NCP: Rg%032b Rd%032b IS%032b TR%032b"),&ignoreOverflow,
			this->RunningValue(),
			this->ReceivedValue(),
			this->InSetValue(),
			this->ToReportValue() );
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}


/*virtual*/ void XCoreCollectorSharedParameterSet::UpdateWithL(const XParameterSet& aRhsBase)
	{
	const XCoreCollectorSharedParameterSet& aRhs = static_cast<const XCoreCollectorSharedParameterSet&>(aRhsBase);

	if(aRhs.iMcprPtr)
		{
		iMcprPtr=aRhs.iMcprPtr;
		iMcprCommsId=aRhs.iMcprCommsId;
		}
	}

/*virtual*/ TInt XCoreCollectorSharedParameterSet::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	aBuf.AppendFormat(_L("CCSPS:mcpr %08x"),&ignoreOverflow,
		reinterpret_cast<TUint32>(this->McprPtr()) );
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}


/*virtual*/ void XIpProtoAccessPointParameterSet::UpdateWithL(const XParameterSet& aRhsBase)
	{
	const XIpProtoAccessPointParameterSet& aRhs = static_cast<const XIpProtoAccessPointParameterSet&>(aRhsBase);

	iIapId = aRhs.iIapId;
	iNetworkId = aRhs.iNetworkId;
	iConnectionType = aRhs.iConnectionType;
	iControlClientId = aRhs.iControlClientId;
	}

/*virtual*/ TInt XIpProtoAccessPointParameterSet::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	aBuf.AppendFormat(_L("IPPAPS:IAP:%d Net:%d ConnType:%d"),&ignoreOverflow,
							this->IapId(),
							this->NetworkId(),
							this->ConnectionType() );	
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}


/*virtual*/ void XAccessPointPlaneStatusParameterSet::UpdateWithL(const XParameterSet& aRhsBase)
	{
	const XAccessPointPlaneStatusParameterSet& aRhs = static_cast<const XAccessPointPlaneStatusParameterSet&>(aRhsBase);
	iPlaneStatus.UpdateWithL(aRhs.iPlaneStatus);
	}

/*virtual*/ void XAccessPointPlaneStatusParameterSet::CopyFieldsRequiredByQueryFromL(
						const CParameterBundleBase& aQueryBundle,const XConnectionServParameterSet& aSourceBase)
	{
	const XAccessPointPlaneStatusParameterSet& aSource = static_cast<const XAccessPointPlaneStatusParameterSet&>(aSourceBase);
	const CParameterSetContainer* aQueryCtr = aQueryBundle.GetParamSetContainer(0);
	User::LeaveIfNull((TAny*)aQueryCtr);
	const XAccessPointPlaneStatusQuery* aQuerySet = XAccessPointPlaneStatusQuery::FindInParamSetContainer(*aQueryCtr);
	User::LeaveIfNull((TAny*)aQuerySet);

	iPlaneStatus.CopyFieldsRequiredByQueryFrom(aQuerySet->PlaneStatusFilter(),aSource.iPlaneStatus);
	}

/*virtual*/ TInt XAccessPointPlaneStatusParameterSet::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	const TAccessPointPlaneStatus& ps = this->PlaneStatus();
	aBuf.AppendFormat(_L("PlSt:T..M..C%c.S..F.."),&ignoreOverflow,
			TAccessPointStatus::FlagValueAsChar(ps.Connection_Exists()));
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}

/*virtual*/ TInt XAccessPointPlaneStatusQuery::AppendPrintableTo(TDes& aBuf) const
	{
#ifdef __CFLOG_ACTIVE
	TDes16IgnoreOverflow ignoreOverflow;
	const TAccessPointPlaneStatusFilter& psf = this->PlaneStatusFilter();
	aBuf.AppendFormat(_L("PlSt:T..M..C%c.S..F.."),&ignoreOverflow,
			TAccessPointStatusFilter::FilterValueAsChar(psf.Connection_Exists()));
	return KErrNone;
#else
	(void)aBuf;
	return KErrNotSupported;
#endif // __CFLOG_ACTIVE
	}