Skip to content

Commit af261c5

Browse files
committed
messagetracking/sendMessageMetrics: use local log
Signed-off-by: Sumner Evans <[email protected]>
1 parent 76e8eb2 commit af261c5

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

messagetracking.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -184,15 +184,16 @@ func (portal *Portal) sendMessageMetrics(ctx context.Context, evt *event.Event,
184184
if evt.Type == event.EventRedaction {
185185
log = log.With().Stringer("redacts", evt.Redacts).Logger()
186186
}
187+
ctx = log.WithContext(ctx)
187188

188189
origEvtID := evt.ID
189190
if retryMeta := evt.Content.AsMessage().MessageSendRetry; retryMeta != nil {
190191
origEvtID = retryMeta.OriginalEventID
191192
}
192193
if err != nil {
193-
logEvt := portal.log.Error()
194+
logEvt := log.Error()
194195
if part == "Ignoring" {
195-
logEvt = portal.log.Debug()
196+
logEvt = log.Debug()
196197
}
197198
logEvt.Err(err).Msg("Sending message metrics for event")
198199
reason, statusCode, isCertain, sendNotice, _ := errorToStatusReason(err)
@@ -203,7 +204,7 @@ func (portal *Portal) sendMessageMetrics(ctx context.Context, evt *event.Event,
203204
}
204205
portal.sendStatusEvent(ctx, origEvtID, evt.ID, err, nil)
205206
} else {
206-
portal.log.Debug().Msg("Sending metrics for successfully handled Matrix event")
207+
log.Debug().Msg("Sending metrics for successfully handled Matrix event")
207208
portal.sendDeliveryReceipt(ctx, evt.ID)
208209
portal.bridge.SendMessageSuccessCheckpoint(evt, status.MsgStepRemote, ms.getRetryNum())
209210
var deliveredTo *[]id.UserID
@@ -218,7 +219,7 @@ func (portal *Portal) sendMessageMetrics(ctx context.Context, evt *event.Event,
218219
}
219220
}
220221
if ms != nil {
221-
portal.log.Debug().Object("timings", ms.timings).Msg("Timings for event")
222+
log.Debug().Object("timings", ms.timings).Msg("Timings for event")
222223
}
223224
}
224225

0 commit comments

Comments
 (0)