#pragma once

#include "envoy/api/api.h"

#include "envoy/common/random_generator.h"

#include "envoy/config/core/v3/config_source.pb.h"

#include "envoy/config/grpc_mux.h"

#include "envoy/config/subscription.h"

#include "envoy/config/subscription_factory.h"

#include "envoy/config/xds_config_tracker.h"

#include "envoy/config/xds_resources_delegate.h"

#include "envoy/server/instance.h"

#include "envoy/stats/scope.h"

#include "envoy/upstream/cluster_manager.h"

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

namespace Envoy {

namespace Config {

class SubscriptionFactoryImpl : public SubscriptionFactory, Logger::Loggable<Logger::Id::config> {

public:

  SubscriptionFactoryImpl(const LocalInfo::LocalInfo& local_info, Event::Dispatcher& dispatcher,

                          Upstream::ClusterManager& cm,

                          ProtobufMessage::ValidationVisitor& validation_visitor, Api::Api& api,

                          const Server::Instance& server,

                          XdsResourcesDelegateOptRef xds_resources_delegate,

                          XdsConfigTrackerOptRef xds_config_tracker);

  // Config::SubscriptionFactory

  absl::StatusOr<SubscriptionPtr> subscriptionFromConfigSource(

      const envoy::config::core::v3::ConfigSource& config, absl::string_view type_url,

      Stats::Scope& scope, SubscriptionCallbacks& callbacks,

      OpaqueResourceDecoderSharedPtr resource_decoder, const SubscriptionOptions& options) override;

  absl::StatusOr<SubscriptionPtr> subscriptionOverAdsGrpcMux(

      GrpcMuxSharedPtr& ads_grpc_mux, const envoy::config::core::v3::ConfigSource& config,

      absl::string_view type_url, Stats::Scope& scope, SubscriptionCallbacks& callbacks,

      OpaqueResourceDecoderSharedPtr resource_decoder, const SubscriptionOptions& options) override;

  absl::StatusOr<SubscriptionPtr>

  collectionSubscriptionFromUrl(const xds::core::v3::ResourceLocator& collection_locator,

                                const envoy::config::core::v3::ConfigSource& config,

                                absl::string_view resource_type, Stats::Scope& scope,

                                SubscriptionCallbacks& callbacks,

                                OpaqueResourceDecoderSharedPtr resource_decoder) override;

private:

  const LocalInfo::LocalInfo& local_info_;

  Event::Dispatcher& dispatcher_;

  Upstream::ClusterManager& cm_;

  ProtobufMessage::ValidationVisitor& validation_visitor_;

  Api::Api& api_;

  const Server::Instance& server_;

  XdsResourcesDelegateOptRef xds_resources_delegate_;

  XdsConfigTrackerOptRef xds_config_tracker_;

};

} // namespace Config

} // namespace Envoy