From 32f9765374c01d14e8191e52f6c866833bafa1f6 Mon Sep 17 00:00:00 2001 From: bagas Date: Mon, 21 Jul 2025 11:37:57 +0700 Subject: [PATCH] refactor: remove slug channel from session struct --- session/handler.go | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/session/handler.go b/session/handler.go index 178e3b1..2181daa 100644 --- a/session/handler.go +++ b/session/handler.go @@ -48,7 +48,6 @@ type Session struct { ForwardedPort uint16 Status SessionStatus Slug string - SlugChannel chan bool Done chan bool } @@ -554,7 +553,7 @@ func (s *Session) HandleForwardedConnection(conn UserConnection, sshConn *ssh.Se } defer channel.Close() - go handleChannelRequests(reqs, conn, channel, s.SlugChannel) + go handleChannelRequests(reqs, conn, channel) if conn.Reader == nil { conn.Reader = bufio.NewReader(conn.Writer) @@ -577,7 +576,7 @@ func (s *Session) HandleForwardedConnection(conn UserConnection, sshConn *ssh.Se io.Copy(conn.Writer, reader) } -func handleChannelRequests(reqs <-chan *ssh.Request, conn UserConnection, channel ssh.Channel, slugChannel <-chan bool) { +func handleChannelRequests(reqs <-chan *ssh.Request, conn UserConnection, channel ssh.Channel) { select { case <-reqs: for req := range reqs { @@ -588,11 +587,6 @@ func handleChannelRequests(reqs <-chan *ssh.Request, conn UserConnection, channe channel.Close() log.Println("Connection closed by timeout") return - case <-slugChannel: - conn.Writer.Close() - channel.Close() - log.Println("Connection closed by slug change") - return } }