try fixing memory leak

relay/wsconn.go

@@ -3,7 +3,6 @@ package relay
 import (
 	"bytes"
 	"encoding/json"
-	"fmt"
 	"strings"
 
 	"github.com/RabbyHub/derelay/log"
@@ -31,7 +30,6 @@ func (c *client) MarshalLogObject(encoder zapcore.ObjectEncoder) error {
 	if c != nil {
 		encoder.AddString("id", c.id)
 		encoder.AddString("role", string(c.role))
-		encoder.AddString("session", string(c.session))
 		encoder.AddArray("pubTopics", c.pubTopics)
 		encoder.AddArray("subTopics", c.subTopics)
 	}
@@ -87,7 +85,6 @@ func (c *client) send(message SocketMessage) {
 	case c.sendbuf <- message:
 	default:
 		metrics.IncSendBlocking()
-		log.Error("client sendbuf full", fmt.Errorf(""), zap.Any("client", c), zap.Any("len(sendbuf)", len(c.sendbuf)), zap.Any("message", message))
 	}
 }
 

relay/wshandlers.go

@@ -54,11 +54,11 @@ func (ws *WsServer) subMessage(message SocketMessage) {
 	if err := ws.redisSubConn.Subscribe(context.TODO(), messageChanKey(topic)); err != nil {
 		log.Warn("[redisSub] subscribe to topic fail", zap.String("topic", topic), zap.Any("client", subscriber))
 	}
-	log.Info("subscribe to topic", zap.String("topic", topic), zap.Any("client", subscriber))
+	//log.Info("subscribe to topic", zap.String("topic", topic), zap.Any("client", subscriber))
 
 	// forward cached notificatoins if there's any
 	notifications := ws.getCachedMessages(topic, true)
-	log.Info("pending notifications", zap.String("topic", topic), zap.Any("num", len(notifications)), zap.Any("client", subscriber))
+	//log.Info("pending notifications", zap.String("topic", topic), zap.Any("num", len(notifications)), zap.Any("client", subscriber))
 	for _, notification := range notifications {
 		subscriber.send(notification)
 	}
@@ -84,7 +84,7 @@ func (ws *WsServer) subMessage(message SocketMessage) {
 			if noti.Phase == string(SessionRequest) { // handle the 1st case stated above
 				subscriber.session = noti.Topic
 				metrics.IncReceivedSessions()
-				log.Info("session been scanned", zap.Any("topic", topic), zap.Any("client", subscriber))
+				//log.Info("session been scanned", zap.Any("topic", topic), zap.Any("client", subscriber))
 
 				// notify the topic publisher, aka the dapp, that the session request has been received by wallet
 				key := dappNotifyChanKey(noti.Topic)