#pragma once

#include "ASyncSerial.h"
#include "DomoticzHardware.h"

class Comm5Serial : public CDomoticzHardwareBase, AsyncSerial
{
	enum RequestState
	{
		Idle,
		QueryRelayState,
		QuerySensorState
	} reqState;
	enum
	{
		STSTART_OCTET1,
		STSTART_OCTET2,
		STFRAME_SIZE,
		STFRAME_CONTROL,
		STFRAME_DATA,
		STFRAME_CRC1,
		STFRAME_CRC2
	} currentState;

      public:
	Comm5Serial(int ID, const std::string &devname, unsigned int baudRate = 115200);
	bool WriteToHardware(const char *pdata, unsigned char length) override;
	boost::signals2::signal<void()> sDisconnected;

      private:
	bool StartHardware() override;
	bool StopHardware() override;
	bool Connect();
	void requestDigitalInputResponseHandler(const std::string &mframe);
	void requestDigitalOutputResponseHandler(const std::string &mframe);
	void enableNotificationResponseHandler(const std::string &mframe);
	void readCallBack(const char *data, size_t len);
	uint16_t crc16_update(uint16_t crc, uint8_t data);

      protected:
	void OnError(const std::exception &e);

	void Do_Work();
	void ParseData(const unsigned char *data, size_t len);
	void parseFrame(const std::string &mframe);
	bool writeFrame(const std::string &);

	void queryRelayState();
	void querySensorState();
	void enableNotifications();

      private:
	std::string m_szSerialPort;
	const unsigned int m_baudRate;

	std::string frame;
	size_t frameSize;
	uint16_t frameCRC;

	bool initSensorData;
	int lastKnownSensorState;
	uint8_t relayStatus;

	bool notificationEnabled;

	bool m_bReceiverStarted;

	std::shared_ptr<std::thread> m_thread;
};