Function telemetryMiddleware

pkg/modules/api/middlewares.go:169–317

telemetryMiddleware manages telemetry. It sets the correlation ID in the [echo.Context] under "correlationId". correlationIdHeader := c.Get("correlationIdHeader").(string) correlationId := c.Get("correlationId").(string)

(logger *slog.Logger, serverName, correlationIdHeader string, disableTelemetryForPaths []string)

//	correlationIdHeader := c.Get("correlationIdHeader").(string)
//	correlationId := c.Get("correlationId").(string)
func telemetryMiddleware(logger *slog.Logger, serverName, correlationIdHeader string, disableTelemetryForPaths []string) echo.MiddlewareFunc {
	meter := gotenberg.Meter()
	semconvSrv := semconvutil.NewHTTPServer(meter)

	return func(next echo.HandlerFunc) echo.HandlerFunc {
		return func(c echo.Context) error {
			startTime := c.Get("startTime").(time.Time)
			rootPath := c.Get("rootPath").(string)

			request := c.Request()
			savedCtx := request.Context()
			defer func() {
				request = request.WithContext(savedCtx)
				c.SetRequest(request)
			}()

			routePath := func() string {
				path := c.Request().URL.Path

				if path == "" {
					path = "/"
				}

				return path
			}()

			// Evaluate if we should skip telemetry for this path.
			skipTelemetry := false
			for _, path := range disableTelemetryForPaths {
				URI := fmt.Sprintf("%s%s", rootPath, path)
				if c.Request().RequestURI == URI {
					skipTelemetry = true
					break
				}
			}

			if skipTelemetry {
				c.Set("logger", slog.New(slog.DiscardHandler))

				err := next(c)
				if err != nil {
					c.Error(err)
				}
				return nil
			}

			correlationId := request.Header.Get(correlationIdHeader)
			if correlationId == "" {
				correlationId = uuid.NewString()
			}
			c.Set("correlationIdHeader", correlationIdHeader)
			c.Set("correlationId", correlationId)

			ctx := otel.GetTextMapPropagator().Extract(savedCtx, propagation.HeaderCarrier(request.Header))

			rAttr := semconvSrv.Route(routePath)
			opts := []trace.SpanStartOption{
				trace.WithAttributes(