processGroupMicChangeRsp

main.go

@@ -254,7 +254,9 @@ func serverWebsocket(w http.ResponseWriter, r *http.Request) {
 						logger.Errorf("processRoomHeartbeat fail:%v", err)
 					}
 				} else if msgType == common.MsgTypeGroupMicChangeRsp {
-					logger.Infof("common.MsgTypeGroupMicChangeRsp arrive")
+					if err := processGroupMicChangeRsp(logger, ci.Uid, pbData); err != nil {
+						logger.Errorf("processGroupMicChangeRsp fail:%v", err)
+					}
 				} else {
 					logger.Warnf("Unknown message type %d", msgType)
 				}
@@ -463,6 +465,17 @@ func processRoomHeartbeat(logger *log.Entry, uid uint64, pbData []byte) error {
 	}
 }
 
+func processGroupMicChangeRsp(logger *log.Entry, uid uint64, pbData []byte) error {
+	msg := &userProxy.GroupMicChangeRsp{}
+	err := proto.Unmarshal(pbData, msg)
+	if err == nil {
+		logger.Infof("groupMicChangeRsp,uid:%v,seqId:%v", uid, msg.SeqId)
+	} else {
+		return err
+	}
+	return err
+}
+
 // 直接发匹配成功消息，调试用
 func homePage(w http.ResponseWriter, r *http.Request) {
 	rsp := "Home Page"