From 6acb4bbd612b800e4121de1aefeb50d0b0e692df Mon Sep 17 00:00:00 2001 From: David Zhao Date: Wed, 25 Dec 2024 22:23:21 -0800 Subject: [PATCH] add room/participant to logger context for SIP APIs (#3290) --- pkg/service/sip.go | 34 ++++++++++++++++++++++++---------- 1 file changed, 24 insertions(+), 10 deletions(-) diff --git a/pkg/service/sip.go b/pkg/service/sip.go index 0b43e8f2b..5f9edd8f2 100644 --- a/pkg/service/sip.go +++ b/pkg/service/sip.go @@ -407,7 +407,18 @@ func (s *SIPService) DeleteSIPDispatchRule(ctx context.Context, req *livekit.Del } func (s *SIPService) CreateSIPParticipant(ctx context.Context, req *livekit.CreateSIPParticipantRequest) (*livekit.SIPParticipantInfo, error) { - unlikelyLogger := logger.GetLogger().WithUnlikelyValues("room", req.RoomName, "sipTrunk", req.SipTrunkId, "toUser", req.SipCallTo) + unlikelyLogger := logger.GetLogger().WithUnlikelyValues( + "room", req.RoomName, + "sipTrunk", req.SipTrunkId, + "toUser", req.SipCallTo, + "participant", req.ParticipantIdentity, + ) + AppendLogFields(ctx, + "room", req.RoomName, + "participant", req.ParticipantIdentity, + "toUser", req.SipCallTo, + "trunkID", req.SipTrunkId, + ) ireq, err := s.CreateSIPParticipantRequest(ctx, req, "", "", "", "") if err != nil { unlikelyLogger.Errorw("cannot create sip participant request", err) @@ -419,9 +430,6 @@ func (s *SIPService) CreateSIPParticipant(ctx context.Context, req *livekit.Crea "toHost", ireq.Address, ) AppendLogFields(ctx, - "room", req.RoomName, - "toUser", req.SipCallTo, - "trunkID", req.SipTrunkId, "callID", ireq.SipCallId, "fromUser", ireq.Number, "toHost", ireq.Address, @@ -478,12 +486,12 @@ func (s *SIPService) CreateSIPParticipantRequest(ctx context.Context, req *livek } func (s *SIPService) TransferSIPParticipant(ctx context.Context, req *livekit.TransferSIPParticipantRequest) (*emptypb.Empty, error) { - log := logger.GetLogger().WithUnlikelyValues("room", req.RoomName, "participant", req.ParticipantIdentity) - ireq, err := s.transferSIPParticipantRequest(ctx, req) - if err != nil { - log.Errorw("cannot create transfer sip participant request", err) - return nil, err - } + log := logger.GetLogger().WithUnlikelyValues( + "room", req.RoomName, + "participant", req.ParticipantIdentity, + "transferTo", req.TransferTo, + "playDialtone", req.PlayDialtone, + ) AppendLogFields(ctx, "room", req.RoomName, "participant", req.ParticipantIdentity, @@ -491,6 +499,12 @@ func (s *SIPService) TransferSIPParticipant(ctx context.Context, req *livekit.Tr "playDialtone", req.PlayDialtone, ) + ireq, err := s.transferSIPParticipantRequest(ctx, req) + if err != nil { + log.Errorw("cannot create transfer sip participant request", err) + return nil, err + } + timeout := 30 * time.Second if deadline, ok := ctx.Deadline(); ok { timeout = time.Until(deadline)