From 4415b8e8925b4af87346d51966bd78bd9203adab Mon Sep 17 00:00:00 2001
From: Joel Wetzell <git@jwetzell.com>
Date: Mon, 18 May 2026 18:42:37 -0500
Subject: [PATCH] cleanup logging

---
 internal/module/tcp-server.go       | 2 --
 internal/module/websocket-client.go | 7 +++++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/internal/module/tcp-server.go b/internal/module/tcp-server.go
index d416bbb..5efc383 100644
--- a/internal/module/tcp-server.go
+++ b/internal/module/tcp-server.go
@@ -158,7 +158,6 @@ ClientRead:
 							break
 						}
 					}
-					ts.logger.Debug("stream ended", "remoteAddr", client.RemoteAddr().String())
 					ts.connectionsMu.Unlock()
 				}
 				return
@@ -213,7 +212,6 @@ AcceptLoop:
 		} else {
 			ts.wg.Go(func() {
 				ts.handleClient(conn)
-				ts.logger.Debug("connection handler done", "remoteAddr", conn.RemoteAddr().String())
 			})
 		}
 	}
diff --git a/internal/module/websocket-client.go b/internal/module/websocket-client.go
index 78f3e40..2f0488d 100644
--- a/internal/module/websocket-client.go
+++ b/internal/module/websocket-client.go
@@ -112,10 +112,14 @@ func (wc *WebSocketClient) readLoop() {
 		messageType, message, err := wc.conn.ReadMessage()
 		if err != nil {
 			if opErr, ok := err.(*net.OpError); ok {
-				//NOTE(jwetzell) we hit deadline
+				// NOTE(jwetzell) we hit deadline
 				if opErr.Timeout() {
 					continue
 				}
+				// NOTE(jwetzell) connection was closed
+				if errors.Is(opErr, net.ErrClosed) {
+					continue
+				}
 			}
 			wc.logger.Error("websocket read error", "error", err)
 			return
@@ -134,7 +138,6 @@ func (wc *WebSocketClient) readLoop() {
 			continue
 		}
 	}
-	wc.logger.Debug("exiting read loop")
 }
 
 func (wc *WebSocketClient) outputBytes(ctx context.Context, payload []byte) error {