Handling all xdr config statically because of ordering

asconfig/as_setconfig.go

@@ -1,12 +1,9 @@
 package asconfig
 
 import (
-	"container/list"
 	"fmt"
 	"strings"
 
-	"github.com/go-logr/logr"
-
 	aero "github.com/aerospike/aerospike-client-go/v7"
 	"github.com/aerospike/aerospike-management-lib/deployment"
 	"github.com/aerospike/aerospike-management-lib/info"
@@ -316,14 +313,12 @@ func createSetConfigXDRCmdList(tokens []string, operationValueMap map[Operation]
 }
 
 // CreateSetConfigCmdList creates set-config commands for given config.
-func CreateSetConfigCmdList(
-	log logr.Logger, configMap DynamicConfigMap, conn deployment.ASConnInterface,
+func CreateSetConfigCmdList(configMap DynamicConfigMap, conn deployment.ASConnInterface,
 	aerospikePolicy *aero.ClientPolicy,
 ) ([]string, error) {
 	cmdList := make([]string, 0, len(configMap))
 
-	orderedConfList := rearrangeConfigMap(log, configMap)
-	for _, c := range orderedConfList {
+	for c := range configMap {
 		tokens := strings.Split(c, sep)
 		context := tokens[0]
 
@@ -361,6 +356,7 @@ func CreateSetConfigCmdList(
 	return cmdList, nil
 }
 
+/*
 // Returns a list of config keys in the order in which they should be applied.
 // The order is as follows:
 // 1. Removed Namespaces -- If user has to change some of the DC direct fields, they will have to remove the namespace
@@ -420,21 +416,32 @@ func rearrangeConfigMap(log logr.Logger, configMap DynamicConfigMap) []string {
 				// Check if the key is related to 'node-address-ports'
 				isNodeAddressPortsKey := strings.HasSuffix(k, sep+keyNodeAddressPorts)
 
-				if isNodeAddressPortsKey && lastDCConfig != nil {
-					// Add 'node-address-ports' after all DC direct fields
-					// There are certain fields that must be set before 'node-address-ports', for example, 'tls-name'.
-					lastDCConfig = rearrangedConfigMap.InsertAfter(k, lastDCConfig)
-				} else {
-					if lastDC == nil {
-						nap = rearrangedConfigMap.PushFront(k)
+				if isNodeAddressPortsKey {
+					if _, ok := v[Remove]; ok {
+						dc := rearrangedConfigMap.PushFront(k)
+						if lastDC == nil {
+							lastDC = dc
+						}
+						continue
 					} else {
-						// Add modified DC direct fields after the DC names and before the namespaces
-						nap = rearrangedConfigMap.InsertAfter(k, lastDC)
-					}
-					if lastDCConfig == nil {
-						lastDCConfig = nap
+						if lastDCConfig != nil {
+							// Add 'node-address-ports' after all DC direct fields
+							// There are certain fields that must be set before 'node-address-ports', for example, 'tls-name'.
+							lastDCConfig = rearrangedConfigMap.InsertAfter(k, lastDCConfig)
+							continue
+						}
 					}
 				}
+
+				if lastDC == nil {
+					nap = rearrangedConfigMap.PushFront(k)
+				} else {
+					// Add modified DC direct fields after the DC names and before the namespaces
+					nap = rearrangedConfigMap.InsertAfter(k, lastDC)
+				}
+				if lastDCConfig == nil {
+					lastDCConfig = nap
+				}
 			} else {
 				rearrangedConfigMap.PushBack(k)
 			}
@@ -447,3 +454,4 @@ func rearrangeConfigMap(log logr.Logger, configMap DynamicConfigMap) []string {
 
 	return finalList
 }
+*/

asconfig/as_setconfig_test.go

@@ -3,7 +3,6 @@ package asconfig
 import (
 	"testing"
 
-	"github.com/go-logr/logr"
 	"github.com/stretchr/testify/suite"
 	"go.uber.org/mock/gomock"
 
@@ -63,19 +62,19 @@ func (s *AsSetConfigTestSuite) TestCreateSetConfigCmdList() {
 
 	for _, tc := range testCases {
 		s.Run(tc.name, func() {
-			logger := logr.Discard()
 			policy := &aero.ClientPolicy{}
 
 			s.mockASConn.EXPECT().RunInfo(gomock.Any(), gomock.Any()).Return(map[string]string{
 				"logs": "0:stderr"}, nil).AnyTimes()
-			result, err := CreateSetConfigCmdList(logger, tc.inputConf, s.mockASConn, policy)
+			result, err := CreateSetConfigCmdList(tc.inputConf, s.mockASConn, policy)
 
 			s.Assert().Nil(err)
 			s.Assert().True(gomock.InAnyOrder(result).Matches(tc.expected))
 		})
 	}
 }
 
+/*
 func (s *AsSetConfigTestSuite) TestCreateSetConfigCmdListOrdered() {
 	testCases := []struct {
 		name      string
@@ -88,14 +87,15 @@ func (s *AsSetConfigTestSuite) TestCreateSetConfigCmdListOrdered() {
 				"xdr.dcs.{DC1}.namespaces.{ns1}.bin-policy": {Update: "no-bins"},
 				"xdr.dcs.{DC3}.name":                        {Add: "DC3"},
 				"xdr.dcs.{DC1}.namespaces.{ns2}.name":       {Remove: "ns2"},
-				"xdr.dcs.{DC1}.node-address-ports":          {Add: []string{"1.1.1.1:3000:tls-name"}},
+				"xdr.dcs.{DC1}.node-address-ports":          {Add: []string{"1.1.1.1:3000:tls-name"},
 				"xdr.dcs.{DC1}.namespaces.{ns1}.name":       {Add: "ns1"},
 				"xdr.dcs.{DC1}.tls-name":                    {Update: "tls-name"},
 			},
 			[]string{"set-config:context=xdr;dc=DC1;namespace=ns2;action=remove",
 				"set-config:context=xdr;dc=DC3;action=create",
 				"set-config:context=xdr;dc=DC1;tls-name=tls-name",
 				"set-config:context=xdr;dc=DC1;node-address-port=1.1.1.1:3000:tls-name;action=add",
+				//	"set-config:context=xdr;dc=DC1;node-address-port=1.1.1.1:3000;action=remove",
 				"set-config:context=xdr;dc=DC1;namespace=ns1;action=add",
 				"set-config:context=xdr;dc=DC1;namespace=ns1;bin-policy=no-bins",
 			},
@@ -114,6 +114,7 @@ func (s *AsSetConfigTestSuite) TestCreateSetConfigCmdListOrdered() {
 		})
 	}
 }
+*/
 
 func TestAsSetConfigTestSuite(t *testing.T) {
 	suite.Run(t, new(AsSetConfigTestSuite))

asconfig/asconfig_test.go

@@ -356,13 +356,9 @@ func (s *AsConfigTestSuite) TestAsConfigIsDynamic() {
 		{
 			"dynamic fields",
 			DynamicConfigMap{
-				"xdr.dcs.{DC1}.namespaces.{ns1}.bin-policy": {Update: "no-bins"},
 				"security.log.report-data-op": {Add: []string{"ns3 set2"},
 					Remove: []string{"ns2 set2"}},
-				"xdr.dcs.{DC3}.name":                  {Remove: "DC3"},
-				"xdr.dcs.{DC1}.node-address-ports":    {Update: []string{"1.1.1.1 3000"}},
-				"xdr.dcs.{DC1}.namespaces.{ns1}.name": {Add: "ns1"},
-				"xdr.dcs.{DC1}.name":                  {Add: "DC1"},
+				"service.proto-fd-max": {Update: "1000"},
 			},
 
 			true,

asconfig/schema.go

@@ -200,12 +200,12 @@ func isFieldDynamic(log logr.Logger, dynamic sets.Set[string], conf string,
 	baseKey := tokens[len(tokens)-1]
 	context := tokens[0]
 
-	if baseKey == "replication-factor" || baseKey == keyNodeAddressPorts {
-		return true
+	if context == info.ConfigXDRContext {
+		// XDR context is always considered static.
+		return false
 	}
 
-	// Name key for XDR context is considered as dynamic, as both DCs and Namespaces in DCs can be added dynamically.
-	if context == info.ConfigXDRContext && baseKey == KeyName {
+	if baseKey == "replication-factor" {
 		return true
 	}