diff options
| author | Kyren223 <ulmliad223@gmail.com> | 2024-10-24 16:39:14 +0300 |
|---|---|---|
| committer | Kyren223 <ulmliad223@gmail.com> | 2024-10-24 16:39:14 +0300 |
| commit | 688668f6d34d4d962247bd5df60c3fca61185927 (patch) | |
| tree | 459a29a76bb3a8cd77cdeccf35d7c1689374d09d /internal/packet/encoders.go | |
| parent | 6f83f199f8311bf7782da59bc2e07df38073e65a (diff) | |
feat: worked on client
Diffstat (limited to 'internal/packet/encoders.go')
| -rw-r--r-- | internal/packet/encoders.go | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/internal/packet/encoders.go b/internal/packet/encoders.go index f5841ce..760c11c 100644 --- a/internal/packet/encoders.go +++ b/internal/packet/encoders.go @@ -3,11 +3,12 @@ package packet import ( "encoding/json" - "github.com/kyren223/eko/pkg/assert" "github.com/vmihailenco/msgpack/v5" + + "github.com/kyren223/eko/pkg/assert" ) -type TypedMessage interface { +type Payload interface { Type() PacketType } @@ -29,24 +30,24 @@ func (e defaultPacketEncoder) Payload() []byte { return e.data } -func NewJsonEncoder(message TypedMessage) PacketEncoder { - data, err := json.Marshal(message) +func NewJsonEncoder(payload Payload) PacketEncoder { + data, err := json.Marshal(payload) assert.NoError(err, "encoding a message with JSON should never fail") return defaultPacketEncoder{ data: data, encoding: EncodingJson, - packetType: message.Type(), + packetType: payload.Type(), } } -func NewMsgPackEncoder(message TypedMessage) PacketEncoder { - data, err := msgpack.Marshal(message) +func NewMsgPackEncoder(payload Payload) PacketEncoder { + data, err := msgpack.Marshal(payload) assert.NoError(err, "encoding a message with msg pack should never fail") return defaultPacketEncoder{ data: data, encoding: EncodingMsgPack, - packetType: message.Type(), + packetType: payload.Type(), } } |
