Skip to content

Commit

Permalink
use constants in validation.
Browse files Browse the repository at this point in the history
  • Loading branch information
jmurret committed May 28, 2024
1 parent 0f5d0ad commit 8a1d017
Show file tree
Hide file tree
Showing 3 changed files with 23 additions and 8 deletions.
23 changes: 18 additions & 5 deletions acl/acl_ce.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,25 @@ package acl
const (
WildcardPartitionName = ""
DefaultPartitionName = ""
)
// NonEmptyDefaultPartitionName is the name of the default partition that is
// not empty. An example of this being supplied is when a partition is specified
// in the request for DNS by consul-dataplane. This has been added to support
// DNS v1.5, which needs to be compatible with the original DNS subsystem which
// supports partition being "default" or empty. Otherwise, use DefaultPartitionName.
NonEmptyDefaultPartitionName = "default"

// DefaultNamespaceName is used to mimic the behavior in consul/structs/intention.go,
// where we define IntentionDefaultNamespace as 'default' and so we use the same here.
// This is a little bit strange; one might want it to be "" like DefaultPartitionName.
DefaultNamespaceName = "default"

// Reviewer Note: This is a little bit strange; one might want it to be "" like partition name
// However in consul/structs/intention.go we define IntentionDefaultNamespace as 'default' and so
// we use the same here
const DefaultNamespaceName = "default"
// EmptyNamespaceName is the name of the default partition that is an empty string.
// An example of this being supplied is when a namespace is specifiedDNS v1.
// EmptyNamespaceName has been added to support DNS v1.5, which needs to be
// compatible with the original DNS subsystem which supports partition being "default" or empty.
// Otherwise, use DefaultNamespaceName.
EmptyNamespaceName = ""
)

type EnterpriseConfig struct {
// no fields in CE
Expand Down
1 change: 0 additions & 1 deletion agent/discovery/query_fetcher_v1.go
Original file line number Diff line number Diff line change
Expand Up @@ -424,7 +424,6 @@ RPC:
}

func (f *V1DataFetcher) ValidateRequest(_ Context, req *QueryPayload) error {
f.logger.Debug(fmt.Sprintf("req %+v", req))
if req.EnableFailover {
return ErrNotSupported
}
Expand Down
7 changes: 5 additions & 2 deletions agent/discovery/query_fetcher_v1_ce.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,16 +7,19 @@ package discovery

import (
"github.com/hashicorp/consul/acl"
"github.com/hashicorp/consul/api"
)

func (f *V1DataFetcher) NormalizeRequest(req *QueryPayload) {
// Nothing to do for CE
return
}

// validateEnterpriseTenancy validates the tenancy fields for an enterprise request to
// make sure that they are either set to an empty string or "default" to align with the behavior
// in CE.
func validateEnterpriseTenancy(req QueryTenancy) error {
if !(req.Namespace == "" || req.Namespace == acl.DefaultNamespaceName) || !(req.Partition == "" || req.Partition == api.PartitionDefaultName) {
if !(req.Namespace == acl.EmptyNamespaceName || req.Namespace == acl.DefaultNamespaceName) ||
!(req.Partition == acl.DefaultPartitionName || req.Partition == acl.NonEmptyDefaultPartitionName) {
return ErrNotSupported
}
return nil
Expand Down

0 comments on commit 8a1d017

Please sign in to comment.