sys.h

Go to the documentation of this file.

// Copyright (c) 2024 anabrid GmbH
// Contact: https://www.anabrid.com/licensing/
//
// SPDX-License-Identifier: MIT OR GPL-2.0-or-later
 
#pragma once
 
#include "build/distributor.h"
#include "lucidac/front_panel_signaling.h"
#include "mode/counters.h"
#include "nvmconfig/vendor.h"
#include "protocol/handler.h"
#include "protocol/jsonl_logging.h"
#include "utils/hashflash.h"
#include "utils/reboot.h"
 
namespace msg {
namespace handlers {
 
class GetSystemIdent : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    msg_out["serial"] = nvmconfig::VendorOTP::get().serial_number;
    msg_out["mac"] = net::StartupConfig::get().mac;
 
    if (req.msg_in.containsKey("blink")) {
      leds::indicate_error(); // this is just blocking blinking for a few seconds
    }
 
    dist::write_to_json(msg_out.createNestedObject("fw_build"));
    loader::flashimage::toJson(msg_out.createNestedObject("fw_image"));
    return utils::status::success();
  }
};
 
#ifdef ANABRID_WRITE_EEPROM
 
class WriteSystemIdent : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    auto &persistent = nvmconfig::PersistentSettingsWriter::get();
    auto &vendor = nvmconfig::VendorOTP::get();
    persistent.read_from_eeprom(); // at first run, this will result in default values
    if (req.msg_in.containsKey("vendor"))
      vendor.fromJson(req.msg_in["vendor"], nvmconfig::Context::User);
    bool valid = vendor.is_valid();
    if (valid)
      persistent.write_to_eeprom();
 
    msg_out["valid"] = valid;
    return utils::status::success();
  }
};
 
class ResetSystemIdent : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    bool write_to_hardware = req.msg_in["write_to_hardware"];
    auto &persistent = nvmconfig::PersistentSettingsWriter::get();
    persistent.reset_defaults(write_to_hardware);
    return utils::status::success();
  }
};
 
 
class ReadSystemIdent : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out)override {
    auto &persistent = nvmconfig::PersistentSettingsWriter::get();
    if (req.msg_in.containsKey("read_from_eeprom"))
      persistent.read_from_eeprom();
 
    // dump infos about all subsystems, including passwords, etc
    auto subsystems = msg_out.createNestedObject("subsystems");
    for (auto const &sys : nvmconfig::PersistentSettingsWriter::get().subsystems) {
      auto sysout = subsystems.createNestedObject(sys->name());
      sys->toJson(sysout, nvmconfig::Context::User);
    }
 
    return utils::status::success();
  }
};
#endif
 
class RebootHandler : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    loader::reboot(); // does actually not return
    return utils::status::success();
  }
};
 
class SyslogHandler : public MessageHandler {
public:
  bool replyStreaming(const Request& req, Stream &io) override {
    msg::StreamingJsonResponse res(io);
    res.begin_envelope(req);
    msg::StartupLog::get().stream_to_json(res);
    res.end_envelope();
    return true; // = is implemented
  }
};
 
class SystemStats : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    auto perf_counters = msg_out.createNestedObject("perf_counters");
    mode::PerformanceCounter::get().to_json(perf_counters);
    return utils::status::success();
  }
};
 
} // namespace handlers
} // namespace msg