/*
* 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 plugin for data syncronization
*
*/


#ifndef __NSMLOBEXDSPLUGIN__
#define __NSMLOBEXDSPLUGIN__

#include <e32std.h>
#include <e32base.h>
#include <es_sock.h>
#include <obex.h>
#include <btsdp.h>
#include <btmanclient.h>
#include <SrcsInterface.h>
#include <nsmldebug.h>
#include <nsmlconstants.h>
#include <nsmldefines.h>
#include <nsmlsyncalerthandlerif.h>

#include "nsmltransport.h"
#include "NSmlObexDSpluginConstants.h"
#include "nsmlobexserversession.h"
#include "nsmlobexcommserver.h"
#include "nsmlobexdefs.h"


#ifdef __NSML_DEBUG__
#include "wbxml2xmlconverter.h"
#endif // __NSML_DEBUG__

const TInt KPluginTimeOutValue = 180000000;// Time (in milliseconds) for the timer

class CDisListener;
class CNSmlObexServerSession;
class CPluginServiceTimer;
class CThreadObserver;
class CNSmlObexPacketWaiterAsync;

enum TNSmlObexContent
    {
    ENSmlDataSync,
    ENSmlDeviceManagement
    };


class CNSmlObexDSplugin : public CSrcsInterface,
			public MObexServerNotifyAsync, public MNSmlAlertObexPluginContext
    {
friend class CDisListener;

public:
	IMPORT_C static CNSmlObexDSplugin* NewL();
    IMPORT_C static CNSmlObexDSplugin* NewLC();
    ~CNSmlObexDSplugin();

	// virtuals from MNSmlAlertObexPluginContext
	RLibrary& AlertLibrary();
	TThreadId* AlertThreadId();

	TBool IsOBEXActive();

public:
	TPtr8 iPtr;
	TPtr8 iSendPtr;
	HBufC8* iData;
	RNSmlDSObexServerSession iSs;
	TBool iStopped;

private:
    void ConstructL();
    CNSmlObexDSplugin();

	static TInt CreateServerL( TAny* aPtr );
	static void StartServerL( TAny* aPtr );
	TInt ForwardZeroPkgL( TNSmlObexContent aSyncSelection );
	TInt CheckMimeType();
	void TrimRightSpaceAndNull( TDes8& aDes ) const;
	void Disconnect();
	TInt ConvertError( TInt aError );
    TInt SetObexServer( CObexServer* aObexServer );
    void BluetoothNameByAddressL( TSockAddr aAddr );

private: // from CSrcsInterface
    void ErrorIndication( TInt aError );
    void TransportUpIndication();
    void TransportDownIndication();
	void ObexDisconnectIndication( const TDesC8& aInfo );
	TInt PutPacketIndication();
	TInt GetPacketIndication();
	void AbortIndication();
	void SetMediaType( TSrcsMediaType aMediaType );
	void GetCompleteIndication ();
	void GetRequestIndication (CObexBaseObject *aRequestedObject);
	void PutCompleteIndication ();
	void PutRequestIndication ();
	void SetPathIndication (const CObex::TSetPathInfo& aPathInfo, const TDesC8& aInfo);
	void ObexConnectIndication  (const TObexConnectInfo& aRemoteInfo, const TDesC8& aInfo);
	void CancelIndicationCallback();

private:
	enum TState
		{
		EIdle,
		EGetSendPacket
		};

	TBool iZeroPkg;
	TNSmlObexContent iObexContent;
    CBufFlat* iObexBufData;
    CObexBufObject* iObexBufObject;
	CDisListener* iListener;
	TState iState;
	TBool iSessCancelled;
	TBool iSessionActive;
    CObexServer* iObexServer;

	RLibrary iAlertLib;
	TThreadId iThreadId;

	TBTDevAddr iBtAddr;
	HBufC* iBtName;

	CPluginServiceTimer* iServiceTimer;
	TBool iStartTimer;
	TSrcsMediaType iMediaType;
	RThread* iServerThread;

	TBool iConnectionAlive;

private:
	friend class CPluginServiceTimer;

	CNSmlObexPacketWaiterAsync* iGetPacketWaiterAo;

	TInt iResponseError;
	};


class CDisListener : public CActive
	{
public:

	CDisListener( RNSmlDSObexServerSession& aSs, CNSmlObexDSplugin* aPlugin )
			: CActive(0), iSessCancelled(EFalse), iSs(aSs), iPlugin( aPlugin )
	{
		CActiveScheduler::Add(this);
	};

	~CDisListener();
	void RunL();
	void DoCancel();
	void ListenDisconnect();
	TBool iSessCancelled;

private:
	enum TState
		{
		EIdle,
		EListening
		};
	TState iState;
	RNSmlDSObexServerSession& iSs;
	CNSmlObexDSplugin* iPlugin;
	};


//============================================================
// Class CPluginServiceTimer declaration
//============================================================

class CPluginServiceTimer : public CActive
	{
	public:
		CPluginServiceTimer( CNSmlObexDSplugin* aEngine, TInt aValue );
		void ConstructL();
		~CPluginServiceTimer();
		void StartTimer();
		void StopTimer();

	private:
		void DoCancel();
		void RunL();

	private:
		RTimer iTimer;
		CNSmlObexDSplugin* iEngine;
		TInt iValue;
	};

//============================================================
// CNSmlObexPacketWaiterAsync
//
//============================================================
class CNSmlObexPacketWaiterAsync : public CActive
	{
public:
	static CNSmlObexPacketWaiterAsync* NewL (RNSmlDSObexServerSession& aSession,
									  CBufFlat* aObexBufData,
									  CObexBufObject* aObexBufObject);

	void WaitForGetData() ;
	inline const TDesC8& Data() const { return *iData; }

	void SetObexServer( CObexServer* aObexServer );

	~CNSmlObexPacketWaiterAsync();

private:
	CNSmlObexPacketWaiterAsync (RNSmlDSObexServerSession& aSession,
							    CBufFlat* aObexBufData,
							    CObexBufObject* aObexBufObject);

	void ConstructL();
	void RunL();
	void DoCancel();

private:

	enum TState
		{
		EIdle,
		EGetting
		};

	RNSmlDSObexServerSession& iSession;
	CObexServer* iObexServer ;
	CBufFlat* iObexBufData;
    CObexBufObject* iObexBufObject;
    HBufC8* iData;
	TPtr8 iPtr;
	TState iState;
	};

#endif // __NSMLOBEXDSPLUGIN__