Function withDefaultMiddlewares

fxhttpserver/module.go:131–201

(httpServer *echo.Echo, p FxHttpServerParam)

}

func withDefaultMiddlewares(httpServer *echo.Echo, p FxHttpServerParam) *echo.Echo {
	// request id middleware
	httpServer.Use(httpservermiddleware.RequestIdMiddlewareWithConfig(
		httpservermiddleware.RequestIdMiddlewareConfig{
			Generator: p.Generator,
		},
	))

	// request tracer middleware
	if p.Config.GetBool("modules.http.server.trace.enabled") {
		httpServer.Use(httpservermiddleware.RequestTracerMiddlewareWithConfig(
			p.Config.AppName(),
			httpservermiddleware.RequestTracerMiddlewareConfig{
				TracerProvider:              httpserver.AnnotateTracerProvider(p.TracerProvider),
				RequestUriPrefixesToExclude: p.Config.GetStringSlice("modules.http.server.trace.exclude"),
			},
		))
	}

	// request logger middleware
	requestHeadersToLog := map[string]string{
		httpservermiddleware.HeaderXRequestId: httpservermiddleware.LogFieldRequestId,
	}

	for headerName, fieldName := range p.Config.GetStringMapString("modules.http.server.log.headers") {
		requestHeadersToLog[headerName] = fieldName
	}

	httpServer.Use(httpservermiddleware.RequestLoggerMiddlewareWithConfig(
		httpservermiddleware.RequestLoggerMiddlewareConfig{
			RequestHeadersToLog:             requestHeadersToLog,
			RequestUriPrefixesToExclude:     p.Config.GetStringSlice("modules.http.server.log.exclude"),
			LogLevelFromResponseOrErrorCode: p.Config.GetBool("modules.http.server.log.level_from_response"),
		},
	))

	// request metrics middleware
	if p.Config.GetBool("modules.http.server.metrics.collect.enabled") {
		namespace := Sanitize(p.Config.GetString("modules.http.server.metrics.collect.namespace"))
		subsystem := Sanitize(p.Config.GetString("modules.http.server.metrics.collect.subsystem"))

		var buckets []float64
		if bucketsConfig := p.Config.GetString("modules.http.server.metrics.buckets"); bucketsConfig != "" {
			for _, s := range Split(bucketsConfig) {
				f, err := strconv.ParseFloat(s, 64)
				if err == nil {
					buckets = append(buckets, f)
				}
			}
		}

		metricsMiddlewareConfig := httpservermiddleware.RequestMetricsMiddlewareConfig{
			Registry:                p.MetricsRegistry,
			Namespace:               namespace,
			Subsystem:               subsystem,
			Buckets:                 buckets,
			NormalizeRequestPath:    p.Config.GetBool("modules.http.server.metrics.normalize.request_path"),
			NormalizeResponseStatus: p.Config.GetBool("modules.http.server.metrics.normalize.response_status"),