private def getMessages()

in app/util/PlutoMessageConsumer.scala [40:64]

• 19 lines of code
• 5 McCabe index (conditional complexity)

  private def getMessages(waitTime: Int, maxMessages: Int): Seq[Message] =
    awsConfig.sqsClient.receiveMessage(
      new ReceiveMessageRequest(awsConfig.plutoQueueUrl)
        .withWaitTimeSeconds(waitTime)
        .withMaxNumberOfMessages(maxMessages)
    ).getMessages.asScala.toList

  private def handleMessage(msg: Message): Unit = {

    val bodyJson = Json.parse(msg.getBody)

    (bodyJson \ "Message").validate[PlutoMessage] match {
      case JsSuccess(plutoMessage, _) => {

        awsConfig.s3Client.deleteObject(awsConfig.userUploadBucket, plutoMessage.s3Key)

        stores.pluto.get(plutoMessage.s3Key) match {
          case Some(upload) => stores.pluto.delete(plutoMessage.s3Key)
          case _ =>
        }

      }
      case undefined => log.error(s"Could not extract a message body from message ${msg.getReceiptHandle()}")
    }
  }