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__ */