(envelope Envelope, err error)
| 1330 | } |
| 1331 | |
| 1332 | func (r *Router) warnThreadParticipantFallback(envelope Envelope, err error) { |
| 1333 | if r == nil || r.logger == nil || err == nil { |
| 1334 | return |
| 1335 | } |
| 1336 | r.logger.Warn( |
| 1337 | "network.router.thread_participants_lookup_failed", |
| 1338 | "error", err, |
| 1339 | "workspace_id", envelope.WorkspaceID, |
| 1340 | "channel", envelope.Channel, |
| 1341 | "thread_id", normalizeOptionalIdentifier(envelope.ThreadID), |
| 1342 | "fallback", "empty_thread_delivery", |
| 1343 | ) |
| 1344 | } |
| 1345 | |
| 1346 | func (r *Router) warnChannelPolicyFallback(envelope Envelope, err error) { |
| 1347 | if r == nil || r.logger == nil || err == nil { |
no test coverage detected