fix(proxy): Correctly close connection pipe when dealing with error

proxy/lib/snowflake.go

@@ -452,12 +452,17 @@ func (sf *SnowflakeProxy) makePeerConnectionFromOffer(sdp *webrtc.SessionDescrip
 			var n int
 			n, err = pw.Write(msg.Data)
 			if err != nil {
-				if inerr := pw.CloseWithError(err); inerr != nil {
+				if inErr := pw.CloseWithError(err); inErr != nil {
-					log.Printf("close with error generated an error: %v", inerr)
+					log.Printf("close with error generated an error: %v", inErr)
 				}
+
+				return
 			}
+
 			conn.bytesLogger.AddOutbound(int64(n))
+
 			if n != len(msg.Data) {
+				// XXX: Maybe don't panic here and log an error instead?
 				panic("short write")
 			}
 		})

proxy/lib/webrtcconn.go

@@ -2,6 +2,7 @@ package snowflake_proxy
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"io"
 	"log"
@@ -62,7 +63,7 @@ func (c *webRTCConn) timeoutLoop(ctx context.Context) {
 	for {
 		select {
 		case <-timer.C:
-			c.Close()
+			_ = c.Close()
 			log.Println("Closed connection due to inactivity")
 			return
 		case <-c.activity:
@@ -90,7 +91,7 @@ func (c *webRTCConn) Write(b []byte) (int, error) {
 	c.lock.Lock()
 	defer c.lock.Unlock()
 	if c.dc != nil {
-		c.dc.Send(b)
+		_ = c.dc.Send(b)
 		if !c.isClosing && c.dc.BufferedAmount() >= maxBufferedAmount {
 			<-c.sendMoreCh
 		}
@@ -106,7 +107,7 @@ func (c *webRTCConn) Close() (err error) {
 	}
 	c.once.Do(func() {
 		c.cancelTimeoutLoop()
-		err = c.pc.Close()
+		err = errors.Join(c.pr.Close(), c.pc.Close())
 	})
 	return
 }