Refactor Jikan API client: improve context management in GetAnimeProducers and enhance logging for pagination

1 files changed, 4 insertions, 3 deletions

diff --git a/utils/api/jikan/jikan.go b/utils/api/jikan/jikan.go
index 920f6dc..87c7cfd 100644
--- a/utils/api/jikan/jikan.go
+++ b/utils/api/jikan/jikan.go
@@ -251,7 +251,6 @@ func GetAnimeByGenre(genreID int, page int, limit int) (*types.JikanAnimeSearchR
 
 func GetAnimeProducers() (*types.JikanProducersResponse, error) {
 	url := fmt.Sprintf("%s/producers", jikanAPIBaseURL)
-	ctx, cancel := context.WithTimeout(context.Background(), contextTimeout)
 	page := 1
 	hasNextPage := true
 
@@ -260,12 +259,12 @@ func GetAnimeProducers() (*types.JikanProducersResponse, error) {
 		Pagination: types.JikanGenericPaginationEntity{},
 	}
 
-	defer cancel()
-
 	for hasNextPage {
 		pageURL := fmt.Sprintf("%s?page=%d", url, page)
 
+		ctx, cancel := context.WithTimeout(context.Background(), contextTimeout)
 		bytes, err := clientInstance.makeRequest(ctx, pageURL)
+		cancel()
 		if err != nil {
 			logger.Errorf("JikanClient", "GetAnimeProducers failed on page %d: %v", page, err)
 			return nil, errors.New("failed to fetch anime producers from Jikan API")
@@ -281,6 +280,8 @@ func GetAnimeProducers() (*types.JikanProducersResponse, error) {
 			response.Pagination = pageResponse.Pagination
 		}
 
+		logger.Debugf("JikanClient", "Fetched page (%d/%d) - %d producers", page, response.Pagination.LastVisiblePage, len(pageResponse.Data))
+
 		response.Data = append(response.Data, pageResponse.Data...)
 		hasNextPage = pageResponse.Pagination.HasNextPage
 		page++