blob: cc0019a874720aae87b706118f4f786428209a42 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
package xyz.driver.core.rest
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
import akka.http.scaladsl.model.StatusCodes
import akka.http.scaladsl.model.headers.Connection
import akka.http.scaladsl.server.Directives.{complete => akkaComplete}
import akka.http.scaladsl.server.{Directives, RejectionHandler, Route}
import akka.http.scaladsl.testkit.ScalatestRouteTest
import com.typesafe.scalalogging.Logger
import org.scalatest.{AsyncFlatSpec, Matchers}
import xyz.driver.core.json.serviceExceptionFormat
import xyz.driver.core.logging.NoLogger
import xyz.driver.core.rest.errors._
import scala.concurrent.Future
class DriverRouteTest
extends AsyncFlatSpec with ScalatestRouteTest with SprayJsonSupport with Matchers with Directives {
class TestRoute(override val route: Route) extends DriverRoute {
override def log: Logger = NoLogger
}
"DriverRoute" should "respond with 200 OK for a basic route" in {
val route = new TestRoute(akkaComplete(StatusCodes.OK))
Get("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.OK
}
}
it should "respond with a 401 for an InvalidInputException" in {
val route = new TestRoute(akkaComplete(Future.failed[String](InvalidInputException())))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.BadRequest
responseAs[ServiceException] shouldBe InvalidInputException()
}
}
it should "respond with a 403 for InvalidActionException" in {
val route = new TestRoute(akkaComplete(Future.failed[String](InvalidActionException())))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.Forbidden
responseAs[ServiceException] shouldBe InvalidActionException()
}
}
it should "respond with a 404 for ResourceNotFoundException" in {
val route = new TestRoute(akkaComplete(Future.failed[String](ResourceNotFoundException())))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.NotFound
responseAs[ServiceException] shouldBe ResourceNotFoundException()
}
}
it should "respond with a 500 for ExternalServiceException" in {
val error = ExternalServiceException("GET /api/v1/users/", "Permission denied", None)
val route = new TestRoute(akkaComplete(Future.failed[String](error)))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.InternalServerError
responseAs[ServiceException] shouldBe error
}
}
it should "allow pass-through of external service exceptions" in {
val innerError = InvalidInputException()
val error = ExternalServiceException("GET /api/v1/users/", "Permission denied", Some(innerError))
val future = Future.failed[String](error)
val route = new TestRoute(akkaComplete(future.passThroughExternalServiceException))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.BadRequest
responseAs[ServiceException] shouldBe innerError
}
}
it should "respond with a 503 for ExternalServiceTimeoutException" in {
val error = ExternalServiceTimeoutException("GET /api/v1/users/")
val route = new TestRoute(akkaComplete(Future.failed[String](error)))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.GatewayTimeout
responseAs[ServiceException] shouldBe error
}
}
it should "respond with a 500 for DatabaseException" in {
val route = new TestRoute(akkaComplete(Future.failed[String](DatabaseException())))
Post("/api/v1/foo/bar") ~> route.routeWithDefaults ~> check {
handled shouldBe true
status shouldBe StatusCodes.InternalServerError
responseAs[ServiceException] shouldBe DatabaseException()
}
}
it should "add a `Connection: close` header to avoid clashing with envoy's timeouts" in {
val rejectionHandler = RejectionHandler.newBuilder().handleNotFound(complete(StatusCodes.NotFound)).result()
val route = new TestRoute(handleRejections(rejectionHandler)((get & path("foo"))(complete("OK"))))
Get("/foo") ~> route.routeWithDefaults ~> check {
status shouldBe StatusCodes.OK
headers should contain(Connection("close"))
}
Get("/bar") ~> route.routeWithDefaults ~> check {
status shouldBe StatusCodes.NotFound
headers should contain(Connection("close"))
}
}
}
|
