luat_mqtt.h

浏览该文件的文档.

#ifndef LUAT_MQTT_H
#define LUAT_MQTT_H
#define MQTT_MSG_RELEASE        0   
#define MQTT_MSG_TCP_TX_DONE    1   
#define MQTT_MSG_TIMER_PING     2   
#define MQTT_MSG_RECONNECT      3   
#define MQTT_MSG_CLOSE          4   
#define MQTT_ERROR_STATE_SOCKET     -1
#define MQTT_ERROR_STATE_DISCONNECT -2
 
#ifndef MQTT_RECV_BUF_LEN_MAX
#if defined(CHIP_EC618) || defined(CHIP_EC718)|| defined(CHIP_EC716)
#define MQTT_RECV_BUF_LEN_MAX (80*1024) 
#else
#define MQTT_RECV_BUF_LEN_MAX 4096 
#endif
#endif
 
 
typedef enum {
    MQTT_STATE_DISCONNECT           ,   
    MQTT_STATE_SCONNECT             ,   
    MQTT_STATE_MQTT                 ,   
    MQTT_STATE_READY                    
}LUAT_MQTT_STATE_E;
 
typedef struct{
    mqtt_broker_handle_t broker;
    network_ctrl_t *netc;       
    luat_ip_addr_t ip_addr;     
    char host[192];             
    uint32_t buffer_offset;     
    uint32_t rxbuff_size;       
    uint8_t *mqtt_packet_buffer;
    void* mqtt_cb;          
    int8_t error_state;         
    uint16_t remote_port;       
    uint32_t keepalive;         
    uint8_t adapter_index;      
    LUAT_MQTT_STATE_E mqtt_state;           
    uint8_t reconnect;          
    uint32_t reconnect_time;    
    void* reconnect_timer;      
    void* ping_timer;           
    int mqtt_ref;               
    void* userdata;             
}luat_mqtt_ctrl_t;
 
typedef struct{
    uint16_t topic_len;
    uint16_t payload_len;
    uint8_t data[];
}luat_mqtt_msg_t;
 
typedef struct luat_mqtt_connopts
{
    const char* host;
    uint16_t port;
    uint8_t is_tls;
    uint8_t is_ipv6;
    uint8_t verify;
    const char* server_cert;
    size_t server_cert_len;
    const char* client_cert;
    size_t client_cert_len;
    const char* client_key;
    size_t client_key_len;
    const char* client_password;
    size_t client_password_len;
}luat_mqtt_connopts_t;
 
typedef void (*luat_mqtt_cb_t)(luat_mqtt_ctrl_t *luat_mqtt_ctrl, uint16_t event);
 
int luat_mqtt_connect(luat_mqtt_ctrl_t *mqtt_ctrl);
// static int luat_mqtt_msg_cb(luat_mqtt_ctrl_t *mqtt_ctrl);
// int l_mqtt_callback(lua_State *L, void* ptr);
int l_luat_mqtt_msg_cb(luat_mqtt_ctrl_t * ctrl, int arg1, int arg2);
int32_t luat_mqtt_callback(void *data, void *param);
LUAT_RT_RET_TYPE luat_mqtt_timer_callback(LUAT_RT_CB_PARAM);
// int luat_mqtt_read_packet(luat_mqtt_ctrl_t *mqtt_ctrl);
int luat_mqtt_send_packet(void* socket_info, const void* buf, unsigned int count);
 
void luat_mqtt_close_socket(luat_mqtt_ctrl_t *mqtt_ctrl);
 
LUAT_MQTT_STATE_E luat_mqtt_state_get(luat_mqtt_ctrl_t *mqtt_ctrl);
 
void luat_mqtt_release_socket(luat_mqtt_ctrl_t *mqtt_ctrl);
 
int luat_mqtt_init(luat_mqtt_ctrl_t *mqtt_ctrl, int adapter_index);
 
int luat_mqtt_set_connopts(luat_mqtt_ctrl_t *mqtt_ctrl, luat_mqtt_connopts_t *opts);
 
int luat_mqtt_set_rxbuff_size(luat_mqtt_ctrl_t *mqtt_ctrl, uint32_t rxbuff_size);
 
int luat_mqtt_reconnect(luat_mqtt_ctrl_t *mqtt_ctrl);
 
int luat_mqtt_ping(luat_mqtt_ctrl_t *mqtt_ctrl);
 
int luat_mqtt_set_will(luat_mqtt_ctrl_t *mqtt_ctrl, const char* topic, const char* payload, size_t payload_len, uint8_t qos, size_t retain);
int luat_mqtt_set_cb(luat_mqtt_ctrl_t *mqtt_ctrl, luat_mqtt_cb_t mqtt_cb);
#endif