options_impl_test.cc

#include <algorithm>
#include <chrono>
#include <fstream>
#include <memory>
#include <string>
#include <vector>

#include "envoy/admin/v3/server_info.pb.h"
#include "envoy/common/exception.h"
#include "envoy/config/bootstrap/v3/bootstrap.pb.h"
#include "envoy/config/filter/http/buffer/v2/buffer.pb.h"
#include "envoy/config/typed_config.h"
#include "envoy/extensions/filters/http/buffer/v3/buffer.pb.h"
#include "envoy/server/filter_config.h"

#include "source/common/common/utility.h"
#include "source/extensions/filters/http/buffer/buffer_filter.h"
#include "source/server/options_impl.h"
#include "source/server/options_impl_platform.h"

#include "absl/strings/ascii.h"

#if defined(__linux__)
#include <sched.h>

#include "source/server/cgroup_cpu_util.h"
#include "source/server/options_impl_platform_linux.h"
#endif
#include "test/mocks/api/mocks.h"
#include "test/test_common/environment.h"
#include "test/test_common/logging.h"
#include "test/test_common/threadsafe_singleton_injector.h"
#include "test/test_common/utility.h"

#include "gmock/gmock.h"
#include "gtest/gtest.h"
#include "spdlog/spdlog.h"

namespace Envoy {
namespace {

class OptionsImplTest : public testing::Test {

public:
  // Do the ugly work of turning a std::string into a vector and create an OptionsImpl. Args are
  // separated by a single space: no fancy quoting or escaping.
  std::unique_ptr<OptionsImpl> createOptionsImpl(const std::string& args) {
    std::vector<std::string> words = TestUtility::split(args, ' ');
    return std::make_unique<OptionsImpl>(
        std::move(words), [](bool) { return "1"; }, spdlog::level::warn);
  }

  std::unique_ptr<OptionsImpl> createOptionsImpl(std::vector<std::string> args) {
    return std::make_unique<OptionsImpl>(
        std::move(args), [](bool) { return "1"; }, spdlog::level::warn);
  }
};

TEST_F(OptionsImplTest, HotRestartVersion) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy --hot-restart-version"), NoServingException,
                          "NoServingException");
}

TEST_F(OptionsImplTest, InvalidMode) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy --mode bogus"), MalformedArgvException, "bogus");
}

TEST_F(OptionsImplTest, InvalidComponentLogLevelWithFineGrainLogging) {
  EXPECT_THROW_WITH_REGEX(
      createOptionsImpl("envoy --enable-fine-grain-logging --component-log-level http:info"),
      MalformedArgvException,
      "--component-log-level will not work with --enable-fine-grain-logging");
}

TEST_F(OptionsImplTest, InvalidCommandLine) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy --blah"), MalformedArgvException,
                          "Couldn't find match for argument");
}

TEST_F(OptionsImplTest, InvalidSocketMode) {
  EXPECT_THROW_WITH_REGEX(
      createOptionsImpl("envoy --socket-path /foo/envoy_domain_socket --socket-mode foo"),
      MalformedArgvException, "error: invalid socket-mode 'foo'");
}

TEST_F(OptionsImplTest, V1Disallowed) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl(
      "envoy --mode validate --concurrency 2 -c hello --admin-address-path path --restart-epoch 1 "
      "--local-address-ip-version v6 -l info --service-cluster cluster --service-node node "
      "--service-zone zone --file-flush-interval-msec 9000 --drain-time-s 60 --log-format [%v] "
      "--parent-shutdown-time-s 90 --log-path /foo/bar --disable-hot-restart");
  EXPECT_EQ(Server::Mode::Validate, options->mode());
}

TEST_F(OptionsImplTest, ConcurrencyZeroIsOne) {
  std::unique_ptr<OptionsImpl> options =
      createOptionsImpl("envoy --mode validate --concurrency 0 ");
  EXPECT_EQ(1U, options->concurrency());

  options = createOptionsImpl("envoy --mode init_only");
  EXPECT_EQ(Server::Mode::InitOnly, options->mode());
}

TEST_F(OptionsImplTest, All) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl(
      "envoy --mode validate --concurrency 2 -c hello --admin-address-path path --restart-epoch 0 "
      "--local-address-ip-version v6 -l info --component-log-level upstream:debug,connection:trace "
      "--service-cluster cluster --service-node node --service-zone zone "
      "--file-flush-interval-msec 9000 "
      "--skip-hot-restart-on-no-parent "
      "--skip-hot-restart-parent-stats "
      "--drain-time-s 60 --log-format [%v] --parent-shutdown-time-s 90 "
      "--log-path "
      "/foo/bar "
      "--disable-hot-restart --cpuset-threads --allow-unknown-static-fields "
      "--reject-unknown-dynamic-fields --base-id 5 "
      "--use-dynamic-base-id --base-id-path /foo/baz "
      "--stats-tag foo:bar --stats-tag baz:bar "
      "--socket-path /foo/envoy_domain_socket --socket-mode 644");
  EXPECT_EQ(Server::Mode::Validate, options->mode());
  EXPECT_EQ(2U, options->concurrency());
  EXPECT_EQ("hello", options->configPath());
  EXPECT_EQ("path", options->adminAddressPath());
  EXPECT_EQ(Network::Address::IpVersion::v6, options->localAddressIpVersion());
  EXPECT_EQ(0U, options->restartEpoch());
  EXPECT_EQ(spdlog::level::info, options->logLevel());
  EXPECT_EQ(2, options->componentLogLevels().size());
  EXPECT_EQ("[%v]", options->logFormat());
  EXPECT_TRUE(options->logFormatSet());
  EXPECT_TRUE(options->skipHotRestartParentStats());
  EXPECT_TRUE(options->skipHotRestartOnNoParent());
  EXPECT_EQ("/foo/bar", options->logPath());
  EXPECT_EQ(false, options->enableFineGrainLogging());
  EXPECT_EQ("cluster", options->serviceClusterName());
  EXPECT_EQ("node", options->serviceNodeName());
  EXPECT_EQ("zone", options->serviceZone());
  EXPECT_EQ(std::chrono::milliseconds(9000), options->fileFlushIntervalMsec());
  EXPECT_EQ(std::chrono::seconds(60), options->drainTime());
  EXPECT_EQ(std::chrono::seconds(90), options->parentShutdownTime());
  EXPECT_TRUE(options->hotRestartDisabled());
  EXPECT_TRUE(options->cpusetThreadsEnabled());
  EXPECT_TRUE(options->allowUnknownStaticFields());
  EXPECT_TRUE(options->rejectUnknownDynamicFields());
  EXPECT_EQ(5U, options->baseId());
  EXPECT_TRUE(options->useDynamicBaseId());
  EXPECT_EQ("/foo/baz", options->baseIdPath());
  EXPECT_EQ("/foo/envoy_domain_socket", options->socketPath());
  EXPECT_EQ(0644, options->socketMode());
  EXPECT_EQ(2U, options->statsTags().size());

  options = createOptionsImpl("envoy --mode init_only");
  EXPECT_EQ(Server::Mode::InitOnly, options->mode());

  // Tested separately because it's mutually exclusive with --component-log-level.
  options = createOptionsImpl("envoy --enable-fine-grain-logging");
  EXPECT_EQ(true, options->enableFineGrainLogging());
}

// Either variants of allow-unknown-[static-]-fields works.
TEST_F(OptionsImplTest, AllowUnknownFields) {
  {
    std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy");
    EXPECT_FALSE(options->allowUnknownStaticFields());
  }
  {
    std::unique_ptr<OptionsImpl> options;
    EXPECT_LOG_CONTAINS(
        "warning",
        "--allow-unknown-fields is deprecated, use --allow-unknown-static-fields instead.",
        options = createOptionsImpl("envoy --allow-unknown-fields"));
    EXPECT_TRUE(options->allowUnknownStaticFields());
  }
  {
    std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --allow-unknown-static-fields");
    EXPECT_TRUE(options->allowUnknownStaticFields());
  }
}

TEST_F(OptionsImplTest, SetAll) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -c hello");
  bool hot_restart_disabled = options->hotRestartDisabled();
  bool signal_handling_enabled = options->signalHandlingEnabled();
  bool cpuset_threads_enabled = options->cpusetThreadsEnabled();

  options->setBaseId(109876);
  options->setUseDynamicBaseId(true);
  options->setBaseIdPath("foo");
  options->setConcurrency(42);
  options->setConfigPath("foo");
  envoy::config::bootstrap::v3::Bootstrap bootstrap_foo{};
  bootstrap_foo.mutable_node()->set_id("foo");
  options->setConfigProto(bootstrap_foo);
  options->setConfigYaml("bogus:");
  options->setAdminAddressPath("path");
  options->setLocalAddressIpVersion(Network::Address::IpVersion::v6);
  options->setDrainTime(std::chrono::seconds(42));
  options->setDrainStrategy(Server::DrainStrategy::Immediate);
  options->setParentShutdownTime(std::chrono::seconds(43));
  options->setLogLevel(spdlog::level::trace);
  options->setLogFormat("%L %n %v");
  options->setLogPath("/foo/bar");
  options->setRestartEpoch(44);
  options->setFileFlushIntervalMsec(std::chrono::milliseconds(45));
  options->setFileFlushMinSizeKB(128);
  options->setMode(Server::Mode::Validate);
  options->setServiceClusterName("cluster_foo");
  options->setServiceNodeName("node_foo");
  options->setServiceZone("zone_foo");
  options->setHotRestartDisabled(!options->hotRestartDisabled());
  options->setSignalHandling(!options->signalHandlingEnabled());
  options->setCpusetThreads(!options->cpusetThreadsEnabled());
  options->setAllowUnknownFields(true);
  options->setRejectUnknownFieldsDynamic(true);
  options->setSocketPath("/foo/envoy_domain_socket");
  options->setSocketMode(0644);
  options->setStatsTags({{"foo", "bar"}});

  EXPECT_EQ(109876, options->baseId());
  EXPECT_EQ(true, options->useDynamicBaseId());
  EXPECT_EQ("foo", options->baseIdPath());
  EXPECT_EQ(42U, options->concurrency());
  EXPECT_EQ("foo", options->configPath());
  envoy::config::bootstrap::v3::Bootstrap bootstrap_bar{};
  bootstrap_bar.mutable_node()->set_id("foo");
  EXPECT_TRUE(TestUtility::protoEqual(bootstrap_bar, options->configProto()));
  EXPECT_EQ("bogus:", options->configYaml());
  EXPECT_EQ("path", options->adminAddressPath());
  EXPECT_EQ(Network::Address::IpVersion::v6, options->localAddressIpVersion());
  EXPECT_EQ(std::chrono::seconds(42), options->drainTime());
  EXPECT_EQ(Server::DrainStrategy::Immediate, options->drainStrategy());
  EXPECT_EQ(spdlog::level::trace, options->logLevel());
  EXPECT_EQ("%L %n %v", options->logFormat());
  EXPECT_TRUE(options->logFormatSet());
  EXPECT_EQ("/foo/bar", options->logPath());
  EXPECT_EQ(std::chrono::seconds(43), options->parentShutdownTime());
  EXPECT_EQ(44, options->restartEpoch());
  EXPECT_EQ(std::chrono::milliseconds(45), options->fileFlushIntervalMsec());
  EXPECT_EQ(128U, options->fileFlushMinSizeKB());
  EXPECT_EQ(Server::Mode::Validate, options->mode());
  EXPECT_EQ("cluster_foo", options->serviceClusterName());
  EXPECT_EQ("node_foo", options->serviceNodeName());
  EXPECT_EQ("zone_foo", options->serviceZone());
  EXPECT_EQ(!hot_restart_disabled, options->hotRestartDisabled());
  EXPECT_EQ(!signal_handling_enabled, options->signalHandlingEnabled());
  EXPECT_EQ(!cpuset_threads_enabled, options->cpusetThreadsEnabled());
  EXPECT_TRUE(options->allowUnknownStaticFields());
  EXPECT_TRUE(options->rejectUnknownDynamicFields());
  EXPECT_EQ("/foo/envoy_domain_socket", options->socketPath());
  EXPECT_EQ(0644, options->socketMode());

  // Validate that CommandLineOptions is constructed correctly.
  Server::CommandLineOptionsPtr command_line_options = options->toCommandLineOptions();

  EXPECT_EQ(options->baseId(), command_line_options->base_id());
  EXPECT_EQ(options->concurrency(), command_line_options->concurrency());
  EXPECT_EQ(options->configPath(), command_line_options->config_path());
  EXPECT_EQ(options->configYaml(), command_line_options->config_yaml());
  EXPECT_EQ(options->adminAddressPath(), command_line_options->admin_address_path());
  EXPECT_EQ(envoy::admin::v3::CommandLineOptions::v6,
            command_line_options->local_address_ip_version());
  EXPECT_EQ(options->drainTime().count(), command_line_options->drain_time().seconds());
  EXPECT_EQ(envoy::admin::v3::CommandLineOptions::Immediate,
            command_line_options->drain_strategy());
  EXPECT_EQ(options->parentShutdownTime().count(),
            command_line_options->parent_shutdown_time().seconds());
  EXPECT_EQ(spdlog::level::to_string_view(options->logLevel()), command_line_options->log_level());
  EXPECT_EQ(options->logFormat(), command_line_options->log_format());
  EXPECT_EQ(options->logPath(), command_line_options->log_path());
  EXPECT_EQ(options->restartEpoch(), command_line_options->restart_epoch());
  EXPECT_EQ(options->fileFlushIntervalMsec().count() / 1000,
            command_line_options->file_flush_interval().seconds());
  EXPECT_EQ(envoy::admin::v3::CommandLineOptions::Validate, command_line_options->mode());
  EXPECT_EQ(options->serviceClusterName(), command_line_options->service_cluster());
  EXPECT_EQ(options->serviceNodeName(), command_line_options->service_node());
  EXPECT_EQ(options->serviceZone(), command_line_options->service_zone());
  EXPECT_EQ(options->hotRestartDisabled(), command_line_options->disable_hot_restart());
  EXPECT_EQ(options->mutexTracingEnabled(), command_line_options->enable_mutex_tracing());
  EXPECT_EQ(options->coreDumpEnabled(), command_line_options->enable_core_dump());
  EXPECT_EQ(options->cpusetThreadsEnabled(), command_line_options->cpuset_threads());
  EXPECT_EQ(options->socketPath(), command_line_options->socket_path());
  EXPECT_EQ(options->socketMode(), command_line_options->socket_mode());
  EXPECT_EQ(1U, command_line_options->stats_tag().size());
  EXPECT_EQ("foo:bar", command_line_options->stats_tag(0));
}

TEST_F(OptionsImplTest, DefaultParams) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -c hello");
  EXPECT_EQ(std::chrono::seconds(600), options->drainTime());
  EXPECT_EQ(Server::DrainStrategy::Gradual, options->drainStrategy());
  EXPECT_EQ(std::chrono::seconds(900), options->parentShutdownTime());
  EXPECT_EQ("", options->adminAddressPath());
  EXPECT_EQ(Network::Address::IpVersion::v4, options->localAddressIpVersion());
  EXPECT_EQ(Server::Mode::Serve, options->mode());
  EXPECT_EQ(spdlog::level::warn, options->logLevel());
  EXPECT_EQ("@envoy_domain_socket", options->socketPath());
  EXPECT_EQ(0, options->socketMode());
  EXPECT_EQ(0U, options->statsTags().size());
  EXPECT_FALSE(options->hotRestartDisabled());
  EXPECT_FALSE(options->cpusetThreadsEnabled());

  // Validate that CommandLineOptions is constructed correctly with default params.
  Server::CommandLineOptionsPtr command_line_options = options->toCommandLineOptions();

  EXPECT_EQ(600, command_line_options->drain_time().seconds());
  EXPECT_EQ(900, command_line_options->parent_shutdown_time().seconds());
  EXPECT_EQ("", command_line_options->admin_address_path());
  EXPECT_EQ(envoy::admin::v3::CommandLineOptions::v4,
            command_line_options->local_address_ip_version());
  EXPECT_EQ(envoy::admin::v3::CommandLineOptions::Serve, command_line_options->mode());
  EXPECT_EQ("@envoy_domain_socket", command_line_options->socket_path());
  EXPECT_EQ(0, command_line_options->socket_mode());
  EXPECT_FALSE(command_line_options->disable_hot_restart());
  EXPECT_FALSE(command_line_options->cpuset_threads());
  EXPECT_FALSE(command_line_options->allow_unknown_static_fields());
  EXPECT_FALSE(command_line_options->reject_unknown_dynamic_fields());
  EXPECT_EQ(0, options->statsTags().size());
}

TEST_F(OptionsImplTest, DefaultParamsNoConstructorArgs) {
  std::unique_ptr<OptionsImplBase> options = std::make_unique<OptionsImplBase>();
  EXPECT_EQ(std::chrono::seconds(600), options->drainTime());
  EXPECT_EQ(Server::DrainStrategy::Gradual, options->drainStrategy());
  EXPECT_EQ(std::chrono::seconds(900), options->parentShutdownTime());
  EXPECT_EQ("", options->adminAddressPath());
  EXPECT_EQ(Network::Address::IpVersion::v4, options->localAddressIpVersion());
  EXPECT_EQ(Server::Mode::Serve, options->mode());
  EXPECT_EQ("@envoy_domain_socket", options->socketPath());
  EXPECT_EQ(0, options->socketMode());
  EXPECT_EQ(0U, options->statsTags().size());
  EXPECT_FALSE(options->hotRestartDisabled());
  EXPECT_FALSE(options->cpusetThreadsEnabled());

  // Not supported for OptionsImplBase
  EXPECT_EQ(nullptr, options->toCommandLineOptions());

  // This is the only difference between this test and DefaultParams above, as
  // the DefaultParams constructor explicitly sets log level to warn.
  EXPECT_EQ(spdlog::level::info, options->logLevel());
}

TEST_F(OptionsImplTest, SetEnableFineGrainLogging) {
  std::unique_ptr<OptionsImplBase> options = std::make_unique<OptionsImplBase>();

  EXPECT_FALSE(options->enableFineGrainLogging());
  options->setEnableFineGrainLogging(true);
  EXPECT_TRUE(options->enableFineGrainLogging());
}

// Validates that the server_info proto is in sync with the options.
TEST_F(OptionsImplTest, OptionsAreInSyncWithProto) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -c hello");
  Server::CommandLineOptionsPtr command_line_options = options->toCommandLineOptions();
  // Failure of this condition indicates that the server_info proto is not in sync with the options.
  // If an option is added/removed, please update server_info proto as well to keep it in sync.

  // Currently the following 6 options are not defined in proto, hence the count differs by 6.
  // 1. version        - default TCLAP argument.
  // 2. help           - default TCLAP argument.
  // 3. ignore_rest    - default TCLAP argument.
  // 4. allow-unknown-fields  - deprecated alias of allow-unknown-static-fields.
  // 5. hot restart version - print the hot restart version and exit.
  const uint32_t options_not_in_proto = 5;

  // There are no deprecated options currently, add here as needed.
  const uint32_t deprecated_options = 0;

  EXPECT_EQ(options->count() - options_not_in_proto,
            command_line_options->GetDescriptor()->field_count() - deprecated_options);
}

TEST_F(OptionsImplTest, OptionsFromArgv) {
  const std::array<const char*, 3> args{"envoy", "-c", "hello"};
  std::unique_ptr<OptionsImpl> options = std::make_unique<OptionsImpl>(
      static_cast<int>(args.size()), args.data(), [](bool) { return "1"; }, spdlog::level::warn);
  // Spot check that the arguments were parsed.
  EXPECT_EQ("hello", options->configPath());
}

TEST_F(OptionsImplTest, OptionsFromArgvPrefix) {
  const std::array<const char*, 5> args{"envoy", "-c", "hello", "--admin-address-path", "goodbye"};
  std::unique_ptr<OptionsImpl> options = std::make_unique<OptionsImpl>(
      static_cast<int>(args.size()) - 2, // Pass in only a prefix of the args
      args.data(), [](bool) { return "1"; }, spdlog::level::warn);
  EXPECT_EQ("hello", options->configPath());
  // This should still have the default value since the extra arguments are
  // ignored.
  EXPECT_EQ("", options->adminAddressPath());
}

TEST_F(OptionsImplTest, BadCliOption) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy -c hello --local-address-ip-version foo"),
                          MalformedArgvException, "error: unknown IP address version 'foo'");
}

TEST_F(OptionsImplTest, ParseComponentLogLevels) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  options->parseComponentLogLevels("upstream:debug,connection:trace");
  const std::vector<std::pair<std::string, spdlog::level::level_enum>>& component_log_levels =
      options->componentLogLevels();
  EXPECT_EQ(2, component_log_levels.size());
  EXPECT_EQ("upstream", component_log_levels[0].first);
  EXPECT_EQ(spdlog::level::level_enum::debug, component_log_levels[0].second);
  EXPECT_EQ("connection", component_log_levels[1].first);
  EXPECT_EQ(spdlog::level::level_enum::trace, component_log_levels[1].second);
}

TEST_F(OptionsImplTest, ParseComponentLogLevelsWithBlank) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  options->parseComponentLogLevels("");
  EXPECT_EQ(0, options->componentLogLevels().size());
}

TEST_F(OptionsImplTest, InvalidComponent) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  EXPECT_THROW_WITH_REGEX(options->parseComponentLogLevels("blah:debug"), MalformedArgvException,
                          "error: invalid component specified 'blah'");
}

TEST_F(OptionsImplTest, InvalidComponentLogLevel) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  EXPECT_THROW_WITH_REGEX(options->parseComponentLogLevels("upstream:blah,connection:trace"),
                          MalformedArgvException, "error: invalid log level specified 'blah'");
}

TEST_F(OptionsImplTest, ComponentLogLevelContainsBlank) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  EXPECT_THROW_WITH_REGEX(options->parseComponentLogLevels("upstream:,connection:trace"),
                          MalformedArgvException, "error: invalid log level specified ''");
}

TEST_F(OptionsImplTest, InvalidComponentLogLevelStructure) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  EXPECT_THROW_WITH_REGEX(options->parseComponentLogLevels("upstream:foo:bar"),
                          MalformedArgvException,
                          "error: component log level not correctly specified 'upstream:foo:bar'");
}

TEST_F(OptionsImplTest, IncompleteComponentLogLevel) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy --mode init_only");
  EXPECT_THROW_WITH_REGEX(options->parseComponentLogLevels("upstream"), MalformedArgvException,
                          "component log level not correctly specified 'upstream'");
}

TEST_F(OptionsImplTest, InvalidLogLevel) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy -l blah"), MalformedArgvException,
                          "error: invalid log level specified 'blah'");
}

TEST_F(OptionsImplTest, ValidLogLevel) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -l critical");
  EXPECT_EQ(spdlog::level::level_enum::critical, options->logLevel());
}

TEST_F(OptionsImplTest, WarnIsValidLogLevel) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -l warn");
  EXPECT_EQ(spdlog::level::level_enum::warn, options->logLevel());
}

TEST_F(OptionsImplTest, AllowedLogLevels) {
  EXPECT_EQ("[trace][debug][info][warning|warn][error][critical][off]",
            OptionsImpl::allowedLogLevels());
}

TEST_F(OptionsImplTest, InvalidStatsTags) {
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy --stats-tag foo"), MalformedArgvException,
                          "error: misformatted stats-tag 'foo'");
}

TEST_F(OptionsImplTest, InvalidCharsInStatsTags) {
  EXPECT_THROW_WITH_REGEX(
      createOptionsImpl("envoy --stats-tag foo:b.ar"), MalformedArgvException,
      "error: misformatted stats-tag 'foo:b.ar' contains invalid char in 'b.ar'");
  EXPECT_THROW_WITH_REGEX(
      createOptionsImpl("envoy --stats-tag foo:b.a.r"), MalformedArgvException,
      "error: misformatted stats-tag 'foo:b.a.r' contains invalid char in 'b.a.r'");
  EXPECT_THROW_WITH_REGEX(createOptionsImpl("envoy --stats-tag f_o:bar"), MalformedArgvException,
                          "error: misformatted stats-tag 'f_o:bar' contains invalid char in 'f_o'");
}

TEST_F(OptionsImplTest, ValidStatsTagsCharacters) {
  Stats::TagVector test_tags{
      Stats::Tag{"foo", "bar"},
      Stats::Tag{"foo", "b:ar"},
      Stats::Tag{"foo", "b_-ar"},
  };

  for (const auto& tag : test_tags) {
    std::unique_ptr<OptionsImpl> options =
        createOptionsImpl(fmt::format("envoy --stats-tag {}:{}", tag.name_, tag.value_));
    EXPECT_EQ(options->statsTags().size(), 1);
    EXPECT_EQ(options->statsTags()[0].name_, tag.name_);
    EXPECT_EQ(options->statsTags()[0].value_, tag.value_);
  }
}

// Test that the test constructor comes up with the same default values as the main constructor.
TEST_F(OptionsImplTest, SaneTestConstructor) {
  std::unique_ptr<OptionsImpl> regular_options_impl(createOptionsImpl("envoy"));
  OptionsImpl test_options_impl("service_cluster", "service_node", "service_zone",
                                spdlog::level::level_enum::info);

  // Specified by constructor
  EXPECT_EQ("service_cluster", test_options_impl.serviceClusterName());
  EXPECT_EQ("service_node", test_options_impl.serviceNodeName());
  EXPECT_EQ("service_zone", test_options_impl.serviceZone());
  EXPECT_EQ(spdlog::level::level_enum::info, test_options_impl.logLevel());

  // Special (simplified) for tests
  EXPECT_EQ(1u, test_options_impl.concurrency());

  EXPECT_EQ(regular_options_impl->baseId(), test_options_impl.baseId());
  EXPECT_EQ(regular_options_impl->configPath(), test_options_impl.configPath());
  EXPECT_TRUE(TestUtility::protoEqual(regular_options_impl->configProto(),
                                      test_options_impl.configProto()));
  EXPECT_EQ(regular_options_impl->configYaml(), test_options_impl.configYaml());
  EXPECT_EQ(regular_options_impl->adminAddressPath(), test_options_impl.adminAddressPath());
  EXPECT_EQ(regular_options_impl->localAddressIpVersion(),
            test_options_impl.localAddressIpVersion());
  EXPECT_EQ(regular_options_impl->drainTime(), test_options_impl.drainTime());
  EXPECT_EQ(spdlog::level::level_enum::info, test_options_impl.logLevel());
  EXPECT_EQ(regular_options_impl->componentLogLevels(), test_options_impl.componentLogLevels());
  EXPECT_EQ(regular_options_impl->logPath(), test_options_impl.logPath());
  EXPECT_EQ(regular_options_impl->parentShutdownTime(), test_options_impl.parentShutdownTime());
  EXPECT_EQ(regular_options_impl->restartEpoch(), test_options_impl.restartEpoch());
  EXPECT_EQ(regular_options_impl->mode(), test_options_impl.mode());
  EXPECT_EQ(regular_options_impl->fileFlushIntervalMsec(),
            test_options_impl.fileFlushIntervalMsec());
  EXPECT_EQ(regular_options_impl->hotRestartDisabled(), test_options_impl.hotRestartDisabled());
  EXPECT_EQ(regular_options_impl->cpusetThreadsEnabled(), test_options_impl.cpusetThreadsEnabled());
}

TEST_F(OptionsImplTest, SetBothConcurrencyAndCpuset) {
  EXPECT_LOG_CONTAINS(
      "warning",
      "Both --concurrency and --cpuset-threads options are set; not applying --cpuset-threads.",
      std::unique_ptr<OptionsImpl> options =
          createOptionsImpl("envoy -c hello --concurrency 42 --cpuset-threads"));
}

TEST_F(OptionsImplTest, SetCpusetOnly) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl("envoy -c hello --cpuset-threads");
  EXPECT_NE(options->concurrency(), 0);
}

TEST_F(OptionsImplTest, LogFormatDefault) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl({"envoy", "-c", "hello"});
  EXPECT_EQ(options->logFormat(), "[%Y-%m-%d %T.%e][%t][%l][%n] [%g:%#] %v");
  EXPECT_FALSE(options->logFormatSet());
}

TEST_F(OptionsImplTest, SkipHotRestartDefaults) {
  std::unique_ptr<OptionsImpl> options = createOptionsImpl({"envoy", "-c", "hello"});
  EXPECT_FALSE(options->skipHotRestartOnNoParent());
  EXPECT_FALSE(options->skipHotRestartParentStats());
}

TEST_F(OptionsImplTest, LogFormatOverride) {
  std::unique_ptr<OptionsImpl> options =
      createOptionsImpl({"envoy", "-c", "hello", "--log-format", "%%v %v %t %v"});
  EXPECT_EQ(options->logFormat(), "%%v %v %t %v");
  EXPECT_TRUE(options->logFormatSet());
}

TEST_F(OptionsImplTest, LogFormatOverrideNoPrefix) {
  std::unique_ptr<OptionsImpl> options =
      createOptionsImpl({"envoy", "-c", "hello", "--log-format", "%%v %v %t %v"});
  EXPECT_EQ(options->logFormat(), "%%v %v %t %v");
  EXPECT_TRUE(options->logFormatSet());
}

// Test that --base-id and --restart-epoch with non-default values are accepted.
TEST_F(OptionsImplTest, SetBaseIdAndRestartEpoch) {
  std::unique_ptr<OptionsImpl> options =
      createOptionsImpl({"envoy", "-c", "hello", "--base-id", "99", "--restart-epoch", "999"});
  EXPECT_EQ(99U, options->baseId());
  EXPECT_EQ(999U, options->restartEpoch());
}

// Test that --use-dynamic-base-id and --restart-epoch with a non-default value is not accepted.
TEST_F(OptionsImplTest, SetUseDynamicBaseIdAndRestartEpoch) {
  EXPECT_THROW_WITH_REGEX(
      createOptionsImpl({"envoy", "-c", "hello", "--use-dynamic-base-id", "--restart-epoch", "1"}),
      MalformedArgvException, "error: cannot use --restart-epoch=1 with --use-dynamic-base-id");
}

#if defined(__linux__)

using testing::DoAll;
using testing::Return;
using testing::SetArgPointee;

class MockCgroupDetector : public CgroupDetectorImpl {
public:
  MOCK_METHOD(absl::optional<uint32_t>, getCpuLimit, (Filesystem::Instance & fs), (override));
};

class OptionsImplPlatformLinuxTest : public testing::Test {
public:
};

TEST_F(OptionsImplPlatformLinuxTest, AffinityTest1) {
  // Success case: cpuset size and hardware thread count are the same.
  unsigned int fake_hw_threads = 4;
  cpu_set_t test_set;
  Api::MockLinuxOsSysCalls linux_os_sys_calls;
  TestThreadsafeSingletonInjector<Api::LinuxOsSysCallsImpl> linux_os_calls(&linux_os_sys_calls);

  // Set cpuset size to be four.
  CPU_ZERO(&test_set);
  for (int i = 0; i < 4; i++) {
    CPU_SET(i, &test_set);
  }

  EXPECT_CALL(linux_os_sys_calls, sched_getaffinity(_, _, _))
      .WillOnce(DoAll(SetArgPointee<2>(test_set), Return(Api::SysCallIntResult{0, 0})));
  EXPECT_EQ(OptionsImplPlatformLinux::getCpuAffinityCount(fake_hw_threads), 4);
}

TEST_F(OptionsImplPlatformLinuxTest, AffinityTest2) {
  // Success case: cpuset size is half of the hardware thread count.
  unsigned int fake_hw_threads = 16;
  cpu_set_t test_set;
  Api::MockLinuxOsSysCalls linux_os_sys_calls;
  TestThreadsafeSingletonInjector<Api::LinuxOsSysCallsImpl> linux_os_calls(&linux_os_sys_calls);

  // Set cpuset size to be eight.
  CPU_ZERO(&test_set);
  for (int i = 0; i < 8; i++) {
    CPU_SET(i, &test_set);
  }

  EXPECT_CALL(linux_os_sys_calls, sched_getaffinity(_, _, _))
      .WillOnce(DoAll(SetArgPointee<2>(test_set), Return(Api::SysCallIntResult{0, 0})));
  EXPECT_EQ(OptionsImplPlatformLinux::getCpuAffinityCount(fake_hw_threads), 8);
}

TEST_F(OptionsImplPlatformLinuxTest, AffinityTest3) {
  // Failure case: cpuset size is bigger than the hardware thread count.
  unsigned int fake_hw_threads = 4;
  cpu_set_t test_set;
  Api::MockLinuxOsSysCalls linux_os_sys_calls;
  TestThreadsafeSingletonInjector<Api::LinuxOsSysCallsImpl> linux_os_calls(&linux_os_sys_calls);

  // Set cpuset size to be eight.
  CPU_ZERO(&test_set);
  for (int i = 0; i < 8; i++) {
    CPU_SET(i, &test_set);
  }

  EXPECT_CALL(linux_os_sys_calls, sched_getaffinity(_, _, _))
      .WillOnce(DoAll(SetArgPointee<2>(test_set), Return(Api::SysCallIntResult{0, 0})));
  EXPECT_EQ(OptionsImplPlatformLinux::getCpuAffinityCount(fake_hw_threads), fake_hw_threads);
}

TEST_F(OptionsImplPlatformLinuxTest, AffinityTest4) {
  // When sched_getaffinity() fails, expect to get the hardware thread count.
  unsigned int fake_hw_threads = 8;
  cpu_set_t test_set;
  Api::MockLinuxOsSysCalls linux_os_sys_calls;
  TestThreadsafeSingletonInjector<Api::LinuxOsSysCallsImpl> linux_os_calls(&linux_os_sys_calls);

  // Set cpuset size to be four.
  CPU_ZERO(&test_set);
  for (int i = 0; i < 4; i++) {
    CPU_SET(i, &test_set);
  }

  EXPECT_CALL(linux_os_sys_calls, sched_getaffinity(_, _, _))
      .WillOnce(DoAll(SetArgPointee<2>(test_set), Return(Api::SysCallIntResult{-1, 0})));
  EXPECT_EQ(OptionsImplPlatformLinux::getCpuAffinityCount(fake_hw_threads), fake_hw_threads);
}

// Mock-based tests for getCpuCount environment variable control

TEST_F(OptionsImplPlatformLinuxTest, EnvVarDisablesCgroupDetectionMocked) {
  // Test that ENVOY_CGROUP_CPU_DETECTION=false prevents getCpuLimit calls
  setenv("ENVOY_CGROUP_CPU_DETECTION", "false", 1);

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Verify getCpuLimit is NOT called when env var disables detection
  EXPECT_CALL(mock_detector, getCpuLimit(_)).Times(0);

  uint32_t result = OptionsImplPlatform::getCpuCount();
  EXPECT_GE(result, 1U); // Should return hardware thread count

  unsetenv("ENVOY_CGROUP_CPU_DETECTION");
}

TEST_F(OptionsImplPlatformLinuxTest, EnvVarAllowsCgroupDetectionMocked) {
  // Test that default behavior (enabled) calls getCpuLimit
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Default: enabled

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock successful cgroup detection returning 2 CPUs
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(2)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Result should be influenced by the mocked cgroup limit of 2
  EXPECT_GE(result, 1U);
}

TEST_F(OptionsImplPlatformLinuxTest, EnvVarTrueAllowsCgroupDetectionMocked) {
  // Test that ENVOY_CGROUP_CPU_DETECTION=true enables detection
  setenv("ENVOY_CGROUP_CPU_DETECTION", "true", 1);

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning no limit (unlimited)
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::nullopt));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  EXPECT_GE(result, 1U); // Should fallback to hardware thread count

  unsetenv("ENVOY_CGROUP_CPU_DETECTION");
}

TEST_F(OptionsImplPlatformLinuxTest, CgroupLimitConstrainsResult) {
  // Test that cgroup limit is used in min() calculation when it's the smallest value
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Enable detection

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning 2 CPUs (lower than typical hardware)
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(2)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Result should be constrained by cgroup limit
  // Since we can't easily mock hardware threads and affinity in this test,
  // we verify the cgroup limit is considered (result influenced by mock)
  EXPECT_GE(result, 1U);
  EXPECT_LE(result, 2U); // Should not exceed the mocked cgroup limit
}

TEST_F(OptionsImplPlatformLinuxTest, CgroupDetectionReturnsNullopt) {
  // Test graceful fallback when cgroup detection returns no limit (unlimited)
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Enable detection

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning nullopt (no limit/unlimited)
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::nullopt));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Should fall back to hardware thread count when no cgroup limit
  EXPECT_GE(result, 1U);
  // Without cgroup constraint, should get at least hardware thread count
  // (limited by affinity in practice, but we can't easily mock that here)
}

TEST_F(OptionsImplPlatformLinuxTest, CgroupLimitVeryLow) {
  // Test that very low cgroup limits are respected (heavy constraint scenario)
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Enable detection

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning 1 CPU (very constrained)
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(1)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Even with very low cgroup limit, Envoy guarantees at least 1 CPU
  EXPECT_EQ(result, 1U); // Should be exactly 1 due to cgroup constraint
}

TEST_F(OptionsImplPlatformLinuxTest, CgroupLimitHigherThanTypicalHardware) {
  // Test when cgroup allows more CPUs than typical hardware might have
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Enable detection

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning high CPU count
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(32)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Result should be constrained by hardware/affinity, not the high cgroup limit
  EXPECT_GE(result, 1U);
  // In practice, hardware thread count or affinity will be the constraint
  EXPECT_LE(result, 32U); // Sanity check - shouldn't exceed the mock value
}

TEST_F(OptionsImplPlatformLinuxTest, EnvoyMinimumOneCPUGuarantee) {
  // Test Envoy's guarantee of at least 1 CPU even with theoretical edge cases
  unsetenv("ENVOY_CGROUP_CPU_DETECTION"); // Enable detection

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock cgroup detection returning 0 (theoretical edge case)
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(0)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  // Envoy's max(1U, effective_count) should ensure at least 1 CPU
  EXPECT_GE(result, 1U); // Must honor Envoy's minimum guarantee
}

TEST_F(OptionsImplPlatformLinuxTest, CombinedEnvVarAndCgroupScenarios) {
  // Test various environment variable states with different cgroup responses

  // Scenario 1: Explicitly enabled with successful detection
  setenv("ENVOY_CGROUP_CPU_DETECTION", "true", 1);

  MockCgroupDetector mock_detector;
  TestThreadsafeSingletonInjector<CgroupDetectorImpl> injector(&mock_detector);

  // Mock successful cgroup detection
  EXPECT_CALL(mock_detector, getCpuLimit(_)).WillOnce(Return(absl::optional<uint32_t>(4)));

  uint32_t result = OptionsImplPlatform::getCpuCount();
  EXPECT_GE(result, 1U);
  EXPECT_LE(result, 4U); // Should consider the cgroup limit

  unsetenv("ENVOY_CGROUP_CPU_DETECTION");
}
#endif

class TestFactory : public Config::TypedFactory {
public:
  ~TestFactory() override = default;
  std::string category() const override { return "test"; }
  ProtobufTypes::MessagePtr createEmptyConfigProto() override {
    return std::make_unique<Protobuf::StringValue>();
  }
};

class TestTestFactory : public TestFactory {
public:
  std::string name() const override { return "test"; }
};

class TestingFactory : public Config::TypedFactory {
public:
  ~TestingFactory() override = default;
  std::string category() const override { return "testing"; }
  ProtobufTypes::MessagePtr createEmptyConfigProto() override {
    return std::make_unique<Protobuf::StringValue>();
  }
};

// Test that deprecated --allow-unknown-fields warning is logged when skip_deprecated_logs is false
TEST_F(OptionsImplTest, DeprecatedAllowUnknownFieldsWarningWhenNotSkipped) {
  EXPECT_LOG_CONTAINS(
      "warn", "--allow-unknown-fields is deprecated, use --allow-unknown-static-fields instead.",
      createOptionsImpl("envoy --allow-unknown-fields"));
}

// Test that deprecated --allow-unknown-fields warning is suppressed when skip_deprecated_logs is
// true
TEST_F(OptionsImplTest, DeprecatedAllowUnknownFieldsWarningWhenSkipped) {
  EXPECT_LOG_NOT_CONTAINS(
      "warn", "--allow-unknown-fields is deprecated, use --allow-unknown-static-fields instead.",
      createOptionsImpl("envoy --allow-unknown-fields --skip-deprecated-logs"));
}

} // namespace
} // namespace Envoy