/*
 *  $Id: socket.h,v 1.8 2010/08/18 10:26:55 schmirl Exp $
 */
 
#ifndef VDR_STREAMDEV_CLIENT_CONNECTION_H
#define VDR_STREAMDEV_CLIENT_CONNECTION_H

#include <tools/socket.h>

#include "common.h"
#include "client/setup.h"

#include <string>

#define CMD_LOCK cMutexLock CmdLock((cMutex*)&m_Mutex)

class cPES2TSRemux;

class cClientSocket: public cTBSocket {
private:
	cTBSocket    *m_DataSockets[si_Count];
	cMutex        m_Mutex;
	char          m_Buffer[BUFSIZ + 1]; // various uses
	unsigned int  m_ServerVersion;
	bool          m_Prio; // server supports command PRIO
	int           m_Priority; // current device priority
	bool          m_Abort; // quit command pending

	time_t        m_LastSignalUpdate;
	int           m_LastSignalStrength;
	int           m_LastSignalQuality;
	int           m_LastDev;
protected:
	/* Send Command, and return true if the command results in Expected. 
	   Returns false on failure. */
	bool Command(const std::string &Command, uint Expected);

	/* Send the given command. Returns false on failure. */
	bool Send(const std::string &Command);

	/* Fetch results from an ongoing Command. The status code and the
	   buffer holding the server's response are stored in Code and Result
	   if non-NULL. Returns false on failure. */
	bool Receive(const std::string &Command, uint *Code = NULL, std::string *Result = NULL, uint TimeoutMs = StreamdevClientSetup.Timeout * 1000);

public:
	cClientSocket(void);
	virtual ~cClientSocket();

	void Reset(void);

	bool CheckConnection(void);
	bool ProvidesChannel(const cChannel *Channel, int Priority);
	bool CreateDataConnection(eSocketId Id);
	bool CloseDataConnection(eSocketId Id);
	bool SetChannelDevice(const cChannel *Channel);
	bool SupportsPrio() { return m_Prio; }
	unsigned int ServerVersion() { return m_ServerVersion; }
	int Priority() const { return m_Priority; }
	bool SetPriority(int Priority);
	bool SetPid(int Pid, bool On);
	bool SetFilter(ushort Pid, uchar Tid, uchar Mask, bool On);
	bool GetSignal(int *SignalStrength, int *SignalQuality, int *Dev);
	bool CloseDvr(void);
	bool SuspendServer(void);
	bool Quit(void);

	cTBSocket *DataSocket(eSocketId Id) const;
};

#endif // VDR_STREAMDEV_CLIENT_CONNECTION_H