diff --git a/internal/nodes/client_tls_conn.go b/internal/nodes/client_tls_conn.go index f0ee400..e5b7d18 100644 --- a/internal/nodes/client_tls_conn.go +++ b/internal/nodes/client_tls_conn.go @@ -55,3 +55,16 @@ func (this *ClientTLSConn) SetReadDeadline(t time.Time) error { func (this *ClientTLSConn) SetWriteDeadline(t time.Time) error { return this.rawConn.SetWriteDeadline(t) } + +func (this *ClientTLSConn) SetIsWebsocket(isWebsocket bool) { + tlsConn, ok := this.rawConn.(*tls.Conn) + if ok { + var rawConn = tlsConn.NetConn() + if rawConn != nil { + clientConn, ok := rawConn.(*ClientConn) + if ok { + clientConn.SetIsWebsocket(isWebsocket) + } + } + } +}