mqtt_connect.hpp

#pragma once

#include <string>
#include "mqtt_message.hpp"

namespace acl {

typedef enum {
	CONNECT_ACCEPTED	= 0x00,
	CONNECT_INVALID_VERSION	= 0x01,
	CONNECT_INVALID_CID	= 0x02,
	CONNECT_NOT_AVAIL	= 0x03,
	CONNECT_LOGIN_FAILED	= 0x04,
	CONNECT_NO_AUTHORITY	= 0x05,
} mqtt_conn_status_t;

/**
 * mqtt message object for the MQTT_CONNECT type.
 */
class ACL_CPP_API mqtt_connect : public mqtt_message {
public:
	/**
	 * constructor for creating MQTT_CONNECT mqtt message object.
	 * @see mqtt_message
	 */
	mqtt_connect();

	/**
	 * constructor for creating MQTT_CONNECT mqtt message object.
	 * @see mqtt_message
	 */
	mqtt_connect(const mqtt_header& header);

	~mqtt_connect();

protected:
	// @override
	bool to_string(string& out);

	// @override
	int update(const char* data, int dlen);

	// @override
	bool finished() const {
		return finished_;
	}

public:
	void set_keep_alive(unsigned short keep_alive);
	void set_cid(const char* cid);
	void set_username(const char* name);
	void set_passwd(const char* passwd);
	void set_will_qos(mqtt_qos_t qos);
	void set_will_topic(const char* topic);
	void set_will_msg(const char* msg);
	void clean_session();

	unsigned short get_keep_alive() const {
		return keep_alive_;
	}

	const char* get_cid() const {
		return cid_.empty() ? NULL : cid_.c_str();;
	}

	const char* get_username() const {
		return username_.empty() ? NULL : username_.c_str();
	}

	const char* get_passwd() const {
		return passwd_.empty() ? NULL : passwd_.c_str();
	}

	mqtt_qos_t get_will_qos() const {
		return will_qos_;
	}

	const char* get_will_topic() const {
		return will_topic_.empty() ? NULL : will_topic_.c_str();
	}

	const char* get_will_msg() const {
		return will_msg_.empty() ? NULL : will_msg_.c_str();
	}

	bool has_session() const;

private:
	unsigned status_;
	bool finished_;
	char buff_[10];
	int  dlen_;

	mqtt_qos_t will_qos_;
	unsigned char  conn_flags_;
	unsigned short keep_alive_;

	std::string cid_;
	std::string username_;
	std::string passwd_;
	std::string will_topic_;
	std::string will_msg_;

public:
	// (internal)
	// the methods below will be used to update mqtt message object when
	// parsing mqtt body data.
	int update_header_var(const char* data, int dlen);
	int update_cid_len(const char* data, int dlen);
	int update_cid_val(const char* data, int dlen);
	int update_username_len(const char* data, int dlen);
	int update_username_val(const char* data, int dlen);
	int update_passwd_len(const char* data, int dlen);
	int update_passwd_val(const char* data, int dlen);
	int update_will_topic_len(const char* data, int dlen);
	int update_will_topic_val(const char* data, int dlen);
	int update_will_msg_len(const char* data, int dlen);
	int update_will_msg_val(const char* data, int dlen);
};

} // namespace acl