| |
| |
| |
|
|
| 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 |
| } |
| } |
| } |
|
|