Correct closing of connections

hub/connection.go

@@ -52,6 +52,7 @@ func (c *connection) write(packet conntypes.Packet) error {
 
 func (c *connection) shutdown() {
 	c.shutdownOnce.Do(func() {
+		c.conn.Close()
 		close(c.done)
 		c.hub.channelBrokenSockets <- c.id
 	})

proxy/direct.go

@@ -27,14 +27,17 @@ func directConnection(request *protocol.TelegramRequest) error {
 	go directPipe(telegramConn, request.ClientConn, wg, request.Logger)
 	go directPipe(request.ClientConn, telegramConn, wg, request.Logger)
 
-	<-request.Ctx.Done()
 	wg.Wait()
 
-	return request.Ctx.Err()
+	return nil
 }
 
-func directPipe(dst io.Writer, src io.Reader, wg *sync.WaitGroup, logger *zap.SugaredLogger) {
+func directPipe(dst io.WriteCloser, src io.ReadCloser, wg *sync.WaitGroup, logger *zap.SugaredLogger) {
-	defer wg.Done()
+	defer func() {
+		dst.Close()
+		src.Close()
+		wg.Done()
+	}()
 
 	buf := make([]byte, directPipeBufferSize)
 	if _, err := io.CopyBuffer(dst, src, buf); err != nil {

proxy/middle.go

@@ -32,17 +32,20 @@ func middleConnection(request *protocol.TelegramRequest) error {
 	go middlePipe(telegramConn, clientConn, wg, request.Logger)
 	go middlePipe(clientConn, telegramConn, wg, request.Logger)
 
-	<-request.Ctx.Done()
 	wg.Wait()
 
-	return request.Ctx.Err()
+	return nil
 }
 
-func middlePipe(dst conntypes.PacketAckWriter,
+func middlePipe(dst conntypes.PacketAckWriteCloser,
-	src conntypes.PacketAckReader,
+	src conntypes.PacketAckReadCloser,
 	wg *sync.WaitGroup,
 	logger *zap.SugaredLogger) {
-	defer wg.Done()
+	defer func() {
+		dst.Close()
+		src.Close()
+		wg.Done()
+	}()
 
 	for {
 		acks := conntypes.ConnectionAcks{}