HttpServer.cpp

Go to the documentation of this file.

 
#include "framework_config.h" // Must be included before DebugTrace.h to ensure framework_config.h is processed first
#include "DebugTrace.h"
TRACE_INIT(HttpServer)
 
#include "http/HttpServer.h"
#include <lwip/sockets.h>
#include <lwip/netif.h>
#include <lwip/ip4_addr.h>
#include "lwip/stats.h"
#include "lwip/memp.h"
#include "lwip/tcp.h"
 
#include <cstring>
#include <cstdio>
#include <cstdlib>
#include <FreeRTOS.h>
#include <task.h>
#include <semphr.h>
 
#include "pico/stdlib.h"
 
#include "utility/utility.h"
#include "http/url_utils.h"
#include "framework/AppContext.h"
#include "time/TimeManager.h"
#include "network/Tcp.h"
#include "http/JsonResponse.h"
#include "events/EventManager.h"
 
// #define HTTP_SERVER_USE_TASK_PER_CLIENT  // ⚠️ NOT READY FOR PRODUCTION – Known instability with task-per-client mode
#ifdef HTTP_SERVER_USE_TASK_PER_CLIENT
#warning "⚠️ HTTP_SERVER_USE_TASK_PER_CLIENT is experimental and not yet production-ready. Use with caution."
#endif
 
static constexpr int MAX_CONCURRENT_CLIENTS = 1;
SemaphoreHandle_t clientSemaphore;
 
StackType_t HttpServer::xStack[HTTP_STACK_SIZE];
StaticTask_t HttpServer::xTaskBuffer;
 
// ----------------------------------------------------------------------------
// Task Context Struct
// ----------------------------------------------------------------------------
 
struct TaskParams
{
    HttpServer *server; // Pointer to the HttpServer instance
    Tcp *tcp;   // The client TCP connection
};
 
// ----------------------------------------------------------------------------
// Constructor and Task Entry
// ----------------------------------------------------------------------------
 
HttpServer::HttpServer(int port, Router &router)
    : port(port), router(router)
{
}
 
bool HttpServer::start()
{
    clientSemaphore = xSemaphoreCreateCounting(MAX_CONCURRENT_CLIENTS, MAX_CONCURRENT_CLIENTS);
    return xTaskCreateStatic(startServerTask, "HttpServer", HTTP_STACK_SIZE, this, 5, xStack, &xTaskBuffer);
}
 
void HttpServer::startServerTask(void *pvParameters)
{
    HttpServer *server = static_cast<HttpServer *>(pvParameters);
    server->run();
    vTaskDelete(NULL);
}
 
// ----------------------------------------------------------------------------
// Server Core
// ----------------------------------------------------------------------------
 
void HttpServer::run()
{
 
    printf("[HttpServer] Starting HTTP Server on port %d\n", port);
 
    if (!initNetwork())
    {
        return;
    }
 
    Tcp* listener = initListener();
    if (!listener)
    {
        printf("[HttpServer] Failed to initialize listener\n");
        return;
    }
 
    AppContext::get<EventManager>()->postEvent({SystemNotification::HttpServerStarted});
 
    // Optional: store listener as a class member if needed later
    while (true)
    {
        TRACE("[HttpServer] Waiting for client connection...\n");
        Tcp* conn = listener->accept();
        if (conn)
        {
            QUIET_PRINTF("\n===== HTTP CLIENT ACCEPTED ====\n");
            QUIET_PRINTF("[HttpServer] Accepted client connection\n");
            startHandlingClient(conn);
            vTaskDelay(pdMS_TO_TICKS(10));
            
            QUIET_PRINTF("[HttpServer] Client connection handled\n");
            QUIET_PRINTF("===============================\n\n");
            #if !defined(HTTP_SERVER_USE_TASK_PER_CLIENT)
                delete conn;
            #endif
        }
        else
        {
            warning("[HttpServer] Failed to accept client connection\n");
            vTaskDelay(pdMS_TO_TICKS(10)); // Wait before retrying 
        }
 
    }
 
    // Note: we never reach here in this model
    delete listener;
}
 
 
bool HttpServer::initNetwork()
{
    struct netif *netif;
 
    //TRACE("Waiting for DHCP lease...\n");
 
    while (true)
    {
        netif = netif_list;
        if (netif && netif->ip_addr.addr != 0)
        {
            break;
        }
        vTaskDelay(pdMS_TO_TICKS(10));
    }
 
    //TRACE("Assigned IP Address: %s\n", ip4addr_ntoa(&netif->ip_addr));
    return true;
}
 
 
Tcp* HttpServer::initListener()
{
    if (!listener.bindAndListen(port)) {
        return nullptr;
    }
    // Once server is listening
    Event e(SystemNotification::HttpServerStarted);
    AppContext::get<EventManager>()->postEvent(e); // tell others that we are up
    return &listener;
}
 
void HttpServer::startHandlingClient(Tcp* conn)
{
#ifdef HTTP_SERVER_USE_TASK_PER_CLIENT
    if (xSemaphoreTake(clientSemaphore, pdMS_TO_TICKS(100)) == pdPASS)
    {
        TaskParams *params = new TaskParams{this, conn};
 
        if (xTaskCreate(handleClientTask, "HttpClient", 4096, params, 4, NULL) == pdPASS)
        {
            TRACE("Client task created successfully");
        }
        else
        {
            TRACE("Failed to create client task");
            conn->close();
            delete params;
            xSemaphoreGive(clientSemaphore);
        }
    }
    else
    {
        TRACE("Max concurrent clients reached, closing connection");
        conn->close();
        // Optional: return a "503 Service Unavailable" if desired
    }
#else
    handleClient(conn);
 
#endif
}
 
void HttpServer::handleClient(Tcp* conn)
{
    int64_t start = to_ms_since_boot(get_absolute_time());
    int64_t lastActivity = start;
    const int64_t idleTimeoutMs = HTTP_IDLE_TIMEOUT; //  idle timeout - kill connection if no data received
 
 
    HttpRequest req = HttpRequest::receive(conn);
    if (req.getMethod().empty())
    {
        TRACE("[HttpServer] Empty HTTP method — client either closed connection or it is Safari trying to reuse closed socket\n");
        return;
    }
    TRACE("HttpRequest received: %s, %s\n", req.getMethod().c_str(), req.getPath().c_str());
    TRACE("HttpRequest content length: %s\n", req.getContentLength());
    TRACE("HttpRequest content type: %s\n", req.getContentType());
    TRACE("HttpRequest boundary: %s\n", req.getBoundary());
    TRACE("HttpRequest is multipart: %s\n", (req.isMultipart() ? "true" : "false"));
    TRACE("HttpRequest header count: %d\n", req.getHeaders().size());
    TRACE("HttpRequest url: %s\n", req.getUri().c_str());
    TRACE("HttpRequest path: %s\n", req.getPath().c_str());
    TRACE("HttpRequest query: %s\n", req.getQuery().c_str());
 
    for (const auto& param : req.getQueryParams())
    {
        TRACE("HttpRequest query parameter %s : %s\n", param.first.c_str(), param.second.c_str());
    }
 
    for (const auto& param : req.getFormParams())
    {
        TRACE("HttpRequest form parameter %s : %s\n", param.first.c_str(), param.second.c_str());
    }
 
    for (const auto& cookie : req.getCookies())
    {
        TRACE("HttpRequest cookie %s : %s\n", cookie.first.c_str(), cookie.second.c_str());
    }
 
    if (req.getContentLength() > 0)
    {
        TRACE("HttpRequest body length: %d\n", req.getBody().length());
        TRACE("HttpRequest start of body index: %d\n", req.getHeaderEnd());
    }
 
    TRACE("HttpRequest headers:\n");
    for (const auto& headr : req.getHeaders())
    {
        TRACE("%s : %s\n", headr.first.c_str(), headr.second.c_str());
    }
 
    TRACE("HttpRequest body: %s\n", req.getBody().c_str());
 
    QUIET_PRINTF("[HttpServer] Client request received: %s, path: %s\n", req.getMethod().c_str(), req.getPath().c_str());
 
    HttpResponse res(conn);
    TRACE("HttpResponse created\n");
    res.setHeader("Connection", "close"); // Close the connection 
 
    bool ok = router.handleRequest(req, res);
    TRACE("HttpRequest handled: %s\n", ok ? "true" : "false");
 
    if (!ok)
    {
        JsonResponse::sendError(res, 404, "NOT_FOUND", "route: " + std::string(req.getUri()));
    }
 
    lastActivity = to_ms_since_boot(get_absolute_time());
 
    if (req.getHeader("Connection") == "close")
    {
        TRACE("[HttpServer] Client requested Connection: close, closing connection\n");
        return;
    }
 
    if (to_ms_since_boot(get_absolute_time()) - lastActivity > idleTimeoutMs)
    {
        printf("[HttpServer] Idle timeout reached, closing connection\n");
        return;
    }
 
    conn->close();
    int64_t end = to_ms_since_boot(get_absolute_time());
    TRACE("[HttpServer] Client handled in %lld ms\n", end - start);
}
 
 
#ifdef HTTP_SERVER_USE_TASK_PER_CLIENT
void HttpServer::handleClientTask(void *pvParameters)
{
    TaskParams *params = static_cast<TaskParams *>(pvParameters);
    HttpServer *server = params->server;
    Tcp* tcp = params->tcp;
 
    TRACE("Handling client in task for socket %d\n", tcp->getSocketFd()); 
 
    server->handleClient(tcp);
 
    tcp->close();
    delete tcp;
    delete params;
 
    xSemaphoreGive(clientSemaphore);
    vTaskDelete(NULL);
}
#endif