#ifndef __LIVEDATA_H__
#define __LIVEDATA_H__
#ifdef __cplusplus

#include <cstdint>
#include <vector>
#include <memory>
#include "icsneo/communication/command.h"
#include "icsneo/api/eventmanager.h"

namespace icsneo {

typedef uint32_t LiveDataHandle;
static constexpr size_t MAX_LIVE_DATA_ENTRIES = 20;

enum class LiveDataCommand : uint32_t {
	STATUS = 0,
	SUBSCRIBE,
	UNSUBSCRIBE,
	RESPONSE,
	CLEAR_ALL,
	SET_VALUE,
};

enum class LiveDataStatus : uint32_t {
	SUCCESS = 0,
	ERR_UNKNOWN_COMMAND,
	ERR_HANDLE,
	ERR_DUPLICATE,
	ERR_FULL
};

enum LiveDataObjectType : uint16_t {
	MISC = 8,
	SNA = UINT16_MAX,
};

enum class LiveDataValueType : uint32_t {
	GPS_LATITUDE = 2,
	GPS_LONGITUDE,
	GPS_ALTITUDE,
	GPS_SPEED,
	GPS_VALID,
	GPS_ENABLE = 62,
	MANUAL_TRIGGER = 108,
	TIME_SINCE_MSG = 111,
	GPS_ACCURACY = 120,
	GPS_BEARING = 121,
	GPS_TIME = 122,
	GPS_TIME_VALID = 123,
	DAQ_ENABLE = 124,
};

inline std::ostream& operator<<(std::ostream& os, const LiveDataCommand cmd) {
	switch (cmd) {
		case LiveDataCommand::STATUS: return os << "Status";
		case LiveDataCommand::SUBSCRIBE: return os << "Subscribe";
		case LiveDataCommand::UNSUBSCRIBE: return os << "Unsubscribe";
		case LiveDataCommand::RESPONSE: return os << "Response";
		case LiveDataCommand::CLEAR_ALL: return os << "Clear All";
		case LiveDataCommand::SET_VALUE: return os << "Set Value";
	}
	return os;
}

inline std::ostream& operator<<(std::ostream& os, const LiveDataStatus cmd) {
	switch (cmd) {
		case LiveDataStatus::SUCCESS: return os << "Success";
		case LiveDataStatus::ERR_UNKNOWN_COMMAND: return os << "Error: Unknown Command";
		case LiveDataStatus::ERR_HANDLE: return os << "Error: Handle";
		case LiveDataStatus::ERR_DUPLICATE: return os << "Error: Duplicate";
		case LiveDataStatus::ERR_FULL: return os << "Error: Argument limit reached";
	}
	return os;
}

inline std::ostream& operator<<(std::ostream& os, const LiveDataValueType cmd) {
	switch (cmd) {
		case LiveDataValueType::GPS_LATITUDE: return os << "GPS Latitude";
		case LiveDataValueType::GPS_LONGITUDE: return os << "GPS Longitude";
		case LiveDataValueType::GPS_ALTITUDE: return os << "GPS Altitude";
		case LiveDataValueType::GPS_SPEED: return os << "GPS Speed";
		case LiveDataValueType::GPS_VALID: return os << "GPS Valid";
		case LiveDataValueType::GPS_ENABLE: return os << "GPS Enabled";
		case LiveDataValueType::GPS_ACCURACY: return os << "GPS Accuracy";
		case LiveDataValueType::GPS_BEARING: return os << "GPS Bearing";
		case LiveDataValueType::GPS_TIME: return os << "GPS Time";
		case LiveDataValueType::GPS_TIME_VALID: return os << "GPS Time Valid";
		case LiveDataValueType::DAQ_ENABLE: return os << "DAQ Enable";
		case LiveDataValueType::MANUAL_TRIGGER: return os << "Manual Trigger";
	}
	return os;
}

#pragma pack(push,2)
struct LiveDataHeader {
	uint32_t version; // See LiveDataVersion
	uint32_t cmd;
	uint32_t handle;
};

struct LiveDataArgument {
	LiveDataObjectType objectType;
	uint32_t objectIndex;
	uint32_t signalIndex;
	LiveDataValueType valueType;
};

struct LiveDataValueHeader {
	uint16_t length; // Number of bytes to follow header
	uint8_t reserved[2];
};

typedef struct
{
	LiveDataValueHeader header;
	int64_t value;
} LiveDataValue;

struct LiveDataValueResponse : public LiveDataHeader {
	uint32_t numArgs;
	LiveDataValue values[1];
};

struct LiveDataStatusResponse : public LiveDataHeader {
	LiveDataCommand requestedCommand;
	LiveDataStatus status;
};

struct LiveDataSubscribe : public LiveDataHeader {
	uint32_t numArgs;
	uint32_t freqMs;
	uint32_t expireMs;
	LiveDataArgument args[1];
};

struct LiveDataSetValueEntry
{
	LiveDataArgument arg;
	LiveDataValue value;
};

struct LiveDataSetValue : public LiveDataHeader {
	uint32_t numArgs;
	LiveDataSetValueEntry values[1];
};

struct ExtResponseHeader {
	ExtendedCommand command;
	uint16_t length;
};
#pragma pack(pop)

namespace LiveDataUtil
{

LiveDataHandle getNewHandle();
double liveDataValueToDouble(const LiveDataValue& val);
int liveDataDoubleToValue(LiveDataValue& value, const double& dFloat);
static constexpr uint32_t LiveDataVersion = 1;

} // namespace LiveDataUtil
} // namespace icsneo

#endif // _cplusplus
#endif // __LIVEDATA_H__