|
@@ -1,7 +1,6 @@
|
|
package http4s.techempower.benchmark
|
|
package http4s.techempower.benchmark
|
|
|
|
|
|
import java.util.concurrent.Executors
|
|
import java.util.concurrent.Executors
|
|
-
|
|
|
|
import scala.concurrent.ExecutionContext
|
|
import scala.concurrent.ExecutionContext
|
|
import cats.effect.{ExitCode, IO, IOApp, Resource}
|
|
import cats.effect.{ExitCode, IO, IOApp, Resource}
|
|
import com.typesafe.config.ConfigValueFactory
|
|
import com.typesafe.config.ConfigValueFactory
|
|
@@ -15,7 +14,8 @@ import org.http4s.dsl._
|
|
import org.http4s.circe._
|
|
import org.http4s.circe._
|
|
import org.http4s.implicits._
|
|
import org.http4s.implicits._
|
|
import org.http4s.server.Router
|
|
import org.http4s.server.Router
|
|
-import org.http4s.server.blaze.BlazeServerBuilder
|
|
|
|
|
|
+import org.http4s.blaze.server.BlazeServerBuilder
|
|
|
|
+import org.http4s.headers.Server
|
|
import org.http4s.twirl._
|
|
import org.http4s.twirl._
|
|
|
|
|
|
final case class Message(message: String)
|
|
final case class Message(message: String)
|
|
@@ -63,9 +63,11 @@ object WebServer extends IOApp with Http4sDsl[IO] {
|
|
// Add Server header container server address
|
|
// Add Server header container server address
|
|
def addServerHeader(service: HttpRoutes[IO]): HttpRoutes[IO] =
|
|
def addServerHeader(service: HttpRoutes[IO]): HttpRoutes[IO] =
|
|
cats.data.Kleisli { req: Request[IO] =>
|
|
cats.data.Kleisli { req: Request[IO] =>
|
|
- service.run(req).map(_.putHeaders(Header("Server", req.serverAddr)))
|
|
|
|
|
|
+ service.run(req).map(_.putHeaders(server))
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ val server = Server(ProductId("http4s", None))
|
|
|
|
+
|
|
// HTTP service definition
|
|
// HTTP service definition
|
|
def service(db: DatabaseService) =
|
|
def service(db: DatabaseService) =
|
|
addServerHeader(HttpRoutes.of[IO] {
|
|
addServerHeader(HttpRoutes.of[IO] {
|