forked from qaz9877/go-smpp
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtag.go
61 lines (57 loc) · 1.06 KB
/
tag.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package pdu
import (
"bytes"
"encoding/binary"
"io"
"sort"
)
type Tags map[uint16][]byte
func (t *Tags) ReadFrom(r io.Reader) (n int64, err error) {
var values [2]uint16
var data []byte
tags := make(Tags)
for {
err = binary.Read(r, binary.BigEndian, values[:])
if err == nil {
data = make([]byte, values[1])
_, err = r.Read(data)
}
if err == nil {
tags[values[0]] = data
}
if err == io.EOF {
err = nil
break
}
if err != nil {
break
}
}
if len(tags) > 0 {
*t = tags
}
return
}
func (t Tags) WriteTo(w io.Writer) (n int64, err error) {
var buf bytes.Buffer
var keys []uint16
for tag := range t {
keys = append(keys, tag)
}
sort.Slice(keys, func(i, j int) bool { return keys[i] < keys[j] })
err = ErrInvalidTagLength
for _, tag := range keys {
data := t[tag]
length := len(data)
if length == 0 {
continue
} else if length < 0xFFFF {
_ = binary.Write(&buf, binary.BigEndian, tag)
_ = binary.Write(&buf, binary.BigEndian, uint16(len(data)))
buf.Write(data)
} else {
return
}
}
return buf.WriteTo(w)
}