aiot_gateway_api.h

浏览该文件的文档.

#ifndef _GATEWAY_MODULE_H_
#define _GATEWAY_MODULE_H_

#if defined(__cplusplus)
extern "C" {
#endif

#include <stdint.h>

#define  STATE_GATEWAY_SUBDEV_REPEATED_CONNECT                    (-0x1301)

#define  STATE_GATEWAY_SYNC_RECV_TIMEOUT                          (-0x1302)

#define  STATE_GATEWAY_SYNC_RECV_ERROR                            (-0x1303)

#define  AIOT_PRODUCT_KEY_MAX_LENTH     64

#define  AIOT_DEVICE_NAME_MAX_LENTH     64

#define  AIOT_PRODUCT_SECRET_MAX_LENTH  64

#define  AIOT_DEVICE_SECRET_MAX_LENTH   64

typedef struct {
    char product_key[AIOT_PRODUCT_KEY_MAX_LENTH];
    char device_name[AIOT_DEVICE_NAME_MAX_LENTH];
    char product_secret[AIOT_PRODUCT_SECRET_MAX_LENTH];
    char device_secret[AIOT_DEVICE_SECRET_MAX_LENTH];
} aiot_subdev_meta_info_t;

typedef struct {
    /*
     * @brief 消息的最大缓存数，0表示不使用消息数作为触发条件， 1～N表示当消息数达到后触发批量发送
     *
     */
    uint32_t max_msg_buff;
    /*
     * @brief 消息的最大延时时间，0表示不使用消息数作为触发条件， 1～N表示当时间Nms后触发批量发送
     *
     */
    uint32_t max_time_delay;
} aiot_batch_pub_policy_t;

typedef enum {
    AIOT_GWRECV_CONNECT_REPLY,
    AIOT_GWRECV_DISCONNECT_REPLY,
    AIOT_GWRECV_ADD_TOPO_REPLY,
    AIOT_GWRECV_DELETE_TOPO_REPLY,
    AIOT_GWRECV_TOPO_CHANGE_NOTICE,
} aiot_gateway_msg_type_t;

typedef struct {
    char *product_key;
    char *device_name;
    char *device_secret;
} subdev_recv_t;

typedef struct {
    uint32_t id;
    int32_t code;
    char *message;
} aiot_gateway_msg_reply_t;

typedef struct {
    int32_t status;
} aiot_gateway_msg_topo_change_t;

typedef struct {
    aiot_gateway_msg_type_t type;
    subdev_recv_t *subdev_table;
    int32_t subdev_num;
    union {
        aiot_gateway_msg_reply_t reply;
        aiot_gateway_msg_topo_change_t topo_change;
    } data;
} aiot_gateway_msg_t;

typedef void (*gateway_msg_callback_t)(void *gateway_device, const aiot_gateway_msg_t *msg, void *userdata);

int32_t aiot_gateway_set_msg_callback(void *gateway_device, gateway_msg_callback_t msg_callback, void *userdata);

int32_t aiot_gateway_set_auto_topo(void *gateway_device, int32_t auto_topo);

int32_t aiot_gateway_set_sync_msg_timeout(void *gateway_device, uint32_t timeout_ms);

int32_t aiot_gateway_set_batch_pub_policy(void *gateway_device, aiot_batch_pub_policy_t *policy);

int32_t aiot_gateway_flush_msg(void *gateway_device);

int32_t aiot_gateway_batch_connect_subdev(void *gateway_device, void* subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_disconnect_subdev(void *gateway_device, void* subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_add_topo(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_delete_topo(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_dynamic_secret(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_dynamic_register(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_connect_subdev_async(void *gateway_device, void* subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_disconnect_subdev_async(void *gateway_device, void* subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_add_topo_async(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);

int32_t aiot_gateway_batch_delete_topo_async(void *gateway_device, aiot_subdev_meta_info_t subdev_table[], int32_t subdev_num);
#if defined(__cplusplus)
}
#endif

#endif