main.cc

#include <iostream>

#include <boost/filesystem.hpp>
#include <boost/program_options.hpp>
#include <boost/property_tree/ini_parser.hpp>
#include <boost/signals2.hpp>

#include "libaktualizr/aktualizr.h"
#include "libaktualizr/config.h"
#include "logging/logging.h"
#include "primary/aktualizr_helpers.h"
#include "secondary.h"
#include "utilities/aktualizr_version.h"
#include "utilities/sig_handler.h"
#include "utilities/utils.h"
#ifdef TORIZON
#include "device_data_proxy.h"
#include "update_events.h"
#endif

#ifdef TORIZON
#define PROGRAM_NAME "aktualizr-torizon"
#else
#define PROGRAM_NAME "aktualizr"
#endif

namespace bpo = boost::program_options;

void checkInfoOptions(const bpo::options_description &description, const bpo::variables_map &vm) {
  if (vm.count("help") != 0) {
    std::cout << description << '\n';
    exit(EXIT_SUCCESS);
  }
  if (vm.count("version") != 0) {
    std::cout << "Current " PROGRAM_NAME " version is: " << aktualizr_version() << "\n";
    exit(EXIT_SUCCESS);
  }
}

bpo::variables_map parseOptions(int argc, char **argv) {
  bpo::options_description description(PROGRAM_NAME " command line options");
  // clang-format off
  // Try to keep these options in the same order as Config::updateFromCommandLine().
  // The first three are commandline only.
  description.add_options()
      ("help,h", "print usage")
      ("version,v", "Current " PROGRAM_NAME " version")
      ("config,c", bpo::value<std::vector<boost::filesystem::path> >()->composing(), "configuration file or directory")
      ("loglevel", bpo::value<int>(), "set log level 0-5 (trace, debug, info, warning, error, fatal)")
      ("run-mode", bpo::value<std::string>(), "run mode of aktualizr: full, once, campaign_check, campaign_accept, campaign_decline, campaign_postpone, check, download, or install")
      ("tls-server", bpo::value<std::string>(), "URL of device gateway")
      ("repo-server", bpo::value<std::string>(), "URL of the Uptane Image repository")
      ("director-server", bpo::value<std::string>(), "URL of the Uptane Director repository")
      ("primary-ecu-serial", bpo::value<std::string>(), "serial number of Primary ECU")
      ("primary-ecu-hardware-id", bpo::value<std::string>(), "hardware ID of Primary ECU")
      ("secondary-config-file", bpo::value<boost::filesystem::path>(), "Secondary ECUs configuration file")
      ("campaign-id", bpo::value<std::string>(), "ID of the campaign to act on")
      ("hwinfo-file", bpo::value<boost::filesystem::path>(), "custom hardware information JSON file")
#ifdef TORIZON
      ("enable-data-proxy", "enable proxy to send device data to Torizon OTA via SendDeviceData()")
      ("data-proxy-port", bpo::value<int>(), "TCP port to be used by the proxy (defaults to 8850)")
#endif
      ;

  // clang-format on

  // consider the first positional argument as the aktualizr run mode
  bpo::positional_options_description pos;
  pos.add("run-mode", 1);

  bpo::variables_map vm;
  std::vector<std::string> unregistered_options;
  try {
    bpo::basic_parsed_options<char> parsed_options =
        bpo::command_line_parser(argc, argv).options(description).positional(pos).allow_unregistered().run();
    bpo::store(parsed_options, vm);
    checkInfoOptions(description, vm);
    bpo::notify(vm);
    unregistered_options = bpo::collect_unrecognized(parsed_options.options, bpo::exclude_positional);
    if (vm.count("help") == 0 && !unregistered_options.empty()) {
      std::cout << description << "\n";
      exit(EXIT_FAILURE);
    }
  } catch (const bpo::required_option &ex) {
    // print the error and append the default commandline option description
    std::cout << ex.what() << std::endl << description;
    exit(EXIT_FAILURE);
  } catch (const bpo::error &ex) {
    checkInfoOptions(description, vm);

    // log boost error
    LOG_ERROR << "boost command line option error: " << ex.what();

    // print the error message to the standard output too, as the user provided
    // a non-supported commandline option
    std::cout << ex.what() << '\n';

    // set the returnValue, thereby ctest will recognize
    // that something went wrong
    exit(EXIT_FAILURE);
  }

  return vm;
}

#ifndef TORIZON
void processEvent(const std::shared_ptr<event::BaseEvent> &event) {
  if (event->isTypeOf<event::DownloadProgressReport>() || event->variant == "UpdateCheckComplete") {
    // Do nothing; libaktualizr already logs it.
  } else if (event->variant == "AllDownloadsComplete") {
    const auto *downloads_complete = dynamic_cast<event::AllDownloadsComplete *>(event.get());
    LOG_INFO << "got " << event->variant << " event with status: " << downloads_complete->result.status;
  } else if (event->variant == "AllInstallsComplete") {
    const auto *installs_complete = dynamic_cast<event::AllInstallsComplete *>(event.get());
    LOG_INFO << "got " << event->variant << " event with status: " << installs_complete->result.dev_report.result_code;
  } else {
    LOG_INFO << "got " << event->variant << " event";
  }
}
#endif

int main(int argc, char *argv[]) {
  logger_init();
  logger_set_threshold(boost::log::trivial::info);

  bpo::variables_map commandline_map = parseOptions(argc, argv);

  LOG_INFO << "Aktualizr version " << aktualizr_version() << " starting";

  int r = EXIT_FAILURE;

  try {
    if (geteuid() != 0) {
      LOG_WARNING << "\033[31mAktualizr is currently running as non-root and may not work as expected! Aktualizr "
                     "should be run as root for proper functionality.\033[0m\n";
    }
    Config config(commandline_map);
    LOG_DEBUG << "Current directory: " << boost::filesystem::current_path().string();

    Aktualizr aktualizr(config);
#ifdef TORIZON
    std::function<void(std::shared_ptr<event::BaseEvent> event)> f_cb = UpdateEvents::processEvent;
#else
    std::function<void(std::shared_ptr<event::BaseEvent> event)> f_cb = processEvent;
#endif
    boost::signals2::scoped_connection conn;

    conn = aktualizr.SetSignalHandler(f_cb);

    if (!config.uptane.secondary_config_file.empty()) {
      try {
        Primary::initSecondaries(aktualizr, config.uptane.secondary_config_file);
      } catch (const std::exception &e) {
        LOG_ERROR << "Failed to initialize Secondaries: " << e.what();
        LOG_ERROR << "Exiting...";
        return EXIT_FAILURE;
      }
    }

    aktualizr.Initialize();

#ifdef TORIZON
    // configure device data proxy
    DeviceDataProxy proxy(&aktualizr);
    if (commandline_map.count("enable-data-proxy") != 0) {
      // proxy conflicts with hwinfo-file
      if (commandline_map.count("hwinfo-file") != 0) {
        LOG_ERROR << "Parameters --enable-data-proxy and --hwinfo-file conflict with each other. "
                  << "Please enable only one of them!";
        return EXIT_FAILURE;
      }

      // setup proxy TCP port
      uint16_t port = 0;
      if (commandline_map.count("data-proxy-port") != 0) {
        port = commandline_map["data-proxy-port"].as<uint16_t>();
      }

      // start proxy
      try {
        proxy.Initialize(port);
        proxy.Start();
      } catch (const std::exception &ex) {
        proxy.Stop(true);
        LOG_ERROR << "PROXY: error: " << ex.what();
      }
    }

    // Check if Offline Updates are enabled
    // TODO: [OFFUPD] Review these logs post-MVP
    if (config.uptane.enable_offline_updates) {
      LOG_INFO << "Offline Updates are enabled";
    } else {
      LOG_INFO << "Offline Updates are disabled";
    }
#endif

    // handle unix signals
#ifdef TORIZON
    SigHandler::get().start([&aktualizr, &proxy]() {
      proxy.Stop(false);
      aktualizr.Abort();
      aktualizr.Shutdown();
    });
#else
    SigHandler::get().start([&aktualizr]() {
      aktualizr.Abort();
      aktualizr.Shutdown();
    });
#endif
    SigHandler::signal(SIGHUP);
    SigHandler::signal(SIGINT);
    SigHandler::signal(SIGTERM);

    if (commandline_map.count("hwinfo-file") != 0) {
      auto file = commandline_map["hwinfo-file"].as<boost::filesystem::path>();
      auto hwinfo = Utils::parseJSONFile(file);
      if (hwinfo.empty()) {
        LOG_ERROR << file << " is not a valid JSON file";
        return EXIT_FAILURE;
      }
      aktualizr.SetCustomHardwareInfo(hwinfo);
    }

    std::string run_mode;
    if (commandline_map.count("run-mode") != 0) {
      run_mode = commandline_map["run-mode"].as<std::string>();
    }
    // launch the first event
    if (run_mode == "campaign_check") {
      aktualizr.CampaignCheck().get();
    } else if (run_mode == "campaign_accept" || run_mode == "campaign_decline" || run_mode == "campaign_postpone") {
      if (commandline_map.count("campaign-id") == 0) {
        throw std::runtime_error(run_mode + " requires a campaign ID");
      }
      aktualizr.CampaignControl(commandline_map["campaign-id"].as<std::string>(), campaign::cmdFromName(run_mode))
          .get();
    } else if (run_mode == "check") {
      aktualizr.SendDeviceData().get();
      aktualizr.CheckUpdates().get();
    } else if (run_mode == "download") {
      result::UpdateCheck update_result = aktualizr.CheckUpdates().get();
      aktualizr.Download(update_result.updates).get();
    } else if (run_mode == "install") {
      result::UpdateCheck update_result = aktualizr.CheckUpdates().get();
      aktualizr.Install(update_result.updates).get();
    } else if (run_mode == "once") {
      aktualizr.UptaneCycle();
    } else {
      boost::signals2::connection ac_conn =
          aktualizr.SetSignalHandler(std::bind(targets_autoclean_cb, std::ref(aktualizr), std::placeholders::_1));

      try {
        aktualizr.RunForever().get();
      } catch (const std::exception &ex) {
        LOG_ERROR << "Aktualizr::RunForever exiting: " << ex.what();
        return EXIT_FAILURE;
      }

      LOG_DEBUG << "Aktualizr daemon exiting...";
    }
    r = EXIT_SUCCESS;
  } catch (const std::exception &ex) {
    LOG_ERROR << ex.what();
  }

  return r;
}