diff options
author | vlad <vlad@driver.xyz> | 2017-03-13 23:38:05 -0700 |
---|---|---|
committer | vlad <vlad@driver.xyz> | 2017-03-13 23:38:05 -0700 |
commit | a999af6e8843785d00d4e636413f701308efbb5d (patch) | |
tree | 8cf8e13987ccfbd03f24f53c5b27879bdae9ab76 | |
parent | 1b2d2b39e18073ba83f59d1572269140ae9f4945 (diff) | |
download | driver-core-a999af6e8843785d00d4e636413f701308efbb5d.tar.gz driver-core-a999af6e8843785d00d4e636413f701308efbb5d.tar.bz2 driver-core-a999af6e8843785d00d4e636413f701308efbb5d.zip |
Added writing tracking Id to MDC so it can be logged for all messages, removed some linkerd legacy and refined Revision equals
-rw-r--r-- | src/main/scala/xyz/driver/core/app.scala | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/main/scala/xyz/driver/core/app.scala b/src/main/scala/xyz/driver/core/app.scala index 8edb427..5a1b803 100644 --- a/src/main/scala/xyz/driver/core/app.scala +++ b/src/main/scala/xyz/driver/core/app.scala @@ -68,7 +68,8 @@ object app { val versionRt = versionRoute(version, gitHash, time.currentTime()) val _ = Future { - http.bindAndHandle(route2HandlerFlow(handleExceptions(ExceptionHandler(exceptionHandler)) { ctx => + http.bindAndHandle(route2HandlerFlow({ ctx => + val trackingId = rest.extractTrackingId(ctx.request) MDC.put("trackingId", trackingId) log.audit(s"Received request ${ctx.request}") @@ -76,9 +77,11 @@ object app { val contextWithTrackingId = ctx.withRequest(ctx.request.addHeader(RawHeader(ContextHeaders.TrackingIdHeader, trackingId))) - respondWithHeaders(List(RawHeader(ContextHeaders.TrackingIdHeader, trackingId))) { - modules.map(_.route).foldLeft(versionRt ~ healthRoute ~ swaggerRoutes)(_ ~ _) - }(contextWithTrackingId) + handleExceptions(ExceptionHandler(exceptionHandler))({ _ => + respondWithHeaders(List(RawHeader(ContextHeaders.TrackingIdHeader, trackingId))) { + modules.map(_.route).foldLeft(versionRt ~ healthRoute ~ swaggerRoutes)(_ ~ _) + }(contextWithTrackingId) + })(contextWithTrackingId) }), interface, port)(materializer) } } |