in associated-press/app/services/AssociatedPressService.scala [64:90]
def handleResponse(response: StandaloneWSResponse): Unit = {
if (response.status == 200) {
FeedResponse
.parse(response.body)
.fold(resendRequest())(response => {
logger
.info(s"Received response with ${response.items.length} items")
imageUploaderServiceActor ! response.items
writeNextPageToDynamoDB(response.nextPage) match {
case Success(_) =>
logger.debug(
s"Successfully wrote next page to table: ${response.nextPage}"
)
case Failure(_) =>
logger.error(
s"Failed to write next page to table: ${response.nextPage}"
)
}
self ! response.nextPage
})
} else {
logger.error(
s"Received ${response.status} response: ${response.body}"
)
resendRequest()
}
}