public/chat-signaling-server
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix server log message

Browse Source
This commit is contained in:
guochao 2024-05-26 14:00:14 +08:00
parent b2a8c41ea0
commit f02c30bbdc
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/impl/signal-server/signaling.go
View File

@ -83,7 +83,7 @@ func (signalingServer SignalingServer) handleStream(ctx context.Context, name st
if received, err := signalingServer.redis.Publish(ctx, signalingServer.redisKeyPrefix+":"+msg.Room+":offer:"+*msg.Receiver, payload.String()).Result(); err != nil { if received, err := signalingServer.redis.Publish(ctx, signalingServer.redisKeyPrefix+":"+msg.Room+":offer:"+*msg.Receiver, payload.String()).Result(); err != nil {
return err return err
} else { } else {
log.Printf("peers received discover response: %v", received) log.Printf("peers received session offer: %v", received)
} }
case *proto.SignalingMessage_SessionAnswer: case *proto.SignalingMessage_SessionAnswer:
payload := &bytes.Buffer{} payload := &bytes.Buffer{}
@ -94,7 +94,7 @@ func (signalingServer SignalingServer) handleStream(ctx context.Context, name st
if received, err := signalingServer.redis.Publish(ctx, signalingServer.redisKeyPrefix+":"+msg.Room+":answer:"+*msg.Receiver, payload.String()).Result(); err != nil { if received, err := signalingServer.redis.Publish(ctx, signalingServer.redisKeyPrefix+":"+msg.Room+":answer:"+*msg.Receiver, payload.String()).Result(); err != nil {
return err return err
} else { } else {
log.Printf("peers received discover response: %v", received) log.Printf("peers received session answer: %v", received)
} }
} }
} else { } else {