XRayTracerFactory::XRayTracerFactory() : FactoryBase("envoy.tracers.xray") {}

                                           Server::Configuration::TracerFactoryContext& context) {

  std::string sampling_rules_json;

  TRY_NEEDS_AUDIT {

    sampling_rules_json =

        THROW_OR_RETURN_VALUE(Config::DataSource::read(proto_config.sampling_rule_manifest(), true,

                                                       context.serverFactoryContext().api()),

                              std::string);

  }

  END_TRY catch (EnvoyException& e) {

    ENVOY_LOG(error, "Failed to read sampling rules manifest because of {}.", e.what());

  }

  if (proto_config.daemon_endpoint().protocol() != envoy::config::core::v3::SocketAddress::UDP) {

    throw EnvoyException("X-Ray daemon endpoint must be a UDP socket address");

  }

  if (proto_config.daemon_endpoint().port_specifier_case() !=

      envoy::config::core::v3::SocketAddress::PortSpecifierCase::kPortValue) {

    throw EnvoyException("X-Ray daemon port must be specified as number. Not a named port.");

  }

  const std::string endpoint = fmt::format("{}:{}", proto_config.daemon_endpoint().address(),

                                           proto_config.daemon_endpoint().port_value());

  auto aws = absl::flat_hash_map<std::string, Protobuf::Value>{};

  for (const auto& field : proto_config.segment_fields().aws().fields()) {

    aws.emplace(field.first, field.second);

  }

  const auto& origin = proto_config.segment_fields().origin();

  XRayConfiguration xconfig{endpoint, proto_config.segment_name(), sampling_rules_json, origin,

                            std::move(aws)};

  return std::make_shared<XRay::Driver>(xconfig, context);

}