log

server/client.go

@@ -56,7 +56,7 @@ func (c *Client) reader() {
 
 		message := deserializeMessage(bytes)
 		switch message.Type {
-		case MessageTypeChating:
+		case MessageTypeUpChating, MessageTypeDownChating:
 
 			// Chat dialogue messages
 			chatingContent := message.Content.(ChatingContent)

server/message.go

@@ -4,16 +4,18 @@ import (
 	"encoding/json"
 
 	"github.com/mitchellh/mapstructure"
+	"sikey.com/websocket/utils/zlog"
 )
 
 type MessageType = int8
 type ChatingContentType = uint8
 
 const (
-	MessageTypeError    MessageType = -1 // MessageTypeError 错误消息,当服务器出现错误时,会发送此消息
-	MessageTypePingPong MessageType = 1  // MessageTypePingPong ping pong 消息
-	MessageTypeEmpty    MessageType = 2  //  MessageTypeEmpty 空消息
-	MessageTypeChating  MessageType = 3  // MessageTypeDialogue 语聊消息
+	MessageTypeError       MessageType = -1 // MessageTypeError 错误消息,当服务器出现错误时,会发送此消息
+	MessageTypePingPong    MessageType = 1  // MessageTypePingPong ping pong 消息
+	MessageTypeEmpty       MessageType = 2  //  MessageTypeEmpty 空消息
+	MessageTypeUpChating   MessageType = 30 // MessageTypeUpChating 语聊消息
+	MessageTypeDownChating MessageType = 31 // MessageTypeDownChating 语聊消息
 )
 
 const (
@@ -75,12 +77,11 @@ func deserializeMessage(bytes []byte) *Message {
 	switch message.Type {
 
 	// Is it a chating message
-	case MessageTypeChating:
+	case MessageTypeUpChating, MessageTypeDownChating:
 		var chatingContent ChatingContent
 		mapstructure.Decode(message.Content, &chatingContent)
 		message.Content = chatingContent
 	}
-
 	return &message
 }
 
@@ -94,6 +95,7 @@ func newReplyMessage(message *Message) *Message {
 	if message.Type == MessageTypePingPong {
 		message.Content = "pong"
 	}
+	zlog.Info("reply message", message)
 	return message
 }