Scalaz FutureValidation retry

future_validation_retry.scala

import com.bfil.api.{FutureValidation, TypedFutureValidation}

case class CustomError(msg: String)

object CustomResult extends TypedFutureValidation[CustomError]

def retry[T](attempts: Int, f: => FutureValidation[CustomError, T]): FutureValidation[CustomError, T] = {

  def attempt(n: Int): FutureValidation[CustomError, T] = n match {
    case n if n > 0 => f.map {
      identity
    }.leftFlatMap { _ => attempt(n - 1) }
    case e => CustomResult.failure(CustomError(s"All retry $attempts attempts failed"))
  }
  
  attempt(attempts)

}