added delete call

Author: wi101

src/main/scala/net/degoes/06-application/db/Persistence.scala

@@ -17,7 +17,7 @@ object Persistence {
   trait Service[R] {
     def get(id: Int): TaskR[R, User]
     def create(user: User): TaskR[R, User]
-    def delete(id: Int): TaskR[R, Boolean]
+    def delete(id: Int): TaskR[R, Unit]
   }
 
   /**
@@ -46,12 +46,12 @@ object Persistence {
           .transact(tnx)
           .foldM(err => Task.fail(err), _ => Task.succeed(user))
 
-      def delete(id: Int): Task[Boolean] =
+      def delete(id: Int): Task[Unit] =
         SQL
           .delete(id)
           .run
           .transact(tnx)
-          .fold(_ => false, _ => true)
+        .foldM(err => Task.fail(err), _ => Task.succeed(()))
     }
 
     object SQL {

src/main/scala/net/degoes/06-application/db/package.scala

@@ -8,5 +8,5 @@ package object db extends Persistence.Service[Persistence] {
 
   def get(id: Int): TaskR[Persistence, User] = ZIO.accessM(_.userPersistence.get(id))
   def create(user: User): TaskR[Persistence, User] = ZIO.accessM(_.userPersistence.create(user))
-  def delete(id: Int): TaskR[Persistence, Boolean] = ZIO.accessM(_.userPersistence.delete(id))
+  def delete(id: Int): TaskR[Persistence, Unit] = ZIO.accessM(_.userPersistence.delete(id))
 }

src/main/scala/net/degoes/06-application/http/Api.scala

@@ -3,8 +3,8 @@ package http
 import data.User
 import db._
 import db.Persistence
-import io.circe.{Decoder, Encoder}
-import org.http4s.{EntityDecoder, EntityEncoder, HttpRoutes}
+import io.circe.{ Decoder, Encoder }
+import org.http4s.{ EntityDecoder, EntityEncoder, HttpRoutes }
 import org.http4s.dsl.Http4sDsl
 import scalaz.zio._
 import org.http4s.circe._
@@ -16,20 +16,21 @@ final case class Api[R <: Persistence](rootUri: String) {
   type UserTask[A] = TaskR[R, A]
 
   implicit def circeJsonDecoder[A](implicit decoder: Decoder[A]): EntityDecoder[UserTask, A] = jsonOf[UserTask, A]
-  implicit def circeJsonEncoder[A](implicit decoder: Encoder[A]): EntityEncoder[UserTask, A] = jsonEncoderOf[UserTask, A]
+  implicit def circeJsonEncoder[A](implicit decoder: Encoder[A]): EntityEncoder[UserTask, A] =
+    jsonEncoderOf[UserTask, A]
 
   val dsl: Http4sDsl[UserTask] = Http4sDsl[UserTask]
   import dsl._
 
-  def route: HttpRoutes[UserTask] = {
-
+  def route: HttpRoutes[UserTask] =
     HttpRoutes.of[UserTask] {
-      case GET -> Root / IntVar(id) => Ok(get(id))
+      case GET -> Root / IntVar(id) => get(id).foldM(_ => NotFound(), Ok(_))
       case request @ POST -> Root =>
         request.decode[User] { user =>
           Created(create(user))
         }
+      case DELETE -> Root / IntVar(id) =>
+        delete(id).foldM(_ => NotFound(), Ok(_))
     }
-  }
 
 }