Условия обработки и свободные монады в Scala

Я играю с Кошками и Free Monads, и я написал игрушечную алгебру службы REST и "программу" под названием ensureOneProduct. К сожалению, ensureOneProduct содержит больше стандартного кода, чем мне хотелось бы. Есть ли лучший способ написать метод ensureOneProduct ниже? Или я просто избалован нотацией Haskell? Спасибо!

import cats.free.Free
import cats.free.Free.liftF
import cats.{Id, ~>}

object Algebra3 {

  type Url = String

  /**
   * The REST Service Algebra
   */
  sealed trait Service[+A]
  case class Get[T](url: Url) extends Service[Option[T]]
  case class Put[T](url: Url, rep: T) extends Service[T]
  case class Post[T](url: Url, rep: T) extends Service[Option[Url]]
  case class Delete(url: Url) extends Service[Unit]

  // A Free REST Service
  type ServiceF[A] = Free[Service, A]

  // The Product resource
  case class Product(name: String, quantity: Int)

  /**
   * Bad example of REST but I'm focusing on learning about Free Monads.
   */
  def ensureOneProduct[T](url: Url, rep: T): ServiceF[Url] = {
    for {
    // Attempt to retrieve the product...
      res <- get[Product](url)
      _ <- if (res.isDefined)
        for {
        // The product existed so delete it.
          _ <- delete(url)
          // Now create the product
          _ <- put(url, rep)
        } yield ()
      else {
        // The product did not exist so create it.
        put(url, rep)
      }
    } yield url
  }

  def get[T](url: Url): ServiceF[Option[T]] = liftF[Service, Option[T]](Get[T](url))
  def put[T](url: Url, rep: T): ServiceF[T] = liftF[Service, T](Put[T](url, rep))
  def post[T](url: Url, value: T): ServiceF[Option[Url]] = liftF[Service, Option[Url]](Post[T](url, value))
  def delete(key: String): ServiceF[Unit] = liftF(Delete(key))

  def defaultCompiler: Service ~> Id =
    new (Service ~> Id) {
      def apply[A](fa: Service[A]): Id[A] =
        fa match {
          case Get(key) =>
            println(s"GET($key)")
            Some(new Product("Hat", 3))
          case Put(key, rep) =>
            println(s"PUT($key, $rep)")
            rep
          case Post(url, rep) =>
            println(s"POST($url)")
            Some(url)
          case Delete(key) =>
            println(s"DELETE($key)")
            ()
        }
    }

  def main(args: Array[String]) = {
    val url = "https://www.example.com/api/v1/hats/1024"
    val product = new Product("Hat", 1)

    println(ensureOneProduct(url, product).foldMap(defaultCompiler))
  }
}

Этот код печатает:

GET(https://www.example.com/api/v1/hats/1024)
DELETE(https://www.example.com/api/v1/hats/1024)
PUT(https://www.example.com/api/v1/hats/1024, Product(Hat,1))
https://www.example.com/api/v1/hats/1024

Это было интересно и немного беспокоило то, что когда я забыл заключить вложенные вызовы delete и put в выражение for, оно скомпилировало, но не выполнило операцию delete. Понятно, почему вызов delete был опущен, но я бы предпочел получить какую-то обратную связь во время компиляции.


person Tim Stewart    schedule 11.05.2017    source источник


Ответы (1)


Вы можете отказаться от внутреннего для понимания, используя оператор followed by (>>):

for {
  res <- get[Product](url)               // Attempt to retrieve the product...
  _   <- if (res.isDefined)
           delete(url) >> put(url, rep)  // It exists: delete & recreate it
         else
           put(url, rep)                 // It does not exist: create it
} yield url
person OlivierBlanvillain    schedule 11.05.2017
comment
Все, что мне нужно было сделать, это добавить: importcats.implicits._ и это отлично сработало. - person Tim Stewart; 11.05.2017