aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/rest.scala
diff options
context:
space:
mode:
authorZach Smith <zach@driver.xyz>2017-05-01 17:37:45 -0700
committerZach Smith <zach@driver.xyz>2017-05-01 17:37:45 -0700
commit066417ab2ca1cc2a8aab76c182115573ec7f5405 (patch)
tree8895f2695248167596384957898168735b983900 /src/main/scala/xyz/driver/core/rest.scala
parentde978cf0a1e44cf906b407ca27089a16537f05c7 (diff)
downloaddriver-core-066417ab2ca1cc2a8aab76c182115573ec7f5405.tar.gz
driver-core-066417ab2ca1cc2a8aab76c182115573ec7f5405.tar.bz2
driver-core-066417ab2ca1cc2a8aab76c182115573ec7f5405.zip
Bump sbt-settings and fix errorsv0.12.3
Diffstat (limited to 'src/main/scala/xyz/driver/core/rest.scala')
-rw-r--r--src/main/scala/xyz/driver/core/rest.scala70
1 files changed, 38 insertions, 32 deletions
diff --git a/src/main/scala/xyz/driver/core/rest.scala b/src/main/scala/xyz/driver/core/rest.scala
index fbadd35..f1eab45 100644
--- a/src/main/scala/xyz/driver/core/rest.scala
+++ b/src/main/scala/xyz/driver/core/rest.scala
@@ -68,21 +68,21 @@ package rest {
}
}
- val indices = dirtyIndices(0, Nil)
-
- indices.headOption.fold(byteString){head =>
- val builder = ByteString.newBuilder
- builder ++= byteString.take(head)
-
- (indices :+ byteString.length).sliding(2).foreach {
- case Seq(start, end) =>
- builder += ' '
- builder ++= byteString.slice(start, end)
- case Seq(byteStringLength) => // Should not match; sliding on at least 2 elements
- assert(indices.nonEmpty, s"Indices should have been nonEmpty: $indices")
- }
- builder.result
- }
+ val indices = dirtyIndices(0, Nil)
+
+ indices.headOption.fold(byteString) { head =>
+ val builder = ByteString.newBuilder
+ builder ++= byteString.take(head)
+
+ (indices :+ byteString.length).sliding(2).foreach {
+ case Seq(start, end) =>
+ builder += ' '
+ builder ++= byteString.slice(start, end)
+ case Seq(byteStringLength) => // Should not match; sliding on at least 2 elements
+ assert(indices.nonEmpty, s"Indices should have been nonEmpty: $indices")
+ }
+ builder.result
+ }
}
val sanitizeRequestEntity: Directive0 = {
@@ -126,8 +126,8 @@ package rest {
}
}
- abstract class AuthProvider[U <: User](val authorization: Authorization,
- log: Logger)(implicit execution: ExecutionContext) {
+ abstract class AuthProvider[U <: User](val authorization: Authorization, log: Logger)(
+ implicit execution: ExecutionContext) {
import akka.http.scaladsl.server._
import Directives._
@@ -155,7 +155,7 @@ package rest {
onComplete(authenticatedUser(ctx).run flatMap { userOption =>
userOption.traverseM[Future, (U, Boolean)] { user =>
isSessionValid(user)(ctx).flatMap { sessionValid =>
- if(sessionValid) {
+ if (sessionValid) {
permissions.toList
.traverse[Future, Boolean](authorization.userHasPermission(user, _)(ctx))
.map(results => Option(user -> results.forall(identity)))
@@ -175,7 +175,8 @@ package rest {
}
case Success(None) =>
- log.warn(s"Wasn't able to find authenticated user for the token provided to verify ${permissions.mkString(", ")}")
+ log.warn(
+ s"Wasn't able to find authenticated user for the token provided to verify ${permissions.mkString(", ")}")
reject(ValidationRejection(s"Wasn't able to find authenticated user for the token provided"))
case Failure(t) =>
@@ -293,7 +294,8 @@ package rest {
if (response.status == StatusCodes.NotFound) {
Unmarshal(HttpEntity.Empty: ResponseEntity)
} else if (response.status.isFailure()) {
- throw new Exception(s"Http status is failure ${response.status} for ${requestStub.method} ${requestStub.uri}")
+ throw new Exception(
+ s"Http status is failure ${response.status} for ${requestStub.method} ${requestStub.uri}")
} else {
Unmarshal(response.entity)
}
@@ -308,11 +310,12 @@ package rest {
version: String,
override val actorSystem: ActorSystem,
override val apiTypes: Seq[Type],
- val config: Config) extends SwaggerHttpService with HasActorSystem {
+ val config: Config)
+ extends SwaggerHttpService with HasActorSystem {
val materializer = ActorMaterializer()(actorSystem)
- override val basePath = config.getString("swagger.basePath")
+ override val basePath = config.getString("swagger.basePath")
override val apiDocsPath = config.getString("swagger.docsPath")
override val info = Info(
@@ -320,16 +323,19 @@ package rest {
version,
config.getString("swagger.apiInfo.title"),
config.getString("swagger.apiInfo.termsOfServiceUrl"),
- contact = Some(Contact(
- config.getString("swagger.apiInfo.contact.name"),
- config.getString("swagger.apiInfo.contact.url"),
- config.getString("swagger.apiInfo.contact.email")
- )),
- license = Some(License(
- config.getString("swagger.apiInfo.license"),
- config.getString("swagger.apiInfo.licenseUrl")
- )),
- vendorExtensions = Map.empty[String, AnyRef])
+ contact = Some(
+ Contact(
+ config.getString("swagger.apiInfo.contact.name"),
+ config.getString("swagger.apiInfo.contact.url"),
+ config.getString("swagger.apiInfo.contact.email")
+ )),
+ license = Some(
+ License(
+ config.getString("swagger.apiInfo.license"),
+ config.getString("swagger.apiInfo.licenseUrl")
+ )),
+ vendorExtensions = Map.empty[String, AnyRef]
+ )
def swaggerUI = get {
pathPrefix("") {