mqtt_sn_common.h

Go to the documentation of this file.

 
#ifndef _MQTT_SN_COMMON_H
#define _MQTT_SN_COMMON_H
 
//Dependencies
#include "core/net.h"
 
//MQTT-SN port number
#define MQTT_SN_PORT 1883
 
//C++ guard
#ifdef __cplusplus
extern "C" {
#endif
 
//MQTT-SN protocol identifier
#define MQTT_SN_PROTOCOL_ID 0x01
//Reserved topic identifier
#define MQTT_SN_INVALID_TOPIC_ID 0x0000
 
 
typedef enum {
   MQTT_SN_TRANSPORT_PROTOCOL_UDP  = 1, 
   MQTT_SN_TRANSPORT_PROTOCOL_DTLS = 2  
} MqttSnTransportProtocol;
 
 
typedef enum
{
   MQTT_SN_QOS_LEVEL_0       = 0, 
   MQTT_SN_QOS_LEVEL_1       = 1, 
   MQTT_SN_QOS_LEVEL_2       = 2, 
   MQTT_SN_QOS_LEVEL_MINUS_1 = 3  
} MqttSnQosLevel;
 
 
typedef enum
{
   MQTT_SN_NORMAL_TOPIC_ID     = 0, 
   MQTT_SN_PREDEFINED_TOPIC_ID = 1, 
   MQTT_SN_NORMAL_TOPIC_NAME   = 0, 
   MQTT_SN_SHORT_TOPIC_NAME    = 2  
} MqttSnTopicIdType;
 
 
typedef enum
{
   MQTT_SN_MSG_TYPE_ADVERTISE     = 0x00,
   MQTT_SN_MSG_TYPE_SEARCHGW      = 0x01,
   MQTT_SN_MSG_TYPE_GWINFO        = 0x02,
   MQTT_SN_MSG_TYPE_CONNECT       = 0x04,
   MQTT_SN_MSG_TYPE_CONNACK       = 0x05,
   MQTT_SN_MSG_TYPE_WILLTOPICREQ  = 0x06,
   MQTT_SN_MSG_TYPE_WILLTOPIC     = 0x07,
   MQTT_SN_MSG_TYPE_WILLMSGREQ    = 0x08,
   MQTT_SN_MSG_TYPE_WILLMSG       = 0x09,
   MQTT_SN_MSG_TYPE_REGISTER      = 0x0A,
   MQTT_SN_MSG_TYPE_REGACK        = 0x0B,
   MQTT_SN_MSG_TYPE_PUBLISH       = 0x0C,
   MQTT_SN_MSG_TYPE_PUBACK        = 0x0D,
   MQTT_SN_MSG_TYPE_PUBCOMP       = 0x0E,
   MQTT_SN_MSG_TYPE_PUBREC        = 0x0F,
   MQTT_SN_MSG_TYPE_PUBREL        = 0x10,
   MQTT_SN_MSG_TYPE_SUBSCRIBE     = 0x12,
   MQTT_SN_MSG_TYPE_SUBACK        = 0x13,
   MQTT_SN_MSG_TYPE_UNSUBSCRIBE   = 0x14,
   MQTT_SN_MSG_TYPE_UNSUBACK      = 0x15,
   MQTT_SN_MSG_TYPE_PINGREQ       = 0x16,
   MQTT_SN_MSG_TYPE_PINGRESP      = 0x17,
   MQTT_SN_MSG_TYPE_DISCONNECT    = 0x18,
   MQTT_SN_MSG_TYPE_WILLTOPICUPD  = 0x1A,
   MQTT_SN_MSG_TYPE_WILLTOPICRESP = 0x1B,
   MQTT_SN_MSG_TYPE_WILLMSGUPD    = 0x1C,
   MQTT_SN_MSG_TYPE_WILLMSGRESP   = 0x1D,
   MQTT_SN_MSG_TYPE_ENCAPSULATED  = 0xFE
} MqttSnMsgType;
 
 
typedef enum
{
   MQTT_SN_RETURN_CODE_ACCEPTED                  = 0,
   MQTT_SN_RETURN_CODE_REJECTED_CONGESTION       = 1,
   MQTT_SN_RETURN_CODE_REJECTED_INVALID_TOPIC_ID = 2,
   MQTT_SN_RETURN_CODE_REJECTED_NOT_SUPPORTED    = 3
} MqttSnReturnCode;
 
 
//CodeWarrior or Win32 compiler?
#if defined(__CWCC__) || defined(_WIN32)
   #pragma pack(push, 1)
#endif
 
 
typedef __packed_struct
{
   __packed_union
   {
      uint8_t all;
      __packed_struct
      {
#if defined(_CPU_BIG_ENDIAN) && !defined(__ICCRX__)
         uint8_t dup : 1;
         uint8_t qos : 2;
         uint8_t retain : 1;
         uint8_t will : 1;
         uint8_t cleanSession : 1;
         uint8_t topicIdType : 2;
#else
         uint8_t topicIdType : 2;
         uint8_t cleanSession : 1;
         uint8_t will : 1;
         uint8_t retain : 1;
         uint8_t qos : 2;
         uint8_t dup : 1;
#endif
      };
   };
} MqttSnFlags;
 
 
typedef __packed_struct
{
   uint8_t length;
   uint8_t msgType;
   uint8_t data[];
} MqttSnHeader;
 
 
typedef __packed_struct
{
   uint8_t prefix;
   uint16_t length;
   uint8_t msgType;
   uint8_t data[];
} MqttSnExtHeader;
 
 
typedef __packed_struct
{
   uint8_t gwId;
   uint16_t duration;
} MqttSnAdvertise;
 
 
typedef __packed_struct
{
   uint8_t radius;
} MqttSnSearchGw;
 
 
typedef __packed_struct
{
   uint8_t gwId;
   uint8_t gwAdd[];
} MqttSnGwInfo;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   uint8_t protocolId;
   uint16_t duration;
   char_t clientId[];
} MqttSnConnect;
 
 
typedef __packed_struct
{
   uint8_t returnCode;
} MqttSnConnAck;
 
 
typedef void MqttSnWillTopicReq;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   char_t willTopic[];
} MqttSnWillTopic;
 
 
typedef void MqttSnWillMsgReq;
 
 
typedef void MqttSnWillMsg;
 
 
typedef __packed_struct
{
   uint16_t topicId;
   uint16_t msgId;
   char_t topicName[];
} MqttSnRegister;
 
 
typedef __packed_struct
{
   uint16_t topicId;
   uint16_t msgId;
   uint8_t returnCode;
} MqttSnRegAck;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   uint16_t topicId;
   uint16_t msgId;
   uint8_t data[];
} MqttSnPublish;
 
 
typedef __packed_struct
{
   uint16_t topicId;
   uint16_t msgId;
   uint8_t returnCode;
} MqttSnPubAck;
 
 
typedef __packed_struct
{
   uint16_t msgId;
} MqttSnPubRec;
 
 
typedef __packed_struct
{
   uint16_t msgId;
} MqttSnPubRel;
 
 
typedef __packed_struct
{
   uint16_t msgId;
} MqttSnPubComp;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   uint16_t msgId;
   char_t topicName[];
} MqttSnSubscribe;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   uint16_t topicId;
   uint16_t msgId;
   uint8_t returnCode;
} MqttSnSubAck;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   uint16_t msgId;
   char_t topicName[];
} MqttSnUnsubscribe;
 
 
typedef __packed_struct
{
   uint16_t msgId;
} MqttSnUnsubAck;
 
 
typedef void MqttSnPingReq;
 
 
typedef void MqttSnPingResp;
 
 
typedef __packed_struct
{
   uint16_t duration;
} MqttSnDisconnect;
 
 
typedef __packed_struct
{
   MqttSnFlags flags;
   char_t willTopic[];
} MqttSnWillTopicUpd;
 
 
typedef __packed_struct
{
   uint8_t returnCode;
} MqttSnWillTopicResp;
 
 
typedef void MqttSnWillMsgUpd;
 
 
typedef __packed_struct
{
   uint8_t returnCode;
} MqttSnWillMsgResp;
 
 
//CodeWarrior or Win32 compiler?
#if defined(__CWCC__) || defined(_WIN32)
   #pragma pack(pop)
#endif
 
 
typedef struct
{
   const char_t *topicName; 
   uint16_t topicId;        
} MqttSnPredefinedTopic;
 
 
//C++ guard
#ifdef __cplusplus
}
#endif
 
#endif