blob: 24b458a6cf3e2f4f3115e01b917316254d51c039 (
plain) (
blame)
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
|
package sfive
import (
"encoding/json"
"fmt"
)
type StatsDecoder interface {
Decode(jsonString []byte) (StatisticsData, error)
}
type StatsEncoder interface {
Encode(data StatisticsData) []byte
}
type StatefulDecoder struct {
sourceId SourceId
}
type PlainDecoder struct{}
type PlainEncoder struct{}
func NewStatefulDecoder(jsonString []byte) (decoder StatsDecoder, err error) {
res := new(StatefulDecoder)
err = json.Unmarshal(jsonString, &res.sourceId)
if err != nil {
return
}
if res.sourceId.Version != 1 {
err = fmt.Errorf("unsupported version, expected 1, actual %v", res.sourceId.Version)
}
decoder = res
return
}
func NewPlainDecoder() (decoder StatsDecoder) {
return new(PlainDecoder)
}
func (self *StatefulDecoder) Decode(jsonString []byte) (dat StatisticsData, err error) {
dat.CopyFrom(&self.sourceId)
err = json.Unmarshal(jsonString, &dat)
// like in PlainDecoder, let the client decide how to use partial results
// (Unmarshal returns partial results in case of errors)
return
}
func (self *PlainDecoder) Decode(jsonString []byte) (dat StatisticsData, err error) {
err = json.Unmarshal(jsonString, &dat)
return
}
func (self *PlainEncoder) Encode(data *StatisticsData) []byte {
res, err := json.Marshal(data)
if err != nil {
panic("oh fuck I cannot event marshal my own data")
}
return res
}
|
