From baafa45aac8f6c97720dbcc44e7e5d60e432dd91 Mon Sep 17 00:00:00 2001
From: poiuty <poiuty@protonmail.com>
Date: Sat, 13 May 2023 15:03:12 +0300
Subject: [PATCH] update

---
 app/main.go | 26 ++++++++++++++++++++++----
 1 file changed, 22 insertions(+), 4 deletions(-)

diff --git a/app/main.go b/app/main.go
index e9be97b..422be82 100644
--- a/app/main.go
+++ b/app/main.go
@@ -92,14 +92,32 @@ func initClickhouse() {
 }
 
 func socketHandler() {
+	
+	var( 
+		err error
+		conn net.Conn
+	)
+	
 	for {
 		select {
 		case b := <-socketServer:
-			conn, err := net.Dial("unix", "/tmp/echo.sock")
-			if err == nil {
-				conn.Write(b)
-				conn.Close()
+			
+			if conn == nil {
+				conn, err = net.Dial("unix", "/tmp/echo.sock")
+				if err != nil {
+					fmt.Println(err.Error())
+					continue
+				}
 			}
+			
+			if conn != nil {
+				if _, err = conn.Write(b); err != nil {
+					fmt.Println(err.Error())
+					conn.Close()
+					conn = nil
+				}
+			}
+			
 		}
 	}
 }