Check OpenID audience when validating token.

cmd/cli/app/auth/auth_login.go

@@ -66,12 +66,11 @@ func LoginCommand(cmd *cobra.Command, _ []string) error {
 	// wait for the token to be received
 	var loginErr loginError
 	token, err := Login(ctx, cmd, clientConfig, nil, skipBrowser)
-	if errors.As(err, &loginErr) {
-		if loginErr.isAccessDenied() {
-			cmd.Println("Access denied. Please run the command again and accept the terms and conditions.")
-			return nil
-		}
-	} else if err != nil {
+	if errors.As(err, &loginErr) && loginErr.isAccessDenied() {
+		cmd.Println("Access denied. Please run the command again and accept the terms and conditions.")
+		return nil
+	}
+	if err != nil {
 		return err
 	}
 

cmd/cli/app/auth/common.go

@@ -167,7 +167,7 @@ func Login(
 	}
 
 	issuerUrl := parsedURL.JoinPath("realms/stacklok")
-	scopes := []string{"openid"}
+	scopes := []string{"openid", "minder-audience"}
 
 	if len(extraScopes) > 0 {
 		scopes = append(scopes, extraScopes...)

cmd/server/app/serve.go

@@ -91,7 +91,7 @@ var serveCmd = &cobra.Command{
 		if err != nil {
 			return fmt.Errorf("failed to create JWKS URL: %w\n", err)
 		}
-		jwt, err := auth.NewJwtValidator(ctx, jwksUrl.String())
+		jwt, err := auth.NewJwtValidator(ctx, jwksUrl.String(), cfg.Identity.Server.Audience)
 		if err != nil {
 			return fmt.Errorf("failed to fetch and cache identity provider JWKS: %w\n", err)
 		}

config/server-config.yaml.example

@@ -49,6 +49,7 @@ identity:
     issuer_url: http://keycloak:8080 # Use http://localhost:8081 instead for running minder outside of docker compose
     client_id: minder-server
     client_secret: secret
+    audience: minder
 
 # Crypto (these should be ultimately stored in a secure vault)
 # The token key can be generated with:

identity/config/stacklok.yaml

@@ -82,7 +82,23 @@ clientScopes:
     attributes:
       "include.in.token.scope": "true"
       "display.on.consent.screen": "false"
-
+  - name: minder-audience
+    description: "Add minder to audience claim"
+    protocol: openid-connect
+    attributes:
+      "include.in.token.scope": "true"
+      "display.on.consent.screen": "false"
+    protocolMappers:
+      - name: minder_audience
+        protocol: openid-connect
+        protocolMapper: oidc-audience-mapper
+        consentRequired: false
+        config:
+          id.token.claim: "false"
+          access.token.claim: "true"
+          introspection.token.claim: "true"
+          included.custom.audience: "minder"
+          userinfo.token.claim: "false"
 
 clients:
   # From:
@@ -100,6 +116,7 @@ clients:
       - roles
       - web-origins
       - gh-data
+      - minder-audience
     optionalClientScopes:
       - microprofile-jwt
       - offline_access
@@ -118,6 +135,7 @@ clients:
       - roles
       - web-origins
       - gh-data
+      - minder-audience
     optionalClientScopes:
       - microprofile-jwt
       - offline_access

internal/auth/jwauth_test.go

@@ -58,7 +58,7 @@ func TestParseAndValidate(t *testing.T) {
 		{
 			name: "Valid token",
 			buildToken: func() string {
-				token, _ := jwt.NewBuilder().Subject("123").Expiration(time.Now().Add(time.Duration(1) * time.Minute)).Build()
+				token, _ := jwt.NewBuilder().Subject("123").Audience([]string{"minder"}).Expiration(time.Now().Add(time.Duration(1) * time.Minute)).Build()
 				signed, _ := jwt.Sign(token, jwt.WithKey(jwa.RS256, privateJwk))
 				return string(signed)
 			},
@@ -71,7 +71,7 @@ func TestParseAndValidate(t *testing.T) {
 		{
 			name: "Expired token",
 			buildToken: func() string {
-				token, _ := jwt.NewBuilder().Subject("123").Expiration(time.Now().Add(-time.Duration(1) * time.Minute)).Build()
+				token, _ := jwt.NewBuilder().Subject("123").Audience([]string{"minder"}).Expiration(time.Now().Add(-time.Duration(1) * time.Minute)).Build()
 				signed, _ := jwt.Sign(token, jwt.WithKey(jwa.RS256, privateJwk))
 				return string(signed)
 			},
@@ -119,6 +119,19 @@ func TestParseAndValidate(t *testing.T) {
 			checkError: func(t *testing.T, err error) {
 				t.Helper()
 
+				assert.Error(t, err)
+			},
+		},
+		{
+			name: "Missing audience claim",
+			buildToken: func() string {
+				token, _ := jwt.NewBuilder().Subject("123").Expiration(time.Now().Add(-time.Duration(1) * time.Minute)).Build()
+				signed, _ := jwt.Sign(token, jwt.WithKey(jwa.RS256, privateJwk))
+				return string(signed)
+			},
+			checkError: func(t *testing.T, err error) {
+				t.Helper()
+
 				assert.Error(t, err)
 			},
 		},
@@ -134,7 +147,10 @@ func TestParseAndValidate(t *testing.T) {
 			mockKeyFetcher := mockjwt.NewMockKeySetFetcher(ctrl)
 			mockKeyFetcher.EXPECT().GetKeySet().Return(jwks, nil)
 
-			jwtValidator := JwkSetJwtValidator{jwksFetcher: mockKeyFetcher}
+			jwtValidator := JwkSetJwtValidator{
+				jwksFetcher: mockKeyFetcher,
+				aud:         "minder",
+			}
 			_, err := jwtValidator.ParseAndValidate(tc.buildToken())
 			tc.checkError(t, err)
 		})

internal/auth/jwtauth.go

@@ -34,6 +34,7 @@ type JwtValidator interface {
 // JwkSetJwtValidator is a JWT validator that uses a JWK set URL to validate the tokens
 type JwkSetJwtValidator struct {
 	jwksFetcher KeySetFetcher
+	aud         string
 }
 
 // KeySetFetcher provides the functions to fetch a JWK set
@@ -60,7 +61,12 @@ func (j *JwkSetJwtValidator) ParseAndValidate(tokenString string) (openid.Token,
 		return nil, err
 	}
 
-	token, err := jwt.ParseString(tokenString, jwt.WithKeySet(set), jwt.WithValidate(true), jwt.WithToken(openid.New()))
+	token, err := jwt.ParseString(
+		tokenString,
+		jwt.WithKeySet(set),
+		jwt.WithValidate(true),
+		jwt.WithToken(openid.New()),
+		jwt.WithAudience(j.aud))
 	if err != nil {
 		return nil, err
 	}
@@ -78,7 +84,7 @@ func (j *JwkSetJwtValidator) ParseAndValidate(tokenString string) (openid.Token,
 }
 
 // NewJwtValidator creates a new JWT validator that uses a JWK set URL to validate the tokens
-func NewJwtValidator(ctx context.Context, jwksUrl string) (JwtValidator, error) {
+func NewJwtValidator(ctx context.Context, jwksUrl string, aud string) (JwtValidator, error) {
 	// Cache the JWK set
 	// The cache will refresh every 15 minutes by default
 	jwks := jwk.NewCache(ctx)
@@ -100,6 +106,7 @@ func NewJwtValidator(ctx context.Context, jwksUrl string) (JwtValidator, error)
 	}
 	return &JwkSetJwtValidator{
 		jwksFetcher: &keySetCache,
+		aud:         aud,
 	}, nil
 }
 

internal/config/server/identity.go

@@ -44,6 +44,8 @@ type IdentityConfig struct {
 	ClientSecret string `mapstructure:"client_secret" default:"secret"`
 	// ClientSecretFile is the location of a file containing the client secret for the minder server (optional)
 	ClientSecretFile string `mapstructure:"client_secret_file"`
+	// Audience is the expected audience for JWT tokens (see OpenID spec)
+	Audience string `mapstructure:"audience" default:"minder"`
 }
 
 // GetClientSecret returns the minder-server client secret

internal/controlplane/handlers_token.go

@@ -67,7 +67,13 @@ func TokenValidationInterceptor(ctx context.Context, req interface{}, info *grpc
 
 	parsedToken, err := server.jwt.ParseAndValidate(token)
 	if err != nil {
-		zerolog.Ctx(ctx).Info().Msgf("Error validating token %s", token)
+		// We don't want to _actually_ log a bearer token.  JWTs will always be > 10 chars,
+		// but by logging the start, we can see if it's actually a JWT or something else.
+		shortToken := token
+		if len(token) > 10 {
+			shortToken = token[:10]
+		}
+		zerolog.Ctx(ctx).Info().Msgf("Error validating token %s", shortToken)
 		return nil, status.Errorf(codes.Unauthenticated, "invalid auth token: %v", err)
 	}