From 2801019c5c41e3307ba16d02961a0af1fa90584f Mon Sep 17 00:00:00 2001 From: Egor Aristov Date: Mon, 27 Oct 2025 11:12:40 +0300 Subject: [PATCH] more correct open/close code --- lib/golang/lib.go | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/lib/golang/lib.go b/lib/golang/lib.go index 1e8f9a7..ae5e783 100644 --- a/lib/golang/lib.go +++ b/lib/golang/lib.go @@ -53,18 +53,18 @@ type ipcCommon struct { } func (ipc *ipcCommon) readConn() { - //scn := bufio.NewScanner(ipc.conn) - //for scn.Scan() { - // var msg Message - // if err := json.Unmarshal(scn.Bytes(), &msg); err != nil { - // ipc.raiseErr(fmt.Errorf("unmarshal message: %w", err)) - // break - // } - // ipc.processMsg(msg) - //} - //if err := scn.Err(); err != nil { - // ipc.raiseErr(err) - //} + scn := bufio.NewScanner(ipc.conn) + for scn.Scan() { + var msg Message + if err := json.Unmarshal(scn.Bytes(), &msg); err != nil { + ipc.raiseErr(fmt.Errorf("unmarshal message: %w", err)) + break + } + ipc.processMsg(msg) + } + if err := scn.Err(); err != nil { + ipc.raiseErr(err) + } } func (ipc *ipcCommon) processMsg(msg Message) {