From d9e9e1af7dc6664425517f23b66d0e63a88328ea Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Wed, 6 Jul 2022 16:21:07 +0200
Subject: [PATCH] close socket if null received

---
 .../adamko/kafkatorio/server/socket/SyslogSocketServer.kt | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
index 86f3637..38a6944 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
@@ -64,8 +64,12 @@ class SyslogSocketServer(
               channel.readUTF8Line()
             }.fold(
               onSuccess = { line ->
-                if (line != null) {
-                  log("received '$line' from ${socket.description()}")
+                when (line) {
+                  null -> {
+                    log("received 'null' from ${socket.description()} - closing connection")
+                    socket.close()
+                  }
+                  else -> log("received '$line' from ${socket.description()}")
                 }
                 line
               },