/**
 *
 * \section COPYRIGHT
 *
 * Copyright 2013-2020 Software Radio Systems Limited
 *
 * By using this file, you agree to the terms and conditions set
 * forth in the LICENSE file which can be found at the top level of
 * the distribution.
 *
 */

#include <assert.h>
#include <boost/program_options.hpp>
#include <boost/program_options/parsers.hpp>
#include <chrono>
#include <iostream>
#include <signal.h>
#include <thread>

#include "srslte/common/basic_pnf.h"

using namespace std;
namespace bpo = boost::program_options;

struct pnf_args_t {
  std::string type;
  std::string vnf_addr;
  uint16_t    vnf_port;
  uint32_t    sf_interval;
  int32_t     num_sf;
  uint32_t    tb_len;
};

void parse_args(pnf_args_t* args, int argc, char* argv[])
{
  // Command line only options
  bpo::options_description general("General options");

  general.add_options()("help,h", "Produce help message")("version,v", "Print version information and exit");

  // Command line or config file options
  bpo::options_description common("Configuration options");

  // clang-format off
  common.add_options()
          ("vnf.type", bpo::value<string>(&args->type)->default_value("gnb"), "VNF instance type [gnb,ue]")
          ("vnf.addr", bpo::value<string>(&args->vnf_addr)->default_value("127.0.0.1"), "VNF address")
          ("vnf.port", bpo::value<uint16_t>(&args->vnf_port)->default_value(3333), "VNF port")
          ("sf_interval", bpo::value<uint32_t>(&args->sf_interval)->default_value(1000), "Interval between subframes in us")
          ("num_sf", bpo::value<int32_t>(&args->num_sf)->default_value(-1), "Number of subframes to signal (-1 infinity)")
          ("tb_len", bpo::value<uint32_t>(&args->tb_len)->default_value(0), "TB lenth (0 for random size)");

  // clang-format on

  // these options are allowed on the command line
  bpo::options_description cmdline_options;
  cmdline_options.add(common).add(general);

  // parse the command line and store result in vm
  bpo::variables_map vm;
  bpo::store(bpo::command_line_parser(argc, argv).options(cmdline_options).run(), vm);
  bpo::notify(vm);

  // help option was given - print usage and exit
  if (vm.count("help")) {
    cout << "Usage: " << argv[0] << " [OPTIONS] config_file" << endl << endl;
    cout << common << endl << general << endl;
    exit(0);
  }
}

bool running = true;
void sig_int_handler(int signo)
{
  printf("SIGINT received. Exiting...\n");
  if (signo == SIGINT) {
    running = false;
  }
}

int main(int argc, char** argv)
{
  signal(SIGINT, sig_int_handler);

  pnf_args_t args;
  parse_args(&args, argc, argv);

  srslte::srslte_basic_pnf pnf(args.type, args.vnf_addr, args.vnf_port, args.sf_interval, args.num_sf, args.tb_len);

  pnf.start();

  while (running) {
    srslte::pnf_metrics_t metrics = pnf.get_metrics();
    printf("RTT=%d, #Error=%d, #PDUs=%d, Total TB size=%d, Rate=%.2f Mbit/s\n",
           metrics.avg_rtt_us,
           metrics.num_timing_errors,
           metrics.num_pdus,
           metrics.tb_size,
           metrics.tb_size * 8 / 1e6);

    std::this_thread::sleep_for(std::chrono::seconds(1));
  }

  pnf.stop();

  return 0;
}