Init: setup uptrace and swagger

middlewares/accessLog.go

@@ -0,0 +1,16 @@
+package middlewares
+
+import (
+	"net/http"
+
+	"gitea.konchin.com/go2025/backend/tracing"
+	"github.com/uptrace/bunrouter"
+)
+
+func AccessLog(next bunrouter.HandlerFunc) bunrouter.HandlerFunc {
+	return func(w http.ResponseWriter, req bunrouter.Request) error {
+		tracing.Logger.Ctx(req.Context()).
+			Info(req.Method + " " + req.Params().Route())
+		return next(w, req)
+	}
+}

middlewares/bunrouterOtel.go

@@ -0,0 +1,48 @@
+package middlewares
+
+import (
+	"net/http"
+
+	"gitea.konchin.com/go2025/backend/utils"
+	"github.com/uptrace/bunrouter"
+	"go.opentelemetry.io/otel/attribute"
+	semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
+	"go.opentelemetry.io/otel/trace"
+)
+
+func BunrouterOtel(next bunrouter.HandlerFunc) bunrouter.HandlerFunc {
+	return func(w http.ResponseWriter, req bunrouter.Request) error {
+		span := trace.SpanFromContext(req.Context())
+		if !span.IsRecording() {
+			return next(w, req)
+		}
+
+		params := req.Params()
+		span.SetName(req.Method + " " + params.Route())
+
+		paramSlice := params.Slice()
+		attrs := make([]attribute.KeyValue, 0, 3+len(paramSlice))
+
+		attrs = append(attrs, semconv.HTTPRouteKey.String(req.Route()))
+
+		if req.URL != nil {
+			attrs = append(attrs, semconv.HTTPTargetKey.String(req.URL.RequestURI()))
+		} else {
+			// This should never occur if the request was generated by the net/http
+			// package. Fail gracefully, if it does though.
+			attrs = append(attrs, semconv.HTTPTargetKey.String(req.RequestURI))
+		}
+
+		attrs = append(attrs, semconv.HTTPClientIPKey.String(
+			utils.GetRemoteAddr(req)))
+
+		for _, param := range paramSlice {
+			attrs = append(attrs, attribute.String("http.route.param."+param.Key,
+				param.Value))
+		}
+
+		span.SetAttributes(attrs...)
+
+		return next(w, req)
+	}
+}

middlewares/cors.go

@@ -0,0 +1,30 @@
+package middlewares
+
+import (
+	"net/http"
+
+	"github.com/spf13/viper"
+	"github.com/uptrace/bunrouter"
+)
+
+func CORSHandler(next bunrouter.HandlerFunc) bunrouter.HandlerFunc {
+	return func(w http.ResponseWriter, req bunrouter.Request) error {
+		origin := viper.GetString("cors-origin")
+		if origin == "" {
+			return next(w, req)
+		}
+
+		w.Header().Set("Access-Control-Allow-Origin", origin)
+		w.Header().Set("Access-Control-Allow-Credentials", "true")
+
+		if req.Method == http.MethodOptions {
+			w.Header().Set("Access-Control-Allow-Methods",
+				"GET,PUT,POST,DELETE,OPTIONS")
+			w.Header().Set("Access-Control-Allow-Headers",
+				"authorization,content-type,content-length")
+			return nil
+		}
+
+		return next(w, req)
+	}
+}

middlewares/errorHandler.go

@@ -0,0 +1,88 @@
+package middlewares
+
+import (
+	"net/http"
+
+	"gitea.konchin.com/go2025/backend/tracing"
+	"github.com/uptrace/bunrouter"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
+	"go.opentelemetry.io/otel/trace"
+	"go.uber.org/zap"
+)
+
+type HTTPError struct {
+	StatusCode  int    `json:"code"`
+	Message     string `json:"message"`
+	OriginError error  `json:"-"`
+
+	TraceID string `json:"traceId"`
+}
+
+func (e HTTPError) Error() string {
+	return e.Message
+}
+
+func NewHTTPError(err error) HTTPError {
+	return HTTPError{
+		StatusCode:  http.StatusInternalServerError,
+		Message:     "Internal server error with unknown reason",
+		OriginError: err,
+	}
+}
+
+func ErrorHandler(next bunrouter.HandlerFunc) bunrouter.HandlerFunc {
+	return func(w http.ResponseWriter, req bunrouter.Request) error {
+		err := next(w, req)
+		ctx := req.Context()
+
+		var httpErr HTTPError
+		switch err := err.(type) {
+		case nil:
+			return nil
+
+		case HTTPError:
+			httpErr = err
+
+		default:
+			tracing.Logger.Ctx(ctx).
+				Error("unhandled error",
+					zap.Error(err))
+			httpErr = NewHTTPError(err)
+		}
+
+		// https://opentelemetry.io/docs/specs/semconv/http/http-spans/#status
+		span := trace.SpanFromContext(ctx)
+		httpErr.TraceID = span.SpanContext().TraceID().String()
+		span.SetAttributes(
+			attribute.Int("http.response.status_code", httpErr.StatusCode),
+		)
+
+		if 500 <= httpErr.StatusCode && httpErr.StatusCode <= 599 {
+			span.SetStatus(codes.Error, err.Error())
+			if httpErr.OriginError == nil {
+				tracing.Logger.Ctx(ctx).
+					Error(httpErr.Message)
+			} else {
+				tracing.Logger.Ctx(ctx).
+					Error(httpErr.Message,
+						zap.Error(httpErr.OriginError))
+			}
+		} else {
+			span.SetStatus(codes.Ok, "")
+			if httpErr.OriginError == nil {
+				tracing.Logger.Ctx(ctx).
+					Warn(httpErr.Message)
+			} else {
+				tracing.Logger.Ctx(ctx).
+					Warn(httpErr.Message,
+						zap.Error(httpErr.OriginError))
+			}
+		}
+
+		w.WriteHeader(httpErr.StatusCode)
+		_ = bunrouter.JSON(w, httpErr)
+
+		return err
+	}
+}