mqtt_client.h

浏览该文件的文档.

 
#ifndef _MQTT_CLIENT_H
#define _MQTT_CLIENT_H
 
#ifdef __cplusplus
    extern "C" {
#endif
 
#include "tuya_cloud_types.h"
#include "tuya_svc_netmgr.h"
 
typedef PVOID_T MQ_HANDLE; //Definition of MQTT client handler
 
typedef VOID (*MQ_DATA_RECV_CB)(IN BYTE_T *data,IN UINT_T len);
 
typedef struct {
    CHAR_T *subcribe_topic;
    CHAR_T *client_id;
    CHAR_T *user_name;
    CHAR_T *passwd;
}MQ_CLIENT_IF_S;
 
OPERATE_RET create_mqtt_hand(IN CONST CHAR_T **domain_tbl,
                             IN CONST BYTE_T domain_num,
                             IN CONST USHORT_T serv_port,
                             IN CONST BOOL_T  enable_tls,
                             IN CONST MQ_CLIENT_IF_S *mqc_if,
                             IN CONST USHORT_T s_alive,
                             IN CONST MQ_DATA_RECV_CB recv_cb,
                             IN CONST CHAR_T **wakeup_domain_tbl,
                             IN CONST BYTE_T wakeup_domain_num,
                             IN CONST USHORT_T wakeup_serv_port,
                             OUT MQ_HANDLE *hand);
typedef struct mqtt_config {
    /*
        mqtt支持的scheme:
        mqtt    ->  tcp
        mqtts   ->  tls
        wss     ->  websocket over tls
    */
    char*           url;/*带有scheme的mqtt url,比如:mqtts://iot.com; wss://iot.com*/
    int             port;   //mqtt boker port
    const char*     cert_pem;
    size_t          cert_len;
    /*兼容老接口的参数*/
    const char*     client_id; //mqtt client id
    const char*     username;// mqtt username
    const char*     password;// mqtt password
 
    MQ_DATA_RECV_CB recv_cb;//data
    char**    domain_tbl;
    uint8_t   domain_num;
    uint16_t  server_port;
    const char**    wakeup_domain_tbl;
    uint8_t   wakeup_domain_num;
    uint16_t  wakeup_serv_port;
    char*     subscribe_topic;
    uint16_t  s_alive_time_s;
    bool      enable_tls;
} mqtt_config_t, *p_mqtt_config_t;
int create_mqtt_handle_ext(IN p_mqtt_config_t p_mqtt_config, OUT MQ_HANDLE*hand);
 
 
int mqtt_set_url(IN MQ_HANDLE*hand, IN char* url);
 
OPERATE_RET mqtt_update_auth(IN CONST MQ_HANDLE hand, IN CONST CHAR_T *p_username, IN CONST CHAR_T *p_passwd);
 
typedef VOID (*MQ_CONNED_CB)(VOID);
typedef VOID (*MQ_DISCONN_CB)(VOID);
typedef VOID (*MQ_CONN_DENY_CB)(IN BYTE_T deny_times);
typedef VOID (*MQ_UPDATE_AUTH_CB)(VOID);
 
typedef INT_T (*MQ_PERMIT_CONN_CB)(VOID);
 
OPERATE_RET mqtt_register_cb(IN CONST MQ_HANDLE hand,
                             IN CONST MQ_CONNED_CB conn_cb,
                             IN CONST MQ_DISCONN_CB dis_conn_cb,
                             IN CONST MQ_CONN_DENY_CB conn_deny_cb,
                             IN CONST MQ_PERMIT_CONN_CB permit_conn_cb,
                             IN CONST MQ_UPDATE_AUTH_CB update_auth_cb);
 
OPERATE_RET mqtt_client_start(IN CONST MQ_HANDLE hand,IN CONST CHAR_T *name);
 
VOID mqtt_restart(IN CONST MQ_HANDLE hand);
 
OPERATE_RET mqtt_client_quit(IN CONST MQ_HANDLE hand);
 
BOOL_T get_mqtt_conn_stat(IN CONST MQ_HANDLE hand);
 
VOID mq_disconnect(IN CONST MQ_HANDLE hand);
 
VOID release_mqtt_hand(IN CONST MQ_HANDLE hand);
 
VOID mqtt_close(IN CONST MQ_HANDLE hand);
 
UINT_T mqtt_get_socket_ip(IN CONST MQ_HANDLE hand);
 
typedef VOID (*MQ_PUB_ASYNC_IFM_CB)(IN CONST OPERATE_RET op_ret,IN CONST VOID *prv_data);
 
OPERATE_RET mqtt_publish_async(IN CONST MQ_HANDLE hand,IN CONST CHAR_T *topic,IN CONST BYTE_T qos,
                               IN CONST BYTE_T *data,IN CONST INT_T len,IN CONST UINT_T to_lmt,
                               IN CONST MQ_PUB_ASYNC_IFM_CB cb,IN VOID *prv_data);
 
INT_T mqtt_get_socket_fd(IN CONST MQ_HANDLE hand);
 
INT_T mqtt_get_alive_time_s(IN CONST MQ_HANDLE hand);
 
OPERATE_RET mqtt_book_wakeup_topic(IN CONST MQ_HANDLE hand,IN CONST CHAR_T *wakeup_topic);
 
OPERATE_RET mqtt_book_additional_topic(IN CONST MQ_HANDLE hand, IN CONST CHAR_T *topic);
 
OPERATE_RET mqtt_keep_alive(IN CONST MQ_HANDLE hand);
 
typedef VOID (*MQ_MSG_RECV_CB)(IN CONST CHAR_T *topic, IN BYTE_T *data,IN UINT_T len);
 
OPERATE_RET mqtt_subscribe_multi_topics(IN CONST MQ_HANDLE hand, IN CONST CHAR_T *topics[], 
                                        IN CONST BYTE_T cnt, MQ_MSG_RECV_CB msg_cb, BOOL_T auto_resub);
 
OPERATE_RET mqtt_unsubscribe_multi_topics(IN CONST MQ_HANDLE hand, IN CONST CHAR_T *topics[], IN CONST BYTE_T cnt);
 
OPERATE_RET mqtt_set_alive_time_s(IN CONST USHORT_T time);
 
OPERATE_RET mqtt_set_connection_linkage(IN CONST MQ_HANDLE hand, netmgr_linkage_t *linkage);
 
OPERATE_RET mqtt_get_connection_linkage(IN CONST MQ_HANDLE hand, netmgr_linkage_t **linkage);
 
#ifdef __cplusplus
}
#endif
 
#endif