Added socket log formatter (#343)

* Added socket log formatter

---------

Co-authored-by: Simon Bengtsson <[email protected]>

Author: troosan

README.md

@@ -14,8 +14,9 @@ It supports the following formats: default, [Elastic Common Schema (ECS)](https:
 | 2.x.x           | 1.x.x, 2.x.x |
 
 # Configuration
-The extension is enabled by default for console, when added to the project.
-Console logging can be disabled using configuration: `quarkus.log.json.console.enabled=false`
+The extension is enabled by default for console and socket, when added to the project.
+Console json logging can be disabled using configuration: `quarkus.log.json.console.enabled=false`
+Socket json logging can be disabled using configuration: `quarkus.log.json.socket.enabled=false`
 
 To see additional configuration options take a look at [Config](https://quarkiverse.github.io/quarkiverse-docs/quarkus-logging-json/dev/index.html)
 

deployment/src/main/java/io/quarkiverse/loggingjson/deployment/LoggingJsonProcessor.java

@@ -20,6 +20,7 @@
 import io.quarkus.deployment.builditem.FeatureBuildItem;
 import io.quarkus.deployment.builditem.LogConsoleFormatBuildItem;
 import io.quarkus.deployment.builditem.LogFileFormatBuildItem;
+import io.quarkus.deployment.builditem.LogSocketFormatBuildItem;
 
 class LoggingJsonProcessor {
 
@@ -44,6 +45,13 @@ LogFileFormatBuildItem setUpFileFormatter(Capabilities capabilities, LoggingJson
         return new LogFileFormatBuildItem(recorder.initializeFileJsonLogging(config, jsonFactory(capabilities)));
     }
 
+    @BuildStep
+    @Record(ExecutionTime.RUNTIME_INIT)
+    LogSocketFormatBuildItem setUpSocketFormatter(Capabilities capabilities, LoggingJsonRecorder recorder,
+            Config config) {
+        return new LogSocketFormatBuildItem(recorder.initializeSocketJsonLogging(config, jsonFactory(capabilities)));
+    }
+
     private JsonFactory jsonFactory(Capabilities capabilities) {
         if (capabilities.isPresent(Capability.JACKSON)) {
             return new JacksonJsonFactory();

deployment/src/test/java/io/quarkiverse/loggingjson/deployment/providers/custom/CustomJsonProviderJsonbTest.java

@@ -55,11 +55,11 @@ void testCustomJsonProvider() throws Exception {
         Assertions.assertTrue(firstCustomJsonProvider.getWriteToNumberOfCalls() > 0);
 
         Assertions.assertTrue(fields.contains("second"));
-        Assertions.assertEquals(2, secondCustomJsonProvider.getIsEnabledNumberOfCalls()); // expecting both console and file formatter to call
+        Assertions.assertEquals(3, secondCustomJsonProvider.getIsEnabledNumberOfCalls()); // expecting console, file and socket formatters to call
         Assertions.assertTrue(secondCustomJsonProvider.getWriteToNumberOfCalls() > 0);
 
         Assertions.assertFalse(fields.contains("third"));
-        Assertions.assertEquals(2, thirdCustomJsonProvider.getIsEnabledNumberOfCalls()); // expecting both console and file formatter to call
+        Assertions.assertEquals(3, thirdCustomJsonProvider.getIsEnabledNumberOfCalls()); // expecting console, file and socket formatters to call
         Assertions.assertEquals(0, thirdCustomJsonProvider.getWriteToNumberOfCalls());
     }
 }