fix(logs): release rejections cap line length at 1KB (#997)

* fix(debug/release/rejection): cap line length at 1KB from unlimited

* flip to a call limit

* dont die on bad metainfo parse

* death is here to stay, for now.
This commit is contained in:
Kyle Sanderson 2023-07-02 04:58:40 -07:00 committed by GitHub
parent 90b5cc9351
commit 5cdf68bc77
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 10 additions and 5 deletions

View file

@ -608,9 +608,14 @@ func (r *Release) resetRejections() {
r.Rejections = []string{}
}
func (r *Release) RejectionsString() string {
func (r *Release) RejectionsString(trim bool) string {
if len(r.Rejections) > 0 {
return strings.Join(r.Rejections, ", ")
out := strings.Join(r.Rejections, ", ")
if trim && len(out) > 1024 {
out = out[:1024]
}
return out
}
return ""
}

View file

@ -328,7 +328,7 @@ func (s *service) CheckFilter(ctx context.Context, f domain.Filter, release *dom
rejections, matchedFilter := f.CheckFilter(release)
if len(rejections) > 0 {
s.log.Debug().Msgf("filter.Service.CheckFilter: (%v) for release: %v rejections: (%v)", f.Name, release.TorrentName, release.RejectionsString())
s.log.Debug().Msgf("filter.Service.CheckFilter: (%v) for release: %v rejections: (%v)", f.Name, release.TorrentName, release.RejectionsString(true))
return false, nil
}

View file

@ -153,9 +153,9 @@ func (s *service) Process(release *domain.Release) {
}
if !match {
l.Trace().Msgf("release.Process: indexer: %s, filter: %s release: %s, no match. rejections: %s", release.Indexer, release.FilterName, release.TorrentName, release.RejectionsString())
l.Trace().Msgf("release.Process: indexer: %s, filter: %s release: %s, no match. rejections: %s", release.Indexer, release.FilterName, release.TorrentName, release.RejectionsString(false))
l.Debug().Msgf("release rejected: %s", release.RejectionsString())
l.Debug().Msgf("release rejected: %s", release.RejectionsString(true))
continue
}