feat: native support for basicauth

Signed-off-by: Matthias Riegler <[email protected]>

Author: xvzf

internal/config/server/latest/server_schema.go

@@ -1,8 +1,18 @@
 package latest
 
+// BasicAuthConfig represents the configuration for basic auth.
+type BasicAuthConfig struct {
+	Users map[string]string `yaml:"users"`
+}
+
+type AuthConfig struct {
+	BasicAuth *BasicAuthConfig `yaml:"basic,omitempty"`
+}
+
 // ServerConfig represents the current server configuration file.
 type ServerConfig struct {
 	Repositories []*GithubRepositoryConfig `yaml:"repositories,omitempty"`
+	AuthConfig   *AuthConfig               `yaml:"auth,omitempty"`
 }
 
 // GithubRepositoryConfig defines how a repository should be handled
@@ -13,6 +23,6 @@ type GithubRepositoryConfig struct {
 	StabilizeDuration    int    `yaml:"stabilize_duration_seconds"`
 	TTL                  int    `yaml:"ttl_seconds"`
 	ExpectedRequestCount int    `yaml:"expected_request_count"`
-	// DelayLEaseASsignmentBy is the number of times a lease can be delayed before it is assigned.
+	// DelayLeaseASsignmentBy is the number of times a lease can be delayed before it is assigned.
 	DelayLeaseAssignmentBy int `yaml:"delay_lease_assignment_by"`
 }

internal/server/server.go

@@ -16,6 +16,7 @@ import (
 	"github.com/ankorstore/mq-lease-service/internal/storage"
 	"github.com/ankorstore/mq-lease-service/internal/version"
 	"github.com/gofiber/fiber/v2"
+	fiberbasicauth "github.com/gofiber/fiber/v2/middleware/basicauth"
 	fiberrecover "github.com/gofiber/fiber/v2/middleware/recover"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/rs/zerolog"
@@ -141,6 +142,14 @@ func (s *serverImpl) Init() error {
 		},
 	}))
 
+	// Configure basic auth if needed
+	if cfg.AuthConfig != nil && cfg.AuthConfig.BasicAuth != nil {
+		log.Ctx(s.ctx).Info().Msg("Basic auth enabled")
+		s.app.Use(fiberbasicauth.New(fiberbasicauth.Config{
+			Users: cfg.AuthConfig.BasicAuth.Users,
+		}))
+	}
+
 	// register k8s probes handlers
 	RegisterK8sProbesRoutes(s.app, s.storage)
 	// register API routes on the fiber app