From cdcf028d96f5dea894ea31e1ab8cf0b6575bc11c Mon Sep 17 00:00:00 2001
From: Zach Smith <zach@driver.xyz>
Date: Fri, 16 Mar 2018 20:26:28 +0100
Subject: Add implicit ServiceRequestContext to PatchRetrievable

---
 .../scala/xyz/driver/core/rest/PatchSupport.scala  | 42 +++++++++++++---------
 1 file changed, 26 insertions(+), 16 deletions(-)

(limited to 'src/main')

diff --git a/src/main/scala/xyz/driver/core/rest/PatchSupport.scala b/src/main/scala/xyz/driver/core/rest/PatchSupport.scala
index 5fd9149..9a28de1 100644
--- a/src/main/scala/xyz/driver/core/rest/PatchSupport.scala
+++ b/src/main/scala/xyz/driver/core/rest/PatchSupport.scala
@@ -11,7 +11,14 @@ import scala.concurrent.Future
 trait PatchSupport extends Directives with SprayJsonSupport {
 
   trait PatchRetrievable[T] {
-    def apply(id: Id[T]): Future[Option[T]]
+    def apply(id: Id[T])(implicit ctx: ServiceRequestContext): Future[Option[T]]
+  }
+
+  object PatchRetrievable {
+    def apply[T](retriever: ((Id[T], ServiceRequestContext) => Future[Option[T]])): PatchRetrievable[T] =
+      new PatchRetrievable[T] {
+        override def apply(id: Id[T])(implicit ctx: ServiceRequestContext): Future[Option[T]] = retriever(id, ctx)
+      }
   }
 
   protected def mergeObjects(oldObj: JsObject, newObj: JsObject, maxLevels: Option[Int] = None): JsObject = {
@@ -57,21 +64,24 @@ trait PatchSupport extends Directives with SprayJsonSupport {
       implicit val jsonFormat: RootJsonFormat[T] = patchable._2
       Directives.patch {
         entity(as[JsValue]) { newValue =>
-          onSuccess(retriever(id).map(_.map(_.toJson))) {
-            case Some(oldValue) =>
-              val mergedObj = mergeJsValues(oldValue, newValue)
-              util
-                .Try(mergedObj.convertTo[T])
-                .transform[Route](
-                  mergedT => util.Success(inner(Tuple1(mergedT))), {
-                    case jsonException: DeserializationException =>
-                      util.Success(reject(Rejections.malformedRequestContent(jsonException.getMessage, jsonException)))
-                    case t => util.Failure(t)
-                  }
-                )
-                .get // intentionally re-throw all other errors
-            case None =>
-              reject()
+          serviceContext { implicit ctx =>
+            onSuccess(retriever(id).map(_.map(_.toJson))) {
+              case Some(oldValue) =>
+                val mergedObj = mergeJsValues(oldValue, newValue)
+                util
+                  .Try(mergedObj.convertTo[T])
+                  .transform[Route](
+                    mergedT => util.Success(inner(Tuple1(mergedT))), {
+                      case jsonException: DeserializationException =>
+                        util.Success(
+                          reject(Rejections.malformedRequestContent(jsonException.getMessage, jsonException)))
+                      case t => util.Failure(t)
+                    }
+                  )
+                  .get // intentionally re-throw all other errors
+              case None =>
+                reject()
+            }
           }
         }
       }(requestCtx)
-- 
cgit v1.2.3