Skip to content

Commit

Permalink
chore: lint
Browse files Browse the repository at this point in the history
  • Loading branch information
kaiserbh committed Feb 20, 2024
1 parent 06a223d commit b58486e
Showing 1 changed file with 25 additions and 24 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,34 +65,35 @@ class AnilistSeriesProvider : SeriesMetadataProvider {
val bodyValue = mapOf("query" to query)

try {
val anilistResponseMono = webClient.post()
.uri("/")
.bodyValue(bodyValue)
.exchangeToMono { response ->
val headers = response.headers().asHttpHeaders()
val rateLimitRemaining = headers.getFirst("X-RateLimit-Remaining")?.toIntOrNull()
val retryAfter = headers.getFirst("Retry-After")?.toLongOrNull()

if (response.statusCode().is2xxSuccessful) {
rateLimitRemaining?.let {
if (it < 10) {
logger.debug { "Approaching rate limit, remaining: $it" }
val anilistResponseMono =
webClient.post()
.uri("/")
.bodyValue(bodyValue)
.exchangeToMono { response ->
val headers = response.headers().asHttpHeaders()
val rateLimitRemaining = headers.getFirst("X-RateLimit-Remaining")?.toIntOrNull()
val retryAfter = headers.getFirst("Retry-After")?.toLongOrNull()

if (response.statusCode().is2xxSuccessful) {
rateLimitRemaining?.let {
if (it < 10) {
logger.debug { "Approaching rate limit, remaining: $it" }
}
}
response.bodyToMono(Root::class.java)
} else if (response.statusCode().value() == 429 && retryAfter != null) {
logger.warn { "Rate limit exceeded, retrying after $retryAfter seconds" }
Mono.delay(Duration.ofSeconds(retryAfter)).flatMap { Mono.empty() }
} else {
logger.error { "Failed to fetch AniList metadata, status code: ${response.statusCode()}" }
Mono.empty()
}
response.bodyToMono(Root::class.java)
} else if (response.statusCode().value() == 429 && retryAfter != null) {
logger.warn { "Rate limit exceeded, retrying after $retryAfter seconds" }
Mono.delay(Duration.ofSeconds(retryAfter)).flatMap { Mono.empty() }
} else {
logger.error { "Failed to fetch AniList metadata, status code: ${response.statusCode()}" }
}
.onErrorResume { e ->
logger.error { "Error fetching AniList metadata: ${e.message}" }
Mono.empty()
}
}
.onErrorResume { e ->
logger.error { "Error fetching AniList metadata: ${e.message}" }
Mono.empty()
}
.block()
.block()

anilistResponseMono?.let { it ->
val media = it.data.media
Expand Down

0 comments on commit b58486e

Please sign in to comment.