extauth_config.cc

#include "extauth_config.h"

#include "extauth.h"

namespace Envoy {
namespace Server {
namespace Configuration {

const std::string EXTAUTH_HTTP_FILTER_SCHEMA(R"EOF(
  {
    "$schema": "http://json-schema.org/schema#",
    "type" : "object",
    "properties" : {
      "cluster" : {"type" : "string"},
      "timeout_ms": {"type" : "integer"}
    },
    "required" : ["cluster", "timeout_ms"],
    "additionalProperties" : false
  }
  )EOF");

HttpFilterFactoryCb ExtAuthConfig::tryCreateFilterFactory(HttpFilterType type,
                                                          const std::string& name,
                                                          const Json::Object& json_config,
                                                          const std::string& stats_prefix,
                                                          Server::Instance& server) {
  if (type != HttpFilterType::Decoder || name != "extauth") {
    return nullptr;
  }

  json_config.validateSchema(EXTAUTH_HTTP_FILTER_SCHEMA);

  Http::ExtAuthConfigConstSharedPtr config(new Http::ExtAuthConfig{
      server.clusterManager(), Http::ExtAuth::generateStats(stats_prefix, server.stats()),
      json_config.getString("cluster"),
      std::chrono::milliseconds(json_config.getInteger("timeout_ms"))});
  return [config](Http::FilterChainFactoryCallbacks& callbacks) -> void {
    callbacks.addStreamDecoderFilter(Http::StreamDecoderFilterSharedPtr{new Http::ExtAuth(config)});
  };
}

/**
 * Static registration for the extauth filter. @see RegisterHttpFilterConfigFactory.
 */
static RegisterHttpFilterConfigFactory<ExtAuthConfig> register_;

} // Configuration
} // Server
} // Envoy