Function Test_PatchOperations

pkg/kube/object_patch/patch_test.go:84–551

(t *testing.T)

}

func Test_PatchOperations(t *testing.T) {
	const (
		namespace   = "default"
		name        = "testcm"
		missingName = "missing-object"
		configMap   = `
apiVersion: v1
kind: ConfigMap
metadata:
  name: testcm
data:
  foo: "bar"
`
		newField         = "baz"
		newValue         = "quux"
		shouldNotAdd     = false
		shouldAdd        = true
		shouldNotBeError = false
		shouldBeError    = true
	)

	// Filter func to add a new field.
	filter := func(u *unstructured.Unstructured) (*unstructured.Unstructured, error) {
		res := u.DeepCopy()
		data := res.Object["data"].(map[string]any)
		data[newField] = newValue
		res.Object["data"] = data
		return res, nil
	}

	tests := []struct {
		name        string
		fn          func(patcher *ObjectPatcher) error
		expectAdd   bool
		expectError bool
	}{
		{
			"merge patch",
			func(patcher *ObjectPatcher) error {
				return patcher.ExecuteOperation(NewMergePatchOperation(
					fmt.Sprintf(`{"data":{"%s":"%s"}}`, newField, newValue),
					"v1", "ConfigMap", namespace, name,
				))
			},
			shouldAdd,
			shouldNotBeError,
		},
		{
			"merge patch a missing object",
			func(patcher *ObjectPatcher) error {
				return patcher.ExecuteOperation(NewMergePatchOperation(
					fmt.Sprintf(`{"data":{"%s":"%s"}}`, newField, newValue),
					"v1", "ConfigMap", namespace, missingName,
				))
			},
			shouldNotAdd,
			shouldBeError,
		},