aiot_dm_api.h

浏览该文件的文档.

#ifndef __AIOT_DM_API_H__
#define __AIOT_DM_API_H__

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

#include <stdint.h>

#define STATE_DM_BASE (-0x0A00)

#define STATE_DM_EVENT_ID_IS_NULL (-0x0A01)

#define STATE_DM_SERVICE_ID_IS_NULL (-0x0A02)

#define STATE_DM_RRPC_ID_IS_NULL (-0x0A03)

#define STATE_DM_MSG_PARAMS_IS_NULL (-0X0A04)

#define STATE_DM_MSG_DATA_IS_NULL (-0X0A05)

#define STATE_DM_INTERNAL_TOPIC_ERROR (-0x0A06)

#define STATE_DM_MQTT_HANDLE_IS_NULL (-0x0A07)

#define STATE_DM_LOG_RECV (-0x0A08)

#define SATAE_DM_LOG_PARSE_RECV_MSG_FAILED (-0x0A09)


typedef enum {
 AIOT_DMOPT_MQTT_HANDLE,

 AIOT_DMOPT_RECV_HANDLER,

 AIOT_DMOPT_USERDATA,

 AIOT_DMOPT_POST_REPLY,

 AIOT_DMOPT_MAX,
} aiot_dm_option_t;

typedef enum {
 AIOT_DMMSG_PROPERTY_POST,

 AIOT_DMMSG_EVENT_POST,

 AIOT_DMMSG_PROPERTY_SET_REPLY,

 AIOT_DMMSG_ASYNC_SERVICE_REPLY,

 AIOT_DMMSG_SYNC_SERVICE_REPLY,

 AIOT_DMMSG_RAW_DATA,

 AIOT_DMMSG_RAW_SERVICE_REPLY,

 AIOT_DMMSG_GET_DESIRED,

 AIOT_DMMSG_DELETE_DESIRED,

 AIOT_DMMSG_PROPERTY_BATCH_POST,

 AIOT_DMMSG_MAX,
} aiot_dm_msg_type_t;

typedef struct {
 char *params;
} aiot_dm_msg_property_post_t;

typedef struct {
 char *event_id;
 char *params;
} aiot_dm_msg_event_post_t;

typedef struct {
 uint64_t msg_id;
 uint32_t code;
 char *data;
} aiot_dm_msg_property_set_reply_t;

typedef struct {
 uint64_t msg_id;
 char *service_id;
 uint32_t code;
 char *data;
} aiot_dm_msg_async_service_reply_t;

typedef struct {
 uint64_t msg_id;
 char *rrpc_id;
 char *service_id;
 uint32_t code;
 char *data;
} aiot_dm_msg_sync_service_reply_t;

typedef struct {
 uint8_t *data;
 uint32_t data_len;
} aiot_dm_msg_raw_data_t;

typedef struct {
 char *rrpc_id;
 uint8_t *data;
 uint32_t data_len;
} aiot_dm_msg_raw_service_reply_t;

typedef struct {
 char *params;
} aiot_dm_msg_get_desired_t;

typedef struct {
 char *params;
} aiot_dm_msg_delete_desired_t;


typedef struct {
 char *params;
} aiot_dm_msg_property_batch_post_t;

typedef struct {
 char *product_key;
 char *device_name;
 aiot_dm_msg_type_t type;
 union {
 aiot_dm_msg_property_post_t property_post;
 aiot_dm_msg_event_post_t event_post;
 aiot_dm_msg_property_set_reply_t property_set_reply;
 aiot_dm_msg_sync_service_reply_t sync_service_reply;
 aiot_dm_msg_async_service_reply_t async_service_reply;
 aiot_dm_msg_raw_data_t raw_data;
 aiot_dm_msg_raw_service_reply_t raw_service_reply;
 aiot_dm_msg_get_desired_t get_desired;
 aiot_dm_msg_delete_desired_t delete_desired;
 } data;
} aiot_dm_msg_t;


typedef enum {
 AIOT_DMRECV_GENERIC_REPLY,

 AIOT_DMRECV_PROPERTY_SET,

 AIOT_DMRECV_ASYNC_SERVICE_INVOKE,

 AIOT_DMRECV_SYNC_SERVICE_INVOKE,

 AIOT_DMRECV_RAW_DATA_REPLY,

 AIOT_DMRECV_RAW_DATA,

 AIOT_DMRECV_RAW_SYNC_SERVICE_INVOKE,

 AIOT_DMRECV_MAX,
} aiot_dm_recv_type_t;

typedef struct {
 uint32_t msg_id;
 uint32_t code;
 char *data;
 uint32_t data_len;
 char *message;
 uint32_t message_len;
} aiot_dm_recv_generic_reply_t;

typedef struct {
 uint64_t msg_id;
 char *params;
 uint32_t params_len;
} aiot_dm_recv_property_set_t;

typedef struct {
 uint64_t msg_id;
 char *rrpc_id;
 char *service_id;
 char *params;
 uint32_t params_len;
} aiot_dm_recv_sync_service_invoke_t;

typedef struct {
 uint64_t msg_id;
 char *service_id;
 char *params;
 uint32_t params_len;
} aiot_dm_recv_async_service_invoke_t;

typedef struct {
 uint8_t *data;
 uint32_t data_len;
} aiot_dm_recv_raw_data_t;

typedef struct {
 char *rrpc_id;
 uint8_t *data;
 uint32_t data_len;
} aiot_dm_recv_raw_service_invoke_t;

typedef struct {
 char *product_key;
 char *device_name;
 aiot_dm_recv_type_t type;
 union {
 aiot_dm_recv_generic_reply_t generic_reply;
 aiot_dm_recv_property_set_t property_set;
 aiot_dm_recv_async_service_invoke_t async_service_invoke;
 aiot_dm_recv_sync_service_invoke_t sync_service_invoke;
 aiot_dm_recv_raw_data_t raw_data;
 aiot_dm_recv_raw_service_invoke_t raw_service_invoke;
 } data;
} aiot_dm_recv_t;

typedef void (*aiot_dm_recv_handler_t)(void *handle, const aiot_dm_recv_t *recv, void *userdata);

void *aiot_dm_init(void);

int32_t aiot_dm_setopt(void *handle, aiot_dm_option_t option, void *data);

int32_t aiot_dm_send(void *handle, const aiot_dm_msg_t *msg);

int32_t aiot_dm_deinit(void **p_handle);


#if defined(__cplusplus)
}
#endif

#endif /* #ifndef __AIOT_DM_API_H__ */