private def sendToKinesisStream()

in app/story_packages/updates/Reindex.scala [110:131]

• 22 lines of code
• 4 McCabe index (conditional complexity)

  private def sendToKinesisStream(storyPackage: StoryPackage, job: RunningJob): Future[Unit] = {
    (for {
      packageId <- storyPackage.id
      displayName <- storyPackage.name
    } yield {
      Logger.info(s"Getting stored package with id $packageId from S3")
      frontsApi.amazonClient.collection(packageId).map {
        case Some(collectionJson) =>
          Logger.info(s"Sending reindex message on kinesis stream for package ${storyPackage.id}")
          if (storyPackage.deleted.getOrElse(false)) {
            kinesisEventSender.putReindexDelete(packageId, displayName, collectionJson, job.isHidden)
          } else {
            kinesisEventSender.putReindexUpdate(packageId, displayName, collectionJson, job.isHidden)
          }
        case None =>
          Logger.info(s"Ignore reindex of empty story package $packageId")
      }
    }).getOrElse({
      Logger.error(s"Story package $storyPackage doesn't have id or name")
      Future.successful(None)
    })
  }