/*

* Copyright (c) 2002 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:  SyncML Obex server binding

*

*/

#include "nsmlobexserverbinding.h"

#include "nsmlerror.h"

// CONSTANTS

_LIT( KInvalidState, "Invalid state" );

//============================================================

// CNSmlObexServerBinding definition

//============================================================

//------------------------------------------------------------

// CNSmlObexServerBinding::NewL()

//------------------------------------------------------------

CNSmlObexServerBinding* CNSmlObexServerBinding::NewL()

    {

	CNSmlObexServerBinding* self = new (ELeave) CNSmlObexServerBinding();

	CleanupStack::PushL( self );

    self->ConstructL();

	CleanupStack::Pop(); //self

    return self;

    }

//------------------------------------------------------------

// CNSmlObexServerBinding::CNSmlObexServerBinding()

//------------------------------------------------------------

CNSmlObexServerBinding::CNSmlObexServerBinding() : CActive(0)

	{

	CActiveScheduler::Add( this );

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::~CNSmlObexServerBinding()

//------------------------------------------------------------

CNSmlObexServerBinding::~CNSmlObexServerBinding()

	{

	_DBG_FILE("CNSmlObexServerBinding::~CNSmlObexServerBinding() begin");

	if( iContent == ENSmlDataSync && iSessionAlive )

		{

		_DBG_FILE("Closing iCsDS");

		iCsDS.Disconnect();

		iCsDS.Close();

		}

	if( iContent == ENSmlDeviceManagement && iSessionAlive )

		{

		_DBG_FILE("Closing iCsDM");

		iCsDM.Disconnect();

		iCsDM.Close();

		}

	Cancel();

	_DBG_FILE("CNSmlObexServerBinding::~CNSmlObexServerBinding() end");

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::ConstructL()

// 2-phase

//------------------------------------------------------------

void CNSmlObexServerBinding::ConstructL()

    {

	iSessionAlive = EFalse;

    }

//------------------------------------------------------------

// CNSmlObexServerBinding* CreateCNsmlObexServerBindingL()

// 

//------------------------------------------------------------

EXPORT_C CNSmlObexServerBinding* CreateCNsmlObexServerBindingL()

	{

	return CNSmlObexServerBinding::NewL();

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::Connect( TNSmlObexTransport /*aTransport*/,TBool /*aServerAlerted*/, TDesC8& /*aMimeType*/, TRequestStatus &aStatus )

// 

//------------------------------------------------------------

void CNSmlObexServerBinding::Connect( TNSmlObexTransport /*aTransport*/,TBool /*aServerAlerted*/, TDesC8& aMimeType, TRequestStatus &aStatus )

	{

	_DBG_FILE("CNSmlObexServerBinding::Connect");

	TInt err ( KErrNone );

	iCancelledByServer = EFalse;

	iAgentStatus = &aStatus;

	*iAgentStatus = KRequestPending;

	if( aMimeType.Compare( KDataSyncMIME ) == 0 )

		{

		_DBG_FILE("Data sync MIME type");

		iContent = ENSmlDataSync;

		}

	else

		{

		_DBG_FILE("Dev Man MIME type");

		iContent = ENSmlDeviceManagement;

		}

	err = ConnectToServer();

	DBG_FILE_CODE( err, _S8("ConnectToServer returned") );

	if ( err )

	    {

	    _DBG_FILE("ConnectToServer error converted to Server not responding");

	    err = TNSmlError::ESmlServerNotResponding;

	    }

	User::RequestComplete( iAgentStatus, err );

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::ConnectToServer()

// 

//------------------------------------------------------------

TInt CNSmlObexServerBinding::ConnectToServer()

	{

	_DBG_FILE("CNSmlObexServerBinding::ConnectToServer");

	TInt err( KErrNone );

	if( iContent == ENSmlDataSync )

		{

		_DBG_FILE("DS client session");

		err = iCsDS.Connect();

		if( err == KErrNone )

			{

			iSessionAlive = ETrue;

			}

		}

	else

		{

		_DBG_FILE("DM client session");

		err = iCsDM.Connect();

		if( err == KErrNone )

			{

			iSessionAlive = ETrue;

			}

		}

	return err;

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::DoCancel()

// From CActive

//------------------------------------------------------------

void CNSmlObexServerBinding::DoCancel()

	{

	_DBG_FILE("CNSmlObexServerBinding::DoCancel");

	if( iState == EReceiving )

		{

		_DBG_FILE("CNSmlObexServerBinding - Canceling receive");

		if( iContent == ENSmlDataSync )

			{

			_DBG_FILE("Canceling iCsDS");

			iCsDS.CancelReceive();

			}

		else

			{

			_DBG_FILE("Canceling iCsDM");

			iCsDM.CancelReceive();

			}

		if( iCancelledByServer )

			{

			_DBG_FILE("iCancelledByServer");

			User::RequestComplete( iAgentStatus, KErrCancel );

			}

		else

			{

			_DBG_FILE("Cancelled by sync app");

			User::RequestComplete( iAgentStatus, KErrNone );

			}

		}

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::RunL()

// From CActive

//------------------------------------------------------------

void CNSmlObexServerBinding::RunL()

	{

	TState s = iState;

	iState = EIdle;

	if( iStatus.Int() != KErrNone )

		{

		DBG_FILE_CODE( iStatus.Int(), _S8("error...") );

		if( iContent == ENSmlDataSync )

			{

			_DBG_FILE("Disconnecting iCsDS");

			iCsDS.Disconnect();

			iCsDS.Close();

			iSessionAlive = EFalse;

			}

		else

			{

			_DBG_FILE("Disconnecting iCsDM");

			iCsDM.Disconnect();

			iCsDM.Close();

			iSessionAlive = EFalse;

			}

		User::RequestComplete( iAgentStatus, iStatus.Int() );

		}

	else

		{

		switch( s )

			{

			case EIdle:

				if( iContent == ENSmlDataSync )

					{

					_DBG_FILE("Disconnecting iCsDS");

					iCsDS.Disconnect();

					iCsDS.Close();

					iSessionAlive = EFalse;

					}

				else

					{

					_DBG_FILE("Disconnecting iCsDM");

					iCsDM.Disconnect();

					iCsDM.Close();

					iSessionAlive = EFalse;

					}

				break;

			case EConnecting:

			case ESending:

			case EReceiving:

				User::RequestComplete( iAgentStatus, iStatus.Int() );

				iState = EIdle;

				break;

			default:

				User::Panic( KInvalidState, s );

			}

		}

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::Send( TDesC8& aStartPtr, TBool /*aFinalPacket*/, TRequestStatus &aStatus )

// 

//------------------------------------------------------------

void CNSmlObexServerBinding::Send( const TDesC8& aStartPtr, TBool /*aFinalPacket*/, TRequestStatus &aStatus )

	{

	_DBG_FILE("CNSmlObexServerBinding::Send");

	iCancelledByServer = EFalse;

	iState = ESending;

	iAgentStatus = &aStatus;

	*iAgentStatus = KRequestPending;

	if( iContent == ENSmlDataSync )

		{

		_DBG_FILE("iCsDS Send");

		iCsDS.Send( aStartPtr );

		}

	else

		{

		_DBG_FILE("iCsDM Send");

		iCsDM.Send( aStartPtr );

		}

	User::RequestComplete( iAgentStatus, KErrNone );

	iState = EIdle;

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::Receive( TDes8& aStartPtr, TRequestStatus &aStatus )

// 

//------------------------------------------------------------

void CNSmlObexServerBinding::Receive( TDes8& aStartPtr, TRequestStatus &aStatus )

	{

	_DBG_FILE("CNSmlObexServerBinding::Receive");

	iCancelledByServer = EFalse;

	iState = EReceiving;

	iAgentStatus = &aStatus;

	*iAgentStatus = KRequestPending;

	if( iContent == ENSmlDataSync )

		{

		_DBG_FILE("iCsDS Receive");

		iCsDS.Receive( aStartPtr, iStatus );

		}

	else

		{

		_DBG_FILE("iCsDM Receive");

		iCsDM.Receive( aStartPtr, iStatus );

		}

	SetActive();

	}

//------------------------------------------------------------

// CNSmlObexServerBinding::Disconnect()

// 

//------------------------------------------------------------

void CNSmlObexServerBinding::Disconnect()

	{

	_DBG_FILE("CNSmlObexServerBinding::Disconnect");

	if( iSessionAlive )

		{

		if( iContent == ENSmlDataSync )

			{

			_DBG_FILE("iCsDS Disconnect");

			iCsDS.Disconnect();

			iCsDS.Close();

			iSessionAlive = EFalse;

			}

		else

			{

			_DBG_FILE("iCsDM Disconnect");

			iCsDM.Disconnect();

			iCsDM.Close();

			iSessionAlive = EFalse;

			}

		}

	}

//End of File