From 688668f6d34d4d962247bd5df60c3fca61185927 Mon Sep 17 00:00:00 2001 From: Kyren223 Date: Thu, 24 Oct 2024 16:39:14 +0300 Subject: feat: worked on client --- internal/packet/encoders.go | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) (limited to 'internal/packet/encoders.go') 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(), } } -- cgit v1.3.1