aiot_mqtt_upload_api.h

浏览该文件的文档.

#ifndef __AIOT_MQTT_UPLOAD_API_H__
#define __AIOT_MQTT_UPLOAD_API_H__

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

#define STATE_MQTT_UPLOAD_BASE                                    (-0x2100)

#define STATE_MQTT_UPLOAD_MQTT_HANDLE_IS_NULL                     (-0x2101)

#define STATE_MQTT_UPLOAD_FILENAME_IS_NULL                        (-0x2102)

#define STATE_MQTT_UPLOAD_PARAMS_IS_NULL                          (-0x2103)

#define STATE_MQTT_UPLOAD_FILE_DATA_IS_NULL                       (-0x2104)

#define STATE_MQTT_UPLOAD_MQTT_SYSDEP_IS_NULL                     (-0x2105)

#define STATE_MQTT_UPLOAD_PARSE_INIT_FAILED                       (-0x2106)

#define STATE_MQTT_UPLOAD_PARSE_UPLOAD_REPLY_FAILED               (-0x2107)

#define STATE_MQTT_UPLOAD_PARSE_CANCEL_FAILED                     (-0x2108)

#define STATE_MQTT_UPLOAD_PARSE_JSON_FAILED                       (-0x2109)

#define STATE_MQTT_UPLOAD_RECV_FILE_INFO_ERROR                    (-0x210A)

#define STATE_MQTT_UPLOAD_RECV_UPLOADID_ERROR                     (-0x210B)

#define STATE_MQTT_UPLOAD_MALLOC_FAILED                           (-0x210C)

#define STATE_MQTT_UPLOAD_UPTASK_IS_NULL                           (-0x210D)

#define STATE_MQTT_UPLOAD_UPLOAD_REPLY_ERROR                       (-0x210E)

#define STATE_MQTT_UPLOAD_HANDLE_DEINIT                            (-0x210F)

#define STATE_MQTT_UPLOAD_FILE_RESTART_FAILED                      (-0x2110)

#define STATE_MQTT_UPLOAD_BLOCK_SIZE_ERROR                         (-0x2111)

#define STATE_MQTT_UPLOAD_READ_DATA_HANDLER_IS_NULL                (-0x2112)

#define STATE_MQTT_UPLOAD_HANDLE_INIT                              (-0x2113)

#define STATE_MQTT_UPLOAD_PROCESS_REPLY_ERROR                      (-0x2114)

#define STATE_MQTT_UPLOAD_NONE                                      (-0x2115)

#define STATE_MQTT_UPLOAD_REQUEST_INIT                               (-0x2116)
    
#define STATE_MQTT_UPLOAD_IS_UPLOADING                               (-0x2117)

#define STATE_MQTT_UPLOAD_REQUEST_CANCEL                             (-0x2118)

#define STATE_MQTT_UPLOAD_CANCEL_SUCCESS                             (-0x2119)

#define STATE_MQTT_UPLOAD_CANCEL_FAILED                               (-0x2120)

#define STATE_MQTT_UPLOAD_FAILED                                    (-0x2121)

#define STATE_MQTT_UPLOAD_FAILED_TIMEOUT                           (-0x2122)

#define STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK                       (-0x2124)

#define STATE_MQTT_UPLOAD_FINISHED                                 (-0x2125)

#define STATE_MQTT_UPLOAD_NO_UPLOAD_TASK                            (-0x2126)

#define STATE_MQTT_UPLOAD_EXTRA_PARAMS_NOT_JSON                     (-0x2127)

#define AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE        "overwrite"

#define AIOT_MQTT_UPLOAD_FILE_MODE_APPEND           "append"

#define AIOT_MQTT_UPLOAD_FILE_MODE_FAIL             "reject"

#define MQTT_UPLOAD_DEFAULT_FILENAME_LEN             (128)   

#define MQTT_UPLOAD_DEFAULT_CRC64_LEN                (32)

#define MQTT_UPLOAD_DEFAULT_UPLOAD_SIZE             (64)         

typedef enum {
    UPLOAD_FILE_OK = 200,

    UPLOAD_FILE_FAILED_PAYLOAD_ERROR = 400,

    UPLOAD_FILE_FAILED_QPS_LIMIT = 429,
    
    UPLOAD_FILE_FAILED_PARAMS = 460,

    UPLOAD_FILE_FAILED_SERVER_OTHER = 500,
    
    UPLOAD_FILE_FAILED_MAX_FILESIZE = 78117,

    UPLOAD_FILE_FALED_BLOCK_SIZE_MORE = 78118,

    UPLOAD_FILE_FAILED_OFFSET_UNEQUAL = 78119,

    UPLOAD_FILE_FAILED_BLOCK_SIZE_LESS = 78120,

    UPLOAD_FILE_FAILED_BLOCK_CRC = 78121,

    UPLOAD_FILE_FAILED_NOT_FILE_TASK = 78122,

    UPLOAD_FILE_FAILED_SAME_FILE = 78123,

    UPLOAD_FILE_HAVE_FINISHED = 78124,

    UPLOAD_FILE_FAILED_WHOLE_CHECK = 78125,

    UPLOAD_FILE_FILE_BLOCK_DUPLICATION = 78126,
    
    UPLOAD_FILE_MESSAGE_LIMIT = 78127
    
} aiot_mqtt_upload_result_code_t;

typedef enum {
    AIOT_MQTT_UPLOADRECV_INIT_REPLY,
    AIOT_MQTT_UPLOADRECV_UPLOAD_REPLY,
    AIOT_MQTT_UPLOADRECV_CANCEL_REPLY
} aiot_mqtt_upload_recv_type_t;

typedef struct {
    char        *file_name;

    uint32_t    file_size;

    char        *upload_id;

    uint32_t    file_offset; 
    
    uint32_t    block_size; 

    aiot_mqtt_upload_result_code_t    code;

    char        *message;

    uint8_t     complete;

} aiot_mqtt_upload_desc_t;

typedef struct {
    aiot_mqtt_upload_recv_type_t type;
    
    aiot_mqtt_upload_desc_t      desc;
} aiot_mqtt_upload_recv_t;

typedef enum {

    AIOT_MQTT_UPLOADOPT_MQTT_HANDLE,
    
    AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS,

    AIOT_MQTT_UPLOADOPT_RETRY_COUNT,

    AIOT_MQTT_UPLOADOPT_DEFAULLT_BLOCK_SIZE,
    
    AIOT_MQTT_UPLOADOPT_FILE_OPTION,
    AIOT_MQTT_UPLOADOPT_MAX

} aiot_mqtt_upload_option_t;

typedef struct 
{   
    int32_t status;

    int32_t err_code;

    char    file_name[MQTT_UPLOAD_DEFAULT_FILENAME_LEN];

    char    uploadid[MQTT_UPLOAD_DEFAULT_UPLOAD_SIZE];

} aiot_mqtt_upload_result_t;

typedef int32_t (*aiot_mqtt_upload_read_handler_t)(const aiot_mqtt_upload_recv_t *packet, uint8_t *data, uint32_t size, void *userdata);

typedef struct  
{
    char *file_name;
    uint32_t file_size;
    char *mode;
    void *digest;
    char *extra_params;
    aiot_mqtt_upload_read_handler_t read_data_handler;
    void *userdata;
}aiot_mqtt_upload_file_opt_t;

void *aiot_mqtt_upload_init(void);

int32_t aiot_mqtt_upload_setopt(void *handle, aiot_mqtt_upload_option_t option, void *data);

int32_t aiot_mqtt_upload_deinit(void **handle);

int32_t aiot_mqtt_upload_open_stream(void *handle, char *file_name, aiot_mqtt_upload_recv_t *packet);

int32_t aiot_mqtt_upload_cancel_stream(void *handle, char *file_name);

aiot_mqtt_upload_result_t aiot_mqtt_upload_process(void *handle);

int32_t aiot_mqtt_upload_send_data(void *handle, char *file_name, uint8_t *data, uint32_t datalen, uint8_t is_complete);


#if defined(__cplusplus)
}
#endif

#endif  /* __AIOT_MQTT_UPLOAD_API_H__ */