in src/main/scala/ophan/google/indexing/observatory/AvailabilityUpdaterService.scala [44:53]
def checkMostUrgentOf(existingRecords: Set[AvailabilityRecord])(using site: Site): Future[Set[AvailabilityRecord]] =
checkAndUpdate(mostUrgent(existingRecords))
private def checkAndUpdate(records: Seq[AvailabilityRecord])(using site: Site): Future[Set[AvailabilityRecord]] = for {
updatedAvailabilityRecords <- Future.traverse(records) { availabilityRecord =>
for {
checkReport <- googleSearchService.contentAvailabilityInGoogleIndex(availabilityRecord.ultimateUri, site)
updatedAvailabilityRecord <- dataStore.update(availabilityRecord.uri, checkReport)
} yield updatedAvailabilityRecord
}