// btincomingserial.h
// 
// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#ifndef __BTINCOMING_H__
#define __BTINCOMING_H__

#include <es_sock.h>
#include <bt_sock.h>
#include <btsdp.h>


enum TBtSerialPanic
	{
	EBtSerialNotConnected,
	EBtSerialWritePending,
	EBtSerialReadPending,	
	};

class CBtService;
class CBtRegQuery;

class MBtIncomingConnectionObserver
	{
public:
	virtual void BtSerialConnected() = 0;
	virtual void BtWriteComplete(TInt aError) = 0;
	virtual void BtReadComplete(TInt aError) = 0;
	virtual void BtSerialError(TInt aError) = 0;
	virtual void BtShutdownComplete(TInt /*aError*/) {};
	virtual void BtNameReceived(TInt /*aError*/, const TDesC& /*aName*/) {};
	};
	
class CBluetoothIncomingSerialConnection	: public CBase
											, public MBluetoothSocketNotifier
	{
public:
	IMPORT_C static CBluetoothIncomingSerialConnection* NewL(MBtIncomingConnectionObserver& aObserver);
	IMPORT_C virtual ~CBluetoothIncomingSerialConnection();
	
	IMPORT_C void WaitForConnection();
	IMPORT_C TBool Connected();
	
	IMPORT_C TBTDevAddr ConnectedDeviceAddrL();
	IMPORT_C void GetConnectedDeviceNameL();
	
	/**
	Write some data. Must already be connected, as signalled via a callback to BtSerialConnected();
	
	Will callback to BtWriteComplete() when completed, no more write must be sent until this event
	occurs.
	*/
	IMPORT_C void Write(const TDesC8& aData);
	IMPORT_C void CancelWrite();
	/**
	Read some data. Must already be connected, as signalled via a callback to BtSerialConnected();
	
	Will callback to BtReadComplete() when completed, no more write must be sent until this event
	occurs.
	*/
	IMPORT_C void Read(TDes8& aData);
	IMPORT_C void CancelRead();
	
	IMPORT_C void ShutDown();
	
private:
friend class CBtService;
friend class CBtRegQuery;
	CBluetoothIncomingSerialConnection(MBtIncomingConnectionObserver& aObserver);
	void ConstructL();

	virtual void HandleConnectCompleteL(TInt aErr);
	virtual void HandleAcceptCompleteL(TInt aErr);
	virtual void HandleShutdownCompleteL(TInt aErr);
	virtual void HandleSendCompleteL(TInt aErr);
	virtual void HandleReceiveCompleteL(TInt aErr);
	virtual void HandleIoctlCompleteL(TInt aErr);
	virtual void HandleActivateBasebandEventNotifierCompleteL(TInt aErr, TBTBasebandEventNotification& aEventNotification);

	void HandleNewConnection(CBluetoothSocket* aConnectedSocket);
	void HandleConnectFailed(TInt aError);
	
	void QueryComplete(TInt aError);
private:
	MBtIncomingConnectionObserver& iObserver;
	RSdp iSdpSession;
	RSocketServ iSockServ;
	CBtService* iService;

	CBluetoothSocket* iSocket;
	TBool iSocketReady;
	TBool iSending;
	TBool iReceiving;
	TSockXfrLength iXferLen;
	
	RBTRegServ iBtRegServ;
	RBTRegistry iBtReg;
	CBTRegistryResponse* iRegReponse;
	CBtRegQuery* iRegQuery;
	
	CBTDevice* iConnectedDevice;
	RBuf iDeviceName;
	};

#endif //__BTINCOMING_H__