/* Copyright 2018 The Kubernetes Authors. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package internal import ( "encoding/json" "errors" "fmt" "strconv" "strings" "sigs.k8s.io/structured-merge-diff/v4/fieldpath" "sigs.k8s.io/structured-merge-diff/v4/value" ) const ( // Field indicates that the content of this path element is a field's name Field = "f" // Value indicates that the content of this path element is a field's value Value = "v" // Index indicates that the content of this path element is an index in an array Index = "i" // Key indicates that the content of this path element is a key value map Key = "k" // Separator separates the type of a path element from the contents Separator = ":" ) // NewPathElement parses a serialized path element func NewPathElement(s string) (fieldpath.PathElement, error) { split := strings.SplitN(s, Separator, 2) if len(split) < 2 { return fieldpath.PathElement{}, fmt.Errorf("missing colon: %v", s) } switch split[0] { case Field: return fieldpath.PathElement{ FieldName: &split[1], }, nil case Value: val, err := value.FromJSON([]byte(split[1])) if err != nil { return fieldpath.PathElement{}, err } return fieldpath.PathElement{ Value: &val, }, nil case Index: i, err := strconv.Atoi(split[1]) if err != nil { return fieldpath.PathElement{}, err } return fieldpath.PathElement{ Index: &i, }, nil case Key: kv := map[string]json.RawMessage{} err := json.Unmarshal([]byte(split[1]), &kv) if err != nil { return fieldpath.PathElement{}, err } fields := value.FieldList{} for k, v := range kv { b, err := json.Marshal(v) if err != nil { return fieldpath.PathElement{}, err } val, err := value.FromJSON(b) if err != nil { return fieldpath.PathElement{}, err } fields = append(fields, value.Field{ Name: k, Value: val, }) } return fieldpath.PathElement{ Key: &fields, }, nil default: // Ignore unknown key types return fieldpath.PathElement{}, nil } } // PathElementString serializes a path element func PathElementString(pe fieldpath.PathElement) (string, error) { switch { case pe.FieldName != nil: return Field + Separator + *pe.FieldName, nil case pe.Key != nil: kv := map[string]json.RawMessage{} for _, k := range *pe.Key { b, err := value.ToJSON(k.Value) if err != nil { return "", err } m := json.RawMessage{} err = json.Unmarshal(b, &m) if err != nil { return "", err } kv[k.Name] = m } b, err := json.Marshal(kv) if err != nil { return "", err } return Key + ":" + string(b), nil case pe.Value != nil: b, err := value.ToJSON(*pe.Value) if err != nil { return "", err } return Value + ":" + string(b), nil case pe.Index != nil: return Index + ":" + strconv.Itoa(*pe.Index), nil default: return "", errors.New("Invalid type of path element") } }