alerter.cpp

#include <nlohmann/json.hpp>
#include <fstream>
#include <iostream>
#include "alerter.h"
#include "alert.h"
#include "manager.h"

using json = nlohmann::json;
using namespace std;

// create buffer from alert object
vector<uint8_t> Alerter::makeAlertBuffer(int type, float distance,
                                         float relativeVelocity)
{
    Alert alert(false, 1, type, distance, relativeVelocity);
    vector<uint8_t> serialized = alert.serialize();
    return serialized;
}

void Alerter::destroyAlertBuffer(char *buffer)
{
    delete[] buffer;
}

// create alerts buffer to send
vector<vector<uint8_t>> Alerter::sendAlerts(
    const vector<ObjectInformation> &output)
{
    vector<vector<uint8_t>> alerts;
    for (const ObjectInformation &objectInformation : output) {
        if (isSendAlert(objectInformation)) {
            vector<uint8_t> alertBuffer = makeAlertBuffer(
                objectInformation.type, objectInformation.distance,
                objectInformation.velocity.value());
            alerts.push_back(alertBuffer);
        }
    }
    return alerts;
}

// Check whether to send alert
bool Alerter::isSendAlert(const ObjectInformation &objectInformation)
{
    return objectInformation.distance < MIN_LEGAL_DISTANCE;
}

// create json file form the alert buffer
void Alerter::makeFileJSON()
{
    json j;
    j["endianness"] = "little";
    j["fields"] = json::array();
    // field AlertDetails
    json alertDetailsJson;
    alertDetailsJson["name"] = "AlertDetails";
    alertDetailsJson["size"] = 8;
    alertDetailsJson["type"] = "bit_field";
    alertDetailsJson["fields"] = json::array(
        {{{"name", "MessageType"}, {"size", 1}, {"type", "unsigned_int"}},
         {{"name", "Level"}, {"size", 3}, {"type", "unsigned_int"}},
         {{"name", "ObjectType"}, {"size", 4}, {"type", "unsigned_int"}}});
    // add AlertDetails to JSON
    j["fields"].push_back(alertDetailsJson);
    // add ObjectDistance
    json objectDistanceJson;
    objectDistanceJson["name"] = "ObjectDistance";
    objectDistanceJson["size"] = 32;
    objectDistanceJson["type"] = "float_fixed";
    j["fields"].push_back(objectDistanceJson);
    // add relativeVelocity
    json relativeVelocityJson;
    relativeVelocityJson["name"] = "relativeVelocity";
    relativeVelocityJson["size"] = 32;
    relativeVelocityJson["type"] = "float_fixed";
    j["fields"].push_back(relativeVelocityJson);
    // Write the JSON to the file
    ofstream output_file("../alert.json");
    if (output_file.is_open()) {
        // 4 = Indent level for easier reading
        output_file << j.dump(4);
        output_file.close();
    }
    else {
        LogManager::logErrorMessage(ErrorType::FILE_ERROR,
                                    "open file for writing");
    }
}