-
Notifications
You must be signed in to change notification settings - Fork 6
/
message_envelope.go
39 lines (33 loc) · 929 Bytes
/
message_envelope.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
package redis
import (
"encoding/json"
"golang.org/x/xerrors"
"github.com/saiya/dsps/server/domain"
)
type messageEnvelope struct {
ID domain.MessageID `json:"id"`
Content json.RawMessage `json:"content"`
}
func wrapMessage(msg domain.Message) (string, error) {
data, err := json.Marshal(messageEnvelope{
ID: msg.MessageID,
Content: msg.Content,
})
if err != nil {
return "", xerrors.Errorf(`%w: %v`, domain.ErrMalformedMessageJSON, err)
}
return string(data), nil
}
func unwrapMessage(ch domain.ChannelID, raw string) (*domain.Message, error) {
envelope := messageEnvelope{}
if err := json.Unmarshal([]byte(raw), &envelope); err != nil {
return nil, xerrors.Errorf(`Failed to parse message envelope JSON '%s': %w`, string(raw), err)
}
return &domain.Message{
MessageLocator: domain.MessageLocator{
ChannelID: ch,
MessageID: envelope.ID,
},
Content: envelope.Content,
}, nil
}