core-legacy/controllers/api_v1_controllers.cc

#include <netdb.h>
#include <models/controller_dbo.h>
#include "api_v1_controllers.h"
using namespace api::v1;

void
controllers::get_all(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback)
{
    controller_dbo **all_controllers = controller_dbo::get_all();
    Json::Value all_controllers_json(Json::arrayValue);

    for(int i = 0; all_controllers[i] != nullptr; i++)
    {
        all_controllers_json.append(all_controllers[i]->to_json());
    }

    auto resp = HttpResponse::newHttpJsonResponse(all_controllers_json);

    callback(resp);

    controller_dbo::free_list(all_controllers);
}

void
controllers::get_one_by_id(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback, const std::string& controller_id)
{
    controller_dbo **controllers = controller_dbo::get_by_simple("id", controller_id.c_str(), (intptr_t) &sqlite3_bind_text);

    if(controllers[0])
    {
        auto resp = HttpResponse::newHttpJsonResponse(controllers[0]->to_json());

        callback(resp);
    }
    else
    {
        auto resp = HttpResponse::newHttpResponse();
        resp->setStatusCode(k404NotFound);

        callback(resp);
    }
    controller_dbo::free_list(controllers);
}

void
controllers::delete_one_by_id(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback, const std::string& controller_id)
{
    controller_dbo **controllers = controller_dbo::get_by_simple("id", controller_id.c_str(), (intptr_t) &sqlite3_bind_text);

    if(controllers[0])
    {
        auto resp = HttpResponse::newHttpResponse();
        if(!controllers[0]->remove())
        {
            resp->setStatusCode(k500InternalServerError);
        }

        callback(resp);
    }
    else
    {
        auto resp = HttpResponse::newHttpResponse();
        resp->setStatusCode(k404NotFound);

        callback(resp);
    }
    controller_dbo::free_list(controllers);
}

void
controllers::put_one_by_id(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback,
                           const std::string &controller_id)
{
    Json::Value body = *req->getJsonObject();

    controller_dbo **controllers = controller_dbo::get_by_simple("id", controller_id.c_str(), (intptr_t) &sqlite3_bind_text);

    if(controllers[0])
    {
        strncpy(controllers[0]->name, body["name"].asCString(), 128);
        strncpy(controllers[0]->ip, body["ip"].asCString(), 17);

        controllers[0]->name[127] = '\0';
        controllers[0]->ip[16] = '\0';

        auto resp = HttpResponse::newHttpResponse();
        if(controllers[0]->update())
        {
            resp = HttpResponse::newHttpJsonResponse(controllers[0]->to_json());
        }
        else
        {
            resp->setStatusCode(k500InternalServerError);
        }

        callback(resp);
    }
    else
    {
        auto resp = HttpResponse::newHttpResponse();
        resp->setStatusCode(k404NotFound);

        callback(resp);
    }
    controller_dbo::free_list(controllers);
}