def checkMostUrgentOf()

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
    }