stream.place
Live video on the AT Protocol
chore: remove some log.warn calls
+4
-4
pkg/director/stream_session.go
+4
-4
pkg/director/stream_session.go
···
473
473
func (ss *StreamSession) UpdateLivestream(ctx context.Context, repoDID string) {
474
474
select {
475
475
case ss.livestreamUpdateChan <- struct{}{}:
476
-
log.Warn(ctx, "livestream update signal sent")
476
+
log.Debug(ctx, "livestream update signal sent")
477
477
default:
478
-
log.Warn(ctx, "livestream update channel full, signal already pending")
478
+
log.Debug(ctx, "livestream update channel full, signal already pending")
479
479
// Channel full, signal already pending
480
480
}
481
481
}
···
489
489
return nil
490
490
case <-ss.livestreamUpdateChan:
491
491
if time.Since(ss.lastLivestreamTime) < livestreamUpdateInterval {
492
-
log.Warn(ctx, "not updating livestream, last livestream was less than 30 seconds ago")
492
+
log.Debug(ctx, "not updating livestream, last livestream was less than 30 seconds ago")
493
493
continue
494
494
}
495
495
if err := ss.doUpdateLivestream(ctx, repoDID); err != nil {
···
547
547
return fmt.Errorf("could not update livestream record: %w", err)
548
548
}
549
549
550
-
log.Warn(ctx, "updated livestream record", "uri", lastLivestream.URI)
550
+
log.Debug(ctx, "updated livestream record", "uri", lastLivestream.URI)
551
551
ss.lastLivestreamTime = time.Now()
552
552
553
553
return nil