requestData.h

//
// Created by Jason.Z on 2020/6/25.
//

#ifndef SOCKETSERVERCPLUS_REQUESTDATA_H
#define SOCKETSERVERCPLUS_REQUESTDATA_H
#include <string>
#include <unordered_map>
#include <memory>
#include <pthread.h>

const int STATE_PARSE_URI = 1;
const int STATE_PARSE_HEADERS = 2;
const int STATE_RECV_BODY = 3;
const int STATE_ANALYSIS = 4;
const int STATE_FINISH = 5;

const int MAX_BUFF = 4096;
// 有请求出现但是读不到数据,可能是Request Aborted,
// 或者来自网络的数据没有达到等原因,
// 对这样的请求尝试超过一定的次数就抛弃

const int AGAIN_MAX_TIMES = 200;

const int PARSE_URI_AGAIN = -1;
const int PARSE_URI_ERROR = -2;
const int PARSE_URI_SUCCESS = 0;

const int PARSE_HEADER_AGAIN = -1;
const int PARSE_HEADER_ERROR = -2;
const int PARSE_HEADER_SUCCESS = 0;

const int ANALYSIS_ERROR = -2;
const int ANALYSIS_SUCCESS = 0;

const int METHOD_POST = 1;
const int METHOD_GET = 2;
const int HTTP_10 = 1;
const int HTTP_11 = 2;

const int EPOLL_WAIT_TIME = 500;

class MimeType{
private:
    static void init();
    static std::unordered_map<std::string, std::string> mime;
    MimeType();
    MimeType(const MimeType &m);
    pthread_once_t once_control;
public:
    static std::string getMime(const std::string &suffix);

};


enum HeadersState
{
    h_start = 0,
    h_key,
    h_colon,
    h_spaces_after_colon,
    h_value,
    h_CR,
    h_LF,
    h_end_CR,
    h_end_LF
};

class RequestData: public std::enable_shared_from_this<RequestData>{
private:
    int againTime;
    std::string path;
    int fd;
    int epollfd;
    // content的内容用完就清
    std::string content;
    int method;
    int HTTPversion;
    std::string  file_name;
    int now_read_pos;
    int state;
    bool is_fin;
    bool keep_alive;
    std::unordered_map<std::string, std::string> headers;
//    std::weak_ptr<>
private:
    int parse_URI();
    int parse_Headers();
    int analysisRequest();

public:
    RequestData();
    RequestData(int _epollfd, int _fd, std::string _path);
    ~RequestData();
//    void linkTimer(std::shared_ptr<TimerNode> mtimer);
    void reset();
//    void seperateTimer();
    int getFd();
    void setFd(int _fd);
    void handleRequest();
    void handleError(int fd, int err_num, std::string short_msg);

};
#endif //SOCKETSERVERCPLUS_REQUESTDATA_H