diff --git a/pkg/node/message.go b/pkg/node/message.go index 4c5e5ab..557dec8 100644 --- a/pkg/node/message.go +++ b/pkg/node/message.go @@ -95,22 +95,22 @@ func NewMessage(msgType MessageType, from, to string, payload interface{}) (*Mes // resp, err := msg.Reply(MsgPong, PongPayload{SentAt: ping.SentAt, ReceivedAt: time.Now().UnixMilli()}) // if err != nil { return nil, err } -func (m *Message) Reply(msgType MessageType, payload interface{}) (*Message, error) { - reply, err := NewMessage(msgType, m.To, m.From, payload) +func (message *Message) Reply(msgType MessageType, payload interface{}) (*Message, error) { + reply, err := NewMessage(msgType, message.To, message.From, payload) if err != nil { return nil, err } - reply.ReplyTo = m.ID + reply.ReplyTo = message.ID return reply, nil } // var ping PingPayload // if err := msg.ParsePayload(&ping); err != nil { return nil, err } -func (m *Message) ParsePayload(v interface{}) error { - if m.Payload == nil { +func (message *Message) ParsePayload(target interface{}) error { + if message.Payload == nil { return nil } - return json.Unmarshal(m.Payload, v) + return json.Unmarshal(message.Payload, target) } // --- Payload Types --- diff --git a/pkg/node/protocol.go b/pkg/node/protocol.go index 8e985f1..93428f9 100644 --- a/pkg/node/protocol.go +++ b/pkg/node/protocol.go @@ -10,8 +10,8 @@ type ProtocolError struct { Message string } -func (e *ProtocolError) Error() string { - return "remote error (" + strconv.Itoa(e.Code) + "): " + e.Message +func (protocolError *ProtocolError) Error() string { + return "remote error (" + strconv.Itoa(protocolError.Code) + "): " + protocolError.Message } // handler := &ResponseHandler{}