diff --git a/integrations/jikan/relations.go b/integrations/jikan/relations.go index 1644ca7..f07832f 100644 --- a/integrations/jikan/relations.go +++ b/integrations/jikan/relations.go @@ -124,7 +124,6 @@ func (c *Client) GetFullRelations(ctx context.Context, id int) ([]RelationEntry, results := make(chan fetchResult, len(allowedEntries)) for i, entry := range allowedEntries { - i, entry := i, entry g.Go(func() error { anime, err := c.GetAnimeByID(gCtx, entry.ID) if err != nil { diff --git a/integrations/jikan/types.go b/integrations/jikan/types.go index 206632b..c624e3e 100644 --- a/integrations/jikan/types.go +++ b/integrations/jikan/types.go @@ -174,10 +174,7 @@ func formatNumber(n int) string { s := fmt.Sprintf("%d", n) var res []string for i := len(s); i > 0; i -= 3 { - start := i - 3 - if start < 0 { - start = 0 - } + start := max(i-3, 0) res = append([]string{s[start:i]}, res...) } return strings.Join(res, " ") diff --git a/internal/worker/relations.go b/internal/worker/relations.go index 15ab8c2..6746361 100644 --- a/internal/worker/relations.go +++ b/internal/worker/relations.go @@ -155,14 +155,12 @@ func (w *Worker) syncRelations(ctx context.Context) { jobs := make(chan database.GetAnimeNeedingRelationSyncRow, len(animes)) var wg sync.WaitGroup - for i := 0; i < workerCount; i++ { - wg.Add(1) - go func() { - defer wg.Done() + for range workerCount { + wg.Go(func() { for a := range jobs { w.syncSingleAnime(ctx, a.ID) } - }() + }) } for _, a := range animes {