// Copyright (c) 1997-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
*/

#include <comms-infras/es_api_ext.h>
#include <comms-infras/es_connectionservermessages.h>
#include <comms-infras/api_ext_msg.h>
#include <comms-infras/sockmes.h>


#ifdef _DEBUG
// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
// (if it could happen through user error then you should give it an explicit, documented, category + code)
_LIT(KSpecAssert_ESockCSockcsp_xt, "ESockCSockcsp_xt");
#endif

using namespace Elements;


CCommsSessionApiExtProvider::CCommsSessionApiExtProvider(RCommsSession& session)
: iSession(session)
	{
	}
	
CCommsSessionApiExtProvider *CCommsSessionApiExtProvider::Open(
		RCommsSession& aExtensionProvider, TSupportedCommsApiExt aInterfaceId, TInt &error)
	{
	__ASSERT_ALWAYS(aExtensionProvider.Handle(), User::Panic(KApiExtPanic, EApiExtBadHandle));
	CCommsSessionApiExtProvider *provider = new CCommsSessionApiExtProvider(aExtensionProvider);
	if (!provider)
		{
		error = KErrNoMemory;
		return NULL;
		}
		
	error = aExtensionProvider.SendReceive(ECMApiExtBindIface, TIpcArgs(aInterfaceId));

	if (KErrNone != error)
		{
		delete provider;
		return NULL;
		}
	return provider;
	}
	
TInt CCommsSessionApiExtProvider::Close(const TIpcArgs& aArgs) const	
	{
	return iSession.SendReceive(ECMApiExtIfaceClose, aArgs);
	}

TInt CCommsSessionApiExtProvider::Handle() const
	{
	return iSession.Handle();
	}

TInt CCommsSessionApiExtProvider::Send(const TIpcArgs& aArgs) const	
	{
	return iSession.SendReceive(ECMApiExtIfaceSend, aArgs);
	}

void CCommsSessionApiExtProvider::SendReceive(const TIpcArgs& aArgs,TRequestStatus& aStatus) const
	{
	iSession.SendReceive(ECMApiExtIfaceSendReceive, aArgs, aStatus);
	}

void CCommsSessionApiExtProvider::Release()
	{
	delete this;
	}

CCommsSubSessionApiExtProvider::CCommsSubSessionApiExtProvider(RCommsSubSession& subsession)
: iSubSession(subsession)
	{
	}

CCommsSubSessionApiExtProvider *CCommsSubSessionApiExtProvider::Open(
		RCommsSubSession& aExtensionProvider, TSupportedCommsApiExt aInterfaceId, TInt &error)
	{
	__ASSERT_ALWAYS(aExtensionProvider.SubSessionHandle(), User::Panic(KApiExtPanic, EApiExtBadHandle));
	CCommsSubSessionApiExtProvider *provider = new CCommsSubSessionApiExtProvider(aExtensionProvider);
	if (!provider)
		{
		error = KErrNoMemory;
		return NULL;
		}
		
	error = aExtensionProvider.SendReceive(ECommsApiExtBindIface, TIpcArgs(aInterfaceId));

	if (KErrNone != error)
		{
		delete provider;
		return NULL;
		}
	return provider;
	}

TInt CCommsSubSessionApiExtProvider::Close(const TIpcArgs& aArgs) const	
	{
	return iSubSession.SendReceive(ECommsApiExtIfaceClose, aArgs);
	}

TInt CCommsSubSessionApiExtProvider::Handle() const
	{
	return iSubSession.SubSessionHandle();
	}

TInt CCommsSubSessionApiExtProvider::Send(const TIpcArgs& aArgs) const	
	{
	return iSubSession.SendReceive(ECommsApiExtIfaceSend, aArgs);
	}

void CCommsSubSessionApiExtProvider::SendReceive(const TIpcArgs& aArgs,TRequestStatus& aStatus) const
	{
	iSubSession.SendReceive(ECommsApiExtIfaceSendReceive, aArgs, aStatus);
	}

void CCommsSubSessionApiExtProvider::Release()
	{
	delete this;
	}


EXPORT_C RCommsApiExtensionBase::RCommsApiExtensionBase()
: iProvider(0)
    {
    }

EXPORT_C TInt RCommsApiExtensionBase::Open(RCommsSession& aExtensionProvider, TSupportedCommsApiExt aInterfaceId)
	{
	if (iProvider)
		{
		return KErrInUse;
		}

	TInt error = KErrNone;
	iProvider = CCommsSessionApiExtProvider::Open(aExtensionProvider, aInterfaceId, error);
	
	if (error == KErrNone)
		{
		iInterfaceId = aInterfaceId;
		}	
	return error;
	}

EXPORT_C TInt RCommsApiExtensionBase::Open(RCommsSubSession& aExtensionProvider, TSupportedCommsApiExt aInterfaceId)
	{
	if (iProvider)
		{
		return KErrInUse;
		}

	TInt error = KErrNone;
	iProvider = CCommsSubSessionApiExtProvider::Open(aExtensionProvider, aInterfaceId, error);
	
	if (error == KErrNone)
		{
		iInterfaceId = aInterfaceId;
		}	
	return error;
	}


EXPORT_C void RCommsApiExtensionBase::Close()
	{
	if (iProvider && iProvider->Handle())
		{
		iProvider->Close(TIpcArgs(iInterfaceId));
		iProvider->Release();
		iProvider = NULL;
		}
	
#if defined( _DEBUG )
	for (TInt index = iBuffers.Count() - 1; index >= 0; --index)
		{
		if (iBuffers[index]->Length()!=0)
			{
			User::Invariant(); //The request has not been processed by the server yet
			}
		}
#endif

	iBuffers.ResetAndDestroy();
	}

EXPORT_C void RCommsApiExtensionBase::SendRequest(TCommsApiExtReqMsg& aRequestMsg, TDes8& aResponseBuf, TRequestStatus& aStatus)
	{
	__ASSERT_ALWAYS(iProvider && iProvider->Handle(), User::Panic(KApiExtPanic, EApiExtBadHandle));

	//clean up all used up buffers
	for (TInt index = iBuffers.Count() - 1; index >= 0; --index)
		{
		if (iBuffers[index]->Length()==0)
			{
			delete iBuffers[index];
			iBuffers.Remove(index);
			}
		}

	TInt error = KErrNoMemory;
	TRBuf8* buffer = TRBuf8::New(aRequestMsg.Length());
	if (buffer!=NULL)
		{
		error = iBuffers.Append(buffer); //stick new buffer into the array
		if (error==KErrNone)
			{
			error = aRequestMsg.Store(*buffer);
			if (error==KErrNone)
				{
				iProvider->SendReceive(TIpcArgs(iInterfaceId,buffer,&aResponseBuf), aStatus);
				}
			else
				{
				__ASSERT_DEBUG(iBuffers[iBuffers.Count()-1]==buffer, User::Panic(KSpecAssert_ESockCSockcsp_xt, 1)); //make sure we are removing what we believe we are removing
				iBuffers.Remove(iBuffers.Count()-1); //remove the buffer
				delete buffer;
				buffer = NULL;
				}
			}
		else
			{
			delete buffer;
			buffer = NULL;
			}
		}

	if (error!=KErrNone)
		{
		TRequestStatus* status = &aStatus;
		User::RequestComplete(status,error);
		return;
		}
	}

EXPORT_C void RCommsApiExtensionBase::SendMessage(TCommsApiExtReqMsg& aRequestMsg)
	{
	__ASSERT_ALWAYS(iProvider && iProvider->Handle(), User::Panic(KApiExtPanic, EApiExtBadHandle));
	__ASSERT_ALWAYS((aRequestMsg.Length() <= KMaxExtApiIpcMsgLength), User::Panic(KApiExtPanic, EApiExtMetaOverflow));

	TBuf8<KMaxExtApiIpcMsgLength> buffer;
	if (aRequestMsg.Store(buffer) != KErrNone)
		{
		User::Panic(KApiExtPanic, EApiExtMetaOverflow);
		}
		
	iProvider->Send(TIpcArgs(iInterfaceId, &buffer));
	}