idanoo/autobrr
1
0
Fork 0
mirror of https://github.com/idanoo/autobrr synced 2025-07-23 08:49:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: use continue instead of break to not exit loop (#53)

Browse source
This commit is contained in:
Ludvig Lundgren 2021-12-26 18:28:02 +01:00 • committed by GitHub
parent b75c40f6a4
commit e496027798
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
internal/announce/announce.go
View file

@ -105,14 +105,14 @@ func (a *announceProcessor) processQueue(queue chan string) {
newRelease, err := domain.NewRelease(a.indexer.Identifier, "") newRelease, err := domain.NewRelease(a.indexer.Identifier, "")
if err != nil { if err != nil {
log.Error().Err(err).Msg("could not create new release") log.Error().Err(err).Msg("could not create new release")
break continue
} }
// on lines matched // on lines matched
err = a.onLinesMatched(a.indexer, tmpVars, newRelease) err = a.onLinesMatched(a.indexer, tmpVars, newRelease)
if err != nil { if err != nil {
log.Debug().Msgf("error match line: %v", "") log.Debug().Msgf("error match line: %v", "")
break continue
} }
// send to filter service to take care of the rest // send to filter service to take care of the rest
@ -121,13 +121,13 @@ func (a *announceProcessor) processQueue(queue chan string) {
filterOK, foundFilter, err := a.filterSvc.FindAndCheckFilters(newRelease) filterOK, foundFilter, err := a.filterSvc.FindAndCheckFilters(newRelease)
if err != nil { if err != nil {
log.Error().Err(err).Msg("could not find filter") log.Error().Err(err).Msg("could not find filter")
break continue
} }
// no foundFilter found, lets return // no foundFilter found, lets return
if !filterOK || foundFilter == nil { if !filterOK || foundFilter == nil {
log.Trace().Msg("no matching filter found") log.Trace().Msg("no matching filter found")
break continue
// TODO check in config for "Save all releases" // TODO check in config for "Save all releases"
// Save as rejected // Save as rejected
@ -149,7 +149,7 @@ func (a *announceProcessor) processQueue(queue chan string) {
err = a.releaseSvc.Store(context.Background(), newRelease) err = a.releaseSvc.Store(context.Background(), newRelease)
if err != nil { if err != nil {
log.Error().Err(err).Msgf("error writing release to database: %+v", newRelease) log.Error().Err(err).Msgf("error writing release to database: %+v", newRelease)
break continue
} }
log.Info().Msgf("Matched '%v' (%v) for %v", newRelease.TorrentName, newRelease.Filter.Name, newRelease.Indexer) log.Info().Msgf("Matched '%v' (%v) for %v", newRelease.TorrentName, newRelease.Filter.Name, newRelease.Indexer)