Simpler default Endpoint#implement (zio#2811)

987Nabil · Jun 7, 2024 · a490218 · a490218
1 parent a5fdfc1
commit a490218
Show file tree

Hide file tree

Showing 20 changed files with 145 additions and 128 deletions.
diff --git a/docs/reference/endpoint.md b/docs/reference/endpoint.md
@@ -34,7 +34,7 @@ In the above example, we defined an endpoint on the path `/books` that accepts a
 After defining the endpoint, we are ready to implement it. We can implement it using the `Endpoint#implement` method, which takes a proper handler function that will be called when the endpoint is invoked and returns a `Route`:
 
 ```scala
-val booksRoute = endpoint.implement(handler((query: String) => BookRepo.find(query)))
+val booksRoute = endpoint.implement(query => BookRepo.find(query))
 ```
 
 We can also generate OpenAPI documentation for our endpoint using the `OpenAPIGen.fromEndpoints` constructor:
@@ -261,13 +261,13 @@ object EndpointWithMultipleOutputTypes extends ZIOAppDefault {
       .out[Quiz]
 
   def run = Server.serve(
-    endpoint.implement(handler {
+    endpoint.implement(_ =>
       ZIO.randomWith(_.nextBoolean)
         .map(r =>
           if (r) Right(Course("Introduction to Programming", 49.99))
           else Left(Quiz("What is the boiling point of water in Celsius?", 2)),
         )
-    })
+    )
     .toRoutes).provide(Server.default, Scope.default)
 }
 ```
@@ -417,7 +417,7 @@ case class Book(
 The `OpenAPIGen.fromEndpoints` constructor generates OpenAPI documentation from the endpoints. By having the OpenAPI documentation, we can easily generate Swagger UI routes using the `SwaggerUI.routes` constructor:
 
 ```scala
-val booksRoute = endpoint.implement(handler((query: String) => BookRepo.find(query)))
+val booksRoute = endpoint.implement(query => BookRepo.find(query))
 val openAPI    = OpenAPIGen.fromEndpoints(title = "Library API", version = "1.0", endpoint)
 val swaggerRoutes = SwaggerUI.routes("docs" / "openapi", openAPI)
 val routes     = Routes(booksRoute) ++ swaggerRoutes

diff --git a/sbt-zio-http-grpc-tests/src/test/scala/zio/http/grpc/ZIOHttpGRPCGenSpec.scala b/sbt-zio-http-grpc-tests/src/test/scala/zio/http/grpc/ZIOHttpGRPCGenSpec.scala
@@ -13,11 +13,7 @@ object ZIOHttpGRPCGenSpec extends ZIOSpecDefault {
         assertTrue(true)
       },
       test("plugin generates Endpoint") {
-        val impl = V1.test.implement {
-          Handler.fromFunction[TestMsg] { msg =>
-            msg
-          }
-        }
+        val impl = V1.test.implementPurely { msg => msg }
         assertTrue(true)
       },
     )

diff --git a/zio-http-benchmarks/src/main/scala-2.13/zio/http/benchmarks/EndpointBenchmark.scala b/zio-http-benchmarks/src/main/scala-2.13/zio/http/benchmarks/EndpointBenchmark.scala
@@ -95,7 +95,7 @@ class EndpointBenchmark {
       .out[ExampleData]
 
   val handledUsersPosts =
-    usersPosts.implement {
+    usersPosts.implementHandler {
       Handler.fromFunction { case (userId, postId, limit) =>
         ExampleData(userId, postId, limit)
       }
@@ -218,7 +218,7 @@ class EndpointBenchmark {
       ) / "seventh" / int("id5"),
   )
     .out[Unit]
-    .implement(Handler.unit)
+    .implementHandler(Handler.unit)
     .toRoutes
 
   // Collect DSL
@@ -333,20 +333,20 @@ class EndpointBenchmark {
 
   // API DSL
 
-  val broadUsers                       = Endpoint(Method.GET / "users").out[Unit].implement(Handler.unit)
+  val broadUsers                       = Endpoint(Method.GET / "users").out[Unit].implementHandler(Handler.unit)
   val broadUsersId                     =
-    Endpoint(Method.GET / "users" / int("userId")).out[Unit].implement(Handler.unit)
+    Endpoint(Method.GET / "users" / int("userId")).out[Unit].implementHandler(Handler.unit)
   val boardUsersPosts                  =
     Endpoint(Method.GET / "users" / int("userId") / "posts")
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardUsersPostsId                =
     Endpoint(
       Method.GET /
         "users" / int("userId") / "posts" / int("postId"),
     )
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardUsersPostsComments          =
     Endpoint(
       Method.GET /
@@ -355,7 +355,7 @@ class EndpointBenchmark {
         ) / "comments",
     )
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardUsersPostsCommentsId        =
     Endpoint(
       Method.GET /
@@ -364,14 +364,14 @@ class EndpointBenchmark {
         ) / "comments" / int("commentId"),
     )
       .out[Unit]
-      .implement(Handler.unit)
-  val broadPosts                       = Endpoint(Method.GET / "posts").out[Unit].implement(Handler.unit)
+      .implementHandler(Handler.unit)
+  val broadPosts                       = Endpoint(Method.GET / "posts").out[Unit].implementHandler(Handler.unit)
   val broadPostsId                     =
-    Endpoint(Method.GET / "posts" / int("postId")).out[Unit].implement(Handler.unit)
+    Endpoint(Method.GET / "posts" / int("postId")).out[Unit].implementHandler(Handler.unit)
   val boardPostsComments               =
     Endpoint(Method.GET / "posts" / int("postId") / "comments")
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardPostsCommentsId             =
     Endpoint(
       Method.GET /
@@ -380,14 +380,14 @@ class EndpointBenchmark {
         ),
     )
       .out[Unit]
-      .implement(Handler.unit)
-  val broadComments                    = Endpoint(Method.GET / "comments").out[Unit].implement(Handler.unit)
+      .implementHandler(Handler.unit)
+  val broadComments                    = Endpoint(Method.GET / "comments").out[Unit].implementHandler(Handler.unit)
   val broadCommentsId                  =
-    Endpoint(Method.GET / "comments" / int("commentId")).out[Unit].implement(Handler.unit)
+    Endpoint(Method.GET / "comments" / int("commentId")).out[Unit].implementHandler(Handler.unit)
   val broadUsersComments               =
     Endpoint(Method.GET / "users" / int("userId") / "comments")
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val broadUsersCommentsId             =
     Endpoint(
       Method.GET /
@@ -396,7 +396,7 @@ class EndpointBenchmark {
         ),
     )
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardUsersPostsCommentsReplies   =
     Endpoint(
       Method.GET /
@@ -406,7 +406,7 @@ class EndpointBenchmark {
         "replies",
     )
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
   val boardUsersPostsCommentsRepliesId =
     Endpoint(
       Method.GET /
@@ -415,7 +415,7 @@ class EndpointBenchmark {
         ) / "comments" / int("commentId") / "replies" / int("replyId"),
     )
       .out[Unit]
-      .implement(Handler.unit)
+      .implementHandler(Handler.unit)
 
   val broadApiApp =
     Routes(

diff --git a/zio-http-example/src/main/scala/example/EndpointExamples.scala b/zio-http-example/src/main/scala/example/EndpointExamples.scala
@@ -19,22 +19,16 @@ object EndpointExamples extends ZIOAppDefault {
     Endpoint(Method.GET / "users" / int("userId")).out[Int] @@ auth
 
   val getUserRoute =
-    getUser.implement {
-      Handler.fromFunction[Int] { id =>
-        id
-      }
-    }
+    getUser.implement { id => ZIO.succeed(id) }
 
   val getUserPosts =
     Endpoint(Method.GET / "users" / int("userId") / "posts" / int("postId"))
       .query(query("name"))
       .out[List[String]] @@ auth
 
   val getUserPostsRoute =
-    getUserPosts.implement[Any] {
-      Handler.fromFunctionZIO[(Int, Int, String)] { case (id1: Int, id2: Int, query: String) =>
-        ZIO.succeed(List(s"API2 RESULT parsed: users/$id1/posts/$id2?name=$query"))
-      }
+    getUserPosts.implement { case (id1: Int, id2: Int, query: String) =>
+      ZIO.succeed(List(s"API2 RESULT parsed: users/$id1/posts/$id2?name=$query"))
     }
 
   val openAPI = OpenAPIGen.fromEndpoints(title = "Endpoint Example", version = "1.0", getUser, getUserPosts)

diff --git a/zio-http-example/src/main/scala/example/ServerSentEventEndpoint.scala b/zio-http-example/src/main/scala/example/ServerSentEventEndpoint.scala
@@ -21,7 +21,7 @@ object ServerSentEventEndpoint extends ZIOAppDefault {
   val sseEndpoint: Endpoint[Unit, Unit, ZNothing, ZStream[Any, Nothing, ServerSentEvent], None] =
     Endpoint(Method.GET / "sse").outStream[ServerSentEvent]
 
-  val sseRoute = sseEndpoint.implement(Handler.succeed(stream))
+  val sseRoute = sseEndpoint.implementHandler(Handler.succeed(stream))
 
   val routes: Routes[Any, Response] = sseRoute.toRoutes
 

diff --git a/zio-http-example/src/main/scala/example/endpoint/BooksEndpointExample.scala b/zio-http-example/src/main/scala/example/endpoint/BooksEndpointExample.scala
@@ -44,7 +44,7 @@ object BooksEndpointExample extends ZIOAppDefault {
       "Endpoint to query books based on a search query",
     )
 
-  val booksRoute    = endpoint.implement(handler((query: String) => BookRepo.find(query)))
+  val booksRoute    = endpoint.implementHandler(handler((query: String) => BookRepo.find(query)))
   val openAPI       = OpenAPIGen.fromEndpoints(title = "Library API", version = "1.0", endpoint)
   val swaggerRoutes = SwaggerUI.routes("docs" / "openapi", openAPI)
   val routes        = Routes(booksRoute) ++ swaggerRoutes

diff --git a/zio-http-example/src/main/scala/example/endpoint/CliExamples.scala b/zio-http-example/src/main/scala/example/endpoint/CliExamples.scala
@@ -81,21 +81,21 @@ object TestCliApp extends zio.cli.ZIOCliDefault with TestCliEndpoints {
 
 object TestCliServer extends zio.ZIOAppDefault with TestCliEndpoints {
   val getUserRoute =
-    getUser.implement {
+    getUser.implementHandler {
       Handler.fromFunctionZIO { case (id, _) =>
         ZIO.succeed(User(id, "Juanito", Some("[email protected]"))).debug("Hello")
       }
     }
 
   val getUserPostsRoute =
-    getUserPosts.implement {
+    getUserPosts.implementHandler {
       Handler.fromFunction { case (userId, postId, name) =>
         List(Post(userId, postId, name))
       }
     }
 
   val createUserRoute =
-    createUser.implement {
+    createUser.implementHandler {
       Handler.fromFunction { user =>
         user.name
       }

diff --git a/zio-http-example/src/main/scala/example/endpoint/EndpointWithMultipleErrorsUsingEither.scala b/zio-http-example/src/main/scala/example/endpoint/EndpointWithMultipleErrorsUsingEither.scala
@@ -56,7 +56,7 @@ object EndpointWithMultipleErrorsUsingEither extends ZIOAppDefault {
         ZIO.fail(Left(AuthenticationError("User is not authenticated", 123)))
     }
 
-  val routes = endpoint.implement(getBookHandler).toRoutes @@ Middleware.debug
+  val routes = endpoint.implementHandler(getBookHandler).toRoutes @@ Middleware.debug
 
   def run = Server.serve(routes).provide(Server.default)
 }
diff --git a/zio-http-example/src/main/scala/example/endpoint/EndpointWithMultipleUnifiedErrors.scala b/zio-http-example/src/main/scala/example/endpoint/EndpointWithMultipleUnifiedErrors.scala
@@ -62,7 +62,7 @@ object EndpointWithMultipleUnifiedErrors extends ZIOAppDefault {
         ZIO.fail(AuthenticationError("User is not authenticated", 123))
     }
 
-  val routes = endpoint.implement(getBookHandler).toRoutes @@ Middleware.debug
+  val routes = endpoint.implementHandler(getBookHandler).toRoutes @@ Middleware.debug
 
   def run = Server.serve(routes).provide(Server.default)
 }
diff --git a/zio-http-example/src/main/scala/example/endpoint/style/DeclarativeProgrammingExample.scala b/zio-http-example/src/main/scala/example/endpoint/style/DeclarativeProgrammingExample.scala
@@ -40,7 +40,7 @@ object DeclarativeProgrammingExample extends ZIOAppDefault {
   val getBookHandler: Handler[Any, NotFoundError, String, Book] =
     handler(BookRepo.find(_))
 
-  val routes = endpoint.implement(getBookHandler).toRoutes @@ Middleware.debug
+  val routes = endpoint.implementHandler(getBookHandler).toRoutes @@ Middleware.debug
 
   def run = Server.serve(routes).provide(Server.default)
 }
diff --git a/zio-http/jvm/src/test/scala/zio/http/endpoint/AuthSpec.scala b/zio-http/jvm/src/test/scala/zio/http/endpoint/AuthSpec.scala
@@ -26,7 +26,9 @@ object AuthSpec extends ZIOSpecDefault {
       test("Auth with context") {
         val endpoint = Endpoint(Method.GET / "test").out[String](MediaType.text.`plain`)
         val routes   =
-          Routes(endpoint.implement(handler((_: Unit) => ZIO.serviceWith[AuthContext](_.value)))) @@ basicAuthContext
+          Routes(
+            endpoint.implementHandler(handler((_: Unit) => ZIO.serviceWith[AuthContext](_.value))),
+          ) @@ basicAuthContext
         val response = routes.run(
           Request(
             method = Method.GET,

diff --git a/zio-http/jvm/src/test/scala/zio/http/endpoint/BadRequestSpec.scala b/zio-http/jvm/src/test/scala/zio/http/endpoint/BadRequestSpec.scala
@@ -17,7 +17,7 @@ object BadRequestSpec extends ZIOSpecDefault {
         val endpoint     = Endpoint(Method.GET / "test")
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2").addHeader(Header.Accept(MediaType.text.`html`))
         val expectedBody =
@@ -38,7 +38,7 @@ object BadRequestSpec extends ZIOSpecDefault {
         val endpoint     = Endpoint(Method.GET / "test")
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2")
             .addHeader(Header.Accept(MediaType.application.json))
@@ -53,7 +53,7 @@ object BadRequestSpec extends ZIOSpecDefault {
         val endpoint     = Endpoint(Method.GET / "test")
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2")
             .addHeader(Header.Accept(MediaType.application.`atf`))
@@ -69,7 +69,7 @@ object BadRequestSpec extends ZIOSpecDefault {
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
           .emptyErrorResponse
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2")
             .addHeader(Header.Accept(MediaType.application.`atf`))
@@ -83,7 +83,7 @@ object BadRequestSpec extends ZIOSpecDefault {
         val endpoint     = Endpoint(Method.GET / "test")
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2")
             .addHeader(Header.Accept(MediaType.application.json))
@@ -99,7 +99,7 @@ object BadRequestSpec extends ZIOSpecDefault {
           .query(QueryCodec.queryInt("age"))
           .out[Unit]
           .outCodecError(default)
-        val route        = endpoint.implement(handler((_: Int) => ()))
+        val route        = endpoint.implementHandler(handler((_: Int) => ()))
         val request      =
           Request(method = Method.GET, url = url"/test?age=1&age=2")
             .addHeader(Header.Accept(MediaType.application.json))

diff --git a/zio-http/jvm/src/test/scala/zio/http/endpoint/CustomErrorSpec.scala b/zio-http/jvm/src/test/scala/zio/http/endpoint/CustomErrorSpec.scala
@@ -39,7 +39,7 @@ object CustomErrorSpec extends ZIOHttpSpec {
           Endpoint(GET / "users" / int("userId"))
             .out[String]
             .outError[String](Status.Custom(customCode))
-            .implement {
+            .implementHandler {
               Handler.fromFunctionZIO { userId =>
                 ZIO.fail(s"path(users, $userId)")
               }
@@ -66,7 +66,7 @@ object CustomErrorSpec extends ZIOHttpSpec {
               HttpCodec.error[TestError.UnexpectedError](Status.InternalServerError),
               HttpCodec.error[TestError.InvalidUser](Status.NotFound),
             )
-            .implement {
+            .implementHandler {
               Handler.fromFunctionZIO { userId =>
                 if (userId == myUserId) ZIO.fail(TestError.InvalidUser(userId))
                 else ZIO.fail(TestError.UnexpectedError("something went wrong"))
@@ -100,7 +100,7 @@ object CustomErrorSpec extends ZIOHttpSpec {
             .in[User](Doc.p("User schema with id"))
             .out[String]
             .emptyErrorResponse
-            .implement {
+            .implementHandler {
               Handler.fromFunctionZIO { _ =>
                 ZIO.succeed("User ID is greater than 0")
               }

diff --git a/zio-http/jvm/src/test/scala/zio/http/endpoint/MultipartSpec.scala b/zio-http/jvm/src/test/scala/zio/http/endpoint/MultipartSpec.scala
@@ -53,7 +53,7 @@ object MultipartSpec extends ZIOHttpSpec {
                     HttpCodec.content[Int]("height", MediaType.text.`plain`) ++
                     HttpCodec.content[ImageMetadata]("metadata"),
                 )
-                .implement {
+                .implementHandler {
                   Handler.succeed(
                     (
                       ZStream.fromChunk(bytes),
@@ -109,7 +109,7 @@ object MultipartSpec extends ZIOHttpSpec {
                     HttpCodec.content[Int](MediaType.text.`plain`) ++
                     HttpCodec.content[ImageMetadata],
                 )
-                .implement {
+                .implementHandler {
                   Handler.succeed(
                     (
                       ZStream.fromChunk(bytes),
@@ -156,7 +156,7 @@ object MultipartSpec extends ZIOHttpSpec {
                 .in[String]("title")
                 .in[ImageMetadata]("metadata", Doc.p("Image metadata with description and creation date and time"))
                 .out[(Long, String, ImageMetadata)]
-                .implement {
+                .implementHandler {
                   Handler.fromFunctionZIO { case (stream, title, metadata) =>
                     stream.runCount.map(count => (count, title, metadata))
                   }
@@ -236,7 +236,7 @@ object MultipartSpec extends ZIOHttpSpec {
                 }
             }
           val route    =
-            endpoint.implement(Handler.identity[Any])
+            endpoint.implementHandler(Handler.identity[Any])
 
           val form =
             Form(