def deleteQueueItems()

in handlers/sf-emails-to-s3-exporter/src/main/scala/com/gu/sf_emails_to_s3_exporter/Handler.scala [166:195]

29 lines of code
7 McCabe index (conditional complexity)


  def deleteQueueItems(sfAuthDetails: SfAuthDetails, recordIds: Seq[String]): Unit = {
    val deleteAttempts = for {
      deletedRecs <- deleteQueueItemsInSf(
        sfAuthDetails,
        recordIds,
      )
    } yield deletedRecs

    deleteAttempts match {
      case Left(ex) => {
        logger.error(s"error:$ex")
      }
      case Right(success) => {
        success.foreach(response =>
          response.success match {
            case Some(true) => {
              logger.info(s"Queue Item:${response.id} deleted")
            }
            case Some(false) => {
              logger.error(s"Failed to delete Queue Item:${response}")
            }
            case None => {
              logger.error(s"Failed to delete Queue Items. Message:${response.message
                  .getOrElse("Something went wrong")}. ErrorCode:${response.errorCode.getOrElse("No Error Code provided")}")
            }
          },
        )
      }
    }
  }