diff --git a/internal/announce/announce.go b/internal/announce/announce.go index 38cff65..75cf693 100644 --- a/internal/announce/announce.go +++ b/internal/announce/announce.go @@ -29,7 +29,7 @@ type announceProcessor struct { func NewAnnounceProcessor(log zerolog.Logger, releaseSvc release.Service, indexer *domain.IndexerDefinition) Processor { ap := &announceProcessor{ - log: log.With().Str("module", "announce_processor").Logger(), + log: log.With().Str("module", "announce_processor").Str("indexer", indexer.Name).Str("network", indexer.IRC.Network).Logger(), releaseSvc: releaseSvc, indexer: indexer, } @@ -75,8 +75,13 @@ func (a *announceProcessor) processQueue(queue chan string) { a.log.Error().Err(err).Msg("could not get line from queue") return } + a.log.Trace().Msgf("announce: process line: %v", line) + if !a.indexer.Enabled { + a.log.Warn().Msgf("indexer %v disabled", a.indexer.Name) + } + // check should ignore match, err := indexer.ParseLine(&a.log, parseLine.Pattern, parseLine.Vars, tmpVars, line, parseLine.Ignore) @@ -131,6 +136,7 @@ func (a *announceProcessor) AddLineToQueue(channel string, line string) error { } queue <- line + a.log.Trace().Msgf("announce: queued line: %v", line) return nil