| | |
| | |
| | |
| |
|
| | package xml |
| |
|
| | import ( |
| | "bytes" |
| | "encoding" |
| | "errors" |
| | "fmt" |
| | "reflect" |
| | "runtime" |
| | "strconv" |
| | "strings" |
| | ) |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | func Unmarshal(data []byte, v any) error { |
| | return NewDecoder(bytes.NewReader(data)).Decode(v) |
| | } |
| |
|
| | |
| | |
| | func (d *Decoder) Decode(v any) error { |
| | return d.DecodeElement(v, nil) |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | func (d *Decoder) DecodeElement(v any, start *StartElement) error { |
| | val := reflect.ValueOf(v) |
| | if val.Kind() != reflect.Pointer { |
| | return errors.New("non-pointer passed to Unmarshal") |
| | } |
| |
|
| | if val.IsNil() { |
| | return errors.New("nil pointer passed to Unmarshal") |
| | } |
| | return d.unmarshal(val.Elem(), start, 0) |
| | } |
| |
|
| | |
| | type UnmarshalError string |
| |
|
| | func (e UnmarshalError) Error() string { return string(e) } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | type Unmarshaler interface { |
| | UnmarshalXML(d *Decoder, start StartElement) error |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | type UnmarshalerAttr interface { |
| | UnmarshalXMLAttr(attr Attr) error |
| | } |
| |
|
| | |
| | func receiverType(val any) string { |
| | t := reflect.TypeOf(val) |
| | if t.Name() != "" { |
| | return t.String() |
| | } |
| | return "(" + t.String() + ")" |
| | } |
| |
|
| | |
| | |
| | func (d *Decoder) unmarshalInterface(val Unmarshaler, start *StartElement) error { |
| | |
| | d.pushEOF() |
| |
|
| | d.unmarshalDepth++ |
| | err := val.UnmarshalXML(d, *start) |
| | d.unmarshalDepth-- |
| | if err != nil { |
| | d.popEOF() |
| | return err |
| | } |
| |
|
| | if !d.popEOF() { |
| | return fmt.Errorf("xml: %s.UnmarshalXML did not consume entire <%s> element", receiverType(val), start.Name.Local) |
| | } |
| |
|
| | return nil |
| | } |
| |
|
| | |
| | |
| | |
| | func (d *Decoder) unmarshalTextInterface(val encoding.TextUnmarshaler) error { |
| | var buf []byte |
| | depth := 1 |
| | for depth > 0 { |
| | t, err := d.Token() |
| | if err != nil { |
| | return err |
| | } |
| | switch t := t.(type) { |
| | case CharData: |
| | if depth == 1 { |
| | buf = append(buf, t...) |
| | } |
| | case StartElement: |
| | depth++ |
| | case EndElement: |
| | depth-- |
| | } |
| | } |
| | return val.UnmarshalText(buf) |
| | } |
| |
|
| | |
| | func (d *Decoder) unmarshalAttr(val reflect.Value, attr Attr) error { |
| | if val.Kind() == reflect.Pointer { |
| | if val.IsNil() { |
| | val.Set(reflect.New(val.Type().Elem())) |
| | } |
| | val = val.Elem() |
| | } |
| | if val.CanInterface() { |
| | |
| | |
| | if unmarshaler, ok := reflect.TypeAssert[UnmarshalerAttr](val); ok { |
| | return unmarshaler.UnmarshalXMLAttr(attr) |
| | } |
| | } |
| | if val.CanAddr() { |
| | pv := val.Addr() |
| | if pv.CanInterface() { |
| | if unmarshaler, ok := reflect.TypeAssert[UnmarshalerAttr](pv); ok { |
| | return unmarshaler.UnmarshalXMLAttr(attr) |
| | } |
| | } |
| | } |
| |
|
| | |
| | if val.CanInterface() { |
| | |
| | |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](val); ok { |
| | return textUnmarshaler.UnmarshalText([]byte(attr.Value)) |
| | } |
| | } |
| | if val.CanAddr() { |
| | pv := val.Addr() |
| | if pv.CanInterface() { |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](pv); ok { |
| | return textUnmarshaler.UnmarshalText([]byte(attr.Value)) |
| | } |
| | } |
| | } |
| |
|
| | if val.Kind() == reflect.Slice && val.Type().Elem().Kind() != reflect.Uint8 { |
| | |
| | |
| | n := val.Len() |
| | val.Grow(1) |
| | val.SetLen(n + 1) |
| |
|
| | |
| | if err := d.unmarshalAttr(val.Index(n), attr); err != nil { |
| | val.SetLen(n) |
| | return err |
| | } |
| | return nil |
| | } |
| |
|
| | if val.Type() == attrType { |
| | val.Set(reflect.ValueOf(attr)) |
| | return nil |
| | } |
| |
|
| | return copyValue(val, []byte(attr.Value)) |
| | } |
| |
|
| | var attrType = reflect.TypeFor[Attr]() |
| |
|
| | const ( |
| | maxUnmarshalDepth = 10000 |
| | maxUnmarshalDepthWasm = 5000 |
| | ) |
| |
|
| | var errUnmarshalDepth = errors.New("exceeded max depth") |
| |
|
| | |
| | func (d *Decoder) unmarshal(val reflect.Value, start *StartElement, depth int) error { |
| | if depth >= maxUnmarshalDepth || runtime.GOARCH == "wasm" && depth >= maxUnmarshalDepthWasm { |
| | return errUnmarshalDepth |
| | } |
| | |
| | if start == nil { |
| | for { |
| | tok, err := d.Token() |
| | if err != nil { |
| | return err |
| | } |
| | if t, ok := tok.(StartElement); ok { |
| | start = &t |
| | break |
| | } |
| | } |
| | } |
| |
|
| | |
| | |
| | if val.Kind() == reflect.Interface && !val.IsNil() { |
| | e := val.Elem() |
| | if e.Kind() == reflect.Pointer && !e.IsNil() { |
| | val = e |
| | } |
| | } |
| |
|
| | if val.Kind() == reflect.Pointer { |
| | if val.IsNil() { |
| | val.Set(reflect.New(val.Type().Elem())) |
| | } |
| | val = val.Elem() |
| | } |
| |
|
| | if val.CanInterface() { |
| | |
| | |
| | if unmarshaler, ok := reflect.TypeAssert[Unmarshaler](val); ok { |
| | return d.unmarshalInterface(unmarshaler, start) |
| | } |
| | } |
| |
|
| | if val.CanAddr() { |
| | pv := val.Addr() |
| | if pv.CanInterface() { |
| | if unmarshaler, ok := reflect.TypeAssert[Unmarshaler](pv); ok { |
| | return d.unmarshalInterface(unmarshaler, start) |
| | } |
| | } |
| | } |
| |
|
| | if val.CanInterface() { |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](val); ok { |
| | return d.unmarshalTextInterface(textUnmarshaler) |
| | } |
| | } |
| |
|
| | if val.CanAddr() { |
| | pv := val.Addr() |
| | if pv.CanInterface() { |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](pv); ok { |
| | return d.unmarshalTextInterface(textUnmarshaler) |
| | } |
| | } |
| | } |
| |
|
| | var ( |
| | data []byte |
| | saveData reflect.Value |
| | comment []byte |
| | saveComment reflect.Value |
| | saveXML reflect.Value |
| | saveXMLIndex int |
| | saveXMLData []byte |
| | saveAny reflect.Value |
| | sv reflect.Value |
| | tinfo *typeInfo |
| | err error |
| | ) |
| |
|
| | switch v := val; v.Kind() { |
| | default: |
| | return errors.New("unknown type " + v.Type().String()) |
| |
|
| | case reflect.Interface: |
| | |
| | |
| | |
| | return d.Skip() |
| |
|
| | case reflect.Slice: |
| | typ := v.Type() |
| | if typ.Elem().Kind() == reflect.Uint8 { |
| | |
| | saveData = v |
| | break |
| | } |
| |
|
| | |
| | |
| | n := v.Len() |
| | v.Grow(1) |
| | v.SetLen(n + 1) |
| |
|
| | |
| | if err := d.unmarshal(v.Index(n), start, depth+1); err != nil { |
| | v.SetLen(n) |
| | return err |
| | } |
| | return nil |
| |
|
| | case reflect.Bool, reflect.Float32, reflect.Float64, reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64, reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr, reflect.String: |
| | saveData = v |
| |
|
| | case reflect.Struct: |
| | typ := v.Type() |
| | if typ == nameType { |
| | v.Set(reflect.ValueOf(start.Name)) |
| | break |
| | } |
| |
|
| | sv = v |
| | tinfo, err = getTypeInfo(typ) |
| | if err != nil { |
| | return err |
| | } |
| |
|
| | |
| | if tinfo.xmlname != nil { |
| | finfo := tinfo.xmlname |
| | if finfo.name != "" && finfo.name != start.Name.Local { |
| | return UnmarshalError("expected element type <" + finfo.name + "> but have <" + start.Name.Local + ">") |
| | } |
| | if finfo.xmlns != "" && finfo.xmlns != start.Name.Space { |
| | e := "expected element <" + finfo.name + "> in name space " + finfo.xmlns + " but have " |
| | if start.Name.Space == "" { |
| | e += "no name space" |
| | } else { |
| | e += start.Name.Space |
| | } |
| | return UnmarshalError(e) |
| | } |
| | fv := finfo.value(sv, initNilPointers) |
| | if _, ok := reflect.TypeAssert[Name](fv); ok { |
| | fv.Set(reflect.ValueOf(start.Name)) |
| | } |
| | } |
| |
|
| | |
| | for _, a := range start.Attr { |
| | handled := false |
| | any := -1 |
| | for i := range tinfo.fields { |
| | finfo := &tinfo.fields[i] |
| | switch finfo.flags & fMode { |
| | case fAttr: |
| | strv := finfo.value(sv, initNilPointers) |
| | if a.Name.Local == finfo.name && (finfo.xmlns == "" || finfo.xmlns == a.Name.Space) { |
| | if err := d.unmarshalAttr(strv, a); err != nil { |
| | return err |
| | } |
| | handled = true |
| | } |
| |
|
| | case fAny | fAttr: |
| | if any == -1 { |
| | any = i |
| | } |
| | } |
| | } |
| | if !handled && any >= 0 { |
| | finfo := &tinfo.fields[any] |
| | strv := finfo.value(sv, initNilPointers) |
| | if err := d.unmarshalAttr(strv, a); err != nil { |
| | return err |
| | } |
| | } |
| | } |
| |
|
| | |
| | for i := range tinfo.fields { |
| | finfo := &tinfo.fields[i] |
| | switch finfo.flags & fMode { |
| | case fCDATA, fCharData: |
| | if !saveData.IsValid() { |
| | saveData = finfo.value(sv, initNilPointers) |
| | } |
| |
|
| | case fComment: |
| | if !saveComment.IsValid() { |
| | saveComment = finfo.value(sv, initNilPointers) |
| | } |
| |
|
| | case fAny, fAny | fElement: |
| | if !saveAny.IsValid() { |
| | saveAny = finfo.value(sv, initNilPointers) |
| | } |
| |
|
| | case fInnerXML: |
| | if !saveXML.IsValid() { |
| | saveXML = finfo.value(sv, initNilPointers) |
| | if d.saved == nil { |
| | saveXMLIndex = 0 |
| | d.saved = new(bytes.Buffer) |
| | } else { |
| | saveXMLIndex = d.savedOffset() |
| | } |
| | } |
| | } |
| | } |
| | } |
| |
|
| | |
| | |
| | Loop: |
| | for { |
| | var savedOffset int |
| | if saveXML.IsValid() { |
| | savedOffset = d.savedOffset() |
| | } |
| | tok, err := d.Token() |
| | if err != nil { |
| | return err |
| | } |
| | switch t := tok.(type) { |
| | case StartElement: |
| | consumed := false |
| | if sv.IsValid() { |
| | |
| | |
| | consumed, err = d.unmarshalPath(tinfo, sv, nil, &t, depth) |
| | if err != nil { |
| | return err |
| | } |
| | if !consumed && saveAny.IsValid() { |
| | consumed = true |
| | if err := d.unmarshal(saveAny, &t, depth+1); err != nil { |
| | return err |
| | } |
| | } |
| | } |
| | if !consumed { |
| | if err := d.Skip(); err != nil { |
| | return err |
| | } |
| | } |
| |
|
| | case EndElement: |
| | if saveXML.IsValid() { |
| | saveXMLData = d.saved.Bytes()[saveXMLIndex:savedOffset] |
| | if saveXMLIndex == 0 { |
| | d.saved = nil |
| | } |
| | } |
| | break Loop |
| |
|
| | case CharData: |
| | if saveData.IsValid() { |
| | data = append(data, t...) |
| | } |
| |
|
| | case Comment: |
| | if saveComment.IsValid() { |
| | comment = append(comment, t...) |
| | } |
| | } |
| | } |
| |
|
| | if saveData.IsValid() && saveData.CanInterface() { |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](saveData); ok { |
| | if err := textUnmarshaler.UnmarshalText(data); err != nil { |
| | return err |
| | } |
| | saveData = reflect.Value{} |
| | } |
| | } |
| |
|
| | if saveData.IsValid() && saveData.CanAddr() { |
| | pv := saveData.Addr() |
| | if pv.CanInterface() { |
| | if textUnmarshaler, ok := reflect.TypeAssert[encoding.TextUnmarshaler](pv); ok { |
| | if err := textUnmarshaler.UnmarshalText(data); err != nil { |
| | return err |
| | } |
| | saveData = reflect.Value{} |
| | } |
| | } |
| | } |
| |
|
| | if err := copyValue(saveData, data); err != nil { |
| | return err |
| | } |
| |
|
| | switch t := saveComment; t.Kind() { |
| | case reflect.String: |
| | t.SetString(string(comment)) |
| | case reflect.Slice: |
| | t.Set(reflect.ValueOf(comment)) |
| | } |
| |
|
| | switch t := saveXML; t.Kind() { |
| | case reflect.String: |
| | t.SetString(string(saveXMLData)) |
| | case reflect.Slice: |
| | if t.Type().Elem().Kind() == reflect.Uint8 { |
| | t.Set(reflect.ValueOf(saveXMLData)) |
| | } |
| | } |
| |
|
| | return nil |
| | } |
| |
|
| | func copyValue(dst reflect.Value, src []byte) (err error) { |
| | dst0 := dst |
| |
|
| | if dst.Kind() == reflect.Pointer { |
| | if dst.IsNil() { |
| | dst.Set(reflect.New(dst.Type().Elem())) |
| | } |
| | dst = dst.Elem() |
| | } |
| |
|
| | |
| | switch dst.Kind() { |
| | case reflect.Invalid: |
| | |
| | default: |
| | return errors.New("cannot unmarshal into " + dst0.Type().String()) |
| | case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64: |
| | if len(src) == 0 { |
| | dst.SetInt(0) |
| | return nil |
| | } |
| | itmp, err := strconv.ParseInt(strings.TrimSpace(string(src)), 10, dst.Type().Bits()) |
| | if err != nil { |
| | return err |
| | } |
| | dst.SetInt(itmp) |
| | case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr: |
| | if len(src) == 0 { |
| | dst.SetUint(0) |
| | return nil |
| | } |
| | utmp, err := strconv.ParseUint(strings.TrimSpace(string(src)), 10, dst.Type().Bits()) |
| | if err != nil { |
| | return err |
| | } |
| | dst.SetUint(utmp) |
| | case reflect.Float32, reflect.Float64: |
| | if len(src) == 0 { |
| | dst.SetFloat(0) |
| | return nil |
| | } |
| | ftmp, err := strconv.ParseFloat(strings.TrimSpace(string(src)), dst.Type().Bits()) |
| | if err != nil { |
| | return err |
| | } |
| | dst.SetFloat(ftmp) |
| | case reflect.Bool: |
| | if len(src) == 0 { |
| | dst.SetBool(false) |
| | return nil |
| | } |
| | value, err := strconv.ParseBool(strings.TrimSpace(string(src))) |
| | if err != nil { |
| | return err |
| | } |
| | dst.SetBool(value) |
| | case reflect.String: |
| | dst.SetString(string(src)) |
| | case reflect.Slice: |
| | if len(src) == 0 { |
| | |
| | src = []byte{} |
| | } |
| | dst.SetBytes(src) |
| | } |
| | return nil |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | func (d *Decoder) unmarshalPath(tinfo *typeInfo, sv reflect.Value, parents []string, start *StartElement, depth int) (consumed bool, err error) { |
| | recurse := false |
| | Loop: |
| | for i := range tinfo.fields { |
| | finfo := &tinfo.fields[i] |
| | if finfo.flags&fElement == 0 || len(finfo.parents) < len(parents) || finfo.xmlns != "" && finfo.xmlns != start.Name.Space { |
| | continue |
| | } |
| | for j := range parents { |
| | if parents[j] != finfo.parents[j] { |
| | continue Loop |
| | } |
| | } |
| | if len(finfo.parents) == len(parents) && finfo.name == start.Name.Local { |
| | |
| | return true, d.unmarshal(finfo.value(sv, initNilPointers), start, depth+1) |
| | } |
| | if len(finfo.parents) > len(parents) && finfo.parents[len(parents)] == start.Name.Local { |
| | |
| | |
| | |
| | recurse = true |
| |
|
| | |
| | |
| | parents = finfo.parents[:len(parents)+1] |
| | break |
| | } |
| | } |
| | if !recurse { |
| | |
| | return false, nil |
| | } |
| | |
| | |
| | |
| | for { |
| | var tok Token |
| | tok, err = d.Token() |
| | if err != nil { |
| | return true, err |
| | } |
| | switch t := tok.(type) { |
| | case StartElement: |
| | |
| | |
| | consumed2, err := d.unmarshalPath(tinfo, sv, parents, &t, depth) |
| | if err != nil { |
| | return true, err |
| | } |
| | if !consumed2 { |
| | if err := d.Skip(); err != nil { |
| | return true, err |
| | } |
| | } |
| | case EndElement: |
| | return true, nil |
| | } |
| | } |
| | } |
| |
|
| | |
| | |
| | |
| | |
| | |
| | func (d *Decoder) Skip() error { |
| | var depth int64 |
| | for { |
| | tok, err := d.Token() |
| | if err != nil { |
| | return err |
| | } |
| | switch tok.(type) { |
| | case StartElement: |
| | depth++ |
| | case EndElement: |
| | if depth == 0 { |
| | return nil |
| | } |
| | depth-- |
| | } |
| | } |
| | } |
| |
|