Client.h

//
// Created by mano on 10.12.16.
//

#ifndef LITTLEPROXYSERVER_CLIENT_H
#define LITTLEPROXYSERVER_CLIENT_H

#include "Cache.h"
#include "Buffer.h"
#include "Parser.h"

class Client {
    int my_socket;
    int http_socket;

    bool flag_correct_my_socket;
    bool flag_correct_http_socket;

    Buffer * buffer_in;
    size_t buffer_in_offs;

    Buffer * buffer_server_request;
    size_t buffer_server_request_offs;

    Buffer * buffer_out;
    size_t buffer_out_offs;

    bool flag_received_get_request;

    bool flag_closed;
    bool flag_closed_correct;
    bool flag_closed_http_socket;
    bool flag_closed_my_socket;

    bool flag_process_http_connecting;
    int http_socket_flags;

    Cache * cache;

    bool flag_take_data_from_cache;

    struct sockaddr_in dest_addr;
    long long last_time_activity;

    std::pair<std::string, std::string> cache_key;

public:

    Client(int my_socket, Cache * cache);

    int get_my_socket() { return my_socket; }

    int get_http_socket() { return http_socket; }

    void set_closed_correct() {
        flag_closed = true;
        flag_closed_correct = true;
    }

    void set_closed_incorrect() {
        flag_closed = true;
        flag_closed_correct = false;
    }

    bool is_closed() { return flag_closed; }

    void set_close_http_socket() { flag_closed_http_socket = true; }

    bool is_closed_http_socket() { return flag_closed_http_socket; }

    void set_close_my_socket() { flag_closed_my_socket = true; }

    bool is_closed_my_socket() { return flag_closed_my_socket; }

    void set_http_socket(int http_socket) { this->http_socket = http_socket; }

    bool is_received_get_request() { return flag_received_get_request; }

    bool can_recv_from_client();

    bool can_recv_from_server();

    bool is_have_data_for_server();

    bool is_have_data_for_client();

    bool can_be_closed();

    Buffer * get_buffer_server_request() { return buffer_server_request; }

    int create_tcp_connection_to_request(std::string host_name);

    int handle_first_line_proxy_request(char * p_new_line, size_t i_next_line);

    void receive_request_from_client();

    void send_answer_to_client();

    void receive_server_response();

    void send_request_to_server();

    ~Client();

};


#endif //LITTLEPROXYSERVER_CLIENT_H