Log all failures in Future

Author: bell-db

bridge/src/main/scala/protocbridge/frontend/PluginFrontend.scala

@@ -47,13 +47,7 @@ object PluginFrontend {
       gen: ProtocCodeGenerator,
       request: Array[Byte]
   ): Array[Byte] = {
-    Try {
-      gen.run(request)
-    }.recover { case throwable =>
-      createCodeGeneratorResponseWithError(
-        throwable.toString + "\n" + getStackTrace(throwable)
-      )
-    }.get
+    gen.run(request)
   }
 
   def createCodeGeneratorResponseWithError(error: String): Array[Byte] = {
@@ -116,9 +110,17 @@ object PluginFrontend {
       gen: ProtocCodeGenerator,
       fsin: InputStream,
       env: ExtraEnv
-  ): Array[Byte] = {
+  ): Array[Byte] = try {
+    System.err.println("readInputStreamToByteArrayWithEnv...")
     val bytes = readInputStreamToByteArrayWithEnv(fsin, env)
+    System.err.println("runWithBytes...")
     runWithBytes(gen, bytes)
+  } catch {
+    case throwable: Throwable =>
+      System.err.println("createCodeGeneratorResponseWithError...")
+      createCodeGeneratorResponseWithError(
+        throwable.toString + "\n" + getStackTrace(throwable)
+      )
   }
 
   def createTempFile(extension: String, content: String): Path = {

bridge/src/main/scala/protocbridge/frontend/PosixPluginFrontend.scala

@@ -36,13 +36,21 @@ object PosixPluginFrontend extends PluginFrontend {
 
     Future {
       blocking {
+        System.err.println("Files.newInputStream...")
         val fsin = Files.newInputStream(inputPipe)
+        System.err.println("PluginFrontend.runWithInputStream...")
         val response = PluginFrontend.runWithInputStream(plugin, fsin, env)
+        System.err.println("fsin.close...")
         fsin.close()
 
+        System.err.println("Files.newOutputStream...")
         val fsout = Files.newOutputStream(outputPipe)
+        System.err.println("fsout.write...")
         fsout.write(response)
+        System.err.println("fsout.close...")
         fsout.close()
+
+        System.err.println("blocking done.")
       }
     }
     (sh, InternalState(inputPipe, outputPipe, tempDirPath, sh))