HyperNet/Nexus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🔇 Disable pushing websocket logs

Browse Source
This commit is contained in:
LittleSheep 2025-03-23 13:16:13 +08:00
parent e670724c4c
commit c7f3c1b2cc
1 changed files with 0 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/internal/grpc/stream.go
View File

@ -5,7 +5,6 @@ import (
"fmt" "fmt"
"git.solsynth.dev/hypernet/nexus/pkg/internal/web/ws" "git.solsynth.dev/hypernet/nexus/pkg/internal/web/ws"
"github.com/rs/zerolog/log"
"git.solsynth.dev/hypernet/nexus/pkg/proto" "git.solsynth.dev/hypernet/nexus/pkg/proto"
"github.com/samber/lo" "github.com/samber/lo"
@ -31,14 +30,6 @@ func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamReques
} }
success := len(successes) success := len(successes)
log.Debug().
Str("client_id", request.GetClientId()).
Uint64("user_id", request.GetUserId()).
Int("count", cnt).
Int("success", success).
Int("failed", len(errs)).
Msgf("Pushed a websocket package to client / user...")
if len(errs) > 0 { if len(errs) > 0 {
// Partial fail // Partial fail
return &proto.PushStreamResponse{ return &proto.PushStreamResponse{
@ -79,14 +70,6 @@ func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamB
} }
success := len(successes) success := len(successes)
log.Debug().
Any("client_id", request.GetClientId()).
Any("user_id", request.GetUserId()).
Int("count", cnt).
Int("success", success).
Int("failed", len(errs)).
Msgf("Pushed a websocket package to client / user...")
if len(errs) > 0 { if len(errs) > 0 {
// Partial fail // Partial fail
return &proto.PushStreamResponse{ return &proto.PushStreamResponse{