v1.3.27: fix Help modal — add -L flag, demo-login docs

2026-05-03 06:46:33 +03:00
parent 9a16ab16c7
commit a6c52074e6
37 changed files with 1179 additions and 2497 deletions
@@ -2,19 +2,20 @@ package api

 import (
 	"context"
-	"crypto/sha256"
-	"encoding/base64"
-	"encoding/hex"
-	"encoding/json"
 	"fmt"
 	"net/http"
 	"strings"
+
+	"fission-console/internal/auth"
 )

-// ctxKeyNS — ключ для хранения namespace пользователя в context.Context.
-// Использует приватный тип чтобы избежать коллизий с ключами из других пакетов.
+// ctxKeyNS — ключ для K8s namespace пользователя в context.Context.
 type ctxKeyNS struct{}

+// ctxKeyIdentity — ключ для UserIdentity пользователя в context.Context.
+type ctxKeyIdentity struct{}
+
+// authTokenFromRequest извлекает Bearer токен из X-Auth-Token или Authorization заголовка.
 func authTokenFromRequest(r *http.Request) string {
 	token := strings.TrimSpace(r.Header.Get("X-Auth-Token"))
 	if token != "" {
@@ -32,61 +33,57 @@ func authTokenFromRequest(r *http.Request) string {
 }

 // userNS возвращает namespace пользователя из контекста запроса.
-// Устанавливается в authMiddleware после успешной аутентификации.
 func (s *Server) userNS(r *http.Request) string {
 	if ns, ok := r.Context().Value(ctxKeyNS{}).(string); ok && ns != "" {
 		return ns
 	}
-	// Fallback: использовать системный namespace (не должно происходить в prod)
 	return s.ns
 }

-// authMiddleware оборачивает handler, добавляя аутентификацию и инициализацию namespace.
+// normalizeEnv приводит название стенда к допустимому значению.
+func normalizeEnv(env string) string {
+	switch strings.TrimSpace(strings.ToLower(env)) {
+	case "prod", "dev", "test":
+		return strings.TrimSpace(strings.ToLower(env))
+	}
+	return "test"
+}
+
+// authMiddleware оборачивает handler аутентификацией.
 //
-// В testMode (FISSION_TEST_MODE=true):
-//   - Deck API не вызывается
-//   - X-Test-Sub или X-Auth-Token задают sub → разные namespace-ы для тестирования
-//
-// В production:
-//   - X-Auth-Token валидируется через Deck API
-//   - Namespace вычисляется из JWT claim "sub"
+// В testMode: заголовок X-Test-Sub позволяет задать sub напрямую (без токена).
+// Иначе: токен передаётся в s.authenticator.Authenticate — детали скрыты за интерфейсом.
 func (s *Server) authMiddleware(h http.HandlerFunc) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		var ns string
-		env := strings.TrimSpace(strings.ToLower(r.Header.Get("X-Auth-Env")))
-		if _, ok := deckAPIs[env]; !ok {
-			env = "test"
-		}
+		var identity auth.UserIdentity
+
+		env := normalizeEnv(r.Header.Get("X-Auth-Env"))

 		if s.testMode {
-			sub := strings.TrimSpace(r.Header.Get("X-Test-Sub"))
-			if sub != "" {
-				ns = namespaceFromSub(sub)
-			} else {
-				token := authTokenFromRequest(r)
-				resolvedNS, err := s.resolveNamespaceForToken(token, env, true)
-				if err != nil {
-					writeJSONError(w, http.StatusUnauthorized, "unauthorized")
+			if sub := strings.TrimSpace(r.Header.Get("X-Test-Sub")); sub != "" {
+				identity = auth.UserIdentity{Sub: sub}
+				ctx := s.contextWithIdentity(r.Context(), identity)
+				if err := s.nsManager.EnsureUserNS(ctx, auth.NamespaceForSub(sub)); err != nil {
+					writeJSONError(w, http.StatusBadGateway, fmt.Sprintf("ensure namespace: %v", err))
 					return
 				}
-				ns = resolvedNS
-			}
-		} else {
-			token := authTokenFromRequest(r)
-			resolvedNS, err := s.resolveNamespaceForToken(token, env, false)
-			if err != nil {
-				writeJSONError(w, http.StatusUnauthorized, "unauthorized")
+				h(w, r.WithContext(ctx))
 				return
 			}
-			ns = resolvedNS
 		}

-		ctx := context.WithValue(r.Context(), ctxKeyNS{}, ns)
+		token := authTokenFromRequest(r)
+		var err error
+		identity, err = s.authenticator.Authenticate(r.Context(), token, env)
+		if err != nil {
+			writeJSONError(w, http.StatusUnauthorized, "unauthorized")
+			return
+		}

-		// Гарантируем что namespace + RBAC + quota + netpol существуют.
-		// EnsureUserNS реализует singleflight + кэш + семафор параллелизма.
-		if ensureErr := s.nsManager.EnsureUserNS(ctx, ns); ensureErr != nil {
-			writeJSONError(w, http.StatusBadGateway, fmt.Sprintf("ensure namespace: %v", ensureErr))
+		ns := auth.NamespaceForSub(identity.Sub)
+		ctx := s.contextWithIdentity(r.Context(), identity)
+		if err := s.nsManager.EnsureUserNS(ctx, ns); err != nil {
+			writeJSONError(w, http.StatusBadGateway, fmt.Sprintf("ensure namespace: %v", err))
 			return
 		}

@@ -94,72 +91,10 @@ func (s *Server) authMiddleware(h http.HandlerFunc) http.HandlerFunc {
 	}
 }

-func namespaceFromSub(sub string) string {
-	h32 := sha256.Sum256([]byte(sub))
-	return "fission-" + hex.EncodeToString(h32[:8])
-}
-
-func (s *Server) resolveNamespaceForToken(token, env string, allowTestSub bool) (string, error) {
-	token = strings.TrimSpace(token)
-	if token == "" {
-		if allowTestSub {
-			return "", fmt.Errorf("test mode: X-Test-Sub required")
-		}
-		return "", fmt.Errorf("unauthorized")
-	}
-
-	if err := s.validateDeckToken(token, env); err == nil {
-		ns, nsErr := namespaceFromJWT(token)
-		if nsErr != nil {
-			return s.ns, nil
-		}
-		return ns, nil
-	}
-
-	if allowTestSub && strings.Contains(token, "@") {
-		return namespaceFromSub(token), nil
-	}
-
-	return "", fmt.Errorf("invalid token")
-}
-
-// namespaceFromJWT декодирует JWT payload (без верификации подписи),
-// извлекает claim "sub" и вычисляет namespace: "fission-" + hex(SHA256(sub)[:8]).
-//
-// Подпись не проверяется — токен уже валидирован через Deck API (validateDeckToken).
-// Здесь нам нужен только deterministic namespace name из sub claim.
-func namespaceFromJWT(token string) (string, error) {
-	parts := strings.SplitN(token, ".", 3)
-	if len(parts) != 3 {
-		return "", fmt.Errorf("invalid JWT format")
-	}
-	payload := parts[1]
-
-	// JWT использует base64url без padding — добавляем если нужно
-	switch len(payload) % 4 {
-	case 2:
-		payload += "=="
-	case 3:
-		payload += "="
-	}
-
-	// base64url без стандартного padding — пробуем оба варианта
-	decoded, err := base64.URLEncoding.DecodeString(payload)
-	if err != nil {
-		decoded, err = base64.StdEncoding.DecodeString(payload)
-		if err != nil {
-			return "", fmt.Errorf("decode JWT payload: %w", err)
-		}
-	}
-
-	var claims map[string]any
-	if err := json.Unmarshal(decoded, &claims); err != nil {
-		return "", fmt.Errorf("unmarshal JWT claims: %w", err)
-	}
-	sub, _ := claims["sub"].(string)
-	if sub == "" {
-		return "", fmt.Errorf("JWT missing sub claim")
-	}
-	h := sha256.Sum256([]byte(sub))
-	return "fission-" + hex.EncodeToString(h[:8]), nil
+// contextWithIdentity кладёт UserIdentity и вычисленный namespace в контекст.
+func (s *Server) contextWithIdentity(ctx context.Context, identity auth.UserIdentity) context.Context {
+	ns := auth.NamespaceForSub(identity.Sub)
+	ctx = context.WithValue(ctx, ctxKeyNS{}, ns)
+	ctx = context.WithValue(ctx, ctxKeyIdentity{}, identity)
+	return ctx
 }