cleanup logging

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())
 			})
 		}
 	}

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 {