Function createHandlersFactoryFromConfig

src/Server/HTTPHandlerFactory.cpp:125–290

}

static inline auto createHandlersFactoryFromConfig(
    IServer & server,
    const Poco::Util::AbstractConfiguration & config,
    const std::string & name,
    const String & prefix,
    AsynchronousMetrics & async_metrics)
{
    auto main_handler_factory = std::make_shared<HTTPRequestHandlerFactoryMain>(name);

    Poco::Util::AbstractConfiguration::Keys keys;
    config.keys(prefix, keys);

    std::unordered_map<String, String> common_headers_override;

    if (std::find(keys.begin(), keys.end(), "common_http_response_headers") != keys.end())
    {
        auto common_headers_prefix = prefix + ".common_http_response_headers";
        Poco::Util::AbstractConfiguration::Keys headers_keys;
        config.keys(common_headers_prefix, headers_keys);
        for (const auto & header_key : headers_keys)
        {
            common_headers_override[header_key] = config.getString(common_headers_prefix + "." + header_key);
        }
    }

    for (const auto & key : keys)
    {
        if (key == "defaults")
        {
            addDefaultHandlersFactory(*main_handler_factory, server, config, async_metrics);
        }
        else if (startsWith(key, "rule"))
        {
            const auto & handler_type = config.getString(prefix + "." + key + ".handler.type", "");

            if (handler_type.empty())
                throw Exception(ErrorCodes::INVALID_CONFIG_PARAMETER, "Handler type in config is not specified here: "
                    "{}.{}.handler.type", prefix, key);

            if (handler_type == "static")
            {
                main_handler_factory->addHandler(createStaticHandlerFactory(server, config, prefix + "." + key, common_headers_override));
            }
            else if (handler_type == "redirect")
            {
                main_handler_factory->addHandler(createRedirectHandlerFactory(config, prefix + "." + key, common_headers_override));
            }
            else if (handler_type == "dynamic_query_handler")
            {
                main_handler_factory->addHandler(createDynamicHandlerFactory(server, config, prefix + "." + key, common_headers_override));
            }
            else if (handler_type == "predefined_query_handler")
            {
                main_handler_factory->addHandler(createPredefinedHandlerFactory(server, config, prefix + "." + key, common_headers_override));
            }
            else if (handler_type.starts_with("prometheus"))
            {
                main_handler_factory->addHandler(