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

// All methods in this file act either to initialise the wrapper object or to forward calls

// from the async server notify class to the synchronous version.

// 

//

/**

 @file

 @internalComponent

 @see MObexServerNotify

 @see MObexServerNotifyAsync

*/

#include <e32base.h>

#include <obexserver.h>

#include <obexobjects.h>

#include "logger.h"

#include "OBEXUTIL.H"

#include "obexservernotifysyncwrapper.h"

#include "obexserverstatemachine.h"

#ifdef _DEBUG

// Save the return value as debugger will (hopefully) then make it easier to see...

#define CHECK_NOERROR(expr) TInt _saved_error = (expr); __ASSERT_ALWAYS(_saved_error == KErrNone, IrOBEXUtil::Fault(ESyncWrapperCallbackError));

#else

#define CHECK_NOERROR(expr) (void)expr

#endif

//

// Initialisation methods

//

CObexServerNotifySyncWrapper* CObexServerNotifySyncWrapper::NewL(CObexServer& aOwner, CObexServerStateMachine& aStateMachine)

	{

	CObexServerNotifySyncWrapper* self = new (ELeave) CObexServerNotifySyncWrapper(aOwner, aStateMachine);

	return self;

	}

CObexServerNotifySyncWrapper::CObexServerNotifySyncWrapper(CObexServer& aOwner, CObexServerStateMachine& aStateMachine)

	: iOwner(aOwner), iStateMachine(aStateMachine)

	{}

CObexServerNotifySyncWrapper::~CObexServerNotifySyncWrapper()

	{

	}

void CObexServerNotifySyncWrapper::SetNotifier(MObexServerNotify* aNotify)

	{

	// if aNotify is NULL this will cause any forwarding methods to dereference NULL.

	// But this should never happen.  K-E 3 will result if they do, but all we'd

	// do otherwise would be to panic anyway...

	iNotify = aNotify;

	}

//

// Forwarding methods

//

void CObexServerNotifySyncWrapper::ErrorIndication(TInt aError)

	{

	iNotify->ErrorIndication(aError);

	}

void CObexServerNotifySyncWrapper::TransportUpIndication()

	{

	iNotify->TransportUpIndication();

	}

void CObexServerNotifySyncWrapper::TransportDownIndication()

	{

	iNotify->TransportDownIndication();

	}

void CObexServerNotifySyncWrapper::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& aInfo)

	{

	// Explicitly code that we're ignoring the return value.  See the doxygen comment.

	(void)iNotify->ObexConnectIndication(aRemoteInfo, aInfo);

	}

void CObexServerNotifySyncWrapper::ObexDisconnectIndication(const TDesC8& aInfo)

	{

	iNotify->ObexDisconnectIndication(aInfo);

	}

//

// Forward the request to the MObexServerNotify implementation, then immediately

// downcall into CObexServer.

//

void CObexServerNotifySyncWrapper::PutRequestIndication()

	{

	WRAPPER_LOG(_L8("Put request indication"));

	iCallbackOutstanding = ETrue;

	iStateMachine.SetAppResponse(ERespSuccess);

	// A NULL return here is OK as it is the response to reject the request.

	CObexBaseObject* object = iNotify->PutRequestIndication();

	WRAPPER_LOG(_L8("Put request indication complete"));

	if(iCallbackOutstanding && (iStateMachine.AppResponse() == ERespSuccess))

		{

		CHECK_NOERROR(iOwner.RequestIndicationCallback(object));

		}

	}

TInt CObexServerNotifySyncWrapper::PutPacketIndication()

	{

	return iNotify->PutPacketIndication();

	}

void CObexServerNotifySyncWrapper::PutCompleteIndication()

	{

	iCallbackOutstanding = ETrue;

	TInt err = iNotify->PutCompleteIndication();

	TObexResponse resp = IrOBEXUtil::ObexResponse(err, ERespSuccess);

	if(iCallbackOutstanding)

		{

		CHECK_NOERROR(iOwner.RequestCompleteIndicationCallback(resp));

		}

	}

//

// Forward the request to the MObexServerNotify implementation, then immediately

// downcall into CObexServer.

//

void CObexServerNotifySyncWrapper::GetRequestIndication(CObexBaseObject* aRequiredObject)

	{

	WRAPPER_LOG(_L8("Get request indication"));

	iCallbackOutstanding = ETrue;

	iStateMachine.SetAppResponse(ERespSuccess);

	// A NULL return here is OK as it is the response to reject the request.

	CObexBaseObject* object = iNotify->GetRequestIndication(aRequiredObject);

	WRAPPER_LOG(_L8("Get request indication complete"));

	if(iCallbackOutstanding && (iStateMachine.AppResponse() == ERespSuccess))

		{

		CHECK_NOERROR(iOwner.RequestIndicationCallback(object));

		}

	}

TInt CObexServerNotifySyncWrapper::GetPacketIndication()

	{

	return iNotify->GetPacketIndication();

	}

void CObexServerNotifySyncWrapper::GetCompleteIndication()

	{

	iCallbackOutstanding = ETrue;

	TInt err = iNotify->GetCompleteIndication();

	TObexResponse resp = IrOBEXUtil::ObexResponse(err, ERespSuccess);

	if(iCallbackOutstanding)

		{

		CHECK_NOERROR(iOwner.RequestCompleteIndicationCallback(resp));

		}

	}

void CObexServerNotifySyncWrapper::SetPathIndication(const CObex::TSetPathInfo& aPathInfo, const TDesC8& aInfo)

	{

	iCallbackOutstanding = ETrue;

	TInt err = iNotify->SetPathIndication(aPathInfo, aInfo);

	TObexResponse resp = IrOBEXUtil::ObexResponse(err, ERespSuccess);

	if(iCallbackOutstanding)

		{

		CHECK_NOERROR(iOwner.RequestCompleteIndicationCallback(resp));

		}

	}

void CObexServerNotifySyncWrapper::AbortIndication()

	{

	iNotify->AbortIndication();

	}

void CObexServerNotifySyncWrapper::CancelIndicationCallback()

	{

	//Appilcation may stop the obex server for whatever reason during an Indication 

	//thus resets the state machine. We have to make sure not to call indication 

	//callback in such cases because the statemachine will panic. 

	iCallbackOutstanding = EFalse;

	}