-
Notifications
You must be signed in to change notification settings - Fork 0
/
device_codec.go
executable file
·81 lines (69 loc) · 2.18 KB
/
device_codec.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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package campid
import (
"encoding/gob"
"encoding/json"
"io"
"github.com/influx6/npkg/nerror"
"github.com/vmihailenco/msgpack/v5"
)
type DeviceCodec interface {
Decode(r io.Reader) (Device, error)
Encode(w io.Writer, c Device) error
}
// MsgPackDeviceCodec implements the DeviceCodec interface for using
// the MsgPack Codec.
type MsgPackDeviceCodec struct{}
// Encode encodes giving session using the internal MsgPack format.
// Returning provided data.
func (gb *MsgPackDeviceCodec) Encode(w io.Writer, s Device) error {
if err := msgpack.NewEncoder(w).Encode(s); err != nil {
return nerror.Wrap(err, "Failed to encode giving session")
}
return nil
}
// Decode decodes giving data into provided session instance.
func (gb *MsgPackDeviceCodec) Decode(r io.Reader) (Device, error) {
var s Device
if err := msgpack.NewDecoder(r).Decode(&s); err != nil {
return s, nerror.WrapOnly(err)
}
return s, nil
}
// JsonDeviceCodec implements the DeviceCodec interface for using
// the Json Codec.
type JsonDeviceCodec struct{}
// Encode encodes giving session using the internal Json format.
// Returning provided data.
func (gb *JsonDeviceCodec) Encode(w io.Writer, s Device) error {
if err := json.NewEncoder(w).Encode(s); err != nil {
return nerror.Wrap(err, "Failed to encode giving session")
}
return nil
}
// Decode decodes giving data into provided session instance.
func (gb *JsonDeviceCodec) Decode(r io.Reader) (Device, error) {
var s Device
if err := json.NewDecoder(r).Decode(&s); err != nil {
return s, nerror.WrapOnly(err)
}
return s, nil
}
// GobDeviceCodec implements the DeviceCodec interface for using
// the gob Codec.
type GobDeviceCodec struct{}
// Encode encodes giving session using the internal gob format.
// Returning provided data.
func (gb *GobDeviceCodec) Encode(w io.Writer, s Device) error {
if err := gob.NewEncoder(w).Encode(s); err != nil {
return nerror.Wrap(err, "Failed to encode giving session")
}
return nil
}
// Decode decodes giving data into provided session instance.
func (gb *GobDeviceCodec) Decode(r io.Reader) (Device, error) {
var s Device
if err := gob.NewDecoder(r).Decode(&s); err != nil {
return s, nerror.WrapOnly(err)
}
return s, nil
}