def processNewUris()

in src/main/scala/ophan/google/indexing/observatory/AvailabilityUpdaterService.scala [36:42]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  def processNewUris(sitemapDownload: SitemapDownload, excludingAlreadyExistingRecords: Set[AvailabilityRecord]): Future[_] = {
    val urisNotSeenBefore = sitemapDownload.allUris -- excludingAlreadyExistingRecords.map(_.uri)
    for {
      redirectResolutionsForUrisNotSeenBefore <- Future.traverse(urisNotSeenBefore)(redirectResolver.resolve)
      _ <- dataStore.storeNewRecordsFor(sitemapDownload, redirectResolutionsForUrisNotSeenBefore)
    } yield ()
  }