Skip to content

Commit 701bb68

Browse files
committed
Iter
1 parent 0209639 commit 701bb68

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

cmd/admin.go

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -401,7 +401,7 @@ func createClient(endpoints []string, certCA *x509.CertPool, auth connection.Aut
401401
}
402402

403403
// getJWTTokenFromSecrets returns token from the secret.
404-
func getJWTTokenFromSecrets(ctx context.Context, secrets generic.ReadClient[*core.Secret], name string) (connection.Authentication, error) {
404+
func getJWTTokenFromSecrets(ctx context.Context, secrets generic.ReadClient[*core.Secret], name string, paths ...string) (connection.Authentication, error) {
405405
ctxChild, cancel := globals.GetGlobalTimeouts().Kubernetes().WithTimeout(ctx)
406406
defer cancel()
407407

@@ -410,11 +410,16 @@ func getJWTTokenFromSecrets(ctx context.Context, secrets generic.ReadClient[*cor
410410
return nil, errors.WithMessage(err, fmt.Sprintf("failed to get secret \"%s\"", name))
411411
}
412412

413-
authz, err := token.NewClaims().With(
413+
claims := token.NewClaims().With(
414414
token.WithDefaultClaims(),
415415
token.WithServerID("kube-arangodb"),
416-
token.WithAllowedPaths("/_api/version"),
417-
).Sign(secret)
416+
)
417+
418+
if len(paths) > 0 {
419+
claims = claims.With(token.WithAllowedPaths(paths...))
420+
}
421+
422+
authz, err := claims.Sign(secret)
418423
if err != nil {
419424
return nil, errors.WithMessage(err, fmt.Sprintf("failed to create bearer token from secret \"%s\"", name))
420425
}

0 commit comments

Comments
 (0)