refactor: initialize verifyChan in Client and Server structs for TLS verification

Author: 𝐘𝐨𝐬𝐞𝐛𝐲𝐭𝐞

internal/client.go

@@ -33,6 +33,7 @@ func NewClient(parsedURL *url.URL, logger *logs.Logger) (*Client, error) {
 			logger:     logger,
 			signalChan: make(chan Signal, semaphoreLimit),
 			writeChan:  make(chan []byte, semaphoreLimit),
+			verifyChan: make(chan struct{}),
 			tcpBufferPool: &sync.Pool{
 				New: func() any {
 					buf := make([]byte, tcpDataBufSize)
@@ -282,9 +283,6 @@ func (c *Client) tunnelHandshake() error {
 	c.maxPoolCapacity = config.Max
 	c.tlsCode = config.TLS
 	c.poolType = config.Type
-	if c.tlsCode == "1" || c.tlsCode == "2" {
-		c.verifyChan = make(chan struct{})
-	}
 
 	c.logger.Info("Loading tunnel config: FLOW=%v|MAX=%v|TLS=%v|TYPE=%v",
 		c.dataFlow, c.maxPoolCapacity, c.tlsCode, c.poolType)

internal/server.go

@@ -37,6 +37,7 @@ func NewServer(parsedURL *url.URL, tlsCode string, tlsConfig *tls.Config, logger
 			logger:     logger,
 			signalChan: make(chan Signal, semaphoreLimit),
 			writeChan:  make(chan []byte, semaphoreLimit),
+			verifyChan: make(chan struct{}),
 			tcpBufferPool: &sync.Pool{
 				New: func() any {
 					buf := make([]byte, tcpDataBufSize)
@@ -213,10 +214,6 @@ func (s *Server) initTunnelPool() error {
 
 // tunnelHandshake 与客户端进行HTTP握手
 func (s *Server) tunnelHandshake() error {
-	if s.tlsCode == "1" || s.tlsCode == "2" {
-		s.verifyChan = make(chan struct{})
-	}
-
 	var clientIP string
 	done := make(chan struct{})