Function createProxyConfig

internal/cmd/proxy.go:37–125

TODO(e.burkov): Use a separate type for the YAML configuration file. createProxyConfig initializes [proxy.Config]. l must not be nil.

(
	ctx context.Context,
	l *slog.Logger,
	conf *configuration,
)

// createProxyConfig initializes [proxy.Config].  l must not be nil.
func createProxyConfig(
	ctx context.Context,
	l *slog.Logger,
	conf *configuration,
) (proxyConf *proxy.Config, err error) {
	hostsFiles, err := conf.hostsFiles(ctx, l)
	if err != nil {
		// Don't wrap the error since it's informative enough as is.
		return nil, err
	}

	hosts, err := middleware.ReadHosts(ctx, l, hostsFiles)
	if err != nil {
		return nil, fmt.Errorf("reading hosts files: %w", err)
	}

	preMw := middleware.New(&middleware.Config{
		Logger: l.With(slogutil.KeyPrefix, "pre_handler_mw"),
		// TODO(e.burkov):  Use the configured message constructor.
		MessageConstructor: dnsmsg.DefaultMessageConstructor{},
		HaltIPv6:           conf.IPv6Disabled,
		HostsFiles:         hosts,
	})

	ratelimitMw, err := conf.newRatelimitMw(l)
	if err != nil {
		return nil, fmt.Errorf("ratelimit mw: %w", err)
	}

	httpConf := &proxy.HTTPConfig{
		ServerHeader:    conf.HTTPSServerName,
		Routes:          conf.DoHRoutes,
		ReadTimeout:     defaultHTTPTimeout,
		WriteTimeout:    defaultHTTPTimeout,
		HTTP3Enabled:    conf.HTTP3,
		InsecureEnabled: conf.DoHInsecureEnabled,
	}

	if uiStr := conf.HTTPSUserinfo; uiStr != "" {
		user, pass, ok := strings.Cut(uiStr, ":")
		if ok {
			httpConf.Userinfo = url.UserPassword(user, pass)
		} else {
			httpConf.Userinfo = url.User(user)
		}
	}

	proxyConf = &proxy.Config{
		Logger:                   l.With(slogutil.KeyPrefix, proxy.LogPrefix),
		CacheEnabled:             conf.Cache,
		CacheSizeBytes:           conf.CacheSizeBytes,
		CacheMinTTL:              conf.CacheMinTTL,
		CacheMaxTTL:              conf.CacheMaxTTL,
		CacheOptimisticAnswerTTL: time.Duration(conf.OptimisticAnswerTTL),
		CacheOptimisticMaxAge:    time.Duration(conf.OptimisticMaxAge),
		CacheOptimistic:          conf.CacheOptimistic,
		RefuseAny:                conf.RefuseAny,
		// TODO(e.burkov):  The following CIDRs are aimed to match any address.