/*
* 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 Device Management
*
*/


#ifndef __NSMLOBEXDMPLUGIN__
#define __NSMLOBEXDMPLUGIN__

#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 "nsmltransport.h"
#include "NSmlObexDMpluginConstants.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 CNSmlObexPacketWaiter;

enum TNSmlObexContent
    {
    ENSmlDataSync,
    ENSmlDeviceManagement
    };



class CNSmlObexDMplugin : public CSrcsInterface, public MObexServerNotify
    {
friend class CDisListener;

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

	// Get MObexServerNotify object to bind to CObexServer
	MObexServerNotify* GetServerCallback();
	TBool IsOBEXActive();

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

private:
    void ConstructL();
    CNSmlObexDMplugin();

	static TInt CreateServer( TAny* aPtr );
	static void StartServerL( TAny* aPtr );
	void TrimRightSpaceAndNull( TDes8& aDes ) const;
	TInt ForwardZeroPkgL( TNSmlObexContent aSyncSelection );
	TInt CheckMimeType();
	void Disconnect();
	TInt ConvertError( TInt aError );

private: // from CSrcsInterface
    void ErrorIndication( TInt aError );
    void TransportUpIndication();
    void TransportDownIndication();
    TInt ObexConnectIndication( const TObexConnectInfo& aRemoteInfo, const TDesC8& aInfo );
    void ObexDisconnectIndication( const TDesC8& aInfo );
    CObexBufObject* PutRequestIndication();
    TInt PutPacketIndication();
    TInt PutCompleteIndication();
    CObexBufObject* GetRequestIndication( CObexBaseObject* aRequestedObject );
    TInt GetPacketIndication();
    TInt GetCompleteIndication();
    TInt SetPathIndication( const CObex::TSetPathInfo& aPathInfo, const TDesC8& aInfo );
    void AbortIndication();
	void SetMediaType( TSrcsMediaType aMediaType );
	TInt SetObexServer( CObexServer* aObexServer );
private:
	enum TState
		{
		EIdle,
		EGetSendPacket
		};

	TBool iZeroPkg;
	TNSmlObexContent iObexContent;
    CBufFlat* iObexBufData;
    CObexBufObject* iObexBufObject;
	CDisListener* iListener;
	TState iState;
	TBool iSessCancelled;
	TBool iSessionActive;
	CObexServer* iObexServer;
	CPluginServiceTimer* iServiceTimer;
	TBool iStartTimer;
	TSrcsMediaType iMediaType;

private:
	friend class CPluginServiceTimer;
	CNSmlObexPacketWaiter* iGetPacketWaiter;

	};


class CDisListener : public CActive
	{
public:
	CDisListener( RNSmlDMObexServerSession& aSs, CNSmlObexDMplugin* 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;
	RNSmlDMObexServerSession& iSs;
	CNSmlObexDMplugin* iPlugin;
	};


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

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

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

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

//============================================================
// CNSmlObexPacketWaiter
//
//============================================================
class CNSmlObexPacketWaiter : public CBase
	{
public:
	CNSmlObexPacketWaiter(RNSmlDMObexServerSession& aSession);
	~CNSmlObexPacketWaiter();
	void ConstructL();

public:
	TInt WaitForGetData();
	inline const TDesC8& Data() const { return *iData; }

private:
	HBufC8* iData;
	RNSmlDMObexServerSession& iSession;
	TPtr8 iPtr;
	};

#endif // __NSMLOBEXDMPLUGIN__