feat(translator): JsonPath in PatchPolicy

JsonPath can be utilized to select elements for JSONPatch
in EnvoyPatchPolicy

Signed-off-by: Dennis Kniep <[email protected]>

api/v1alpha1/envoypatchpolicy_types.go

@@ -111,7 +111,12 @@ type JSONPatchOperation struct {
 	Op JSONPatchOperationType `json:"op"`
 	// Path is the location of the target document/field where the operation will be performed
 	// Refer to https://datatracker.ietf.org/doc/html/rfc6901 for more details.
-	Path string `json:"path"`
+	// +optional
+	Path *string `json:"path,omitempty"`
+	// JsonPath specifies the locations of the target document/field where the operation will be performed
+	// Refer to https://datatracker.ietf.org/doc/rfc9535/ for more details.
+	// +optional
+	JsonPath *string `json:"jsonPath,omitempty"`
 	// From is the source location of the value to be copied or moved. Only valid
 	// for move or copy operations
 	// Refer to https://datatracker.ietf.org/doc/html/rfc6901 for more details.

charts/gateway-helm/crds/generated/gateway.envoyproxy.io_envoypatchpolicies.yaml

@@ -71,6 +71,11 @@ spec:
                             for move or copy operations
                             Refer to https://datatracker.ietf.org/doc/html/rfc6901 for more details.
                           type: string
+                        jsonPath:
+                          description: |-
+                            JsonPath specifies the locations of the target document/field where the operation will be performed
+                            Refer to https://datatracker.ietf.org/doc/rfc9535/ for more details.
+                          type: string
                         op:
                           description: Op is the type of operation to perform
                           enum:
@@ -93,7 +98,6 @@ spec:
                           x-kubernetes-preserve-unknown-fields: true
                       required:
                       - op
-                      - path
                       type: object
                     type:
                       description: Type is the typed URL of the Envoy xDS Resource

go.mod

@@ -27,6 +27,7 @@ require (
 	github.com/grafana/tempo v1.5.0
 	github.com/hashicorp/go-multierror v1.1.1
 	github.com/miekg/dns v1.1.61
+	github.com/ohler55/ojg v1.22.1
 	github.com/prometheus/client_golang v1.19.1
 	github.com/prometheus/common v0.55.0
 	github.com/spf13/cobra v1.8.1

go.sum

@@ -518,6 +518,8 @@ github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f/go.mod h1:qRW
 github.com/mxk/go-flowrate v0.0.0-20140419014527-cca7078d478f h1:y5//uYreIhSUg3J1GEMiLbxo1LJaP8RfCpH6pymGZus=
 github.com/mxk/go-flowrate v0.0.0-20140419014527-cca7078d478f/go.mod h1:ZdcZmHo+o7JKHSa8/e818NopupXU1YMK5fe1lsApnBw=
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
+github.com/ohler55/ojg v1.22.1 h1:MvUieaWTwksoYk47GYyP9kzXIAkxHYX6rxeLjUEeq/8=
+github.com/ohler55/ojg v1.22.1/go.mod h1:gQhDVpQLqrmnd2eqGAvJtn+NfKoYJbe/A4Sj3/Vro4o=
 github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
 github.com/olekukonko/tablewriter v0.0.0-20170122224234-a0225b3f23b5/go.mod h1:vsDQFd/mU46D+Z4whnwzcISnGGzXWMclvtLoiIKAKIo=
 github.com/onsi/ginkgo v0.0.0-20170829012221-11459a886d9c/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=

internal/gatewayapi/envoypatchpolicy.go

@@ -135,6 +135,7 @@ func (t *Translator) ProcessEnvoyPatchPolicies(envoyPatchPolicies []*egv1a1.Envo
 			irPatch.Name = patch.Name
 			irPatch.Operation.Op = string(patch.Operation.Op)
 			irPatch.Operation.Path = patch.Operation.Path
+			irPatch.Operation.JsonPath = patch.Operation.JsonPath
 			irPatch.Operation.From = patch.Operation.From
 			irPatch.Operation.Value = patch.Operation.Value
 

internal/ir/xds.go

@@ -25,6 +25,10 @@ import (
 	egv1a1validation "github.com/envoyproxy/gateway/api/v1alpha1/validation"
 )
 
+const (
+	EmptyPath = ""
+)
+
 var (
 	ErrListenerNameEmpty                       = errors.New("field Name must be specified")
 	ErrListenerAddressInvalid                  = errors.New("field Address must be a valid IP address")
@@ -1691,7 +1695,12 @@ type JSONPatchOperation struct {
 	Op string `json:"op" yaml:"op"`
 	// Path is the location of the target document/field where the operation will be performed
 	// Refer to https://datatracker.ietf.org/doc/html/rfc6901 for more details.
-	Path string `json:"path" yaml:"path"`
+	// +optional
+	Path *string `json:"path,omitempty"  yaml:"path,omitempty"`
+	// JsonPath specifies the locations of the target document/field where the operation will be performed
+	// Refer to https://datatracker.ietf.org/doc/rfc9535/ for more details.
+	// +optional
+	JsonPath *string `json:"jsonPath,omitempty"  yaml:"jsonPath,omitempty"`
 	// From is the source location of the value to be copied or moved. Only valid
 	// for move or copy operations
 	// Refer to https://datatracker.ietf.org/doc/html/rfc6901 for more details.
@@ -1701,6 +1710,14 @@ type JSONPatchOperation struct {
 	Value *apiextensionsv1.JSON `json:"value,omitempty" yaml:"value,omitempty"`
 }
 
+func (o *JSONPatchOperation) IsPathEmpty() bool {
+	return o.Path == nil || *o.Path == EmptyPath
+}
+
+func (o *JSONPatchOperation) IsJsonPathEmpty() bool {
+	return o.JsonPath == nil || *o.JsonPath == EmptyPath
+}
+
 // Tracing defines the configuration for tracing a Envoy xDS Resource
 // +k8s:deepcopy-gen=true
 type Tracing struct {

internal/xds/translator/jsonpatch.go

@@ -84,9 +84,9 @@ func processJSONPatches(tCtx *types.ResourceVersionTable, envoyPatchPolicies []*
 				}
 			}
 
-			// If Path is "" and op is "add", unmarshal and add the patch as a complete
+			// If Path and JsonPath is "" and op is "add", unmarshal and add the patch as a complete
 			// resource
-			if p.Operation.Op == AddOperation && p.Operation.Path == EmptyPath {
+			if p.Operation.Op == AddOperation && p.Operation.IsPathEmpty() && p.Operation.IsJsonPathEmpty() {
 				// Convert patch to JSON
 				// The patch library expects an array so convert it into one
 				y, err := yaml.Marshal(p.Operation.Value)
@@ -240,125 +240,150 @@ func processJSONPatches(tCtx *types.ResourceVersionTable, envoyPatchPolicies []*
 				}
 			}
 
-			// Convert patch to JSON
-			// The patch library expects an array so convert it into one
-			y, err := yaml.Marshal([]ir.JSONPatchOperation{p.Operation})
-			if err != nil {
-				tErr := fmt.Errorf("unable to marshal patch %+v, err: %s", p.Operation, err.Error())
-				tErrs = errors.Join(tErrs, tErr)
-				continue
-			}
-			jsonBytes, err := yaml.YAMLToJSON(y)
-			if err != nil {
-				tErr := fmt.Errorf("unable to convert patch to json %s, err: %s", string(y), err.Error())
-				tErrs = errors.Join(tErrs, tErr)
-				continue
-			}
-			patchObj, err := jsonpatchv5.DecodePatch(jsonBytes)
-			if err != nil {
-				tErr := fmt.Errorf("unable to decode patch %s, err: %s", string(jsonBytes), err.Error())
-				tErrs = errors.Join(tErrs, tErr)
-				continue
-			}
-
-			// Apply patch
-			opts := jsonpatchv5.NewApplyOptions()
-			opts.EnsurePathExistsOnAdd = true
-			modifiedJSON, err := patchObj.ApplyWithOptions(resourceJSON, opts)
-			if err != nil {
-				tErr := fmt.Errorf("unable to apply patch:\n%s on resource:\n%s, err: %s", string(jsonBytes), string(resourceJSON), err.Error())
-				tErrs = errors.Join(tErrs, tErr)
-				continue
-			}
-
-			// Unmarshal back to typed resource
-			// Use a temp staging variable that can be marshalled
-			// into and validated before saving it into the xds output resource
-			switch p.Type {
-			case resourcev3.ListenerType:
-				temp := &listenerv3.Listener{}
-				if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
-					tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
-					tErrs = errors.Join(tErrs, tErr)
-					continue
+			var jsonPointers []string
+			if p.Operation.JsonPath != nil {
+				path := ""
+				if p.Operation.Path != nil {
+					path = *p.Operation.Path
 				}
-				if err = temp.Validate(); err != nil {
-					tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-				if err = deepCopyPtr(temp, listener); err != nil {
-					tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-			case resourcev3.RouteType:
-				temp := &routev3.RouteConfiguration{}
-				if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
-					tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-				if err = temp.Validate(); err != nil {
-					tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-				if err = deepCopyPtr(temp, routeConfig); err != nil {
-					tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-			case resourcev3.ClusterType:
-				temp := &clusterv3.Cluster{}
-				if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
-					tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-				if err = temp.Validate(); err != nil {
-					tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
-					tErrs = errors.Join(tErrs, tErr)
-					continue
-				}
-				if err = deepCopyPtr(temp, cluster); err != nil {
-					tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+				jsonPointers, err = ConvertPathToPointers(resourceJSON, *p.Operation.JsonPath, path)
+				if err != nil {
+					tErr := fmt.Errorf("unable to convert jsonPath: '%s' into jsonPointers, err: %s", *p.Operation.JsonPath, err.Error())
 					tErrs = errors.Join(tErrs, tErr)
 					continue
 				}
-			case resourcev3.EndpointType:
-				temp := &endpointv3.ClusterLoadAssignment{}
-				if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
-					tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
-					tErrs = errors.Join(tErrs, tErr)
-					continue
+			} else {
+				jsonPointers = []string{*p.Operation.Path}
+			}
+
+			for _, path := range jsonPointers {
+				op := ir.JSONPatchOperation{
+					Path:  &path,
+					Op:    p.Operation.Op,
+					Value: p.Operation.Value,
+					From:  p.Operation.From,
 				}
-				if err = temp.Validate(); err != nil {
-					tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+
+				// Convert patch to JSON
+				// The patch library expects an array so convert it into one
+				y, err := yaml.Marshal([]ir.JSONPatchOperation{op})
+				if err != nil {
+					tErr := fmt.Errorf("unable to marshal patch %+v, err: %s", op, err.Error())
 					tErrs = errors.Join(tErrs, tErr)
 					continue
 				}
-				if err = deepCopyPtr(temp, endpoint); err != nil {
-					tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+				jsonBytes, err := yaml.YAMLToJSON(y)
+				if err != nil {
+					tErr := fmt.Errorf("unable to convert patch to json %s, err: %s", string(y), err.Error())
 					tErrs = errors.Join(tErrs, tErr)
 					continue
 				}
-			case resourcev3.SecretType:
-				temp := &tlsv3.Secret{}
-				if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
-					tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+				patchObj, err := jsonpatchv5.DecodePatch(jsonBytes)
+				if err != nil {
+					tErr := fmt.Errorf("unable to decode patch %s, err: %s", string(jsonBytes), err.Error())
 					tErrs = errors.Join(tErrs, tErr)
 					continue
 				}
-				if err = temp.Validate(); err != nil {
-					tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+
+				// Apply patch
+				opts := jsonpatchv5.NewApplyOptions()
+				opts.EnsurePathExistsOnAdd = true
+				modifiedJSON, err := patchObj.ApplyWithOptions(resourceJSON, opts)
+				if err != nil {
+					tErr := fmt.Errorf("unable to apply patch:\n%s on resource:\n%s, err: %s", string(jsonBytes), string(resourceJSON), err.Error())
 					tErrs = errors.Join(tErrs, tErr)
 					continue
 				}
-				if err = deepCopyPtr(temp, secret); err != nil {
-					tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
-					tErrs = errors.Join(tErrs, tErr)
-					continue
+
+				// Unmarshal back to typed resource
+				// Use a temp staging variable that can be marshalled
+				// into and validated before saving it into the xds output resource
+				switch p.Type {
+				case resourcev3.ListenerType:
+					temp := &listenerv3.Listener{}
+					if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
+						tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = temp.Validate(); err != nil {
+						tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = deepCopyPtr(temp, listener); err != nil {
+						tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+				case resourcev3.RouteType:
+					temp := &routev3.RouteConfiguration{}
+					if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
+						tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = temp.Validate(); err != nil {
+						tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = deepCopyPtr(temp, routeConfig); err != nil {
+						tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+				case resourcev3.ClusterType:
+					temp := &clusterv3.Cluster{}
+					if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
+						tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = temp.Validate(); err != nil {
+						tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = deepCopyPtr(temp, cluster); err != nil {
+						tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+				case resourcev3.EndpointType:
+					temp := &endpointv3.ClusterLoadAssignment{}
+					if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
+						tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = temp.Validate(); err != nil {
+						tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = deepCopyPtr(temp, endpoint); err != nil {
+						tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+				case resourcev3.SecretType:
+					temp := &tlsv3.Secret{}
+					if err = protojson.Unmarshal(modifiedJSON, temp); err != nil {
+						tErr := fmt.Errorf(unmarshalErrorMessage(err, string(modifiedJSON)))
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = temp.Validate(); err != nil {
+						tErr := fmt.Errorf("validation failed for xds resource %s, err:%s", string(modifiedJSON), err.Error())
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
+					if err = deepCopyPtr(temp, secret); err != nil {
+						tErr := fmt.Errorf("unable to copy xds resource %s, err: %w", string(modifiedJSON), err)
+						tErrs = errors.Join(tErrs, tErr)
+						continue
+					}
 				}
 			}
 		}