Skip to content

Commit

Permalink
skip GO-R1005
Browse files Browse the repository at this point in the history
  • Loading branch information
MindHunter86 committed Oct 19, 2024
1 parent e917ccf commit 756a7e9
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions internal/anilibria/randomizer.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ func (m *Randomizer) peekReleaseKeyChunks() (_ int, e error) {
return strconv.Atoi(futils.UnsafeString(dres))
}

func (m *Randomizer) lookupReleases() (_ []string, e error) {
func (m *Randomizer) lookupReleases() (_ []string, e error) { // skipcq: GO-R1005 needed to be kept as it is
var chunks int
if chunks, e = m.peekReleaseKeyChunks(); e != nil {
return
Expand Down Expand Up @@ -172,7 +172,8 @@ func (m *Randomizer) lookupReleases() (_ []string, e error) {
m.log.Trace().Msgf("parsing chunk %d/%d...", i, chunks)
}

if res, e = m.rclient.Get(m.rctx, m.releasesKey+strconv.Itoa(i)).Result(); e == redis.Nil { // get compressed chunk response from redis
// get compressed chunk response from redis
if res, e = m.rclient.Get(m.rctx, m.releasesKey+strconv.Itoa(i)).Result(); e == redis.Nil {
e = fmt.Errorf("given chunk number %d is not exists", i)
m.log.Warn().Msg(e.Error())
errs = append(errs, e.Error())
Expand All @@ -183,15 +184,17 @@ func (m *Randomizer) lookupReleases() (_ []string, e error) {
continue
}

// decompress chunk response from redis
var dres []byte
if dres, e = m.decompressPayload(futils.UnsafeBytes(res)); e != nil { // decompress chunk response from redis
if dres, e = m.decompressPayload(futils.UnsafeBytes(res)); e != nil {
m.log.Warn().Msg("an error occurred while decompress redis response - " + e.Error())
errs = append(errs, e.Error())
continue
}

// get json formated response from decompressed response
var releasesChunk Releases
if e = json.Unmarshal(dres, &releasesChunk); e != nil { // get json formated response from decompressed response
if e = json.Unmarshal(dres, &releasesChunk); e != nil {
m.log.Warn().Msg("an error occurred while unmarshal release chunk - " + e.Error())
errs = append(errs, e.Error())
continue
Expand Down

0 comments on commit 756a7e9

Please sign in to comment.