-
Notifications
You must be signed in to change notification settings - Fork 15
/
message.go
91 lines (77 loc) · 2.31 KB
/
message.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
82
83
84
85
86
87
88
89
90
91
package proto
import (
"github.com/jexia/semaphore/v2/pkg/references"
"github.com/jexia/semaphore/v2/pkg/specs"
"github.com/jexia/semaphore/v2/pkg/specs/types"
"github.com/jhump/protoreflect/desc"
"github.com/jhump/protoreflect/dynamic"
)
// Message represents a protobuffer message
type Message specs.Template
// Marshal attempts to encode the given template as a protobuf message using the
// given store.
func (tmpl Message) Marshal(result *dynamic.Message, message *desc.MessageDescriptor, root string, store references.Store, tracker references.Tracker) error {
if tmpl.Message == nil {
return nil
}
for _, field := range message.GetFields() {
name := field.GetName()
path := specs.JoinPath(root, name)
specs, has := tmpl.Message[name]
if !has {
continue
}
switch {
case specs.Repeated != nil:
err := Repeated(specs.Template).Marshal(result, field, path, store, tracker)
if err != nil {
return err
}
case specs.Message != nil:
desc := field.GetMessageType()
nested := dynamic.NewMessage(desc)
err := Message(specs.Template).Marshal(nested, desc, path, store, tracker)
if err != nil {
return err
}
err = result.TrySetField(field, nested)
if err != nil {
return err
}
default:
err := Field(specs.Template).Marshal(result.TrySetField, field, store, tracker)
if err != nil {
return err
}
}
}
return nil
}
// Unmarshal unmarshals the given protobuffer message into the given reference store.
func (tmpl Message) Unmarshal(protobuf *dynamic.Message, path string, store references.Store, tracker references.Tracker) {
if tmpl.Message == nil {
return
}
fields := protobuf.GetKnownFields()
store.Define(tracker.Resolve(path), len(fields))
for _, field := range fields {
property := tmpl.Message[field.GetName()]
if property == nil {
continue
}
path := specs.JoinPath(path, field.GetName())
switch property.Type() {
case types.Array:
tmpl, err := property.Repeated.Template()
if err != nil {
panic(err)
}
Repeated(tmpl).Unmarshal(protobuf, field, path, store, tracker)
case types.Message:
nested := protobuf.GetField(field).(*dynamic.Message)
Message(property.Template).Unmarshal(nested, path, store, tracker)
default:
Field(property.Template).Unmarshal(protobuf.GetField(field), path, store, tracker)
}
}
}