Merge pull request #4154 from prisma/MongoSSLBug

Add explicit dependency for netty

Author: do4gr

server/build.sbt

@@ -242,7 +242,7 @@ lazy val deployConnectorMongo = connectorProject("deploy-connector-mongo")
   .dependsOn(deployConnector)
   .dependsOn(mongoUtils)
   .settings(
-    libraryDependencies ++= Seq(mongoClient)
+    libraryDependencies ++= Seq(mongoClient) ++ netty
   )
 
 lazy val apiConnector = connectorProject("api-connector")
@@ -272,7 +272,7 @@ lazy val apiConnectorPostgres = connectorProject("api-connector-postgres")
 
 lazy val apiConnectorMongo = connectorProject("api-connector-mongo")
   .dependsOn(apiConnector)
-  .settings(libraryDependencies ++= Seq(mongoClient),
+  .settings(libraryDependencies ++= Seq(mongoClient) ++netty,
     scalacOptions := {
       val oldOptions = scalacOptions.value
       oldOptions.filterNot(_ == "-Xfatal-warnings")

server/libs/sangria-server/src/main/scala/com/prisma/sangria_server/AkkaHttpSangriaServer.scala

@@ -4,19 +4,19 @@ import akka.actor.ActorSystem
 import akka.http.scaladsl.Http
 import akka.http.scaladsl.Http.ServerBinding
 import akka.http.scaladsl.model.StatusCodes._
+import akka.http.scaladsl.model._
 import akka.http.scaladsl.model.headers.RawHeader
 import akka.http.scaladsl.model.ws.{Message, TextMessage}
-import akka.http.scaladsl.model._
 import akka.http.scaladsl.server.Directives.{as, entity, extractClientIP, _}
 import akka.http.scaladsl.server.directives.RouteDirectives.reject
 import akka.http.scaladsl.server.{ExceptionHandler, Route, UnsupportedWebSocketSubprotocolRejection}
 import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Flow
-import de.heikoseeberger.akkahttpplayjson.PlayJsonSupport
-import play.api.libs.json.{JsObject, JsValue, Json}
 import ch.megard.akka.http.cors.scaladsl.CorsDirectives
 import ch.megard.akka.http.cors.scaladsl.CorsDirectives._
 import com.prisma.akkautil.throttler.Throttler.ThrottlerException
+import de.heikoseeberger.akkahttpplayjson.PlayJsonSupport
+import play.api.libs.json.JsValue
 
 import scala.concurrent.{Await, Future}
 
@@ -35,9 +35,10 @@ case class AkkaHttpSangriaServer(
 )(implicit val system: ActorSystem, val materializer: ActorMaterializer)
     extends SangriaServer
     with PlayJsonSupport {
-  import scala.concurrent.duration._
   import system.dispatcher
 
+  import scala.concurrent.duration._
+
   val routes = {
     handleRejections(CorsDirectives.corsRejectionHandler) {
       cors() {

server/project/Dependencies.scala

@@ -42,6 +42,10 @@ object Dependencies {
   val playJson    = "com.typesafe.play" %% "play-json"    % v.play
   val playStreams = "com.typesafe.play" %% "play-streams" % v.play
 
+  val nettyTransport = "io.netty" % "netty-transport" % "4.1.17.Final"
+  val nettyHandler   = "io.netty" % "netty-handler" % "4.1.17.Final"
+  val netty          = Seq(nettyTransport, nettyHandler)
+
   val akka            = "com.typesafe.akka" %% "akka-actor"        % v.akka
   val akkaStream      = "com.typesafe.akka" %% "akka-stream"       % v.akka
   val akkaTestKit     = "com.typesafe.akka" %% "akka-testkit"      % v.akka