|
|
|
|
|
|
|
|
|
package xml |
|
|
|
import ( |
|
"bytes" |
|
"encoding" |
|
"errors" |
|
"fmt" |
|
"reflect" |
|
"strconv" |
|
"strings" |
|
) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func Unmarshal(data []byte, v interface{}) error { |
|
return NewDecoder(bytes.NewReader(data)).Decode(v) |
|
} |
|
|
|
|
|
|
|
func (d *Decoder) Decode(v interface{}) error { |
|
return d.DecodeElement(v, nil) |
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (d *Decoder) DecodeElement(v interface{}, start *StartElement) error { |
|
val := reflect.ValueOf(v) |
|
if val.Kind() != reflect.Ptr { |
|
return errors.New("non-pointer passed to Unmarshal") |
|
} |
|
return d.unmarshal(val.Elem(), start) |
|
} |
|
|
|
|
|
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 interface{}) string { |
|
t := reflect.TypeOf(val) |
|
if t.Name() != "" { |
|
return t.String() |
|
} |
|
return "(" + t.String() + ")" |
|
} |
|
|
|
|
|
|
|
func (p *Decoder) unmarshalInterface(val Unmarshaler, start *StartElement) error { |
|
|
|
p.pushEOF() |
|
|
|
p.unmarshalDepth++ |
|
err := val.UnmarshalXML(p, *start) |
|
p.unmarshalDepth-- |
|
if err != nil { |
|
p.popEOF() |
|
return err |
|
} |
|
|
|
if !p.popEOF() { |
|
return fmt.Errorf("xml: %s.UnmarshalXML did not consume entire <%s> element", receiverType(val), start.Name.Local) |
|
} |
|
|
|
return nil |
|
} |
|
|
|
|
|
|
|
|
|
func (p *Decoder) unmarshalTextInterface(val encoding.TextUnmarshaler, start *StartElement) error { |
|
var buf []byte |
|
depth := 1 |
|
for depth > 0 { |
|
t, err := p.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 (p *Decoder) unmarshalAttr(val reflect.Value, attr Attr) error { |
|
if val.Kind() == reflect.Ptr { |
|
if val.IsNil() { |
|
val.Set(reflect.New(val.Type().Elem())) |
|
} |
|
val = val.Elem() |
|
} |
|
|
|
if val.CanInterface() && val.Type().Implements(unmarshalerAttrType) { |
|
|
|
|
|
return val.Interface().(UnmarshalerAttr).UnmarshalXMLAttr(attr) |
|
} |
|
if val.CanAddr() { |
|
pv := val.Addr() |
|
if pv.CanInterface() && pv.Type().Implements(unmarshalerAttrType) { |
|
return pv.Interface().(UnmarshalerAttr).UnmarshalXMLAttr(attr) |
|
} |
|
} |
|
|
|
|
|
if val.CanInterface() && val.Type().Implements(textUnmarshalerType) { |
|
|
|
|
|
return val.Interface().(encoding.TextUnmarshaler).UnmarshalText([]byte(attr.Value)) |
|
} |
|
if val.CanAddr() { |
|
pv := val.Addr() |
|
if pv.CanInterface() && pv.Type().Implements(textUnmarshalerType) { |
|
return pv.Interface().(encoding.TextUnmarshaler).UnmarshalText([]byte(attr.Value)) |
|
} |
|
} |
|
|
|
copyValue(val, []byte(attr.Value)) |
|
return nil |
|
} |
|
|
|
var ( |
|
unmarshalerType = reflect.TypeOf((*Unmarshaler)(nil)).Elem() |
|
unmarshalerAttrType = reflect.TypeOf((*UnmarshalerAttr)(nil)).Elem() |
|
textUnmarshalerType = reflect.TypeOf((*encoding.TextUnmarshaler)(nil)).Elem() |
|
) |
|
|
|
|
|
func (p *Decoder) unmarshal(val reflect.Value, start *StartElement) error { |
|
|
|
if start == nil { |
|
for { |
|
tok, err := p.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.Ptr && !e.IsNil() { |
|
val = e |
|
} |
|
} |
|
|
|
if val.Kind() == reflect.Ptr { |
|
if val.IsNil() { |
|
val.Set(reflect.New(val.Type().Elem())) |
|
} |
|
val = val.Elem() |
|
} |
|
|
|
if val.CanInterface() && val.Type().Implements(unmarshalerType) { |
|
|
|
|
|
return p.unmarshalInterface(val.Interface().(Unmarshaler), start) |
|
} |
|
|
|
if val.CanAddr() { |
|
pv := val.Addr() |
|
if pv.CanInterface() && pv.Type().Implements(unmarshalerType) { |
|
return p.unmarshalInterface(pv.Interface().(Unmarshaler), start) |
|
} |
|
} |
|
|
|
if val.CanInterface() && val.Type().Implements(textUnmarshalerType) { |
|
return p.unmarshalTextInterface(val.Interface().(encoding.TextUnmarshaler), start) |
|
} |
|
|
|
if val.CanAddr() { |
|
pv := val.Addr() |
|
if pv.CanInterface() && pv.Type().Implements(textUnmarshalerType) { |
|
return p.unmarshalTextInterface(pv.Interface().(encoding.TextUnmarshaler), start) |
|
} |
|
} |
|
|
|
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 p.Skip() |
|
|
|
case reflect.Slice: |
|
typ := v.Type() |
|
if typ.Elem().Kind() == reflect.Uint8 { |
|
|
|
saveData = v |
|
break |
|
} |
|
|
|
|
|
|
|
n := v.Len() |
|
if n >= v.Cap() { |
|
ncap := 2 * n |
|
if ncap < 4 { |
|
ncap = 4 |
|
} |
|
new := reflect.MakeSlice(typ, n, ncap) |
|
reflect.Copy(new, v) |
|
v.Set(new) |
|
} |
|
v.SetLen(n + 1) |
|
|
|
|
|
if err := p.unmarshal(v.Index(n), start); 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) |
|
if _, ok := fv.Interface().(Name); ok { |
|
fv.Set(reflect.ValueOf(start.Name)) |
|
} |
|
} |
|
|
|
|
|
|
|
for i := range tinfo.fields { |
|
finfo := &tinfo.fields[i] |
|
switch finfo.flags & fMode { |
|
case fAttr: |
|
strv := finfo.value(sv) |
|
|
|
for _, a := range start.Attr { |
|
if a.Name.Local == finfo.name && (finfo.xmlns == "" || finfo.xmlns == a.Name.Space) { |
|
if err := p.unmarshalAttr(strv, a); err != nil { |
|
return err |
|
} |
|
break |
|
} |
|
} |
|
|
|
case fCharData: |
|
if !saveData.IsValid() { |
|
saveData = finfo.value(sv) |
|
} |
|
|
|
case fComment: |
|
if !saveComment.IsValid() { |
|
saveComment = finfo.value(sv) |
|
} |
|
|
|
case fAny, fAny | fElement: |
|
if !saveAny.IsValid() { |
|
saveAny = finfo.value(sv) |
|
} |
|
|
|
case fInnerXml: |
|
if !saveXML.IsValid() { |
|
saveXML = finfo.value(sv) |
|
if p.saved == nil { |
|
saveXMLIndex = 0 |
|
p.saved = new(bytes.Buffer) |
|
} else { |
|
saveXMLIndex = p.savedOffset() |
|
} |
|
} |
|
} |
|
} |
|
} |
|
|
|
|
|
|
|
Loop: |
|
for { |
|
var savedOffset int |
|
if saveXML.IsValid() { |
|
savedOffset = p.savedOffset() |
|
} |
|
tok, err := p.Token() |
|
if err != nil { |
|
return err |
|
} |
|
switch t := tok.(type) { |
|
case StartElement: |
|
consumed := false |
|
if sv.IsValid() { |
|
consumed, err = p.unmarshalPath(tinfo, sv, nil, &t) |
|
if err != nil { |
|
return err |
|
} |
|
if !consumed && saveAny.IsValid() { |
|
consumed = true |
|
if err := p.unmarshal(saveAny, &t); err != nil { |
|
return err |
|
} |
|
} |
|
} |
|
if !consumed { |
|
if err := p.Skip(); err != nil { |
|
return err |
|
} |
|
} |
|
|
|
case EndElement: |
|
if saveXML.IsValid() { |
|
saveXMLData = p.saved.Bytes()[saveXMLIndex:savedOffset] |
|
if saveXMLIndex == 0 { |
|
p.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() && saveData.Type().Implements(textUnmarshalerType) { |
|
if err := saveData.Interface().(encoding.TextUnmarshaler).UnmarshalText(data); err != nil { |
|
return err |
|
} |
|
saveData = reflect.Value{} |
|
} |
|
|
|
if saveData.IsValid() && saveData.CanAddr() { |
|
pv := saveData.Addr() |
|
if pv.CanInterface() && pv.Type().Implements(textUnmarshalerType) { |
|
if err := pv.Interface().(encoding.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: |
|
t.Set(reflect.ValueOf(saveXMLData)) |
|
} |
|
|
|
return nil |
|
} |
|
|
|
func copyValue(dst reflect.Value, src []byte) (err error) { |
|
dst0 := dst |
|
|
|
if dst.Kind() == reflect.Ptr { |
|
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: |
|
itmp, err := strconv.ParseInt(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: |
|
utmp, err := strconv.ParseUint(string(src), 10, dst.Type().Bits()) |
|
if err != nil { |
|
return err |
|
} |
|
dst.SetUint(utmp) |
|
case reflect.Float32, reflect.Float64: |
|
ftmp, err := strconv.ParseFloat(string(src), dst.Type().Bits()) |
|
if err != nil { |
|
return err |
|
} |
|
dst.SetFloat(ftmp) |
|
case reflect.Bool: |
|
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 (p *Decoder) unmarshalPath(tinfo *typeInfo, sv reflect.Value, parents []string, start *StartElement) (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, p.unmarshal(finfo.value(sv), start) |
|
} |
|
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 = p.Token() |
|
if err != nil { |
|
return true, err |
|
} |
|
switch t := tok.(type) { |
|
case StartElement: |
|
consumed2, err := p.unmarshalPath(tinfo, sv, parents, &t) |
|
if err != nil { |
|
return true, err |
|
} |
|
if !consumed2 { |
|
if err := p.Skip(); err != nil { |
|
return true, err |
|
} |
|
} |
|
case EndElement: |
|
return true, nil |
|
} |
|
} |
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func (d *Decoder) Skip() error { |
|
for { |
|
tok, err := d.Token() |
|
if err != nil { |
|
return err |
|
} |
|
switch tok.(type) { |
|
case StartElement: |
|
if err := d.Skip(); err != nil { |
|
return err |
|
} |
|
case EndElement: |
|
return nil |
|
} |
|
} |
|
} |
|
|