Env.cpp

Go to the documentation of this file.

#include "webserv.hpp"
 
/*|==========|
 * Environment constructor:
 *
 * Input: The JSONParser output
 * Output: The env object containing servers and sockets vectors defined inside
 * conf file by servers blocks and listens.
 */
Env::Env(JSONNode *conf) {
    try {
        JSONNode *node;
        JSONList    lst;
        if ((node = conf->obj()["servers"])) {
            lst = conf->obj()["servers"]->lst();
            for (std::vector<JSONNode *>::iterator it = lst.begin(); it < lst.end(); it++) {
                Server *server = new Server(*it);
                this->_servers.push_back(server);
                std::vector<Master *> tmp_s = server->get_sockets(*it);
                this->_masters.insert(this->_masters.end(), tmp_s.begin(), tmp_s.end());
            }
        }
        if ((node = conf->obj()["allowed_methods"])) {
            JSONList lst = node->lst();
            for (JSONList::iterator it = lst.begin(); it < lst.end(); it++) {
                this->_allowed_methods.push_back((*it)->str());
            }
        }
    } catch (std::exception &e) {
        std::cerr << e.what() << "\n";
    }
    delete conf;
}
 
Env::~Env() {
    for (std::vector<Server *>::iterator it = this->_servers.begin(); it < this->_servers.end(); it++) {
        delete *it;
    }
    for (std::vector<Master *>::iterator it = this->_masters.begin(); it < this->_masters.end(); it++) {
        delete *it;
    }
}
 
void Env::cycle(void) {
    FD_ZERO(&Master::_readfds);
    Master::_max_fd = Master::_min_fd;
    pre_select();
    cout << "|===||===| Waiting some HTTP request... |===||===|\n";
    int activity = select(Master::_min_fd + Master::_amount, &(Master::_readfds), NULL, NULL, NULL);
    if ((activity < 0) && (errno != EINTR))
        std::cerr << "Select: " << strerror(errno) << "\n";
    post_select();
}
 
void Env::pre_select(void) {
    cout << "==> Check sockets still alive to listen\n";
    for (std::vector<Master *>::iterator it = this->_masters.begin(); it < this->_masters.end(); it++)
        (*it)->pre_select();
}
void Env::post_select(void) {
    cout << "==> Handle requests and answers:\n";
    for (std::vector<Master *>::iterator it = this->_masters.begin(); it < this->_masters.end(); it++)
        try {
            (*it)->post_select(this);
        } catch (std::exception &e) {
            std::cerr << e.what();
        }
}