forward port of: #16261

digital-asset · Mar 7, 2023 · 072d97c · 072d97c
1 parent 39d816f
commit 072d97c
Showing 1 changed file with 13 additions and 4 deletions.
diff --git a/ledger-service/http-json/src/main/scala/com/digitalasset/http/Endpoints.scala b/ledger-service/http-json/src/main/scala/com/digitalasset/http/Endpoints.scala
@@ -402,8 +402,9 @@ class Endpoints(
       output.map(_.fold(httpResponseError, identity))
     }
 
-  private def searchHttpResponse(searchResult: SearchResult[Error \/ JsValue]): HttpResponse = {
-    import json.JsonProtocol._
+  private def searchHttpResponse(
+                                  searchResult: SearchResult[Error \/ JsValue]
+                                )(implicit lc: LoggingContextOf[RequestID]): HttpResponse = {    import json.JsonProtocol._
 
     val response: Source[ByteString, NotUsed] = searchResult match {
       case domain.OkResponse(result, warnings, _) =>
@@ -421,9 +422,17 @@ class Endpoints(
     )
   }
 
-  private[this] def filterStreamErrors[E, A]: Flow[Error \/ A, Error \/ A, NotUsed] =
+  private[this] def filterStreamErrors[A](implicit
+                                          lc: LoggingContextOf[RequestID]
+                                         ): Flow[Error \/ A, Error \/ A, NotUsed] =
     Flow[Error \/ A].map {
-      case -\/(ServerError(_)) => -\/(ServerError.fromMsg("internal server error"))
+      case -\/(ServerError(t)) =>
+        val hideMsg = "internal server error"
+        logger.error(
+          s"hiding internal error details from response, responding '$hideMsg' instead",
+          t,
+        )
+        -\/(ServerError.fromMsg(hideMsg))
       case o => o
     }