fix logging

pom.xml

@@ -137,6 +137,12 @@
             <artifactId>kotlin-logging-jvm</artifactId>
             <version>7.0.3</version>
         </dependency>
+        <dependency>
+            <groupId>net.logstash.logback</groupId>
+            <artifactId>logstash-logback-encoder</artifactId>
+            <version>8.0</version>
+        </dependency>
+
     </dependencies>
     <pluginRepositories>
         <pluginRepository>

src/main/kotlin/com/example/fhirvalidator/controller/ValidateController.kt

@@ -30,21 +30,28 @@ class ValidateController(
         @RequestBody input: String,
         @RequestHeader("x-request-id", required = false) requestId: String?
     ): String {
-        requestId?.let { logger.info { "started processing message $it" } }
-        val result = parseAndValidateResource(input)
+        requestId?.let { logger.info { "started processing message $it"} }
+        val result = parseAndValidateResource(input, requestId ?: "unknown_request_id")
         requestId?.let { logger.info { "finished processing message $it"} }
         return fhirContext.newJsonParser().encodeResourceToString(result)
     }
 
-    fun parseAndValidateResource(input: String): OperationOutcome {
+    fun parseAndValidateResource(input: String, requestId: String): OperationOutcome {
         return try {
             val inputResource = fhirContext.newJsonParser().parseResource(input)
             val resources = getResourcesToValidate(inputResource)
             val operationOutcomeList = resources.map { validateResource(it) }
             val operationOutcomeIssues = operationOutcomeList.filterNotNull().flatMap { it.issue }
             return createOperationOutcome(operationOutcomeIssues)
         } catch (e: DataFormatException) {
-            logger.error(e) { "Caught parser error" }
+            logger.atError {
+                message = "Caught parser error"
+                cause = e
+                payload = buildMap(capacity = 2) {
+                    put("requestId", requestId)
+                    put("payload", input)
+                }
+            }
             createOperationOutcome(e.message ?: "Invalid JSON", null)
         }
     }

src/main/resources/logback-spring.xml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <appender name="jsonConsoleAppender" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder class="net.logstash.logback.encoder.LogstashEncoder" />
+    </appender>
+
+    <root level="${LOG_LEVEL:-INFO}">
+        <appender-ref ref="jsonConsoleAppender" />
+    </root>
+</configuration>

src/test/kotlin/com/example/fhirvalidator/controller/FhirExamplesTest.kt

@@ -39,7 +39,7 @@ internal class FhirExamplesTest {
     fun testFhirExamples(exampleFile: File) {
         val lines = exampleFile.bufferedReader().readLines()
         val fileContent = lines.joinToString(" ")
-        val actualResult = testValidateController.parseAndValidateResource(fileContent)
+        val actualResult = testValidateController.parseAndValidateResource(fileContent, "dummy_request_id")
         for (issue in actualResult.issue) {
             if (issue.severity.equals(OperationOutcome.IssueSeverity.ERROR)) {
                 throw AssertionFailedError("Error found checking file ${exampleFile.absolutePath}. Error: ${issue.diagnostics}")