luat_http.h

浏览该文件的文档.

#ifndef LUAT_HTTP_H
#define LUAT_HTTP_H
 
#ifdef __LUATOS__
#include "luat_zbuff.h"
 
 
#if defined(AIR101) || defined(AIR103)
// #define HTTP_REQ_HEADER_MAX_SIZE     (2048)
#define HTTP_RESP_BUFF_SIZE         (2048)
#else
// #define HTTP_REQ_HEADER_MAX_SIZE     (8192)
#define HTTP_RESP_BUFF_SIZE         (8192)
#endif
#else
#include "http_parser.h"
#define HTTP_HEADER_BASE_SIZE   (1024)
#define HTTP_RESP_BUFF_SIZE     (4096)
 
#endif
enum
{
    HTTP_STATE_IDLE,
    HTTP_STATE_CONNECT,
    HTTP_STATE_SEND_HEAD,
    HTTP_STATE_SEND_BODY_START,
    HTTP_STATE_SEND_BODY,
    HTTP_STATE_GET_HEAD,
    HTTP_STATE_GET_BODY,
    HTTP_STATE_DONE,
    HTTP_STATE_WAIT_CLOSE,
};
 
#ifndef __LUATOS__
 
/*
 * http运行过程的回调函数
 * status >=0 表示运行状态，看HTTP_STATE_XXX <0说明出错停止了，==0表示结束了
 * data 在获取响应阶段，会回调head数据，如果为NULL，则head接收完成了。如果设置了data_mode，body数据也直接回调。
 * data_len 数据长度，head接收时，每行会多加一个\0，方便字符串处理
 * user_param 用户自己的参数
 */
typedef void (*luat_http_cb)(int status, void *data, uint32_t data_len, void *user_param);
 
#define HTTP_GET_DATA       (2)
#define HTTP_POST_DATA      (1)
#endif
 
#define HTTP_OK             (0)
#define HTTP_ERROR_STATE    (-1)
#define HTTP_ERROR_HEADER   (-2)
#define HTTP_ERROR_BODY     (-3)
#define HTTP_ERROR_CONNECT  (-4)
#define HTTP_ERROR_CLOSE    (-5)
#define HTTP_ERROR_RX       (-6)
#define HTTP_ERROR_DOWNLOAD (-7)
#define HTTP_ERROR_TIMEOUT  (-8)
#define HTTP_ERROR_FOTA     (-9)
 
#define HTTP_CALLBACK       (1)
 
#define HTTP_RE_REQUEST_MAX (3)
 
#define HTTP_TIMEOUT        (10*60*1000) // 10分钟
 
typedef struct{
    network_ctrl_t *netc;       // http netc
    http_parser  parser;        //解析相关
    char *host;             
    char* request_line; 
    uint16_t remote_port;       
    uint8_t is_tls;             // 是否SSL
    uint8_t custom_host;        
    uint8_t is_post;
    void* timeout_timer;            
    uint32_t timeout;
    uint32_t tx_offset;
#ifdef __LUATOS__
    luat_ip_addr_t ip_addr;     // http ip
    // const char *url;         // url
    // const char *uri;         // uri
    // char method[12];         // method
 
    // 发送相关
    // uint8_t request_message[HTTP_REQUEST_BUF_LEN_MAX];
    char *req_header;
    char *req_body;             //发送body
    size_t req_body_len;        //发送body长度
    luat_zbuff_t *zbuff_body;
    char *req_auth;
#ifdef LUAT_USE_FOTA
    //OTA相关
    uint8_t isfota;             //是否为ota下载
    uint32_t address;           
    uint32_t length;        
    luat_spi_device_t* spi_device;
#endif
    int http_cb;                // http lua回调函数
    int http_cb_userdata;               // http lua回调函数用户传参
    //下载相关
    uint8_t is_download;        //是否下载
    char *dst;          //下载路径
 
    // http_parser_settings parser_settings;
    char* headers;
    uint32_t headers_len;       //headers缓存长度
    char* body;
    uint32_t body_len;          //body缓存长度
    // uint8_t is_chunk;        //是否chunk编码
    uint8_t re_request_count;
    // 响应相关
    int32_t resp_content_len;   //content 长度
    FILE* fd;                   //下载 FILE
    uint64_t idp;
 
    uint8_t headers_complete;
    uint8_t close_state;
    char resp_buff[HTTP_RESP_BUFF_SIZE];
    size_t resp_buff_offset;
    size_t resp_headers_done;
#else
    Buffer_Struct request_head_buffer;  
    luat_http_cb http_cb;               
    void *http_cb_userdata;             
    Buffer_Struct response_head_buffer; 
    int error_code;
    Buffer_Struct response_cache;
    uint32_t total_len;
    uint32_t done_len;
    uint32_t offset;
    uint8_t retry_cnt_max;      
    uint8_t retry_cnt;
    uint8_t state;
    uint8_t data_mode;
    uint8_t is_pause;
    uint8_t debug_onoff;
    uint8_t new_data;
#endif
}luat_http_ctrl_t;
#ifdef __LUATOS__
int luat_http_client_init(luat_http_ctrl_t* http, int ipv6);
int luat_http_client_start(luat_http_ctrl_t* http);
#else
 
luat_http_ctrl_t* luat_http_client_create(luat_http_cb cb, void *user_param, int adapter_index);
int luat_http_client_base_config(luat_http_ctrl_t* http_ctrl, uint32_t timeout, uint8_t debug_onoff, uint8_t retry_cnt);
int luat_http_client_ssl_config(luat_http_ctrl_t* http_ctrl, int mode, const char *server_cert, uint32_t server_cert_len,
        const char *client_cert, uint32_t client_cert_len,
        const char *client_cert_key, uint32_t client_cert_key_len,
        const char *client_cert_key_password, uint32_t client_cert_key_password_len);
 
int luat_http_client_clear(luat_http_ctrl_t *http_ctrl);
 
int luat_http_client_set_user_head(luat_http_ctrl_t *http_ctrl, const char *name, const char *value);
 
 
int luat_http_client_start(luat_http_ctrl_t *http_ctrl, const char *url, uint8_t type, uint8_t ipv6, uint8_t continue_mode);
int luat_http_client_close(luat_http_ctrl_t *http_ctrl);
int luat_http_client_destroy(luat_http_ctrl_t **p_http_ctrl);
 
int luat_http_client_post_body(luat_http_ctrl_t *http_ctrl, void *data, uint32_t len);
int luat_http_client_get_status_code(luat_http_ctrl_t *http_ctrl);
int luat_http_client_pause(luat_http_ctrl_t *http_ctrl, uint8_t is_pause);
int luat_http_client_set_get_offset(luat_http_ctrl_t *http_ctrl, uint32_t offset);
// int luat_http_client_start(luat_http_ctrl_t *http_ctrl, const char *url, uint8_t is_post, uint8_t ipv6, uint8_t data_mode);
#endif
#endif