-
Notifications
You must be signed in to change notification settings - Fork 184
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Read secrets for client-onboarding-token-validation #2827
base: main
Are you sure you want to change the base?
Conversation
services/ux-backend/handlers/onboarding/clienttokens/handler.go
Outdated
Show resolved
Hide resolved
a suggestion, we are seeing this PR for third time, second time it's fine that you weren't able to recover GH (remember you can't create new a/c every-time though) but last time it's better if you can focus on rebasing properly. yes, GH doesn't have any issue w/ closing & opening a new PR but for reviewers it's kinda hard to relook from the start. |
674b54c
to
dc8a56b
Compare
I have tested this PR, with the latest 4.18 build. I could see the keys getting exchanged when the rotate signing key is clicked in storageclient page. |
services/ux-backend/handlers/onboarding/clienttokens/handler.go
Outdated
Show resolved
Hide resolved
services/ux-backend/handlers/onboarding/clienttokens/handler.go
Outdated
Show resolved
Hide resolved
|
@@ -225,7 +225,7 @@ func (r *StorageClusterReconciler) SetupWithManager(mgr ctrl.Manager) error { | |||
Owns(&appsv1.Deployment{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Service{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.ConfigMap{}, builder.MatchEveryOwner, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Secret{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Secret{}, builder.MatchEveryOwner, builder.WithPredicates(predicate.GenerationChangedPredicate{})). |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why do we need a MatchEveryOwner here? Isn't StorageCluster the controller owner of the secret we want to watch?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
controller owner reference set to secrets, ack
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This comment was not addressed as tall! You are matching by controller ownership, it does not make sense to match every owner
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Owner reference were set during creation of secrets in on-boarding job, when the rotate signing key is clicked the re-consiliation is not happening, The onboarding-token needs to be created which is failing.
Any suggestion for this issue.
services/ux-backend/handlers/onboarding/clienttokens/handler.go
Outdated
Show resolved
Hide resolved
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: mrudraia1 The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
4dac720
to
8198c71
Compare
ecddbf0
to
d31f826
Compare
infra issue |
@@ -225,7 +225,7 @@ func (r *StorageClusterReconciler) SetupWithManager(mgr ctrl.Manager) error { | |||
Owns(&appsv1.Deployment{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Service{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.ConfigMap{}, builder.MatchEveryOwner, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Secret{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})). | |||
Owns(&corev1.Secret{}, builder.MatchEveryOwner, builder.WithPredicates(predicate.GenerationChangedPredicate{})). |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This comment was not addressed as tall! You are matching by controller ownership, it does not make sense to match every owner
controllers/util/provider.go
Outdated
privateKey, err := x509.ParsePKCS1PrivateKey(Block.Bytes) | ||
if err != nil { | ||
return nil, fmt.Errorf("failed to parse private key: %v", err) | ||
if privateSecret.Data != nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You don't need this check: Maps in golang, even when not initialized, support the key access operator.
if privateSecret.Data != nil { |
controllers/util/provider.go
Outdated
if privateSecretKey, ok := privateSecret.Data["key"]; ok { | ||
Block, _ := pem.Decode(privateSecretKey) | ||
privateKey, err := x509.ParsePKCS1PrivateKey(Block.Bytes) | ||
if err != nil { | ||
return nil, fmt.Errorf("failed to parse private key: %v", err) | ||
} | ||
return privateKey, nil | ||
} | ||
} | ||
return privateKey, nil | ||
|
||
return nil, fmt.Errorf("No data found in secret") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would prefer, from code readability and extensibility concerns, if we first handle error conditions and only at the end have the return that is not erroneous. This way you don't need nested returns and extending the function in the future with more checks become easier
if privateSecretKey, ok := privateSecret.Data["key"]; ok { | |
Block, _ := pem.Decode(privateSecretKey) | |
privateKey, err := x509.ParsePKCS1PrivateKey(Block.Bytes) | |
if err != nil { | |
return nil, fmt.Errorf("failed to parse private key: %v", err) | |
} | |
return privateKey, nil | |
} | |
} | |
return privateKey, nil | |
return nil, fmt.Errorf("No data found in secret") | |
privateSecretKey, ok := privateSecret.Data["key"]; | |
if !ok { | |
return nil, fmt.Errorf("No data found in secret") | |
} | |
Block, _ := pem.Decode(privateSecretKey) | |
privateKey, err := x509.ParsePKCS1PrivateKey(Block.Bytes) | |
if err != nil { | |
return nil, fmt.Errorf("failed to parse private key: %v", err) | |
} | |
return privateKey, nil | |
return | ||
} | ||
|
||
if onboardingToken, err := util.GenerateClientOnboardingToken(tokenLifetimeInHours, privateKey, storageQuotaInGiB, storageCluster.UID); err != nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This line is too long, please split over multi-lines
if onboardingToken, err := util.GenerateClientOnboardingToken(tokenLifetimeInHours, privateKey, storageQuotaInGiB, storageCluster.UID); err != nil { | |
if onboardingToken, err := util.GenerateClientOnboardingToken( | |
tokenLifetimeInHours, | |
privateKey, | |
storageQuotaInGiB, | |
storageCluster.UID, | |
); err != nil { |
return | ||
} | ||
|
||
if onboardingToken, err := util.GeneratePeerOnboardingToken(tokenLifetimeInHours, privateKey, storageCluster.UID); err != nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Line too long, see last comment for breaking into multi lines
storageCluster, err := util.GetStorageClusterInNamespace(r.Context(), cl, namespace) | ||
if err != nil { | ||
http.Error(w, err.Error(), http.StatusInternalServerError) | ||
return | ||
} | ||
|
||
if onboardingToken, err := util.GeneratePeerOnboardingToken(tokenLifetimeInHours, onboardingPrivateKeyFilePath, storageCluster.UID); err != nil { | ||
ctx := context.TODO() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
- You should not use a TODO context but a background context
- If there is a need to create a context for handling a request it should be created at the topmost level of the request handling and passed down
services/ux-backend/main.go
Outdated
@@ -87,10 +87,10 @@ func main() { | |||
// Set the Deprecation header | |||
w.Header().Set("Deprecation", "true") // Standard "Deprecation" header | |||
w.Header().Set("Link", "/onboarding/client-tokens; rel=\"alternate\"") | |||
clienttokens.HandleMessage(w, r, config.tokenLifetimeInHours, cl, namespace) | |||
clienttokens.HandleMessage(r.Context(), w, r, config.tokenLifetimeInHours, cl, namespace) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You should not use the same context for main and for specific request handling. Each request should initialize its own background context that will be used during the entire request.
services/ux-backend/main.go
Outdated
}) | ||
http.HandleFunc("/onboarding/client-tokens", func(w http.ResponseWriter, r *http.Request) { | ||
clienttokens.HandleMessage(w, r, config.tokenLifetimeInHours, cl, namespace) | ||
clienttokens.HandleMessage(r.Context(), w, r, config.tokenLifetimeInHours, cl, namespace) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same as last comment
e627033
to
bbae1f7
Compare
bbae1f7
to
36162f4
Compare
36162f4
to
e3bba8e
Compare
Signed-off-by: Mrudraia1 <[email protected]>
e3bba8e
to
f6ee295
Compare
This PR reads the secrets instead of reading the secrets from the volume mounts.
whenever the new onboarding secrets are created, it takes more time to read the secrets from the volume mounts,
The user clicks the rotate onboarding keys, the kubernetes still uses the old public, private keys , the new keys are mounted later, So this PR will read the secrets directly from the kubernetes secrets.