#include "source/extensions/tracers/dynamic_ot/config.h"

#include "envoy/config/trace/v3/dynamic_ot.pb.h"

#include "envoy/config/trace/v3/dynamic_ot.pb.validate.h"

#include "envoy/registry/registry.h"

#include "source/common/common/utility.h"

#include "source/extensions/tracers/dynamic_ot/dynamic_opentracing_driver_impl.h"

namespace Envoy {

namespace Extensions {

namespace Tracers {

namespace DynamicOt {

DynamicOpenTracingTracerFactory::DynamicOpenTracingTracerFactory()

    : FactoryBase("envoy.tracers.dynamic_ot") {}

Tracing::DriverSharedPtr DynamicOpenTracingTracerFactory::createTracerDriverTyped(

    const envoy::config::trace::v3::DynamicOtConfig& proto_config,

    Server::Configuration::TracerFactoryContext& context) {

  const std::string& library = proto_config.library();

  const ProtobufWkt::Struct& config_struct = proto_config.config();

  absl::StatusOr<std::string> json_or_error = MessageUtil::getJsonStringFromMessage(config_struct);

  ENVOY_BUG(json_or_error.ok(), "Failed to parse json");

  const std::string config = json_or_error.ok() ? json_or_error.value() : "";

  return std::make_shared<DynamicOpenTracingDriver>(context.serverFactoryContext().scope(), library,

                                                    config);

}

/**

 * Static registration for the dynamic opentracing tracer. @see RegisterFactory.

 */

LEGACY_REGISTER_FACTORY(DynamicOpenTracingTracerFactory, Server::Configuration::TracerFactory,

                        "envoy.dynamic.ot");

} // namespace DynamicOt

} // namespace Tracers

} // namespace Extensions

} // namespace Envoy