mirror of
https://github.com/kubernetes-sigs/kustomize.git
synced 2026-05-17 18:25:26 +00:00
101 lines
2.5 KiB
Go
101 lines
2.5 KiB
Go
// Code generated by pluginator on PatchJson6902Transformer; DO NOT EDIT.
|
|
// pluginator {unknown 1970-01-01T00:00:00Z }
|
|
|
|
package builtins
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
jsonpatch "github.com/evanphx/json-patch"
|
|
"github.com/pkg/errors"
|
|
"sigs.k8s.io/kustomize/api/ifc"
|
|
"sigs.k8s.io/kustomize/api/resid"
|
|
"sigs.k8s.io/kustomize/api/resmap"
|
|
"sigs.k8s.io/kustomize/api/types"
|
|
"sigs.k8s.io/yaml"
|
|
)
|
|
|
|
type PatchJson6902TransformerPlugin struct {
|
|
ldr ifc.Loader
|
|
decodedPatch jsonpatch.Patch
|
|
Target types.PatchTarget `json:"target,omitempty" yaml:"target,omitempty"`
|
|
Path string `json:"path,omitempty" yaml:"path,omitempty"`
|
|
JsonOp string `json:"jsonOp,omitempty" yaml:"jsonOp,omitempty"`
|
|
}
|
|
|
|
func (p *PatchJson6902TransformerPlugin) Config(
|
|
h *resmap.PluginHelpers, c []byte) (err error) {
|
|
p.ldr = h.Loader()
|
|
err = yaml.Unmarshal(c, p)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if p.Target.Name == "" {
|
|
return fmt.Errorf("must specify the target name")
|
|
}
|
|
if p.Path == "" && p.JsonOp == "" {
|
|
return fmt.Errorf("empty file path and empty jsonOp")
|
|
}
|
|
if p.Path != "" {
|
|
if p.JsonOp != "" {
|
|
return fmt.Errorf("must specify a file path or jsonOp, not both")
|
|
}
|
|
rawOp, err := p.ldr.Load(p.Path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
p.JsonOp = string(rawOp)
|
|
if p.JsonOp == "" {
|
|
return fmt.Errorf("patch file '%s' empty seems to be empty", p.Path)
|
|
}
|
|
}
|
|
if p.JsonOp[0] != '[' {
|
|
// if it doesn't seem to be JSON, imagine
|
|
// it is YAML, and convert to JSON.
|
|
op, err := yaml.YAMLToJSON([]byte(p.JsonOp))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
p.JsonOp = string(op)
|
|
}
|
|
p.decodedPatch, err = jsonpatch.DecodePatch([]byte(p.JsonOp))
|
|
if err != nil {
|
|
return errors.Wrapf(err, "decoding %s", p.JsonOp)
|
|
}
|
|
if len(p.decodedPatch) == 0 {
|
|
return fmt.Errorf(
|
|
"patch appears to be empty; file=%s, JsonOp=%s", p.Path, p.JsonOp)
|
|
}
|
|
return err
|
|
}
|
|
|
|
func (p *PatchJson6902TransformerPlugin) Transform(m resmap.ResMap) error {
|
|
id := resid.NewResIdWithNamespace(
|
|
resid.Gvk{
|
|
Group: p.Target.Group,
|
|
Version: p.Target.Version,
|
|
Kind: p.Target.Kind,
|
|
},
|
|
p.Target.Name,
|
|
p.Target.Namespace,
|
|
)
|
|
obj, err := m.GetById(id)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
rawObj, err := obj.MarshalJSON()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
modifiedObj, err := p.decodedPatch.Apply(rawObj)
|
|
if err != nil {
|
|
return errors.Wrapf(
|
|
err, "failed to apply json patch '%s'", p.JsonOp)
|
|
}
|
|
return obj.UnmarshalJSON(modifiedObj)
|
|
}
|
|
|
|
func NewPatchJson6902TransformerPlugin() resmap.TransformerPlugin {
|
|
return &PatchJson6902TransformerPlugin{}
|
|
}
|