src/Source/handle_client.cpp - master - vint10tov/HomeServer

src/Source/handle_client.cpp
103 строки3 KB
vint10tov
15:23/1/12/24
01 дек 2024, 12:23
01 дек 2024, 12:23717f67d
#include "handle_client.hpp"
#include "template_relay.hpp"
#include "parser_body_relay.hpp"
#include "uart_uno.hpp"
#include "smart_home.hpp"

handleClientBase::handleClientBase(std::shared_ptr<ClientSocket> client_socket, UartUno * uartuno) {
    this->uartuno = uartuno;
    this->client_socket = client_socket;
    // Чтение данных из сокета
    if (client_socket->IsOpen()) {
        if (!client_socket->reading_data_socket(buffer)) {
            return;
        }
        // запрос
        request = new Request(buffer, BUFFER_SIZE);
        // ответ
        response = new Response();
        // получено сообщение от клиента
        Logger::debug_log("handleClientBase: Получено сообщение от клиента");
        request->Show_RequestHeders();
        if (request->GET_url() == "/relay") {
            relay();
        } else {
            response->SET_status_code_500();
        }
        sending_response_client();
    }
}

handleClientBase::~handleClientBase() {
    if (request != nullptr)
        delete request;
    if (response != nullptr)
        delete response;
}

// отправка ответа клиенту
void handleClientBase::sending_response_client() {
    client_socket->writing_data_socket(response->GET_result());
}

void handleClientBase::relay() {
    static const int SIZE_BUF_in = 21;
    static const int SIZE_BUF_out = 11;
    uint8_t bufer_in[SIZE_BUF_in];
    uint8_t bufer_out[SIZE_BUF_out];
    SmartHome smart_home(0);
    
    if (request->GET_method() == Request::Method::GET) {
        RequestFromServer rfs;
        rfs.SET_PING();
        if (!rfs.serialize(bufer_out, SIZE_BUF_out)) {
            response->SET_status_code_500();
            return;
        }
        
        if (!uartuno->sending_string(bufer_in, bufer_out, SIZE_BUF_in, SIZE_BUF_out)) {
            response->SET_status_code_500();
            return;
        }
        
        if(!smart_home.deserialize(bufer_in, SIZE_BUF_in)) {
            response->SET_status_code_500();
            return;
        }
        response->SET_status_code_200();
        response->SET_headlines(Content_Type, text_html);
        response->Upload_text_file(std::string(PATH) + std::string(RELAY_HTML), smart_home, TemplateHTML::replace_matches);
        
        
    } else if (request->GET_method() == Request::Method::POST) {
        std::string body = request->reading_request_body();
        ParserBodyRelay pbr(body);

        if (!pbr.string_out()) {
            response->SET_status_code_500();
            return;
        }
        
        if (!pbr.GET_request_from_server().serialize(bufer_out, SIZE_BUF_out)) {
            response->SET_status_code_500();
            return;
        }
        Logger::info_log(pbr.GET_request_from_server().show_request());
        
        if (!uartuno->sending_string(bufer_in, bufer_out, SIZE_BUF_in, SIZE_BUF_out)) {
            response->SET_status_code_500();
            return;
        }
        
        if(!smart_home.deserialize(bufer_in, SIZE_BUF_in)) {
            response->SET_status_code_500();
            return;
        }
        response->SET_status_code_200();
        response->SET_headlines(Content_Type, text_html);
        response->Upload_text_file(std::string(PATH) + std::string(RELAY_HTML), smart_home, TemplateHTML::replace_matches);
        
    } else {
        response->SET_status_code_404();
    }
}