Fix Validator Config

Use the server config provided validator config, by copying it to the datastoreconfigs.

Author: steiler

pkg/config/validation.go

@@ -1,14 +1,22 @@
 package config
 
 type Validation struct {
-	DisabledValidators Validators `yaml:"disabled-validators,omitempty" json:"disabled-validators,omitempty"`
-	DisableConcurrency bool       `yaml:"disable-concurrency,omitempty" json:"disable-concurrency,omitempty"`
+	DisabledValidators *Validators `yaml:"disabled-validators,omitempty" json:"disabled-validators,omitempty"`
+	DisableConcurrency bool        `yaml:"disable-concurrency,omitempty" json:"disable-concurrency,omitempty"`
 }
 
 func (v *Validation) validateSetDefaults() error {
+	// no change required, all the bools default to false
 	return nil
 }
 
+func (v *Validation) DeepCopy() *Validation {
+	return &Validation{
+		DisabledValidators: v.DisabledValidators.DeepCopy(),
+		DisableConcurrency: v.DisableConcurrency,
+	}
+}
+
 type Validators struct {
 	Mandatory               bool `yaml:"mandatory,omitempty" json:"mandatory,omitempty"`
 	Leafref                 bool `yaml:"leafref,omitempty" json:"leafref,omitempty"`
@@ -30,3 +38,16 @@ func (v *Validators) DisableAll() {
 	v.Pattern = true
 	v.Range = true
 }
+
+func (v *Validators) DeepCopy() *Validators {
+	return &Validators{
+		Mandatory:               v.Mandatory,
+		Leafref:                 v.Leafref,
+		LeafrefMinMaxAttributes: v.LeafrefMinMaxAttributes,
+		Pattern:                 v.Pattern,
+		MustStatement:           v.MustStatement,
+		Length:                  v.Length,
+		Range:                   v.Range,
+		MaxElements:             v.MaxElements,
+	}
+}

pkg/datastore/transaction_rpc.go

@@ -7,7 +7,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/sdcio/data-server/pkg/config"
 	"github.com/sdcio/data-server/pkg/datastore/types"
 	"github.com/sdcio/data-server/pkg/tree"
 	treeproto "github.com/sdcio/data-server/pkg/tree/importer/proto"
@@ -23,10 +22,6 @@ var (
 	ErrValidationError = errors.New("validation error")
 )
 
-const (
-	ConcurrentValidate = false
-)
-
 // SdcpbTransactionIntentToInternalTI converts sdcpb.TransactionIntent to types.TransactionIntent
 func (d *Datastore) SdcpbTransactionIntentToInternalTI(ctx context.Context, req *sdcpb.TransactionIntent) (*types.TransactionIntent, error) {
 
@@ -96,7 +91,7 @@ func (d *Datastore) replaceIntent(ctx context.Context, transaction *types.Transa
 	log.TraceFn(func() []interface{} { return []interface{}{root.String()} })
 
 	// perform validation
-	validationResult := root.Validate(ctx, &config.Validation{DisableConcurrency: !ConcurrentValidate})
+	validationResult := root.Validate(ctx, d.config.Validation)
 	validationResult.ErrorsStr()
 	if validationResult.HasErrors() {
 		return nil, validationResult.JoinErrors()
@@ -126,7 +121,7 @@ func (d *Datastore) replaceIntent(ctx context.Context, transaction *types.Transa
 func (d *Datastore) LoadAllButRunningIntents(ctx context.Context, root *tree.RootEntry) ([]string, error) {
 
 	intentNames := []string{}
-	IntentChan := make(chan *tree_persist.Intent, 0)
+	IntentChan := make(chan *tree_persist.Intent)
 	ErrChan := make(chan error, 1)
 
 	go d.cacheClient.IntentGetAll(ctx, []string{"running"}, IntentChan, ErrChan)
@@ -223,7 +218,7 @@ func (d *Datastore) lowlevelTransactionSet(ctx context.Context, transaction *typ
 	log.Debug(root.String())
 
 	// perform validation
-	validationResult := root.Validate(ctx, &config.Validation{DisableConcurrency: !ConcurrentValidate})
+	validationResult := root.Validate(ctx, d.config.Validation)
 
 	// prepare the response struct
 	result := &sdcpb.TransactionSetResponse{

pkg/server/datastore.go

@@ -132,7 +132,8 @@ func (s *Server) CreateDataStore(ctx context.Context, req *sdcpb.CreateDataStore
 			Vendor:  req.GetSchema().GetVendor(),
 			Version: req.GetSchema().GetVersion(),
 		},
-		SBI: sbi,
+		SBI:        sbi,
+		Validation: s.config.Validation.DeepCopy(),
 	}
 	if req.GetSync() != nil {
 		dsConfig.Sync = &config.Sync{

pkg/tree/default_value_test.go

@@ -149,7 +149,7 @@ func TestDefaultValueRetrieve(t *testing.T) {
 				return rsp.GetSchema()
 			},
 			wanterr: false,
-			want:    types.NewUpdate(types.PathSlice{}, &sdcpb.TypedValue{Value: &sdcpb.TypedValue_LeaflistVal{LeaflistVal: &sdcpb.ScalarArray{Element: []*sdcpb.TypedValue{&sdcpb.TypedValue{Value: &sdcpb.TypedValue_StringVal{StringVal: "foo"}}, &sdcpb.TypedValue{Value: &sdcpb.TypedValue_StringVal{StringVal: "bar"}}}}}}, 5, "owner1", 0),
+			want:    types.NewUpdate(types.PathSlice{}, &sdcpb.TypedValue{Value: &sdcpb.TypedValue_LeaflistVal{LeaflistVal: &sdcpb.ScalarArray{Element: []*sdcpb.TypedValue{{Value: &sdcpb.TypedValue_StringVal{StringVal: "foo"}}, {Value: &sdcpb.TypedValue_StringVal{StringVal: "bar"}}}}}}, 5, "owner1", 0),
 		},
 	}
 	for _, tt := range tests {

pkg/tree/sharedEntryAttributes_test.go

@@ -718,7 +718,7 @@ func Test_sharedEntryAttributes_validateMandatory(t *testing.T) {
 			dv.DisableAll()
 			dv.Mandatory = false
 
-			validationResults := root.Validate(ctx, &config.Validation{DisableConcurrency: true, DisabledValidators: *dv})
+			validationResults := root.Validate(ctx, &config.Validation{DisableConcurrency: true, DisabledValidators: dv})
 
 			results := []string{}
 			for _, e := range validationResults {