def cancelPendingReindex()

in app/com/gu/floodgate/contentsource/ContentSourceApi.scala [169:181]

• 13 lines of code
• 6 McCabe index (conditional complexity)

  def cancelPendingReindex(id: String, environment: String) = Action.async { implicit request =>
    bulkJobActorsMap.get(environment) match {
      case Some(actor) => {
        val futureActorResponse = (actor ? DropPendingJob(id, environment)).mapTo[DropPendingJobResult]
        futureActorResponse.map {
          case CancelledPendingJob => Ok(s"""{ "CancelledJob": true, "data": { "id": $id, "env": $environment}}""")
          case FailedToCancelPendingJob =>
            Ok(s"""{ "CancelledJob": false, "data": { "id": $id, "env": $environment}}""")
        }
      }
      case None => Future.successful(Ok(s"""{ "ActorUnavailable": $environment}"""))
    }
  }