override def handleRequest()

in src/main/scala/PurgerLambda.scala [22:86]
55 lines of code
6 McCabe index (conditional complexity)

  override def handleRequest(event: SQSEvent, context: Context): Boolean = {

    // Get the front path from the SQS message
    val scalaRecords = event.getRecords.asScala.toList
    val pressJobs: List[PressJob] = scalaRecords
      .flatMap(r => {
        PressJobMessage
          .toPressJobMessage(r.getBody)
          .map(_.Message)
          .flatMap(PressJobMessage.toPressJob) match {
          case Left(error) =>
            logger.error(error.getMessage)
            None
          case Right(pressJob) => Some(pressJob)
        }
      })
    // Currently we do not expect to receive more than one front path in a message, but we want to anticipate
    // for this changing in the future
    val frontPathList: List[String] =
      pressJobs
        .filter(_.pressType != "draft") // We are not interested in draft changes
        .map(_.path)

    // Set up credentials to get the config.json from the CMS fronts S3 bucket
    val purgerConfig: Config = Config.load()
    val provider = new AWSCredentialsProviderChain(
      new ProfileCredentialsProvider("cmsFronts"),
      new STSAssumeRoleSessionCredentialsProvider.Builder(purgerConfig.faciaRole, "mobile-fastly-cache-purger").build(),
    )
    val s3Client = AmazonS3ClientBuilder.standard().withRegion(Regions.EU_WEST_1).withCredentials(provider).build()
    lazy val faciaS3Client = AmazonSdkS3Client(s3Client)
    val apiClient: ApiClient = new ApiClient("facia-tool-store", purgerConfig.faciaEnvironment, faciaS3Client)

    // Take the front path (e.g. app/front-mss) and return the list of collection IDs in that front from the config.json
    if (frontPathList.isEmpty) {
      logger.warn("No fronts to send a purge request for")
    } else {
      val allCollectionsForFront: Future[Boolean] = apiClient
        .config
        .map(configJson =>
          frontPathList
            .flatMap(frontPath =>
              configJson
                .fronts
                .get(frontPath) match {
                case Some(frontJson) => Some(frontJson.collections)
                case None =>
                  logger.error("Front does not match any front in the config.json")
                  None
              }
            )
            .flatten
            .distinct
        )
        .map(collectionKeys => {
          val containerIds = collectionKeys.map(i => s"Container/$i")
          val bpContainerIds = collectionKeys.map(i => s"BlueprintContainer/$i")
          sendPurgeRequest(containerIds ::: bpContainerIds, purgerConfig)
        })

      Await.result(allCollectionsForFront, 10.seconds) // define the right timeout

    }
    true
  }